Versions in this module Expand all Collapse all v0 v0.5.0 Aug 8, 2018 Changes in this version + type SubscriptionsSupervisor struct + func StartSubscriptionsSupervisor(opts *opts.Options, tracer *trc.Tracer) *SubscriptionsSupervisor + func (s *SubscriptionsSupervisor) IsNATSConnected() bool + func (s *SubscriptionsSupervisor) IsRunning() bool + func (s *SubscriptionsSupervisor) PoisonPill() + func (s *SubscriptionsSupervisor) ReconnectToNATSStreaming() + func (s *SubscriptionsSupervisor) StartSubscriptionReq(sub *v1alpha1.Subscription) + func (s *SubscriptionsSupervisor) StopSubscriptionReq(sub *v1alpha1.Subscription) + type SubscriptionsSupervisorInterface interface + IsNATSConnected func() bool + IsRunning func() bool + PoisonPill func() + StartSubscriptionReq func(sub *v1alpha1.Subscription) + StopSubscriptionReq func(sub *v1alpha1.Subscription)
Go to main page