provider

package

v1.2.7-prerelease6 Latest Latest Go to latest Published: Feb 5, 2024 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func RegisterAsyncQueueConsumerProvider(queueType string, consumerConstructor ConsumerConstructor) error

RegisterAsyncQueueConsumerProvider registers a queue consumer constructor for a given queue type

func RegisterAsyncQueueProducerProvider(queueType string, producerConstructor ProducerConstructor) error

RegisterAsyncQueueProducerProvider registers a queue producer constructor for a given queue type

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

ConsumerConstructor is a function that constructs a queue consumer

func GetAsyncQueueConsumerProvider(queueType string) (ConsumerConstructor, bool)

GetAsyncQueueConsumerProvider returns a queue consumer constructor for a given queue type

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

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

ProducerConstructor is a function that constructs a queue producer

func GetAsyncQueueProducerProvider(queueType string) (ProducerConstructor, bool)

GetAsyncQueueProducerProvider returns a queue producer constructor for a given queue type