messaging

Documentation

Index

• func WithRabbitMqMaxRetries(retries uint) func(*RabbitMqMessenger)
• func WithRabbitMqRetryInterval(interval time.Duration) func(*RabbitMqMessenger)
• func WithRabbitMqSerializer(serializer serialization.ISerializer) func(*RabbitMqMessenger)
• func WithRabbitMqStreamBufferSize(size uint) func(*RabbitMqMessenger)
• type IMessenger
  • func NewRabbitMqMessenger(ctx context.Context, logger log.ILogger, host string, port uint16, user string, ...) IMessenger[RabbitMqExchange, amqp.Delivery]
• type RabbitMqExchange
• type RabbitMqMessenger
  • func (r *RabbitMqMessenger) Publish(topic RabbitMqExchange, msg any) error
  • func (r *RabbitMqMessenger) Subscribe(topic RabbitMqExchange) async.Stream[amqp.Delivery]
  • func (r *RabbitMqMessenger) Unsubscribe(subsciption async.Stream[amqp.Delivery])

Functions

func WithRabbitMqMaxRetries

func WithRabbitMqMaxRetries(retries uint) func(*RabbitMqMessenger)

func WithRabbitMqRetryInterval

func WithRabbitMqRetryInterval(interval time.Duration) func(*RabbitMqMessenger)

func WithRabbitMqSerializer

func WithRabbitMqSerializer(serializer serialization.ISerializer) func(*RabbitMqMessenger)

func WithRabbitMqStreamBufferSize

func WithRabbitMqStreamBufferSize(size uint) func(*RabbitMqMessenger)

Types

type IMessenger

type IMessenger[K, M any] interface {
	Publish(topic K, msg any) error
	Subscribe(topic K) async.Stream[M]
	Unsubscribe(subsciption async.Stream[M])
}

func NewRabbitMqMessenger

func NewRabbitMqMessenger(ctx context.Context, logger log.ILogger, host string, port uint16, user string, password string, opts ...func(*RabbitMqMessenger)) IMessenger[RabbitMqExchange, amqp.Delivery]

type RabbitMqExchange

type RabbitMqExchange struct {
	Type       string
	Exchange   string
	RoutingKey string
}

type RabbitMqMessenger

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

func (*RabbitMqMessenger) Publish

func (r *RabbitMqMessenger) Publish(topic RabbitMqExchange, msg any) error

Publish implements IMessenger.

func (*RabbitMqMessenger) Subscribe

func (r *RabbitMqMessenger) Subscribe(topic RabbitMqExchange) async.Stream[amqp.Delivery]

Subscribe implements IMessenger.

func (*RabbitMqMessenger) Unsubscribe

func (r *RabbitMqMessenger) Unsubscribe(subsciption async.Stream[amqp.Delivery])

Unsubscribe implements IMessenger.