Documentation
¶
Index ¶
- type MonitorIncident
- type MonitorIncidentRepository
- func (r *MonitorIncidentRepository) CloseIncident(ctx context.Context, monitorID uuid.UUID, endTime time.Time) (uuid.UUID, bool, error)
- func (r *MonitorIncidentRepository) Create(ctx context.Context, startTime time.Time, e executor.HTTPResult) (uuid.UUID, error)
- func (r *MonitorIncidentRepository) GetByID(ctx context.Context, incidentID uuid.UUID) (MonitorIncident, error)
- type MonitorService
- type ResultProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MonitorIncident ¶
type MonitorIncidentRepository ¶
type MonitorIncidentRepository struct {
// contains filtered or unexported fields
}
func NewMonitorIncidentRepo ¶
func NewMonitorIncidentRepo(dbExecutor db.DBTX, logger *zerolog.Logger) *MonitorIncidentRepository
func (*MonitorIncidentRepository) CloseIncident ¶
func (*MonitorIncidentRepository) Create ¶
func (r *MonitorIncidentRepository) Create(ctx context.Context, startTime time.Time, e executor.HTTPResult) (uuid.UUID, error)
func (*MonitorIncidentRepository) GetByID ¶
func (r *MonitorIncidentRepository) GetByID(ctx context.Context, incidentID uuid.UUID) (MonitorIncident, error)
type MonitorService ¶
type ResultProcessor ¶
type ResultProcessor struct {
// contains filtered or unexported fields
}
func NewResultProcessor ¶
func NewResultProcessor( ctx context.Context, resProcessorConfig *config.ResultProcessorConfig, redisSvc *redis.Client, resultChan chan executor.HTTPResult, incidentRepo *MonitorIncidentRepository, monitorSvc MonitorService, alertChan chan alert.AlertEvent, logger *zerolog.Logger, ) *ResultProcessor
func (*ResultProcessor) StartResultProcessor ¶
func (rp *ResultProcessor) StartResultProcessor()
StartResultProcessor starts the Result Processor
func (*ResultProcessor) WorkersClosingWait ¶
func (rp *ResultProcessor) WorkersClosingWait()
WorkersClosingWait waits for all workers to complete
Click to show internal directories.
Click to hide internal directories.