processor

Documentation

Index

• func Register(name string, factory Factory) error
• func WriteToOutput(ctx context.Context, dest string, input <-chan *event.ProcessorEvent) (err error)
• type Factory
  • func GetFactory(name string) (Factory, error)

Functions

func Register

func Register(name string, factory Factory) error

func WriteToOutput

func WriteToOutput(ctx context.Context, dest string, input <-chan *event.ProcessorEvent) (err error)

Types

type Factory

type Factory = func(cxt context.Context, config interface{}, input <-chan *event.ProcessorEvent) (chan *event.ProcessorEvent, error)

Factory is used to register functions creating new output instances.

func GetFactory

func GetFactory(name string) (Factory, error)