input

Documentation

Index

• func Register(name string, factory Factory) error
• type Factory
  • func GetFactory(name string) (Factory, error)
• type Input

Functions

func Register

func Register(name string, factory Factory) error

Types

type Factory

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

Factory is used to register functions creating new Input instances.

func GetFactory

func GetFactory(name string) (Factory, error)

type Input

type Input interface {
	Run() (err error)
	Stop()
	Ctx() (ctx context.Context)
}