rabbitmq

Documentation

Index

• func NewAdapter(ctx context.Context, processed adapter.EnvConfigAccessor, ...) adapter.MessageAdapter
• func NewEnvConfig() adapter.EnvConfigAccessor
• func PollCycle(retryChan chan bool, stopCh <-chan struct{}, workerQueue chan amqp.Delivery, ...)
• type Adapter
  • func (a *Adapter) ConsumeMessages(queue *amqp.Queue, logger *zap.SugaredLogger) (<-chan amqp.Delivery, error)
  • func (a *Adapter) PollForMessages(stopCh <-chan struct{}) error
  • func (a *Adapter) Start(ctx context.Context) error

Functions

func NewAdapter

func NewAdapter(ctx context.Context, processed adapter.EnvConfigAccessor, httpMessageSender *kncloudevents.HTTPMessageSender, reporter source.StatsReporter) adapter.MessageAdapter

func NewEnvConfig

func NewEnvConfig() adapter.EnvConfigAccessor

func PollCycle

func PollCycle(
	retryChan chan bool,
	stopCh <-chan struct{},
	workerQueue chan amqp.Delivery,
	wg *sync.WaitGroup,
	msgs <-chan amqp.Delivery,
	rmqHelper rabbit.RabbitMQHelperInterface,
	logger *zap.SugaredLogger)

Types

type Adapter

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

func (*Adapter) ConsumeMessages

func (a *Adapter) ConsumeMessages(queue *amqp.Queue, logger *zap.SugaredLogger) (<-chan amqp.Delivery, error)

func (*Adapter) PollForMessages

func (a *Adapter) PollForMessages(stopCh <-chan struct{}) error

func (*Adapter) Start

func (a *Adapter) Start(ctx context.Context) error