v1

Documentation

Index

• Constants
• type DatabasesOpSpec
  • func (s *DatabasesOpSpec) Kind() flux.OperationKind
• 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
  • func (s *DatabasesRemoteProcedureSpec) BuildQuery() *ast.File
  • func (s *DatabasesRemoteProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *DatabasesRemoteProcedureSpec) Kind() plan.ProcedureKind
  • func (s *DatabasesRemoteProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
• type DatabasesRemoteRule
  • func (p DatabasesRemoteRule) Name() string
  • func (p DatabasesRemoteRule) Pattern() plan.Pattern
  • func (p DatabasesRemoteRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)
• type FromInfluxJSONOpSpec
  • func (s *FromInfluxJSONOpSpec) Kind() flux.OperationKind
• type FromInfluxJSONProcedureSpec
  • func (s *FromInfluxJSONProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *FromInfluxJSONProcedureSpec) Kind() plan.ProcedureKind
• type JSONSource
  • func (c *JSONSource) AddTransformation(t execute.Transformation)
  • func (c *JSONSource) Run(ctx context.Context)

Constants

const (
	DatabasesKind       = "databases"
	DatabasesRemoteKind = "influxdata/influxdb/v1.databasesRemote"
)

const FromInfluxJSONKind = "fromInfluxJSON"

Types

type DatabasesOpSpec

type DatabasesOpSpec struct {
	Org   *influxdb.NameOrID
	Host  *string
	Token *string
}

func (*DatabasesOpSpec) Kind

func (s *DatabasesOpSpec) Kind() flux.OperationKind

type DatabasesProcedureSpec

type DatabasesProcedureSpec struct {
	plan.DefaultCost

	Org   *influxdb.NameOrID
	Host  *string
	Token *string
}

func (*DatabasesProcedureSpec) Copy

func (s *DatabasesProcedureSpec) Copy() plan.ProcedureSpec

func (*DatabasesProcedureSpec) GetHost

func (s *DatabasesProcedureSpec) GetHost() *string

func (*DatabasesProcedureSpec) GetOrg

func (s *DatabasesProcedureSpec) GetOrg() *influxdb.NameOrID

func (*DatabasesProcedureSpec) GetToken

func (s *DatabasesProcedureSpec) GetToken() *string

func (*DatabasesProcedureSpec) Kind

func (s *DatabasesProcedureSpec) Kind() plan.ProcedureKind

func (*DatabasesProcedureSpec) PostPhysicalValidate

func (s *DatabasesProcedureSpec) PostPhysicalValidate(id plan.NodeID) error

func (*DatabasesProcedureSpec) SetHost

func (s *DatabasesProcedureSpec) SetHost(host *string)

func (*DatabasesProcedureSpec) SetOrg

func (s *DatabasesProcedureSpec) SetOrg(org *influxdb.NameOrID)

func (*DatabasesProcedureSpec) SetToken

func (s *DatabasesProcedureSpec) SetToken(token *string)

type DatabasesRemoteProcedureSpec

type DatabasesRemoteProcedureSpec struct {
	plan.DefaultCost
	*DatabasesProcedureSpec
}

func (*DatabasesRemoteProcedureSpec) BuildQuery

func (s *DatabasesRemoteProcedureSpec) BuildQuery() *ast.File

func (*DatabasesRemoteProcedureSpec) Copy

func (s *DatabasesRemoteProcedureSpec) Copy() plan.ProcedureSpec

func (*DatabasesRemoteProcedureSpec) Kind

func (s *DatabasesRemoteProcedureSpec) Kind() plan.ProcedureKind

func (*DatabasesRemoteProcedureSpec) PostPhysicalValidate

func (s *DatabasesRemoteProcedureSpec) PostPhysicalValidate(id plan.NodeID) error

type DatabasesRemoteRule

type DatabasesRemoteRule struct{}

func (DatabasesRemoteRule) Name

func (p DatabasesRemoteRule) Name() string

func (DatabasesRemoteRule) Pattern

func (p DatabasesRemoteRule) Pattern() plan.Pattern

func (DatabasesRemoteRule) Rewrite

func (p DatabasesRemoteRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

type FromInfluxJSONOpSpec

type FromInfluxJSONOpSpec struct {
	JSON string `json:"json"`
	File string `json:"file"`
}

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)