message

Documentation

Index

• Variables
• func ValidateOpts(opts *Options) error
• type Broker
• type Options
• type Producer
  • func NewProducer(opts *Options, log logr.Logger) (Producer, error)

Variables

var SupportedBrokers = []Broker{AmqpBroker}

SupportedBrokers defines the list of implemented message publishers.

Functions

func ValidateOpts

func ValidateOpts(opts *Options) error

ValidateOpts enforces broker-specific configuration requirements.

Types

type Broker

type Broker string

Broker represents a messaging protocol implementation.

const AmqpBroker Broker = "amqp"

AmqpBroker publishes messages using the AMQP protocol.

type Options

type Options struct {
	Broker Broker

	AmqpURI   string
	AmqpQueue string
}

Options defines the configuration for supported brokers.

type Producer

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

Producer defines the operations required by all message producers.

func NewProducer

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

NewProducer configures a new message producer using the provided options.