Documentation
¶
Index ¶
- func NewDefaultConfigFromTOMLFile(configFilePath string) (ouretl.Config, error)
- func NewHandler(definition ouretl.PluginDefinition, config ouretl.Config) *wrapper
- func NewHandlerPool(config ouretl.Config) []*wrapper
- func NewHandlerPoolFromConfig(channel <-chan *DefaultDataMessage, config ouretl.Config)
- func NewWorker(definition ouretl.PluginDefinition, config ouretl.Config) ouretl.WorkerPlugin
- func NewWorkerPool(channel chan<- *DefaultDataMessage, config ouretl.Config) []string
- func NewWorkerPoolFromConfig(channel chan<- *DefaultDataMessage, config ouretl.Config)
- type DefaultDataMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewHandler ¶
func NewHandler(definition ouretl.PluginDefinition, config ouretl.Config) *wrapper
func NewHandlerPool ¶
func NewHandlerPoolFromConfig ¶
func NewHandlerPoolFromConfig(channel <-chan *DefaultDataMessage, config ouretl.Config)
func NewWorker ¶
func NewWorker(definition ouretl.PluginDefinition, config ouretl.Config) ouretl.WorkerPlugin
func NewWorkerPool ¶
func NewWorkerPool(channel chan<- *DefaultDataMessage, config ouretl.Config) []string
func NewWorkerPoolFromConfig ¶
func NewWorkerPoolFromConfig(channel chan<- *DefaultDataMessage, config ouretl.Config)
Types ¶
type DefaultDataMessage ¶
type DefaultDataMessage struct {
// contains filtered or unexported fields
}
func (*DefaultDataMessage) Data ¶
func (dm *DefaultDataMessage) Data() []byte
func (*DefaultDataMessage) ID ¶
func (dm *DefaultDataMessage) ID() string
func (*DefaultDataMessage) Origin ¶
func (dm *DefaultDataMessage) Origin() string
Click to show internal directories.
Click to hide internal directories.