subscriptionmanager

Documentation

Index

• type Factory
  • func NewFactory(k8sRestCfg *rest.Config, metricsAddress string, ...) *Factory
  • func (f Factory) NewEventMeshManager(domain string) (manager.Manager, error)
  • func (f Factory) NewJetStreamManager(eventing v1alpha1.Eventing, natsConfig env.NATSConfig) manager.Manager
• type ManagerFactory

Types

type Factory

type Factory struct {
	// contains filtered or unexported fields
}

func NewFactory

func NewFactory(
	k8sRestCfg *rest.Config,
	metricsAddress string,
	metricsCollector *metrics.Collector,
	resyncPeriod time.Duration,
	logger *logger.Logger,
) *Factory

func (Factory) NewEventMeshManager

func (f Factory) NewEventMeshManager(domain string) (manager.Manager, error)

func (Factory) NewJetStreamManager

func (f Factory) NewJetStreamManager(eventing v1alpha1.Eventing, natsConfig env.NATSConfig) manager.Manager

type ManagerFactory

type ManagerFactory interface {
	NewJetStreamManager(eventing v1alpha1.Eventing, config env.NATSConfig) manager.Manager
	NewEventMeshManager(domain string) (manager.Manager, error)
}