package amqp

import "github.com/openzipkin/zipkin-go/reporter/amqp"

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

Source Files ¶

amqp.go