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 cspreport.Logger // contains filtered or unexported fields }
ReportStorage is an AMQP implementation of cspreport.ReportStorage interface
func (*ReportStorage) AddCSPReport ¶
func (rs *ReportStorage) AddCSPReport(report cspreport.CSPReport)
AddCSPReport adds a report to next batch
func (*ReportStorage) AddPKPReport ¶
func (rs *ReportStorage) AddPKPReport(report cspreport.PKPReport)
AddPKPReport adds a report 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.