Versions in this module Expand all Collapse all v1 v1.0.44 Dec 24, 2025 v1.0.43 Dec 24, 2025 Changes in this version + const ConditionTypeDegraded + const ConditionTypeProgressing + const ConditionTypeReady + const ConnectionStateConnected + const ConnectionStateDisconnected + const ConnectionStateError + const ConnectionStateStarting + func GetScheme() *runtime.Scheme + func SetupWithManager(mgr ctrl.Manager, rootCtx dutyctx.Context) error + type BatchTriggerReconciler struct + Manager *ConsumerManager + Scheme *runtime.Scheme + func (r *BatchTriggerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *BatchTriggerReconciler) SetupWithManager(mgr ctrl.Manager) error + type ConsumerManager struct + func NewConsumerManager(rootCtx dutyctx.Context) *ConsumerManager + func (m *ConsumerManager) GetStats(key types.NamespacedName) *ConsumerStats + func (m *ConsumerManager) IsRunning(key types.NamespacedName) bool + func (m *ConsumerManager) Start(key types.NamespacedName, config *v1.Config) error + func (m *ConsumerManager) Stop(key types.NamespacedName) + func (m *ConsumerManager) StopAll() + func (m *ConsumerManager) UpdateConfig(key types.NamespacedName, newConfig *v1.Config) error + type ConsumerStats struct + ConnectionState string + LastError string + LastErrorTime time.Time + MessagesFailed int64 + MessagesProcessed int64 + MessagesRetried int64 + func (s *ConsumerStats) RecordFailed(err error) + func (s *ConsumerStats) RecordProcessed() + func (s *ConsumerStats) RecordRetried() + func (s *ConsumerStats) SetConnectionState(state string) + func (s *ConsumerStats) Snapshot() ConsumerStats + type ManagedConsumer struct
Go to main page