collector

Documentation

Index

• type CollectorFunc
• type FuncCollector
  • func Func(f CollectorFunc) *FuncCollector
  • func (c *FuncCollector) Close(api.StreamContext) error
  • func (c *FuncCollector) Collect(ctx api.StreamContext, item api.RawTuple) error
  • func (c *FuncCollector) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error
  • func (c *FuncCollector) Provision(ctx api.StreamContext, configs map[string]any) error

Types

type CollectorFunc

type CollectorFunc func(api.StreamContext, interface{}) error

CollectorFunc is a function used to colllect incoming stream data. It can be used as a stream sink.

type FuncCollector

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

FuncCollector is a colletor that uses a function to collect data. The specified function must be of type:

CollectorFunc

func Func

func Func(f CollectorFunc) *FuncCollector

Func creates a new value *FuncCollector that will use the specified function parameter to collect streaming data.

func (*FuncCollector) Close

func (c *FuncCollector) Close(api.StreamContext) error

func (*FuncCollector) Collect

func (c *FuncCollector) Collect(ctx api.StreamContext, item api.RawTuple) error

func (*FuncCollector) Connect

func (c *FuncCollector) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error

func (*FuncCollector) Provision

func (c *FuncCollector) Provision(ctx api.StreamContext, configs map[string]any) error