metrics

package

v0.0.0-...-9b5cd94 Latest Latest Go to latest Published: Apr 5, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

git.canopsis.net/canopsis/canopsis-community

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

View Source

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"
)

View Source

const (
	EntityCriteriaType = iota
	UserCriteriaType
)

criteria type

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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)
}

func NewTimescaleDBSender ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL