producer

Documentation

Index

• type Option
  • func WithAsync() Option
  • func WithBatch(size int, timeout time.Duration) Option
  • func WithExchange(exchange string) Option
  • func WithHeaders(headers amqp.Table) Option
  • func WithPersistentDelivery() Option
  • func WithRoutingKey(key string) Option
• type Options
• type Producer
  • func NewProducer(ch *amqp.Channel, opts ...Option) *Producer
  • func (p *Producer) Close() error
  • func (p *Producer) Publish(ctx context.Context, msg interface{}) error

Types

type Option

type Option func(*Options)

func WithAsync

func WithAsync() Option

func WithBatch

func WithBatch(size int, timeout time.Duration) Option

func WithExchange

func WithExchange(exchange string) Option

func WithHeaders

func WithHeaders(headers amqp.Table) Option

func WithPersistentDelivery

func WithPersistentDelivery() Option

func WithRoutingKey

func WithRoutingKey(key string) Option

type Options

type Options struct {
	Exchange     string
	RoutingKey   string
	Mandatory    bool
	Immediate    bool
	Headers      amqp.Table
	DeliveryMode uint8
	Async        bool
	BatchSize    int
	BatchTimeout time.Duration
}

type Producer

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

func NewProducer

func NewProducer(ch *amqp.Channel, opts ...Option) *Producer

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) Publish

func (p *Producer) Publish(ctx context.Context, msg interface{}) error