alert

Jun 4, 2025

Changes in this version

+ type AlertDestination struct

+ Config models.Config

+ CreatedAt time.Time

+ DisabledAt *time.Time

+ ID string

+ TenantID string

+ Topics models.Topics

+ Type string

+ type AlertedEvent struct

+ Data map[string]interface{}

+ ID string

+ Metadata map[string]string

+ Topic string

type ConsecutiveFailureData

+ DeliveryResponse map[string]interface{}

+ Event AlertedEvent

type DeliveryAttempt

+ DeliveryResponse map[string]interface{}

May 6, 2025

Changes in this version

+ type Alert interface

+ type AlertEvaluator interface

+ ShouldAlert func(failures int) (level int, shouldAlert bool)

+ func NewAlertEvaluator(thresholds []int, autoDisableFailureCount int) AlertEvaluator

+ type AlertMonitor interface

+ HandleAttempt func(ctx context.Context, attempt DeliveryAttempt) error

+ func NewAlertMonitor(logger *logging.Logger, redisClient *redis.Client, opts ...AlertOption) AlertMonitor

+ type AlertNotifier interface

+ Notify func(ctx context.Context, alert Alert) error

+ func NewHTTPAlertNotifier(callbackURL string, opts ...NotifierOption) AlertNotifier

+ type AlertOption func(*alertMonitor)

+ func WithAlertThresholds(thresholds []int) AlertOption

+ func WithAutoDisableFailureCount(count int) AlertOption

+ func WithDisabler(disabler DestinationDisabler) AlertOption

+ func WithEvaluator(evaluator AlertEvaluator) AlertOption

+ func WithLogger(logger *logging.Logger) AlertOption

+ func WithNotifier(notifier AlertNotifier) AlertOption

+ func WithStore(store AlertStore) AlertOption

+ type AlertStore interface

+ IncrementConsecutiveFailureCount func(ctx context.Context, tenantID, destinationID string) (int, error)

+ ResetConsecutiveFailureCount func(ctx context.Context, tenantID, destinationID string) error

+ func NewRedisAlertStore(client *redis.Client) AlertStore

+ type ConsecutiveFailureAlert struct

+ Data ConsecutiveFailureData

+ Timestamp time.Time

+ Topic string

+ func NewConsecutiveFailureAlert(data ConsecutiveFailureData) ConsecutiveFailureAlert

+ func (a ConsecutiveFailureAlert) MarshalJSON() ([]byte, error)

+ type ConsecutiveFailureData struct

+ ConsecutiveFailures int

+ Data map[string]interface{}

+ Destination *models.Destination

+ MaxConsecutiveFailures int

+ WillDisable bool

+ type DeliveryAttempt struct

+ Data map[string]interface{}

+ DeliveryEvent *models.DeliveryEvent

+ Destination *models.Destination

+ Success bool

+ Timestamp time.Time

+ type DestinationDisabler interface

+ DisableDestination func(ctx context.Context, tenantID, destinationID string) error

+ type NotifierOption func(n *httpAlertNotifier)

+ func NotifierWithBearerToken(token string) NotifierOption

+ func NotifierWithTimeout(timeout time.Duration) NotifierOption