provider

Documentation

Index

• func RegisterAsyncQueueConsumerProvider(queueType string, consumerConstructor ConsumerConstructor) error
• func RegisterAsyncQueueProducerProvider(queueType string, producerConstructor ProducerConstructor) error
• type ConsumerConstructor
  • func GetAsyncQueueConsumerProvider(queueType string) (ConsumerConstructor, bool)
• type Params
• type ProducerConstructor
  • func GetAsyncQueueProducerProvider(queueType string) (ProducerConstructor, bool)

Functions

func RegisterAsyncQueueConsumerProvider

func RegisterAsyncQueueConsumerProvider(queueType string, consumerConstructor ConsumerConstructor) error

RegisterAsyncQueueConsumerProvider registers a queue consumer constructor for a given queue type

func RegisterAsyncQueueProducerProvider

func RegisterAsyncQueueProducerProvider(queueType string, producerConstructor ProducerConstructor) error

RegisterAsyncQueueProducerProvider registers a queue producer constructor for a given queue type

Types

type ConsumerConstructor

type ConsumerConstructor func(*config.YamlNode, *Params) (messaging.Consumer, error)

ConsumerConstructor is a function that constructs a queue consumer

func GetAsyncQueueConsumerProvider

func GetAsyncQueueConsumerProvider(queueType string) (ConsumerConstructor, bool)

GetAsyncQueueConsumerProvider returns a queue consumer constructor for a given queue type

type Params

type Params struct {
	Logger        log.Logger
	MetricsClient metrics.Client
}

type ProducerConstructor

type ProducerConstructor func(*config.YamlNode, *Params) (messaging.Producer, error)

ProducerConstructor is a function that constructs a queue producer

func GetAsyncQueueProducerProvider

func GetAsyncQueueProducerProvider(queueType string) (ProducerConstructor, bool)

GetAsyncQueueProducerProvider returns a queue producer constructor for a given queue type