Documentation
¶
Overview ¶
Package pubsub implements the GCP Pub/Sub v1 REST API as a server.Handler. Real google.golang.org/api/pubsub/v1 clients configured with a custom endpoint hit this handler the same way they hit pubsub.googleapis.com.
MVP coverage:
PUT /v1/projects/{p}/topics/{name} — Create
GET /v1/projects/{p}/topics/{name} — Get
GET /v1/projects/{p}/topics — List
DELETE /v1/projects/{p}/topics/{name} — Delete
POST /v1/projects/{p}/topics/{name}:publish — Publish
PUT /v1/projects/{p}/subscriptions/{name} — Create
GET /v1/projects/{p}/subscriptions/{name} — Get
GET /v1/projects/{p}/subscriptions — List
DELETE /v1/projects/{p}/subscriptions/{name} — Delete
POST /v1/projects/{p}/subscriptions/{name}:pull — Pull
POST /v1/projects/{p}/subscriptions/{name}:acknowledge — Ack
The portable messagequeue driver pairs a topic and subscription under a single queue keyed by name. SDK-compat reflects this: a subscription's "topic" must point at a topic with the same trailing name. Cross-name subscriptions (sub "billing-events" linked to topic "events") are not modeled in the MVP.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler serves Pub/Sub v1 REST requests against a messagequeue driver.
Click to show internal directories.
Click to hide internal directories.