Versions in this module Expand all Collapse all v1 v1.23.0 Oct 27, 2025 Changes in this version + type Event struct + Type EventType + type EventType string + const NamespaceSyncEventType + const RetrySyncEventType + const StatusUpdateEventType + const SyncEventType + type Funnel struct + Publishers []Publisher + Subscriber Subscriber + func (f *Funnel) Start(ctx context.Context) <-chan struct{} + type Publisher interface + HandleResult func(Result) + Publish func(Subscriber) Result + Start func(context.Context) reflect.Value + Type func() EventType + type PublishingGroupBuilder struct + Clock clock.Clock + NamespaceControllerPeriod time.Duration + RetryBackoff wait.Backoff + StatusUpdatePeriod time.Duration + SyncPeriod time.Duration + func (t *PublishingGroupBuilder) Build() []Publisher + type ResetOnRunAttemptPublisher struct + func NewResetOnRunAttemptPublisher(eventType EventType, c clock.Clock, period time.Duration) *ResetOnRunAttemptPublisher + func (s *ResetOnRunAttemptPublisher) HandleResult(result Result) + type Result struct + ResetRetryBackoff bool + RunAttempted bool + type RetrySyncPublisher struct + Backoff wait.Backoff + Clock clock.Clock + EventType EventType + func NewRetrySyncPublisher(c clock.Clock, backoff wait.Backoff) *RetrySyncPublisher + func (s *RetrySyncPublisher) HandleResult(result Result) + func (s *RetrySyncPublisher) Publish(subscriber Subscriber) Result + func (s *RetrySyncPublisher) Start(ctx context.Context) reflect.Value + func (s *RetrySyncPublisher) Type() EventType + type Subscriber interface + Handle func(Event) Result + type TimeDelayPublisher struct + Clock clock.Clock + EventType EventType + Period time.Duration + func NewTimeDelayPublisher(eventType EventType, c clock.Clock, period time.Duration) *TimeDelayPublisher + func (s *TimeDelayPublisher) HandleResult(_ Result) + func (s *TimeDelayPublisher) Publish(subscriber Subscriber) Result + func (s *TimeDelayPublisher) Start(ctx context.Context) reflect.Value + func (s *TimeDelayPublisher) Type() EventType v1.23.0-rc.1 Oct 27, 2025
Go to main page