memory

package

v2.4.1 Latest Latest Go to latest Published: Sep 12, 2021 License: MIT Imports: 12 Imported by: 0

Details

View Source

const PluginName string = "memory"

This section is empty.

This section is empty.

type Plugin struct {
	// contains filtered or unexported fields
}

func (p *Plugin) Available()

func (p *Plugin) FromPipeline(pipeline *pipeline.Pipeline, e events.Handler, pq priorityqueue.Queue) (jobs.Consumer, error)

FromPipeline creates new ephemeral consumer from the provided pipeline

func (p *Plugin) Init(log logger.Logger, cfg config.Configurer) error

func (p *Plugin) JobsConstruct(configKey string, e events.Handler, pq priorityqueue.Queue) (jobs.Consumer, error)

JobsConstruct creates new ephemeral consumer from the configuration

func (p *Plugin) KVConstruct(key string) (kv.Storage, error)

func (p *Plugin) Name() string

func (p *Plugin) PSConstruct(key string) (pubsub.PubSub, error)

func (p *Plugin) Serve() chan error

func (p *Plugin) Stop() error