rabbitmq

package module

Go to main page

Versions in this module

v0

v0.1.7

Jun 4, 2024

v0.1.6

Jun 4, 2024

v0.1.5

Jun 4, 2024

Changes in this version

type Publisher

+ func (p *Publisher) Close() error

v0.1.4

Apr 3, 2024

v0.1.3

Jul 30, 2023

v0.1.2

Jul 4, 2023

Changes in this version

type DeliveryContext

+ func (c *DeliveryContext) Get(key string) (any, bool)

+ func (c *DeliveryContext) Set(key string, value any)

v0.1.1

Jul 3, 2023

Changes in this version

type Logger

+ ErrorStr func(ctx context.Context, message string)

+ TraceStr func(ctx context.Context, message string)

v0.1.0

Mar 18, 2023

Changes in this version

+ const DefaultCircuitBreakerConsecutiveFailuresAllowed

+ type Connection struct

+ func NewConnection(conn *amqp.Connection, factory ConnectionFactory) *Connection

+ func (c *Connection) Close()

+ func (c *Connection) IsAlive() bool

+ func (c *Connection) NotifyClose(ch chan error) chan error

+ func (c *Connection) NotifyReconnect(ch chan error) chan error

+ type ConnectionFactory func() (*amqp.Connection, error)

+ type Consumer struct

+ Channel *amqp.Channel

+ Conn *Connection

+ func NewConsumer(conn *Connection, queueParams QueueParams, opts ...ConsumerOption) (*Consumer, error)

+ func (c *Consumer) Consume(consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) <-chan amqp.Delivery

+ func (c *Consumer) DeclaredQueue() amqp.Queue

+ type ConsumerOption func(p *Consumer)

+ func WithConsumerQos(qos QualityOfService) ConsumerOption

+ func WithExchangeDeclare(exchangeParams ExchangeParams, queueBindingKey string) ConsumerOption

+ type ConsumerParams struct

+ AutoAck bool

+ ConsumerArgs amqp.Table

+ ConsumerName string

+ type ControllerFunc func(ctx *DeliveryContext)

+ type DeliveryContext struct

+ Acked bool

+ Channel *amqp.Channel

+ Delivery amqp.Delivery

+ Nacked bool

+ func NewDeliveryContext(baseCtx context.Context, delivery amqp.Delivery, ch *amqp.Channel, ...) *DeliveryContext

+ func (c *DeliveryContext) Ack() bool

+ func (c *DeliveryContext) BindJSON(ptr interface{}) error

+ func (c *DeliveryContext) Nack(requeue bool, err error) bool

+ func (c *DeliveryContext) Next()

+ type ExchangeParams struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ Kind string

+ Name string

+ NoWait bool

+ type GroupOption func(g *RouterGroup)

+ func WithNumWorkers(workers int) GroupOption

+ func WithRouterEngine(engine RouterEngine) GroupOption

+ type LogParams struct

+ ExchangeName string

+ Key string

+ type Logger interface

+ InfoStr func(ctx context.Context, message string)

+ type LoggerConfig struct

+ Formatter func(params *LogParams) string

+ Logger Logger

+ type Publisher struct

+ Conn *Connection

+ func NewPublisher(connection *Connection, exchangeParams ExchangeParams, opts ...PublisherOption) (*Publisher, error)

+ func (p *Publisher) Broken() bool

+ func (p *Publisher) Publish(ctx context.Context, key string, mandatory, immediate bool, ...) (err error)

+ type PublisherOption func(p *Publisher)

+ func WithLogger(cfg LoggerConfig) PublisherOption

+ func WithQueueDeclaration(queueParams QueueParams, bindingKey string) PublisherOption

+ func WithRetries() PublisherOption

+ func WithTraceInjection() PublisherOption

+ type QualityOfService struct

+ PrefetchCount int

+ PrefetchSize int

+ type QueueParams struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool

+ type Router struct

+ func NewRouter() *Router

+ func (r *Router) Group(exchange ExchangeParams, queue QueueParams, qos QualityOfService, ...) *RouterGroup

+ type RouterEngine interface

+ AddBinding func(bindingKey string, controllers ...ControllerFunc)

+ Route func(routingKey string) []ControllerFunc

+ func NewDirectRouterEngine() RouterEngine

+ func NewTopicRouterEngine() RouterEngine

+ type RouterGroup struct

+ func (g *RouterGroup) Route(routingKey string, controllers ...ControllerFunc) *RouterGroup

+ type Server struct

+ Conn *Connection

+ func NewServer(conn *Connection, router *Router) *Server

+ func (s *Server) ListenAndServe(ctx context.Context) error

+ func (s *Server) Shutdown(ctx context.Context) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL