generate

package
v0.46.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 12, 2019 License: MIT Imports: 13 Imported by: 1

Documentation

Index

Constants

View Source
const FromGeneratorKind = "fromGenerator"

Variables

This section is empty.

Functions

This section is empty.

Types

type FromGeneratorOpSpec

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

func (*FromGeneratorOpSpec) Kind

type FromGeneratorProcedureSpec

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

func (*FromGeneratorProcedureSpec) Copy

func (*FromGeneratorProcedureSpec) Kind

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 added in v0.18.0

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL