jetstream

Documentation

Index

• func AddToScheme(scheme *runtime.Scheme) error
• func AddV1Alpha2ToScheme(scheme *runtime.Scheme) error
• type SubscriptionManager
  • func NewSubscriptionManager(restCfg *rest.Config, natsConfig env.NATSConfig, metricsAddr string, ...) *SubscriptionManager
  • func (sm *SubscriptionManager) Init(mgr manager.Manager) error
  • func (sm *SubscriptionManager) Start(defaultSubsConfig env.DefaultSubscriptionConfig, _ submgrmanager.Params) error
  • func (sm *SubscriptionManager) Stop(runCleanup bool) error

Functions

func AddToScheme

func AddToScheme(scheme *runtime.Scheme) error

AddToScheme adds all types of clientset and eventing into the given scheme.

func AddV1Alpha2ToScheme

func AddV1Alpha2ToScheme(scheme *runtime.Scheme) error

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