testing

Documentation

Index

• func NewDispatcherDoNothing() dispatcher.NatsDispatcher
• type DispatcherDoNothing
  • func (s *DispatcherDoNothing) ProcessChannels(_ context.Context, _ []messagingv1.Channel) error
  • func (s *DispatcherDoNothing) Start(_ context.Context) error
  • func (s *DispatcherDoNothing) UpdateSubscriptions(ctx context.Context, name, ns string, ...) (map[eventingduckv1.SubscriberSpec]error, error)
• type DispatcherFailNatssSubscription
  • func NewDispatcherFailNatssSubscription() *DispatcherFailNatssSubscription
  • func (s *DispatcherFailNatssSubscription) ProcessChannels(_ context.Context, _ []messagingv1.Channel) error
  • func (s *DispatcherFailNatssSubscription) Start(_ context.Context) error
  • func (s *DispatcherFailNatssSubscription) UpdateSubscriptions(ctx context.Context, name, ns string, ...) (map[eventingduckv1.SubscriberSpec]error, error)

Functions

func NewDispatcherDoNothing

func NewDispatcherDoNothing() dispatcher.NatsDispatcher

Types

type DispatcherDoNothing

type DispatcherDoNothing struct{}

DispatcherDoNothing is a mock which doesn't do anything

func (*DispatcherDoNothing) ProcessChannels

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

func (*DispatcherDoNothing) Start

func (s *DispatcherDoNothing) Start(_ context.Context) error

func (*DispatcherDoNothing) UpdateSubscriptions

func (s *DispatcherDoNothing) UpdateSubscriptions(ctx context.Context, name, ns string, subscriptions []eventingduckv1.SubscriberSpec, isFinalizer bool) (map[eventingduckv1.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, _ []messagingv1.Channel) error

func (*DispatcherFailNatssSubscription) Start

func (s *DispatcherFailNatssSubscription) Start(_ context.Context) error

func (*DispatcherFailNatssSubscription) UpdateSubscriptions

func (s *DispatcherFailNatssSubscription) UpdateSubscriptions(ctx context.Context, name, ns string, subscriptions []eventingduckv1.SubscriberSpec, isFinalizer bool) (map[eventingduckv1.SubscriberSpec]error, error)

UpdateSubscriptions returns a failed natss subscription