publisher

Documentation

Index

• type DeclareExchangeArgs
• type PublisherOption
  • func WithDeclareExchangeArgs(args DeclareExchangeArgs) PublisherOption
  • func WithInitFunc(args func(channel *amqp091.Channel) (err error)) PublisherOption
  • func WithLogger(logger2 logger.Logger) PublisherOption
• type ReliableRabbitPublisher
  • func NewReliableRabbitPublisher(url string, opts ...PublisherOption) *ReliableRabbitPublisher
  • func (c *ReliableRabbitPublisher) Publish(ctx context.Context, exchange, key string, msg amqp091.Publishing) (err error)
  • func (c *ReliableRabbitPublisher) Reset() error
  • func (c *ReliableRabbitPublisher) Start() (err error)
  • func (c *ReliableRabbitPublisher) Stop()

Types

type DeclareExchangeArgs

type DeclareExchangeArgs struct {
	ExchangeName string
	Kind         string
	Durable      bool
	AutoDelete   bool
	Internal     bool
	NoWait       bool
	Args         map[string]interface{}
}

type PublisherOption

type PublisherOption func(*ReliableRabbitPublisher)

func WithDeclareExchangeArgs

func WithDeclareExchangeArgs(args DeclareExchangeArgs) PublisherOption

func WithInitFunc

func WithInitFunc(args func(channel *amqp091.Channel) (err error)) PublisherOption

func WithLogger

func WithLogger(logger2 logger.Logger) PublisherOption

type ReliableRabbitPublisher

type ReliableRabbitPublisher struct {
	URL                 string
	DeclareExchangeArgs DeclareExchangeArgs
	// contains filtered or unexported fields
}

func NewReliableRabbitPublisher

func NewReliableRabbitPublisher(url string, opts ...PublisherOption) *ReliableRabbitPublisher

func (*ReliableRabbitPublisher) Publish

func (c *ReliableRabbitPublisher) Publish(ctx context.Context, exchange, key string, msg amqp091.Publishing) (err error)

func (*ReliableRabbitPublisher) Reset

func (c *ReliableRabbitPublisher) Reset() error

func (*ReliableRabbitPublisher) Start

func (c *ReliableRabbitPublisher) Start() (err error)

func (*ReliableRabbitPublisher) Stop

func (c *ReliableRabbitPublisher) Stop()