dispatcher

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

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
}

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