Documentation
¶
Overview ¶
Package pubsub contains utilities for handling Google Cloud Pub/Sub events.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExtractTopicFromRequestPath ¶
ExtractTopicFromRequestPath extracts a Pub/Sub topic from a URL request path.
Types ¶
type LegacyPushSubscriptionEvent ¶
type LegacyPushSubscriptionEvent struct {
Subscription string `json:"subscription"`
Message `json:"message"`
}
LegacyPushSubscriptionEvent is the event payload for legacy Cloud Pub/Sub push subscription triggers (https://cloud.google.com/functions/docs/calling/pubsub#legacy_cloud_pubsub_triggers). This matched the event payload that is sent by Pub/Sub to HTTP push subscription endpoints (https://cloud.google.com/pubsub/docs/push#receiving_messages).
func (*LegacyPushSubscriptionEvent) ToBackgroundEvent ¶
func (e *LegacyPushSubscriptionEvent) ToBackgroundEvent(topic string) *fftypes.BackgroundEvent
ToBackgroundEvent converts the event to the standard BackgroundEvent format for Background Functions.
type Message ¶
type Message struct {
// ID identifies this message.
// This ID is assigned by the server and is populated for Messages obtained from a subscription.
// This field is read-only.
ID string `json:"messageId"`
// Data is the actual data in the message.
Data []byte `json:"data"`
// Attributes represents the key-value pairs the current message
// is labelled with.
Attributes map[string]string `json:"attributes"`
// The time at which the message was published.
// This is populated by the server for Messages obtained from a subscription.
// This field is read-only.
PublishTime time.Time `json:"publishTime"`
}
Message represents a Pub/Sub message.
Click to show internal directories.
Click to hide internal directories.