output

Documentation

Index

• func ChanConnect(ctx context.Context, from <-chan *event.ProcessorEvent, ...)
• func GetOutputChan(name string) (chan *event.ProcessorEvent, error)
• func OutputExists(name string) bool
• func OutputRunning(name string) bool
• func ReadConfig() (value string, err error)
• func Register(name string, factory Factory) error
• func RegisterOutput(name string, o Output) error
• type Factory
  • func GetFactory(name string) (Factory, error)
• type Output

Functions

func ChanConnect

func ChanConnect(ctx context.Context, from <-chan *event.ProcessorEvent, to chan<- *event.ProcessorEvent)

func GetOutputChan

func GetOutputChan(name string) (chan *event.ProcessorEvent, error)

func OutputExists

func OutputExists(name string) bool

func OutputRunning

func OutputRunning(name string) bool

func ReadConfig

func ReadConfig() (value string, err error)

ReadConfig read config for default output

func Register

func Register(name string, factory Factory) error

func RegisterOutput

func RegisterOutput(name string, o Output) error

Types

type Factory

type Factory = func(ctx context.Context, config interface{}) (Output, error)

Factory is used to register functions creating new Input instances.

func GetFactory

func GetFactory(name string) (Factory, error)

type Output

type Output interface {
	Run() (err error)
	Stop()
	InputChan() chan *event.ProcessorEvent
}