package generate

import "github.com/influxdata/flux/stdlib/generate"

Index ¶

• Constants
• type FromGeneratorOpSpec
• func (s *FromGeneratorOpSpec) Kind() flux.OperationKind
• type FromGeneratorProcedureSpec
• func (s *FromGeneratorProcedureSpec) Copy() plan.ProcedureSpec
• func (s *FromGeneratorProcedureSpec) Kind() plan.ProcedureKind
• type GeneratorSource
• func NewGeneratorSource(a memory.Allocator) *GeneratorSource
• func (s *GeneratorSource) Close() error
• func (s *GeneratorSource) Connect(ctx context.Context) error
• func (s *GeneratorSource) Decode(ctx context.Context) (flux.Table, error)
• func (s *GeneratorSource) Fetch(ctx context.Context) (bool, error)

Constants ¶

const FromGeneratorKind = "fromGenerator"

Types ¶

type FromGeneratorOpSpec ¶

type FromGeneratorOpSpec struct {
	Start flux.Time                    `json:"start"`
	Stop  flux.Time                    `json:"stop"`
	Count int64                        `json:"count"`
	Fn    interpreter.ResolvedFunction `json:"fn"`
}

func (*FromGeneratorOpSpec) Kind ¶

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

type FromGeneratorProcedureSpec ¶

type FromGeneratorProcedureSpec struct {
	plan.DefaultCost
	Start time.Time
	Stop  time.Time
	Count int64
	Fn    interpreter.ResolvedFunction
}

func (*FromGeneratorProcedureSpec) Copy ¶

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

func (*FromGeneratorProcedureSpec) Kind ¶

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

type GeneratorSource ¶

type GeneratorSource struct {
	Start time.Time
	Stop  time.Time
	Count int64

	Fn compiler.Func
	// contains filtered or unexported fields
}

func NewGeneratorSource ¶

func NewGeneratorSource(a memory.Allocator) *GeneratorSource

func (*GeneratorSource) Close ¶

func (s *GeneratorSource) Close() error

func (*GeneratorSource) Connect ¶

func (s *GeneratorSource) Connect(ctx context.Context) error

func (*GeneratorSource) Decode ¶

func (s *GeneratorSource) Decode(ctx context.Context) (flux.Table, error)

func (*GeneratorSource) Fetch ¶

func (s *GeneratorSource) Fetch(ctx context.Context) (bool, error)

Source Files ¶

from.go