subscription

Documentation

Index

• type Options
• type Subscription
  • func New(opts Options) (*Subscription, error)
  • func (s *Subscription) Stop()

Types

type Options

type Options struct {
	AppID           string
	Namespace       string
	PubSubName      string
	Topic           string
	IsHTTP          bool
	PubSub          *rtpubsub.PubsubItem
	Resiliency      resiliency.Provider
	TraceSpec       *config.TracingSpec
	Route           rtpubsub.Subscription
	Channels        *channels.Channels
	GRPC            *manager.Manager
	Adapter         rtpubsub.Adapter
	AdapterStreamer rtpubsub.AdapterStreamer
}

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

func New

func New(opts Options) (*Subscription, error)

func (*Subscription) Stop

func (s *Subscription) Stop()