Versions in this module Expand all Collapse all v1 v1.1.3 Sep 29, 2024 Changes in this version + func NewController(client dynamic.NamespaceableResourceInterface, ...) *notificationController + func NewControllerWithNamespaceSupport(client dynamic.NamespaceableResourceInterface, ...) *notificationController + func StateItemKey(isSelfConfig bool, apiNamespace, trigger string, ...) 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 NotificationDelivery struct + AlreadyNotified bool + Destination services.Destination + Trigger string + type NotificationEventSequence struct + Delivered []NotificationDelivery + Errors []error + Key string + Resource v1.Object + Warnings []error + 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(isSelfConfig bool, apiNamespace, trigger string, ...) bool + type Opts func(ctrl *notificationController) + func WithAlterDestinations(...) Opts + func WithEventCallback(f func(eventSequence NotificationEventSequence)) 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
Go to main page