testing

Documentation

Index

• func NewDispatcherDoNothing() dispatcher.NatssDispatcher
• type DispatcherDoNothing
  • func (s *DispatcherDoNothing) ProcessChannels(_ context.Context, _ []messagingv1alpha1.Channel) error
  • func (s *DispatcherDoNothing) Start(_ <-chan struct{}) error
  • func (s *DispatcherDoNothing) UpdateSubscriptions(_ *messagingv1alpha1.Channel, _ bool) (map[eventingduck.SubscriberSpec]error, error)
• type DispatcherFailNatssSubscription
  • func NewDispatcherFailNatssSubscription() *DispatcherFailNatssSubscription
  • func (s *DispatcherFailNatssSubscription) ProcessChannels(_ context.Context, _ []messagingv1alpha1.Channel) error
  • func (s *DispatcherFailNatssSubscription) Start(_ <-chan struct{}) error
  • func (s *DispatcherFailNatssSubscription) UpdateSubscriptions(channel *messagingv1alpha1.Channel, _ bool) (map[eventingduck.SubscriberSpec]error, error)

Functions

func NewDispatcherDoNothing

func NewDispatcherDoNothing() dispatcher.NatssDispatcher

Types

type DispatcherDoNothing

type DispatcherDoNothing struct{}

DispatcherDoNothing is a dummy mock which doesn't do anything

func (*DispatcherDoNothing) ProcessChannels

func (s *DispatcherDoNothing) ProcessChannels(_ context.Context, _ []messagingv1alpha1.Channel) error

func (*DispatcherDoNothing) Start

func (s *DispatcherDoNothing) Start(_ <-chan struct{}) error

func (*DispatcherDoNothing) UpdateSubscriptions

func (s *DispatcherDoNothing) UpdateSubscriptions(_ *messagingv1alpha1.Channel, _ bool) (map[eventingduck.SubscriberSpec]error, error)

type DispatcherFailNatssSubscription

type DispatcherFailNatssSubscription struct {
}

DispatcherFailNatssSubscription simulates that natss has a failed subscription

func NewDispatcherFailNatssSubscription

func NewDispatcherFailNatssSubscription() *DispatcherFailNatssSubscription

func (*DispatcherFailNatssSubscription) ProcessChannels

func (s *DispatcherFailNatssSubscription) ProcessChannels(_ context.Context, _ []messagingv1alpha1.Channel) error

func (*DispatcherFailNatssSubscription) Start

func (s *DispatcherFailNatssSubscription) Start(_ <-chan struct{}) error

func (*DispatcherFailNatssSubscription) UpdateSubscriptions

func (s *DispatcherFailNatssSubscription) UpdateSubscriptions(channel *messagingv1alpha1.Channel, _ bool) (map[eventingduck.SubscriberSpec]error, error)

UpdateSubscriptions returns a failed natss subscription