subscriber

Documentation

Index

• type Options
• type Subscriber
  • func New(opts Options) *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(key string) error
  • func (s *Subscriber) StopAllSubscriptionsForever()
  • func (s *Subscriber) StopAppSubscriptions()
  • func (s *Subscriber) StopPubSub(name string)
  • func (s *Subscriber) StopStreamerSubscription(pubsubName, key string)

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) Run

func (s *Subscriber) Run(ctx context.Context) error

func (*Subscriber) StartAppSubscriptions

func (s *Subscriber) StartAppSubscriptions() error

func (*Subscriber) StartStreamerSubscription

func (s *Subscriber) StartStreamerSubscription(key string) 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(pubsubName, key string)