Documentation ¶
Index ¶
- func Config(config *models.Config)
- func FileExists(file string) bool
- func Inputs(inputMsgs chan<- models.Message, config *models.Config)
- func Outputs(outputMsgs <-chan models.Message, config *models.Config)
- func Params(config *models.Config)
- func Pipeline(inputMsgs <-chan models.Message, outputMsgs chan<- models.Message, ...)
- func Starter(config *models.Config)
- type State
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FileExists ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.