notification

package

Go to main page

Versions in this module

v0

v0.5.9

Feb 22, 2023

Changes in this version

type Notification

+ UniqueKey string

v0.5.8

Feb 6, 2023

Changes in this version

+ const ReceiverIDLabelKey

+ const TypeReceiver

+ const TypeSubscriber

+ const ValidDurationRequestKey

+ type AlertService interface

+ UpdateSilenceStatus func(ctx context.Context, alertIDs []int64, hasSilenced bool, hasNonSilenced bool) error

+ type Deps struct

+ AlertService AlertService

+ DispatchReceiverService Dispatcher

+ DispatchSubscriberService Dispatcher

+ IdempotencyRepository IdempotencyRepository

+ LogService LogService

+ ReceiverService ReceiverService

+ SilenceService SilenceService

+ SubscriptionService SubscriptionService

+ type DispatchReceiverService struct

+ func NewDispatchReceiverService(receiverService ReceiverService, notifierPlugins map[string]Notifier) *DispatchReceiverService

+ func (s *DispatchReceiverService) PrepareMessage(ctx context.Context, n Notification) ([]Message, []log.Notification, bool, error)

+ type DispatchSubscriberService struct

+ func NewDispatchSubscriberService(logger saltlog.Logger, subscriptionService SubscriptionService, ...) *DispatchSubscriberService

+ func (s *DispatchSubscriberService) PrepareMessage(ctx context.Context, n Notification) ([]Message, []log.Notification, bool, error)

+ type Dispatcher interface

+ PrepareMessage func(ctx context.Context, n Notification) ([]Message, []log.Notification, bool, error)

+ type Idempotency struct

+ CreatedAt time.Time

+ ID uint64

+ Key string

+ Scope string

+ Success bool

+ UpdatedAt time.Time

+ type IdempotencyFilter struct

+ TTL time.Duration

+ type LogService interface

+ LogNotifications func(ctx context.Context, nlogs ...log.Notification) error

type Message

+ func InitMessage(ctx context.Context, notifierPlugin Notifier, n Notification, ...) (Message, error)

type MessageStatus

+ const DetailsKeyNotificationType

type Notification

+ AlertIDs []int64

+ NamespaceID uint64

+ Type string

+ ValidDuration time.Duration

+ func BuildFromAlerts(as []alert.Alert, firingLen int, createdTime time.Time) Notification

+ func BuildTypeReceiver(receiverID uint64, payloadMap map[string]interface{}) (Notification, error)

+ func (n *Notification) EnrichID(id string)

+ func (n Notification) Validate() error

+ type Repository interface

+ Create func(context.Context, Notification) (Notification, error)

type Service

+ func (s *Service) Dispatch(ctx context.Context, n Notification) error

+ type SilenceService interface

+ List func(ctx context.Context, filter silence.Filter) ([]silence.Silence, error)

v0.5.7

Feb 2, 2023

v0.5.6

Jan 16, 2023

Changes in this version

+ type IdempotencyRepository interface

+ Delete func(context.Context, idempotency.Filter) error

+ InsertOnConflictReturning func(context.Context, string, string) (*idempotency.Idempotency, error)

+ UpdateSuccess func(context.Context, uint64, bool) error

+ type Service struct

+ func (ns *Service) DispatchToReceiver(ctx context.Context, n Notification, receiverID uint64) error

+ func (ns *Service) DispatchToSubscribers(ctx context.Context, namespaceID uint64, n Notification) error

+ func (s *Service) CheckAndInsertIdempotency(ctx context.Context, scope, key string) (uint64, error)

+ func (s *Service) MarkIdempotencyAsSuccess(ctx context.Context, id uint64) error

+ func (s *Service) RemoveIdempotencies(ctx context.Context, TTL time.Duration) error

v0.5.5

Jan 10, 2023

v0.5.4

Dec 5, 2022

v0.5.3

Dec 2, 2022

v0.5.2

Nov 25, 2022

Changes in this version

type MessageStatus

+ func (ms MessageStatus) String() string

type Queuer

+ Type func() string

