amqp

Documentation

Overview

Package amqp implements a RabbitMq reporter to send spans to a Rabbit server/cluster.

Index

• func NewReporter(address string, options ...ReporterOption) (reporter.Reporter, error)
• type ReporterOption
  • func Channel(ch *amqp.Channel) ReporterOption
  • func Connection(conn *amqp.Connection) ReporterOption
  • func Exchange(exchange string) ReporterOption
  • func Logger(logger *log.Logger) ReporterOption
  • func Queue(queue string) ReporterOption

Functions

func NewReporter

func NewReporter(address string, options ...ReporterOption) (reporter.Reporter, error)

NewReporter returns a new RabbitMq-backed Reporter. address should be as described here: https://www.rabbitmq.com/uri-spec.html

Types

type ReporterOption

type ReporterOption func(c *rmqReporter)

ReporterOption sets a parameter for the rmqReporter

func Channel

func Channel(ch *amqp.Channel) ReporterOption

Channel sets the Channel used to send messages

func Connection

func Connection(conn *amqp.Connection) ReporterOption

Connection sets the Connection used to send messages

func Exchange

func Exchange(exchange string) ReporterOption

Exchange sets the Exchange used to send messages ( see https://github.com/openzipkin/zipkin/tree/master/zipkin-collector/rabbitmq if want to change default routing key or exchange

func Logger

func Logger(logger *log.Logger) ReporterOption

Logger sets the logger used to report errors in the collection process.

func Queue

func Queue(queue string) ReporterOption

Queue sets the Queue used to send messages