scan

Documentation

Index

• Constants
• type ScanOp
  • func New(r engine.Reader, lua string, cols []int, proc *process.Process) *ScanOp
  • func (o *ScanOp) AddCtrlConsumer(_ ...int32)
  • func (o *ScanOp) AddMessageConsumer(_ ...int32)
  • func (o *ScanOp) Close() error
  • func (o *ScanOp) Exec(msg *pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *ScanOp) Free() error
  • func (o *ScanOp) GetExecFunc() func(*pipeline.Message) ([]*pipeline.Message, int, error)
  • func (o *ScanOp) Read(p []byte) (int, error)
  • func (o *ScanOp) Specialize() error
  • func (o *ScanOp) String() string

Constants

const (
	DefaultBufferSize = 4 << 10
)

Types

type ScanOp

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

func New

func New(r engine.Reader, lua string, cols []int, proc *process.Process) *ScanOp

func (*ScanOp) AddCtrlConsumer

func (o *ScanOp) AddCtrlConsumer(_ ...int32)

func (*ScanOp) AddMessageConsumer

func (o *ScanOp) AddMessageConsumer(_ ...int32)

func (*ScanOp) Close

func (o *ScanOp) Close() error

func (*ScanOp) Exec

func (o *ScanOp) Exec(msg *pipeline.Message) ([]*pipeline.Message, int, error)

func (*ScanOp) Free

func (o *ScanOp) Free() error

func (*ScanOp) GetExecFunc

func (o *ScanOp) GetExecFunc() func(*pipeline.Message) ([]*pipeline.Message, int, error)

func (*ScanOp) Read

func (o *ScanOp) Read(p []byte) (int, error)

func (*ScanOp) Specialize

func (o *ScanOp) Specialize() error

func (*ScanOp) String

func (o *ScanOp) String() string