message

package

v0.4.13 Latest Latest Go to latest Published: Jun 24, 2022 License: Apache-2.0 Imports: 4 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.

View Source

var SupportedBrokers = []Broker{AmqpBroker}

SupportedBrokers defines the list of implemented message publishers.

func ValidateOpts(opts *Options) error

ValidateOpts enforces broker-specific configuration requirements.

type Broker string

Broker represents a messaging protocol implementation.

const AmqpBroker Broker = "amqp"

AmqpBroker publishes messages using the AMQP protocol.

type Options struct {
	Broker Broker

	AmqpURI   string
	AmqpQueue string
}

Options defines the configuration for supported brokers.

type Producer interface {
	Push(message interface{}) error
	Close() error
}

Producer defines the operations required by all message producers.

func NewProducer(opts *Options, log logr.Logger) (Producer, error)

NewProducer configures a new message producer using the provided options.

Path	Synopsis
amqp