GCP Pub/Sub APIs and Methods

Last updated
Save as PDF

Google Cloud Platform (GCP) publish/subscribe (Pub/Sub) is a messaging service. Below are the Pub/Sub APIs, methods, and models used internally in Skyhigh CASB architecture to process GCP config audit events.

Class	Request	Models	Methods	Data Retrieved	Result
Pubsub.Projects.Topics.List	projectId	pubsub.model.ListTopicsResponse	list listTopicsResponse.getTopics listTopicsResponse.execute listTopicsResponse.getNextPageToken	Name, kmsKeyName, Labels	Lists Pub/Sub Topics using service account
Pubsub.Projects.Topics	projectId, topicName	pubsub.model.Topic pubsub.model.ExpirationPolicy pubsub.model.Empty	topics.get().execute() topics.create().execute() -This will get executed when there is no topics present topics.delete().execute()	Name, kmsKeyName, Labels	Get, Create, Delete Pub/Sub Topics using service account
Pubsub.Projects	pubSubType, resourceName	pubsub.model.Policy pubsub.model.Topic pubsub.model.Binding	projects().subscriptions().getIamPolicy().excute() projects().snapshots().getIamPolicy().excute() projects().topics().getIamPolicy().excute()	Bindings, Etag, Version	To get pub sub policy
Pubsub.Projects.Subscriptions.List	projectId	pubsub.model.ListSubscriptionsResponse	projects().subscriptions().list() subscriptions().excute()	AckDeadlineSeconds, expirationPolicy, Labels, MessageRetentionDuration, Name, PushConfig, RetainAckedMessages	Lists Pub/Sub Subscription using service account
Pubsub.Projects.Subscriptions	projectId, subscriptionName, topicName, isSubscriptionPersistent	pubsub.model.Subscription pubsub.model.ExpirationPolicy pubsub.model.Empty	projects().subscriptions() subscriptions().get().excute() subscriptions().create().excute() subscriptions().delete().excute()	AckDeadlineSeconds, ExpirationPolicy, labels, MessageRetentionDuration, Name, PushConfig, RetainAckedMessages	Create, Get, Delete Pub/Sub Subscription using service account, Project, SubscriptionName and Topic
Pubsub.Projects.Snapshots.List	projectId	pubsub.model.ListSnapshotsResponse	projects().snapshots().list() snapshots().excute()	ExpireTime, Labels, Name, Topic	Lists Pub/Sub Snapshot using service account and project
Pubsub.Projects.Snapshots	projectId, snapshotName	pubsub.model.Snapshots	projects().snapshots() snapshots().get().excute() snapshots().create().excute() snapshots().delete().excute()	ExpireTime, Labels, Name, Topic	Get Pub/Sub Snapshot using service account and project and snapshotName
Pubsub.Projects.Subscriptions.Pull	subscription, pull limit	pubsub.model.PullResponse pubsub.model.ReceivedMessage pubsub.model.PullRequest	projects().subscription().pull() pull().excute() pullResponse.getReceivedMessages()	java.util.List<ReceivedMessage>	Lists pull received message Pub/Sub subscription using service account
Pubsub.Projects.Subscriptions.Acknowledge	messageAckIds, subscription	pubsub.model.AcknowledgeRequest pubsub.model.ReceivedMessage pubsub.model.PullRequest	projects().subscription().acknowledge() acknowledge().excute()	Id , Kind, Name, Bucket, Generation, TimeCreated, Updated, StorageClass, Size, MediaLink, Metadata, Etag, EventBasedHold, SelfLink, EventType, Action, Digest, Tag, PublishTime	Pull received message of Pub/Sub subscription using service account and project