Versions in this module Expand all Collapse all v0 v0.26.0 Dec 20, 2021 Changes in this version + var NewSubscription = newSubscription + var NewTopic = newTopic + var OpenCensusViews = oc.Views(pkgName, latencyMeasure) + type Message struct + AfterSend func(asFunc func(interface{}) bool) error + BeforeSend func(asFunc func(interface{}) bool) error + Body []byte + LoggableID string + Metadata map[string]string + func (m *Message) Ack() + func (m *Message) As(i interface{}) bool + func (m *Message) Nack() + func (m *Message) Nackable() bool + type Subscription struct + func OpenSubscription(ctx context.Context, urlstr string) (*Subscription, error) + func (s *Subscription) As(i interface{}) bool + func (s *Subscription) ErrorAs(err error, i interface{}) bool + func (s *Subscription) Receive(ctx context.Context) (_ *Message, err error) + func (s *Subscription) Shutdown(ctx context.Context) (err error) + type SubscriptionURLOpener interface + OpenSubscriptionURL func(ctx context.Context, u *url.URL) (*Subscription, error) + type Topic struct + func OpenTopic(ctx context.Context, urlstr string) (*Topic, error) + func (t *Topic) As(i interface{}) bool + func (t *Topic) ErrorAs(err error, i interface{}) bool + func (t *Topic) Send(ctx context.Context, m *Message) (err error) + func (t *Topic) Shutdown(ctx context.Context) (err error) + type TopicURLOpener interface + OpenTopicURL func(ctx context.Context, u *url.URL) (*Topic, error) + type URLMux struct + func DefaultURLMux() *URLMux + func (mux *URLMux) OpenSubscription(ctx context.Context, urlstr string) (*Subscription, error) + func (mux *URLMux) OpenSubscriptionURL(ctx context.Context, u *url.URL) (*Subscription, error) + func (mux *URLMux) OpenTopic(ctx context.Context, urlstr string) (*Topic, error) + func (mux *URLMux) OpenTopicURL(ctx context.Context, u *url.URL) (*Topic, error) + func (mux *URLMux) RegisterSubscription(scheme string, opener SubscriptionURLOpener) + func (mux *URLMux) RegisterTopic(scheme string, opener TopicURLOpener) + func (mux *URLMux) SubscriptionSchemes() []string + func (mux *URLMux) TopicSchemes() []string + func (mux *URLMux) ValidSubscriptionScheme(scheme string) bool + func (mux *URLMux) ValidTopicScheme(scheme string) bool
Go to main page