v2

Documentation

Overview

Package v2 provides a client with included tracing capabilities.

Index

• type OptionFunc
  • func Config(cfg amqp.Config) OptionFunc
• type Publisher
  • func New(url string, oo ...OptionFunc) (*Publisher, error)
  • func (tc *Publisher) Close() error
  • func (tc *Publisher) Publish(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error

Types

type OptionFunc

type OptionFunc func(*Publisher) error

OptionFunc definition for configuring the publisher in a functional way.

func Config

func Config(cfg amqp.Config) OptionFunc

Config option for providing dial configuration.

type Publisher

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

Publisher defines a RabbitMQ publisher with tracing instrumentation.

func New

func New(url string, oo ...OptionFunc) (*Publisher, error)

New constructor.

func (*Publisher) Close

func (tc *Publisher) Close() error

Close the channel and connection.

func (*Publisher) Publish

func (tc *Publisher) Publish(ctx context.Context, exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

Publish a message to a exchange.