dispatcher

Documentation

Index

• type SubscriptionsSupervisor
  • func NewDispatcher(natssUrl string, logger *zap.Logger) (*SubscriptionsSupervisor, error)
  • func (s *SubscriptionsSupervisor) Start(stopCh <-chan struct{}) error
  • func (s *SubscriptionsSupervisor) UpdateSubscriptions(channel *eventingv1alpha1.Channel, isFinalizer bool) error

Types

type SubscriptionsSupervisor

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

SubscriptionsSupervisor manages the state of NATS Streaming subscriptions

func NewDispatcher

func NewDispatcher(natssUrl string, logger *zap.Logger) (*SubscriptionsSupervisor, error)

func (*SubscriptionsSupervisor) Start

func (s *SubscriptionsSupervisor) Start(stopCh <-chan struct{}) error

func (*SubscriptionsSupervisor) UpdateSubscriptions

func (s *SubscriptionsSupervisor) UpdateSubscriptions(channel *eventingv1alpha1.Channel, isFinalizer bool) error