rabbit

Documentation

Overview

Package rabbit contains an experimental RabbitMQ publishing client.

Index

• Constants
• type Config
• type PublisherPool
  • func Load(ctx context.Context, cfg Config, sys *system.System) (*PublisherPool, error)
  • func NewPublisherPool(ctx context.Context, name string, dialer *amqpextra.Dialer, ...) *PublisherPool
  • func (p *PublisherPool) Close(ctx context.Context) (err error)
  • func (p *PublisherPool) Gauges(_ context.Context) map[string]float64
  • func (p *PublisherPool) MetricName() string
  • func (p *PublisherPool) Publish(ctx context.Context, msg publisher.Message) (err error)
  • func (p *PublisherPool) PublishJSON(ctx context.Context, msg publisher.Message, v interface{}) (err error)

Constants

const JSON = "application/json; charset=utf-8"

Types

type Config

type Config struct {
	URL            secret.String
	ConnectionName string
	QueueName      string
}

type PublisherPool

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

func Load

func Load(ctx context.Context, cfg Config, sys *system.System) (*PublisherPool, error)

func NewPublisherPool

func NewPublisherPool(ctx context.Context, name string, dialer *amqpextra.Dialer,
	opts ...publisher.Option) *PublisherPool

func (*PublisherPool) Close

func (p *PublisherPool) Close(ctx context.Context) (err error)

func (*PublisherPool) Gauges

func (p *PublisherPool) Gauges(_ context.Context) map[string]float64

func (*PublisherPool) MetricName

func (p *PublisherPool) MetricName() string

func (*PublisherPool) Publish

func (p *PublisherPool) Publish(ctx context.Context, msg publisher.Message) (err error)

func (*PublisherPool) PublishJSON

func (p *PublisherPool) PublishJSON(ctx context.Context, msg publisher.Message, v interface{}) (err error)