Method OpenTopicURL

pubsub/pubsub.go:834–834 · view source on GitHub ↗

(ctx context.Context, u *url.URL)

Source from the content-addressed store, hash-verified

832	// This interface is generally implemented by types in driver packages.
833	type TopicURLOpener interface {
834	OpenTopicURL(ctx context.Context, u url.URL) (Topic, error)
835	}
836
837	// SubscriptionURLOpener represents types than can open Subscriptions based on a URL.

TestURLMuxFunction · 0.65

OpenTopicMethod · 0.65

OpenTopicURLMethod · 0.65

fakeOpenerpubsub/pubsub_test.go

URLMuxpubsub/pubsub.go

defaultOpenerpubsub/kafkapubsub/kafka.go

URLOpenerpubsub/kafkapubsub/kafka.go

defaultDialerpubsub/natspubsub/nats.go

URLOpenerpubsub/natspubsub/nats.go

lazyCredsOpenerpubsub/gcppubsub/gcppubsub.go

URLOpenerpubsub/gcppubsub/gcppubsub.go

URLOpenerpubsub/mempubsub/mem.go

defaultOpenerpubsub/azuresb/azuresb.go

URLOpenerpubsub/azuresb/azuresb.go

defaultDialerpubsub/rabbitpubsub/rabbit.go

no outgoing calls

TestURLMuxFunction · 0.52