amqp

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 5, 2022 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL