Reference

Topics
topics_create()	Creates a pub/sub topic
topics_delete()	Deletes a pub/sub topic
topics_exists()	Check if a topic exists
topics_get()	Gets a topic configuration
topics_list()	Lists topics from project
topics_list_subscriptions()	List attached subscriptions to a topic.
topics_patch()	Updates an existing topic
topics_publish()	Adds one or more messages to the topic
Subscriptions
subscriptions_ack()	Acknowledges the messages
subscriptions_create()	Creates a subscription to a given topic
subscriptions_delete()	Deletes an existing subscription.
subscriptions_detach()	Detaches a subscription from a topic.
subscriptions_exists()	Check if a subscription exists
subscriptions_get()	Gets the configuration details of a subscription.
subscriptions_list()	List subscriptions
subscriptions_modify_ack_deadline()	Modify the ack deadline for a subscription
subscriptions_modify_pushconf()	Modify PushConfig for a subscription
subscriptions_patch()	Updates an existing subscription.
subscriptions_pull()	Pulls messages from the server.
subscriptions_seek()	Seek a subscription to a point in time
Schemas
schemas_create()	Creates a schema
schemas_delete()	Deletes a schema
schemas_exists()	Check if a schema exists
schemas_get()	Gets a schema
schemas_list()	Lists all schemas in a project
schemas_validate()	Validates a schema
schemas_validate_message()	Validates a message against a schema
Snapshots
snapshots_create()	Creates a snapshot from the requested subscription
snapshots_delete()	Removes an existing snapshot
snapshots_exists()	Check if a snapshot exists
snapshots_get()	Gets the configuration details of a snapshot
snapshots_list()	Lists the existing snapshots
snapshots_patch()	Updates an existing snapshot
Objects
PubsubMessage()	Builds a PubsubMessage Object
Topic()	Builds a Topic Object
DlqPolicy()	Builds a DqlPolicy object
MessageStoragePolicy()	Builds a MessageStoragePolicy object
RetryPolicy()	Builds a retry policy object
PushConfig()	Builds a PushConfig Object
Subscription()	Builds a Subscription Object
Schema()	Builds a Schema Object
SchemaSettings()	SchemaSettings Object
Snapshot()	Builds a Snapshot Object
DeadLetterPolicy()	Builds a DeadLetterPolicy Object
ExpirationPolicy()	Builds a ExpirationPolicy Object
Auth
pubsub_auth()	Authenticate a Pub/Sub client
ps_project_get()	Get GCP projectId
ps_project_set()	Set GCP projectId
Utils
msg_encode()	Encode Pub/Sub message
msg_decode()	Decode Pub/Sub message