generate

Documentation

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() error
  • func (s *GeneratorSource) Decode() (flux.Table, error)
  • func (s *GeneratorSource) Fetch() (bool, error)

Constants

const FromGeneratorKind = "fromGenerator"

Types

type FromGeneratorOpSpec

type FromGeneratorOpSpec struct {
	Start time.Time                    `json:"start"`
	Stop  time.Time                    `json:"stop"`
	Count int64                        `json:"count"`
	Fn    *semantic.FunctionExpression `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    compiler.Func
}

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() error

func (*GeneratorSource) Decode

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

func (*GeneratorSource) Fetch

func (s *GeneratorSource) Fetch() (bool, error)