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
- type Output
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 OutputRunning ¶
func ReadConfig ¶
ReadConfig read config for default output
func RegisterOutput ¶
Types ¶
type Factory ¶
Factory is used to register functions creating new Input instances.
func GetFactory ¶
type Output ¶
type Output interface {
Run() (err error)
Stop()
InputChan() chan *event.ProcessorEvent
}
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
lancergateway
Package StreamEvent is a generated protocol buffer package.
|
Package StreamEvent is a generated protocol buffer package. |
Click to show internal directories.
Click to hide internal directories.