rabbitmq

Documentation

Index

• Constants
• Variables
• func New(shutdownHandler shutdown.ShutdownHandler, ...) []*transport.Transporter
• func NewBatchFactory(transportConfig map[string]interface{}) transport.BatchFactory

Constants

const (
	ConfVarExchangeName   = "exchange-name"
	ConfVarURL            = "rabbitmq-url"
	ConfVarWriteBatchSize = "rabbitmq-batch-size"
)

Variables

var Flags = []cli.Flag{
	cli.StringFlag{
		Name:  "config",
		Value: "config.yaml",
		Usage: "bifrost YAML config file",
	},
	altsrc.NewStringFlag(cli.StringFlag{
		Name:   ConfVarExchangeName,
		Usage:  "RabbitMQ Exchange Name",
		EnvVar: "BIFROST_RABBITMQ_EXCHANGE_NAME",
	}),
	altsrc.NewStringFlag(cli.StringFlag{
		Name:   ConfVarURL,
		Usage:  "RabbitMQ URL",
		EnvVar: "BIFROST_RABBITMQ_URL",
	}),
	altsrc.NewIntFlag(cli.IntFlag{
		Name:   ConfVarWriteBatchSize,
		Usage:  "RabbitMQ Number of messages to write before waiting for confirmations",
		EnvVar: "BIFROST_RABBITMQ_BATCH_SIZE",
		Value:  5000,
	}),
}

Functions

func New

func New(shutdownHandler shutdown.ShutdownHandler,
	txnsWritten chan<- *ordered_map.OrderedMap,
	statsChan chan stats.Stat,
	workers int,
	inputChans []<-chan transport.Batch,
	transportConfig map[string]interface{}) []*transport.Transporter

New creates a rabbitmq transport which has rabbitmq batching and rabbitmq transporting, connected by channels

func NewBatchFactory

func NewBatchFactory(transportConfig map[string]interface{}) transport.BatchFactory

NewBatchFactory returns a GenericBatchFactory configured for RabbitMQ