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 interface{}) error
  • func (c *FuncCollector) Configure(props map[string]interface{}) error
  • func (c *FuncCollector) Open(ctx api.StreamContext) 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 interface{}) error

func (*FuncCollector) Configure

func (c *FuncCollector) Configure(props map[string]interface{}) error

func (*FuncCollector) Open

func (c *FuncCollector) Open(ctx api.StreamContext) error

Open is the starting point that starts the collector