subscriptions

Jul 21, 2025

Changes in this version

+ const WILDCARD_TOPIC

+ var ErrNilEnvelope = errors.New("received nil envelope")

+ type Subscription struct

+ MessagesCh chan *proto.Envelope

+ func (sub *Subscription) Unsubscribe()

+ type SubscriptionDispatcher struct

+ func NewSubscriptionDispatcher(log *zap.Logger) *SubscriptionDispatcher

+ func (d *SubscriptionDispatcher) HandleEnvelope(env *proto.Envelope)

+ func (d *SubscriptionDispatcher) Subscribe(topics map[string]bool) *Subscription