amqp

package
v2.2.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Mar 15, 2017 License: BSD-2-Clause-Views Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ReportStorage

type ReportStorage struct {
	MaxBatchSize         uint
	MaxConcurrentBatches uint
	BatchTimeout         time.Duration
	PendingWorkCapacity  uint
	ExchangeName         string
	RoutingKey           string
	AMQPConnectionString string
	Logger               frontreport.Logger
	MetricStorage        frontreport.MetricStorage
	// contains filtered or unexported fields
}

ReportStorage is an AMQP implementation of frontreport.ReportStorage interface

func (*ReportStorage) AddReport

func (rs *ReportStorage) AddReport(report frontreport.Reportable)

AddReport adds a report of any type to next batch

func (*ReportStorage) Start

func (rs *ReportStorage) Start() error

Start initializes AMQP connections and muster batching

func (*ReportStorage) Stop

func (rs *ReportStorage) Stop() error

Stop flushes and stops muster batching

Jump to

Keyboard shortcuts

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