Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddToScheme ¶
AddToScheme adds all types of clientset and eventing into the given scheme.
func AddV1Alpha2ToScheme ¶
AddV1Alpha2ToScheme adds v1alpha2 scheme into the given scheme.
Types ¶
type SubscriptionManager ¶
type SubscriptionManager struct {
// contains filtered or unexported fields
}
func NewSubscriptionManager ¶
func NewSubscriptionManager(restCfg *rest.Config, natsConfig env.NATSConfig, metricsAddr string, metricsCollector *backendmetrics.Collector, logger *logger.Logger, ) *SubscriptionManager
NewSubscriptionManager creates the subscription manager for JetStream.
func (*SubscriptionManager) Init ¶
func (sm *SubscriptionManager) Init(mgr manager.Manager) error
Init initialize the JetStream subscription manager.
func (*SubscriptionManager) Start ¶
func (sm *SubscriptionManager) Start(defaultSubsConfig env.DefaultSubscriptionConfig, _ submgrmanager.Params) error
func (*SubscriptionManager) Stop ¶
func (sm *SubscriptionManager) Stop(runCleanup bool) error
Source Files
Click to show internal directories.
Click to hide internal directories.