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