compile

Documentation

Index

• type Compile
  • func New(spl string, e engine.Engine, proc *process.Process, ...) (*Compile, error)
  • func (c *Compile) Columns() []string
  • func (c *Compile) Compile() error
  • func (c *Compile) Run() error
• type Operator

Types

type Compile

type Compile struct {
	// contains filtered or unexported fields
}

func New

func New(spl string, e engine.Engine, proc *process.Process,
	emit func(*batch.Batch) error) (*Compile, error)

func (*Compile) Columns

func (c *Compile) Columns() []string

func (*Compile) Compile

func (c *Compile) Compile() error

func (*Compile) Run

func (c *Compile) Run() error

type Operator

type Operator interface {
	String() string
	Free() error
	Specialize() error
	AddCtrlConsumer(...int32)
	AddMessageConsumer(...int32)
	GetExecFunc() func(*pipeline.Message) ([]*pipeline.Message, int, error)
}