Documentation
¶
Index ¶
- type Options
- type Subscriber
- func (s *Subscriber) InitProgramaticSubscriptions(ctx context.Context) error
- func (s *Subscriber) ReloadDeclaredAppSubscription(name, pubsubName string) error
- func (s *Subscriber) ReloadPubSub(name string) error
- func (s *Subscriber) Run(ctx context.Context) error
- func (s *Subscriber) StartAppSubscriptions() error
- func (s *Subscriber) StartStreamerSubscription(subscription *subapi.Subscription, connectionID rtpubsub.ConnectionID) error
- func (s *Subscriber) StopAllSubscriptionsForever()
- func (s *Subscriber) StopAppSubscriptions()
- func (s *Subscriber) StopPubSub(name string)
- func (s *Subscriber) StopStreamerSubscription(subscription *subapi.Subscription, connectionID rtpubsub.ConnectionID)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
AppID string
Namespace string
Resiliency resiliency.Provider
TracingSpec *config.TracingSpec
IsHTTP bool
Channels *channels.Channels
GRPC *manager.Manager
CompStore *compstore.ComponentStore
Adapter rtpubsub.Adapter
AdapterStreamer rtpubsub.AdapterStreamer
}
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func New ¶
func New(opts Options) *Subscriber
func (*Subscriber) InitProgramaticSubscriptions ¶
func (s *Subscriber) InitProgramaticSubscriptions(ctx context.Context) error
func (*Subscriber) ReloadDeclaredAppSubscription ¶
func (s *Subscriber) ReloadDeclaredAppSubscription(name, pubsubName string) error
func (*Subscriber) ReloadPubSub ¶
func (s *Subscriber) ReloadPubSub(name string) error
func (*Subscriber) StartAppSubscriptions ¶
func (s *Subscriber) StartAppSubscriptions() error
func (*Subscriber) StartStreamerSubscription ¶
func (s *Subscriber) StartStreamerSubscription(subscription *subapi.Subscription, connectionID rtpubsub.ConnectionID) error
func (*Subscriber) StopAllSubscriptionsForever ¶
func (s *Subscriber) StopAllSubscriptionsForever()
func (*Subscriber) StopAppSubscriptions ¶
func (s *Subscriber) StopAppSubscriptions()
func (*Subscriber) StopPubSub ¶
func (s *Subscriber) StopPubSub(name string)
func (*Subscriber) StopStreamerSubscription ¶
func (s *Subscriber) StopStreamerSubscription(subscription *subapi.Subscription, connectionID rtpubsub.ConnectionID)
Source Files
Click to show internal directories.
Click to hide internal directories.