v1

Documentation

Index

• Constants
• Variables
• 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"

const FromInfluxJSONKind = "fromInfluxJSON"

Variables

var DatabasesSignature = semantic.FunctionPolySignature{
	Return: flux.TableObjectType,
}

Types

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 {
	// 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)