dispatcher

Documentation

Index

• type Args
• type NatsDispatcher
  • func NewNatssDispatcher(args Args) (NatsDispatcher, error)
• type SubscriptionChannelMapping

Types

type Args

type Args struct {
	NatssURL       string
	ClusterID      string
	ClientID       string
	AckWaitMinutes int
	MaxInflight    int
	Cargs          kncloudevents.ConnectionArgs
	Logger         *zap.Logger
	Reporter       eventingchannels.StatsReporter
}

type NatsDispatcher

type NatsDispatcher interface {
	Start(ctx context.Context) error
	UpdateSubscriptions(ctx context.Context, name, ns string, subscriptions []eventingduckv1.SubscriberSpec, isFinalizer bool) (map[eventingduckv1.SubscriberSpec]error, error)
	ProcessChannels(ctx context.Context, chanList []messagingv1.Channel) error
}

func NewNatssDispatcher

func NewNatssDispatcher(args Args) (NatsDispatcher, error)

NewNatssDispatcher returns a new NatsDispatcher.

type SubscriptionChannelMapping

type SubscriptionChannelMapping map[eventingchannels.ChannelReference]map[types.UID]*stan.Subscription