amqp

Documentation

Overview

Package amqp provides a client with included tracing capabilities.

Deprecated: The AMQP client package is superseded by the `github.com/beatlabs/client/amqp/v2` package. Please refer to the documents and the examples for the usage.

This package is frozen and no new functionality will be added.

Index

• type Message
  • func NewJSONMessage(d interface{}) (*Message, error)
  • func NewMessage(ct string, body []byte) *Message
  • func NewProtobufMessage(d interface{}) (*Message, error)
• type OptionFunc
  • func Timeout(timeout time.Duration) OptionFunc
• type Publisher
• type TracedPublisher
  • func NewPublisher(url, exc string, oo ...OptionFunc) (*TracedPublisher, error)
  • func (tc *TracedPublisher) Close(_ context.Context) error
  • func (tc *TracedPublisher) Publish(ctx context.Context, msg *Message) error

Types

type Message

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

Message abstraction for publishing.

func NewJSONMessage

func NewJSONMessage(d interface{}) (*Message, error)

NewJSONMessage creates a new message with a JSON encoded body.

func NewMessage

func NewMessage(ct string, body []byte) *Message

NewMessage creates a new message.

func NewProtobufMessage

func NewProtobufMessage(d interface{}) (*Message, error)

NewProtobufMessage creates a new message with a protobuf encoded body.

type OptionFunc

type OptionFunc func(*TracedPublisher) error

OptionFunc definition for configuring the publisher in a functional way.

func Timeout

func Timeout(timeout time.Duration) OptionFunc

Timeout option for adjusting the timeout of the connection.

type Publisher

type Publisher interface {
	Publish(ctx context.Context, msg *Message) error
	Close(ctx context.Context) error
}

Publisher interface of a RabbitMQ publisher.

type TracedPublisher

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

TracedPublisher defines a RabbitMQ publisher with tracing instrumentation.

func NewPublisher

func NewPublisher(url, exc string, oo ...OptionFunc) (*TracedPublisher, error)

NewPublisher creates a new publisher with the following defaults - exchange type: fanout - notifications are not handled at this point TBD.

Deprecated: The AMQP client package is superseded by the `github.com/beatlabs/client/amqp/v2` package. Please refer to the documents and the examples for the usage.

This package is frozen and no new functionality will be added.

func (*TracedPublisher) Close

func (tc *TracedPublisher) Close(_ context.Context) error

Close the connection and channel of the publisher.

func (*TracedPublisher) Publish

func (tc *TracedPublisher) Publish(ctx context.Context, msg *Message) error

Publish a message to a exchange.