Documentation ¶
Index ¶
- Constants
- type DatabasesOpSpec
- type DatabasesProcedureSpec
- func (s *DatabasesProcedureSpec) Copy() plan.ProcedureSpec
- func (s *DatabasesProcedureSpec) GetHost() *string
- func (s *DatabasesProcedureSpec) GetOrg() *influxdb.NameOrID
- func (s *DatabasesProcedureSpec) GetToken() *string
- func (s *DatabasesProcedureSpec) Kind() plan.ProcedureKind
- func (s *DatabasesProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
- func (s *DatabasesProcedureSpec) SetHost(host *string)
- func (s *DatabasesProcedureSpec) SetOrg(org *influxdb.NameOrID)
- func (s *DatabasesProcedureSpec) SetToken(token *string)
- type DatabasesRemoteProcedureSpec
- type DatabasesRemoteRule
- type FromInfluxJSONOpSpec
- type FromInfluxJSONProcedureSpec
- type JSONSource
Constants ¶
View Source
const ( DatabasesKind = "databases" DatabasesRemoteKind = "influxdata/influxdb/v1.databasesRemote" )
View Source
const FromInfluxJSONKind = "fromInfluxJSON"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DatabasesOpSpec ¶ added in v0.68.0
func (*DatabasesOpSpec) Kind ¶ added in v0.68.0
func (s *DatabasesOpSpec) Kind() flux.OperationKind
type DatabasesProcedureSpec ¶ added in v0.68.0
type DatabasesProcedureSpec struct { plan.DefaultCost Org *influxdb.NameOrID Host *string Token *string }
func (*DatabasesProcedureSpec) Copy ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) Copy() plan.ProcedureSpec
func (*DatabasesProcedureSpec) GetHost ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) GetHost() *string
func (*DatabasesProcedureSpec) GetOrg ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) GetOrg() *influxdb.NameOrID
func (*DatabasesProcedureSpec) GetToken ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) GetToken() *string
func (*DatabasesProcedureSpec) Kind ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) Kind() plan.ProcedureKind
func (*DatabasesProcedureSpec) PostPhysicalValidate ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
func (*DatabasesProcedureSpec) SetHost ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) SetHost(host *string)
func (*DatabasesProcedureSpec) SetOrg ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) SetOrg(org *influxdb.NameOrID)
func (*DatabasesProcedureSpec) SetToken ¶ added in v0.68.0
func (s *DatabasesProcedureSpec) SetToken(token *string)
type DatabasesRemoteProcedureSpec ¶ added in v0.68.0
type DatabasesRemoteProcedureSpec struct { plan.DefaultCost *DatabasesProcedureSpec }
func (*DatabasesRemoteProcedureSpec) BuildQuery ¶ added in v0.68.0
func (s *DatabasesRemoteProcedureSpec) BuildQuery() *ast.File
func (*DatabasesRemoteProcedureSpec) Copy ¶ added in v0.68.0
func (s *DatabasesRemoteProcedureSpec) Copy() plan.ProcedureSpec
func (*DatabasesRemoteProcedureSpec) Kind ¶ added in v0.68.0
func (s *DatabasesRemoteProcedureSpec) Kind() plan.ProcedureKind
func (*DatabasesRemoteProcedureSpec) PostPhysicalValidate ¶ added in v0.68.0
func (s *DatabasesRemoteProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
type DatabasesRemoteRule ¶ added in v0.68.0
type DatabasesRemoteRule struct{}
func (DatabasesRemoteRule) Name ¶ added in v0.68.0
func (p DatabasesRemoteRule) Name() string
func (DatabasesRemoteRule) Pattern ¶ added in v0.68.0
func (p DatabasesRemoteRule) Pattern() plan.Pattern
type FromInfluxJSONOpSpec ¶
FromInfluxJSONOpSpec defines the `fromInfluxJSON` function signature
func (*FromInfluxJSONOpSpec) Kind ¶
func (s *FromInfluxJSONOpSpec) Kind() flux.OperationKind
type FromInfluxJSONProcedureSpec ¶
type FromInfluxJSONProcedureSpec struct { plan.DefaultCost JSON string File string }
FromInfluxJSONProcedureSpec describes the `fromInfluxJSON` prodecure
func (*FromInfluxJSONProcedureSpec) Copy ¶
func (s *FromInfluxJSONProcedureSpec) Copy() plan.ProcedureSpec
func (*FromInfluxJSONProcedureSpec) Kind ¶
func (s *FromInfluxJSONProcedureSpec) Kind() plan.ProcedureKind
type JSONSource ¶
type JSONSource struct { execute.ExecutionNode // contains filtered or unexported fields }
func (*JSONSource) AddTransformation ¶
func (c *JSONSource) AddTransformation(t execute.Transformation)
func (*JSONSource) Run ¶
func (c *JSONSource) Run(ctx context.Context)
Click to show internal directories.
Click to hide internal directories.