amqp

Mar 14, 2023

Changes in this version

type Plugin

+ func (p *Plugin) Collects() []*dep.In

+ type Tracer interface

+ Tracer func() *sdktrace.TracerProvider

Jan 21, 2023

Changes in this version

type Plugin

+ func (p *Plugin) DriverFromConfig(configKey string, pq pq.Queue, pipeline jobs.Pipeline, ...) (jobs.Driver, error)

+ func (p *Plugin) DriverFromPipeline(pipe jobs.Pipeline, pq pq.Queue, cmder chan<- jobs.Commander) (jobs.Driver, error)

Jan 9, 2023

Changes in this version

+ type Configurer interface

+ Has func(name string) bool

+ UnmarshalKey func(name string, out any) error

+ type Logger interface

+ NamedLogger func(name string) *zap.Logger

+ type Plugin struct

+ func (p *Plugin) ConsumerFromConfig(configKey string, queue pq.Queue) (jobs.Consumer, error)

+ func (p *Plugin) ConsumerFromPipeline(pipe jobs.Pipeline, queue pq.Queue) (jobs.Consumer, error)

+ func (p *Plugin) Init(log Logger, cfg Configurer) error

+ func (p *Plugin) Name() string