v0.5.1

Nov 17, 2022

v0.5.0

Nov 8, 2022

Changes in this version

+ var ErrNoMessage = errors.New("no message found")

+ type Config struct

+ DLQHandler HandlerConfig

+ MessageHandler HandlerConfig

+ Queue queues.Config

+ type Handler struct

+ func NewHandler(cfg HandlerConfig, logger log.Logger, q Queuer, registry map[string]Notifier, ...) *Handler

+ func (h *Handler) MessageHandler(ctx context.Context, messages []Message) error

+ func (h *Handler) Process(ctx context.Context, runAt time.Time) error

+ type HandlerConfig struct

+ BatchSize int

+ Enabled bool

+ PollDuration time.Duration

+ ReceiverTypes []string

+ type HandlerOption func(*Handler)

+ func HandlerWithBatchSize(bs int) HandlerOption

+ func HandlerWithIdentifier(identifier string) HandlerOption

+ type Message struct

+ Configs map[string]interface{}

+ CreatedAt time.Time

+ Details map[string]interface{}

+ ExpiredAt time.Time

+ ID string

+ LastError string

+ MaxTries int

+ ReceiverType string

+ Retryable bool

+ Status MessageStatus

+ TryCount int

+ UpdatedAt time.Time

+ func (m *Message) AddStringDetail(key, value string)

+ func (m *Message) Initialize(n Notification, receiverType string, ...)

+ func (m *Message) MarkFailed(updatedAt time.Time, retryable bool, err error)

+ func (m *Message) MarkPending(updatedAt time.Time)

+ func (m *Message) MarkPublished(updatedAt time.Time)

+ type MessageOption func(*Message)

+ func InitWithCreateTime(timeNow time.Time) MessageOption

+ func InitWithExpiryDuration(dur time.Duration) MessageOption

+ func InitWithID(id string) MessageOption

+ func InitWithMaxTries(mt int) MessageOption

+ type MessageStatus string

+ const DefaultMaxTries

+ const DetailsKeyRoutingMethod

+ const MessageStatusEnqueued

+ const MessageStatusFailed

+ const MessageStatusPending

+ const MessageStatusPublished

+ type Notification struct

+ CreatedAt time.Time

+ Data map[string]interface{}

+ ID string

+ Labels map[string]string

+ Template string

+ ValidDurationString string

+ func (n Notification) ToMessage(receiverType string, notificationConfigMap map[string]interface{}) (*Message, error)

+ type NotificationService struct

+ func NewService(logger log.Logger, q Queuer, receiverService ReceiverService, ...) *NotificationService

+ func (ns *NotificationService) DispatchToReceiver(ctx context.Context, n Notification, receiverID uint64) error

+ func (ns *NotificationService) DispatchToSubscribers(ctx context.Context, n Notification) error

+ type Notifier interface

+ GetSystemDefaultTemplate func() string

+ PostHookQueueTransformConfigs func(ctx context.Context, notificationConfigMap map[string]interface{}) (map[string]interface{}, error)

+ PreHookQueueTransformConfigs func(ctx context.Context, notificationConfigMap map[string]interface{}) (map[string]interface{}, error)

+ Send func(ctx context.Context, message Message) (bool, error)

+ type Queuer interface

+ Cleanup func(ctx context.Context, filter queues.FilterCleanup) error

+ Dequeue func(ctx context.Context, receiverTypes []string, batchSize int, ...) error

+ Enqueue func(ctx context.Context, ms ...Message) error

+ ErrorCallback func(ctx context.Context, ms Message) error

+ Stop func(ctx context.Context) error

+ SuccessCallback func(ctx context.Context, ms Message) error

+ type ReceiverService interface

+ Get func(ctx context.Context, id uint64) (*receiver.Receiver, error)

+ type RoutingMethod string

+ const RoutingMethodReceiver

+ const RoutingMethodSubscribers

+ func (rm RoutingMethod) String() string

+ type SubscriptionService interface

+ MatchByLabels func(ctx context.Context, labels map[string]string) ([]subscription.Subscription, error)

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