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
Click to show internal directories.
Click to hide internal directories.