Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var InputTypes = []string{
"nats",
"stan",
"kafka",
}
View Source
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)
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.