inputs

Documentation

Index

• Variables
• func Register(name string, initFn Initializer)
• type Initializer
• type Input
• type Option
  • func WithEventProcessors(eps map[string]map[string]interface{}, log *log.Logger, ...) Option
  • func WithLogger(logger *log.Logger) Option
  • func WithName(name string) Option
  • func WithOutputs(outs map[string]outputs.Output) Option

Variables

var InputTypes = []string{
	"nats",
	"stan",
	"kafka",
}

var Inputs = map[string]Initializer{}

Functions

func Register

func Register(name string, initFn Initializer)

Types

type Initializer

type Initializer func() Input

type Input

type Input interface {
	Start(context.Context, string, map[string]interface{}, ...Option) error
	Close() error
	SetLogger(*log.Logger)
	SetOutputs(map[string]outputs.Output)
	SetEventProcessors(map[string]map[string]interface{}, *log.Logger, map[string]*types.TargetConfig, map[string]map[string]interface{}) error
	SetName(string)
}

type Option

type Option func(Input) error

func WithEventProcessors

func WithEventProcessors(eps map[string]map[string]interface{}, log *log.Logger, tcs map[string]*types.TargetConfig, acts map[string]map[string]interface{}) Option

func WithLogger

func WithLogger(logger *log.Logger) Option

func WithName

func WithName(name string) Option

func WithOutputs

func WithOutputs(outs map[string]outputs.Output) Option