metrics

Documentation

Index

• Constants
• type AsyncMetaUpdater
• type MetaUpdater
  • func NewNullMetaUpdater() MetaUpdater
• type Sender
  • func NewTimescaleDBSender(pgPoolProvider postgres.PoolProvider, ...) Sender

Constants

const (
	TotalAlarmNumber        = "total_alarm_number"
	NonDisplayedAlarmNumber = "non_displayed_alarm_number"
	PbhAlarmNumber          = "pbh_alarm_number"
	InstructionAlarmNumber  = "instruction_alarm_number"
	TicketAlarmNumber       = "ticket_alarm_number"
	CorrelationAlarmNumber  = "correlation_alarm_number"
	AckAlarmNumber          = "ack_alarm_number"
	CancelAckAlarmNumber    = "cancel_ack_alarm_number"
	AckDuration             = "ack_duration"
	ResolveDuration         = "resolve_duration"
	SliDuration             = "sli_duration"
	AlarmStateChangeNumber  = "alarm_state_change_number"

	UserActivity = "user_activity"
	UserSessions = "user_sessions"
	TicketNumber = "ticket_number"

	ManualInstructionAssignedAlarms = "manual_instruction_assigned_alarms"
	ManualInstructionExecutedAlarms = "manual_instruction_executed_alarms"

	InstructionAssignedInstructions = "instruction_assigned_instructions"
	InstructionExecutedInstructions = "instruction_executed_instructions"

	EntityMetaData         = "entities"
	UserMetaData           = "users"
	EntityCategoryMetaData = "entity_categories"

	InstructionExecution             = "instruction_execution"
	InstructionExecutionHourly       = "instruction_execution_hourly"
	InstructionExecutionByModifiedOn = "instruction_execution_by_modified_on"

	NotAckedInHourAlarms      = "not_acked_in_hour_alarms"
	NotAckedInFourHoursAlarms = "not_acked_in_four_hours_alarms"
	NotAckedInDayAlarms       = "not_acked_in_day_alarms"

	PerfData     = "perf_data"
	PerfDataName = "perf_data_name"

	MessageRate       = "message_rate"
	MessageRateHourly = "message_rate_hourly"
)

const (
	EntityCriteriaType = iota
	UserCriteriaType
)

criteria type

Types

type AsyncMetaUpdater

type AsyncMetaUpdater interface {
	MetaUpdater
	Run(ctx context.Context)
}

type MetaUpdater

type MetaUpdater interface {
	UpdateAll(ctx context.Context)
	UpdateById(ctx context.Context, ids ...string)
	DeleteById(ctx context.Context, ids ...string)
}

func NewNullMetaUpdater

func NewNullMetaUpdater() MetaUpdater

type Sender

type Sender interface {
	Run(ctx context.Context)
	SendAck(alarm types.Alarm, userID string, timestamp time.Time)
	SendCancelAck(alarm types.Alarm, timestamp time.Time)
	SendTicket(alarm types.Alarm, userID string, timestamp time.Time)
	SendResolve(alarm types.Alarm, entity types.Entity, timestamp time.Time)
	SendCreate(alarm types.Alarm, timestamp time.Time)
	SendCreateAndPbhEnter(alarm types.Alarm, timestamp time.Time)
	SendCorrelation(timestamp time.Time, child types.Alarm)
	SendUserActivity(timestamp time.Time, username string, value int64)
	SendPbhEnter(alarm types.Alarm, entity types.Entity)
	SendPbhLeave(entity types.Entity, timestamp time.Time, prevCanonicalType string, prevTimestamp time.Time)
	SendPbhLeaveAndEnter(alarm types.Alarm, entity types.Entity, prevCanonicalType string, prevTimestamp time.Time)
	SendUpdateState(alarm types.Alarm, entity types.Entity, previousState types.CpsNumber)

	SendAutoInstructionExecutionStart(alarm types.Alarm, timestamp time.Time)
	SendAutoInstructionExecutionForInstruction(instructionID string, timestamp time.Time)
	SendAutoInstructionAssignForInstructions(instructionIDs []string, timestamp time.Time)

	SendInstructionAssignForAlarm(entityID string, timestamp time.Time)
	SendInstructionAssignForAlarms(entityIDs []string, timestamp time.Time)
	SendInstructionExecutionForAlarm(entityID string, timestamp time.Time)
	SendInstructionAssignForInstruction(instructionID string, timestamp time.Time, value int64)
	SendInstructionAssignForInstructions(instructionIDs []string, timestamp time.Time)
	SendInstructionExecutionForInstruction(instructionID string, timestamp time.Time)

	SendNotAckedInHourInc(alarm types.Alarm, timestamp time.Time)
	SendNotAckedInFourHoursInc(alarm types.Alarm, timestamp time.Time)
	SendNotAckedInDayInc(alarm types.Alarm, timestamp time.Time)
	SendNotAckedInHourDec(alarm types.Alarm, timestamp time.Time)
	SendNotAckedInFourHoursDec(alarm types.Alarm, timestamp time.Time)
	SendNotAckedInDayDec(alarm types.Alarm, timestamp time.Time)
	SendRemoveNotAckedMetric(alarm types.Alarm, timestamp time.Time, notAckedMetricType string)

	SendPerfData(timestamp time.Time, entityID, name string, value float64, unit string)

	SendEventMetrics(alarm types.Alarm, entity types.Entity, alarmChange types.AlarmChange, timestamp time.Time, initiator, userID, instructionID, notAckedMetricType string)

	SendSliMetric(timestamp time.Time, alarm types.Alarm, entity types.Entity)

	SendMessageRate(timestamp time.Time, eventType, connectorName string)
}

func NewTimescaleDBSender

func NewTimescaleDBSender(
	pgPoolProvider postgres.PoolProvider,
	configProvider config.MetricsConfigProvider,
	logger zerolog.Logger,
) Sender