base

Documentation

Index

• type FilterFunc
• type Writer
  • func New(filter, encoderFunc string, monitor monitor.Monitor) (*Writer, error)
  • func (w *Writer) Close() error
  • func (w *Writer) Encode(input interface{}) ([]byte, error)
  • func (w *Writer) Filter(input interface{}) (interface{}, error)
  • func (w *Writer) Run(ctx context.Context) (async.Task, error)

Types

type FilterFunc

type FilterFunc func(map[string]interface{}) (interface{}, error)

FilterFunc used for filter

type Writer

type Writer struct {
	Process func(context.Context) error
	// contains filtered or unexported fields
}

Writer is to filter and encode row of events

func New

func New(filter, encoderFunc string, monitor monitor.Monitor) (*Writer, error)

New creates a new encoder

func (*Writer) Close

func (w *Writer) Close() error

Close invoked task

func (*Writer) Encode

func (w *Writer) Encode(input interface{}) ([]byte, error)

Encode will encode a row/block to the format the user specifies

func (*Writer) Filter

func (w *Writer) Filter(input interface{}) (interface{}, error)

Filter filters out a row/blocks

func (*Writer) Run

func (w *Writer) Run(ctx context.Context) (async.Task, error)

Run task to process work using async invoke