Method OpenSubscriptionURL

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

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

Source from the content-addressed store, hash-verified

841	// This interface is generally implemented by types in driver packages.
842	type SubscriptionURLOpener interface {
843	OpenSubscriptionURL(ctx context.Context, u url.URL) (Subscription, error)
844	}
845
846	// URLMux is a URL opener multiplexer. It matches the scheme of the URLs

TestURLMuxFunction · 0.65

OpenSubscriptionMethod · 0.65

OpenSubscriptionURLMethod · 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