controller

Sep 8, 2025

Changes in this version

+ func NewControllerWithNamespaceSupport(client dynamic.NamespaceableResourceInterface, ...) *notificationController

+ type NotificationDelivery struct

+ AlreadyNotified bool

+ Destination services.Destination

+ Trigger string

+ type NotificationEventSequence struct

+ Delivered []NotificationDelivery

+ Errors []error

+ Key string

+ Resource metav1.Object

+ Warnings []error

type Opts

+ func WithEventCallback(f func(eventSequence NotificationEventSequence)) Opts

May 4, 2021

Changes in this version

+ const NotifiedAnnotationKey

+ func NewController(client dynamic.NamespaceableResourceInterface, ...) *notificationController

+ func StateItemKey(trigger string, conditionResult triggers.ConditionResult, ...) string

+ type MetricsRegistry struct

+ func NewMetricsRegistry(prefix string) *MetricsRegistry

+ func (r *MetricsRegistry) IncDeliveriesCounter(trigger string, service string, succeeded bool)

+ func (r *MetricsRegistry) IncTriggerEvaluationsCounter(name string, triggered bool)

+ type NotificationController interface

+ Run func(threadiness int, stopCh <-chan struct{})

+ type NotificationsState map[string]int64

+ func NewState(val string) NotificationsState

+ func NewStateFromRes(res metav1.Object) NotificationsState

+ func (s NotificationsState) Persist(res metav1.Object) (map[string]string, error)

+ func (s NotificationsState) SetAlreadyNotified(trigger string, result triggers.ConditionResult, dest services.Destination, ...) bool

+ type Opts func(ctrl *notificationController)

+ func WithAlterDestinations(...) Opts

+ func WithMetricsRegistry(r *MetricsRegistry) Opts

+ func WithSkipProcessing(f func(obj v1.Object) (bool, string)) Opts

+ func WithToUnstructured(f func(obj v1.Object) (*unstructured.Unstructured, error)) Opts