Documentation
¶
Index ¶
- Constants
- type Plugin
- func (p *Plugin) Available()
- func (p *Plugin) ConsumerFromConfig(configKey string, e events.Handler, pq priorityqueue.Queue) (jobs.Consumer, error)
- func (p *Plugin) ConsumerFromPipeline(pipeline *pipeline.Pipeline, e events.Handler, pq priorityqueue.Queue) (jobs.Consumer, error)
- func (p *Plugin) Init(log logger.Logger, cfg config.Configurer) error
- func (p *Plugin) KvFromConfig(key string) (kv.Storage, error)
- func (p *Plugin) Name() string
- func (p *Plugin) PubSubFromConfig(key string) (pubsub.PubSub, error)
- func (p *Plugin) Serve() chan error
- func (p *Plugin) Stop() error
Constants ¶
View Source
const PluginName string = "memory"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) ConsumerFromConfig ¶
func (p *Plugin) ConsumerFromConfig(configKey string, e events.Handler, pq priorityqueue.Queue) (jobs.Consumer, error)
JobsConstruct creates new ephemeral consumer from the configuration
func (*Plugin) ConsumerFromPipeline ¶
func (p *Plugin) ConsumerFromPipeline(pipeline *pipeline.Pipeline, e events.Handler, pq priorityqueue.Queue) (jobs.Consumer, error)
FromPipeline creates new ephemeral consumer from the provided pipeline
func (*Plugin) PubSubFromConfig ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.