Documentation
¶
Index ¶
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
PubSubName string
Topic string
PubSub *rtpubsub.PubsubItem
Resiliency resiliency.Provider
TraceSpec *config.TracingSpec
Route rtpubsub.Subscription
GRPC *manager.Manager
Adapter rtpubsub.Adapter
AdapterStreamer rtpubsub.AdapterStreamer
ConnectionID rtpubsub.ConnectionID
Postman postman.Interface
}
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(err ...error)
Click to show internal directories.
Click to hide internal directories.