Documentation ¶ Index ¶ func HandleConcurrent(ctx context.Context, u *url.URL, handler pubsub.HandlerFunc[pubsub.Message], ...) (pubsub.Subscription, error) func OpenTopic(ctx context.Context, u *url.URL) (pubsub.Topic[pubsub.Message], error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func HandleConcurrent ¶ func HandleConcurrent(ctx context.Context, u *url.URL, handler pubsub.HandlerFunc[pubsub.Message], concurrency int) (pubsub.Subscription, error) func OpenTopic ¶ func OpenTopic(ctx context.Context, u *url.URL) (pubsub.Topic[pubsub.Message], error) Types ¶ This section is empty. Source Files ¶ View all Source files envelope.go pub.go sub.go url.go Click to show internal directories. Click to hide internal directories.