1"use strict";(self.webpackChunkembedded_workflow_builder_docs=self.webpackChunkembedded_workflow_builder_docs||[]).push([["4735"],{50427(e,n,s){s.r(n),s.d(n,{metadata:()=>t,default:()=>a,frontMatter:()=>o,contentTitle:()=>d,toc:()=>l,assets:()=>c});var t=JSON.parse('{"id":"connectors/google-cloud-pub-sub","title":"Google Cloud Pub/Sub Connector","description":"Manage topics, subscriptions, and messages in Google Cloud Pub/Sub.","source":"@site/docs/connectors/google-cloud-pub-sub.md","sourceDirName":"connectors","slug":"/connectors/google-cloud-pub-sub","permalink":"/connectors/google-cloud-pub-sub","draft":false,"unlisted":false,"tags":[],"version":"current","frontMatter":{"title":"Google Cloud Pub/Sub Connector","sidebar_label":"Google Cloud Pub/Sub","description":"Manage topics, subscriptions, and messages in Google Cloud Pub/Sub."},"sidebar":"docs","previous":{"title":"Google Cloud BigQuery","permalink":"/connectors/google-cloud-bigquery"},"next":{"title":"Google Cloud Storage","permalink":"/connectors/google-cloud-storage"}}'),i=s(74848),r=s(28453);let o={title:"Google Cloud Pub/Sub Connector",sidebar_label:"Google Cloud Pub/Sub",description:"Manage topics, subscriptions, and messages in Google Cloud Pub/Sub."},d,c={},l=[{value:"API Documentation",id:"api-documentation",level:2},{value:"Connections",id:"connections",level:2},{value:"Google Pub/Sub Private Key",id:"privatekey",level:3},{value:"OAuth2",id:"oauth2",level:3},{value:"Prerequisites",id:"prerequisites",level:4},{value:"Setup Steps",id:"setup-steps",level:4},{value:"Configure the Connection",id:"configure-the-connection",level:4},{value:"App Verification",id:"app-verification",level:4},{value:"Publishing the App",id:"publishing-the-app",level:4},{value:"Requesting Verification",id:"requesting-verification",level:4},{value:"Triggers",id:"triggers",level:2},{value:"PubSub Notification",id:"mytrigger",level:3},{value:"Actions",id:"actions",level:2},{value:"Create Subscription",id:"createsubscription",level:3},{value:"Create Topic",id:"createtopic",level:3},{value:"Create Webhook Subscription",id:"createwebhooksubscription",level:3},{value:"Delete Subscription",id:"deletesubscription",level:3},{value:"Delete Topic",id:"deletetopic",level:3},{value:"Get Policy",id:"getpolicy",level:3},{value:"Get Subscription",id:"getsubscription",level:3},{value:"Get Topic",id:"gettopic",level:3},{value:"List Subscriptions",id:"listsubscriptions",level:3},{value:"List Topics",id:"listtopics",level:3},{value:"Pull Messages",id:"pullmessages",level:3},{value:"Raw Request",id:"rawrequest",level:3},{value:"Set Gmail IAM Policy for Topic",id:"settopiciampolicy",level:3},{value:"Set Policy",id:"setpolicy",level:3},{value:"Update Push Config",id:"updatepushconfig",level:3},{value:"Update Subscription",id:"updatesubscription",level:3},{value:"Update Topic",id:"updatetopic",level:3}];function h(e){let n={a:"a",code:"code",em:"em",h2:"h2",h3:"h3",h4:"h4",img:"img",li:"li",ol:"ol",p:"p",pre:"pre",strong:"strong",table:"table",tbody:"tbody",td:"td",th:"th",thead:"thead",tr:"tr",ul:"ul",...(0,r.R)(),...e.components};return(0,i.jsxs)(i.Fragment,{children:[(0,i.jsxs)(n.p,{children:[(0,i.jsx)(n.img,{alt:"Google Cloud Pub/Sub",src:s(90559).A+"#connector-icon",width:"32",height:"32"}),"\n",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub",children:"Google Cloud Pub/Sub"})," is a messaging service from Google Cloud Platform for asynchronous communication between applications.\nThe Google Cloud Pub/Sub component allows you to create, update, delete, and list topics and subscriptions, as well as publish and pull messages."]}),"\n",(0,i.jsx)(n.h2,{id:"api-documentation",children:"API Documentation"}),"\n",(0,i.jsxs)(n.p,{children:["This component was built using the ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest",children:"Google Cloud Pub/Sub REST API"})," currently utilizing v1."]}),"\n",(0,i.jsx)(n.h2,{id:"connections",children:"Connections"}),"\n",(0,i.jsx)(n.h3,{id:"privatekey",children:"Google Pub/Sub Private Key"}),"\n",(0,i.jsx)(n.p,{children:"Authenticate requests to Google Cloud Storage using values obtained from the Google Cloud Platform."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Client Email"}),(0,i.jsx)(n.td,{children:"The service account email address from the Google Cloud service account JSON key file."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Private Key"}),(0,i.jsx)(n.td,{children:"The private key from the Google Cloud service account JSON key file. This should be the entire key value including the BEGIN and END markers."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID that contains the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Scopes"}),(0,i.jsxs)(n.td,{children:["Space-delimited list of OAuth 2.0 scopes. See ",(0,i.jsx)(n.a,{href:"https://developers.google.com/identity/protocols/oauth2/scopes#pubsub",children:"OAuth 2.0 Scopes for Google APIs"})," for more information."]}),(0,i.jsxs)(n.td,{children:[(0,i.jsx)(n.a,{href:"https://www.googleapis.com/auth/cloud-platform",children:"https://www.googleapis.com/auth/cloud-platform"})," ",(0,i.jsx)(n.a,{href:"https://www.googleapis.com/auth/pubsub",children:"https://www.googleapis.com/auth/pubsub"})]})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"oauth2",children:"OAuth2"}),"\n",(0,i.jsx)(n.p,{children:"OAuth2 Connection"}),"\n",(0,i.jsx)(n.p,{children:"All requests to the Google Cloud Pub/Sub API must be authorized by an authenticated user."}),"\n",(0,i.jsxs)(n.p,{children:["To create a Google Cloud Pub/Sub OAuth 2.0 connection, configure an OAuth application in the ",(0,i.jsx)(n.a,{href:"https://console.cloud.google.com/",children:"Google Cloud Console"}),"."]}),"\n",(0,i.jsx)(n.h4,{id:"prerequisites",children:"Prerequisites"}),"\n",(0,i.jsxs)(n.ul,{children:["\n",(0,i.jsx)(n.li,{children:"A Google Cloud account with access to create projects and credentials"}),"\n",(0,i.jsx)(n.li,{children:"A Google Cloud project (or the ability to create one)"}),"\n"]}),"\n",(0,i.jsx)(n.h4,{id:"setup-steps",children:"Setup Steps"}),"\n",(0,i.jsxs)(n.ol,{children:["\n",(0,i.jsxs)(n.li,{children:["Navigate to the ",(0,i.jsx)(n.a,{href:"https://console.cloud.google.com/",children:"Google Cloud Console"})," and select or create a project"]}),"\n",(0,i.jsxs)(n.li,{children:["From ",(0,i.jsx)(n.strong,{children:"APIs & Services"})," > ",(0,i.jsx)(n.strong,{children:"Library"}),", search for and enable the ",(0,i.jsx)(n.strong,{children:"Cloud Pub/Sub API"})]}),"\n",(0,i.jsxs)(n.li,{children:["Navigate to ",(0,i.jsx)(n.strong,{children:"APIs & Services"})," > ",(0,i.jsx)(n.strong,{children:"Credentials"})," and select ",(0,i.jsx)(n.strong,{children:"Create Credentials"})]}),"\n",(0,i.jsxs)(n.li,{children:["Choose ",(0,i.jsx)(n.strong,{children:"OAuth client ID"})]}),"\n",(0,i.jsxs)(n.li,{children:["If this is the first time creating credentials, configure the OAuth consent screen:\n",(0,i.jsxs)(n.ul,{children:["\n",(0,i.jsxs)(n.li,{children:["Enter an ",(0,i.jsx)(n.strong,{children:"App name"})," (company or product name)"]}),"\n",(0,i.jsxs)(n.li,{children:["Provide a ",(0,i.jsx)(n.strong,{children:"User support email"})]}),"\n",(0,i.jsxs)(n.li,{children:["Add ",(0,i.jsx)(n.strong,{children:"App logo"}),", ",(0,i.jsx)(n.strong,{children:"Application home page"}),", and ",(0,i.jsx)(n.strong,{children:"Authorized domains"})," as needed"]}),"\n",(0,i.jsxs)(n.li,{children:["Enter ",(0,i.jsx)(n.strong,{children:"Developer contact information"})]}),"\n"]}),"\n"]}),"\n",(0,i.jsxs)(n.li,{children:["On the ",(0,i.jsx)(n.strong,{children:"Scopes"})," screen, select ",(0,i.jsx)(n.strong,{children:"Add Or Remove Scopes"}),":\n",(0,i.jsxs)(n.ul,{children:["\n",(0,i.jsxs)(n.li,{children:['Search for "Pub/Sub" and add the following scopes:\n',(0,i.jsxs)(n.ul,{children:["\n",(0,i.jsx)(n.li,{children:(0,i.jsx)(n.code,{children:"https://www.googleapis.com/auth/cloud-platform"})}),"\n",(0,i.jsx)(n.li,{children:(0,i.jsx)(n.code,{children:"https://www.googleapis.com/auth/pubsub"})}),"\n"]}),"\n"]}),"\n",(0,i.jsxs)(n.li,{children:["Refer to ",(0,i.jsx)(n.a,{href:"https://developers.google.com/identity/protocols/oauth2/scopes#pubsub",children:"Google's OAuth 2.0 Scopes documentation"})," for additional scope information"]}),"\n"]}),"\n"]}),"\n",(0,i.jsxs)(n.li,{children:["Return to ",(0,i.jsx)(n.strong,{children:"Create OAuth client ID"}),":\n",(0,i.jsxs)(n.ul,{children:["\n",(0,i.jsxs)(n.li,{children:["Under ",(0,i.jsx)(n.strong,{children:"Application type"})," select ",(0,i.jsx)(n.strong,{children:"Web application"})]}),"\n",(0,i.jsxs)(n.li,{children:["Provide a ",(0,i.jsx)(n.strong,{children:"Name"})," for the OAuth client"]}),"\n",(0,i.jsxs)(n.li,{children:["Under ",(0,i.jsx)(n.strong,{children:"Authorized redirect URIs"})," click ",(0,i.jsx)(n.strong,{children:"Add URI"})," and enter: ",(0,i.jsx)(n.code,{children:"https://oauth2.integrations.acme.com/callback"})]}),"\n",(0,i.jsxs)(n.li,{children:["Click ",(0,i.jsx)(n.strong,{children:"CREATE"})]}),"\n"]}),"\n"]}),"\n",(0,i.jsxs)(n.li,{children:["Copy the ",(0,i.jsx)(n.strong,{children:"Client ID"})," and ",(0,i.jsx)(n.strong,{children:"Client Secret"})," from the confirmation dialog"]}),"\n"]}),"\n",(0,i.jsxs)(n.p,{children:["The ",(0,i.jsx)(n.strong,{children:"Client ID"})," and ",(0,i.jsx)(n.strong,{children:"Client Secret"})," can be retrieved later from ",(0,i.jsx)(n.strong,{children:"APIs & Services"})," > ",(0,i.jsx)(n.strong,{children:"Credentials"})," under the ",(0,i.jsx)(n.strong,{children:"OAuth 2.0 Client IDs"})," section by selecting the name of the OAuth client."]}),"\n",(0,i.jsx)(n.h4,{id:"configure-the-connection",children:"Configure the Connection"}),"\n",(0,i.jsxs)(n.ul,{children:["\n",(0,i.jsxs)(n.li,{children:["Enter the ",(0,i.jsx)(n.strong,{children:"Client ID"})," and ",(0,i.jsx)(n.strong,{children:"Client Secret"})," from the OAuth client created above"]}),"\n",(0,i.jsxs)(n.li,{children:["For ",(0,i.jsx)(n.strong,{children:"Scopes"}),", use the following value:\n",(0,i.jsx)(n.pre,{children:(0,i.jsx)(n.code,{children:"https://www.googleapis.com/auth/cloud-platform https://www.googleapis.com/auth/pubsub\n"})}),"\n"]}),"\n"]}),"\n",(0,i.jsx)(n.h4,{id:"app-verification",children:"App Verification"}),"\n",(0,i.jsx)(n.p,{children:"Google requires OAuth apps that request access to user data to pass a verification review before being deployed at scale. This process ensures the app complies with Google's API Services
1User Data Policy, accurately represents its functionality, and handles user data responsibly."}),"\n",(0,i.jsx)(n.p,{children:"Google OAuth apps pass through three stages before they are ready for production use."}),"\n",(0,i.jsxs)(n.p,{children:[(0,i.jsx)(n.strong,{children:"Testing (unpublished):"})," The app is only accessible to users manually added as test users in the OAuth consent screen. Up to 100 test users are allowed \u2014 all other users receive an error. This is the expected state during initial development."]}),"\n",(0,i.jsxs)(n.p,{children:[(0,i.jsx)(n.strong,{children:"Published, unverified:"})," After publishing the app, all Google users can authenticate. However, for sensitive scopes, users see a ",(0,i.jsx)(n.strong,{children:'"This app isn\'t verified"'})," warning. Users can proceed by clicking ",(0,i.jsx)(n.strong,{children:"Advanced"})," \u2192 ",(0,i.jsx)(n.strong,{children:"Go to [app name] (unsafe)"}),", but this warning reduces trust and may be blocked by organizations with strict Google Workspace policies."]}),"\n",(0,i.jsxs)(n.p,{children:[(0,i.jsx)(n.strong,{children:"Verified:"})," Google has reviewed and approved the app. No warning is shown. Verification is required before deploying to production users."]}),"\n",(0,i.jsx)(n.h4,{id:"publishing-the-app",children:"Publishing the App"}),"\n",(0,i.jsx)(n.p,{children:"Publishing is required before any users outside the test list can authenticate:"}),"\n",(0,i.jsxs)(n.ol,{children:["\n",(0,i.jsxs)(n.li,{children:["In the ",(0,i.jsx)(n.a,{href:"https://console.cloud.google.com/",children:"Google Cloud Console"}),", navigate to ",(0,i.jsx)(n.strong,{children:"APIs & Services"})," \u2192 ",(0,i.jsx)(n.strong,{children:"OAuth consent screen"})]}),"\n",(0,i.jsxs)(n.li,{children:["Click ",(0,i.jsx)(n.strong,{children:"PUBLISH APP"})," and confirm"]}),"\n"]}),"\n",(0,i.jsx)(n.h4,{id:"requesting-verification",children:"Requesting Verification"}),"\n",(0,i.jsxs)(n.p,{children:["The scopes used by this component are classified as ",(0,i.jsx)(n.strong,{children:"sensitive"}),' by Google. Submitting for verification removes the "This app isn\'t verified" warning:']}),"\n",(0,i.jsxs)(n.ol,{children:["\n",(0,i.jsxs)(n.li,{children:["On the ",(0,i.jsx)(n.strong,{children:"OAuth consent screen"}),", click ",(0,i.jsx)(n.strong,{children:"Prepare for verification"})]}),"\n",(0,i.jsx)(n.li,{children:"Provide a privacy policy URL, authorized domain, and app logo"}),"\n",(0,i.jsx)(n.li,{children:"Submit for review \u2014 Google typically responds within several weeks"}),"\n"]}),"\n",(0,i.jsxs)(n.p,{children:["Refer to ",(0,i.jsx)(n.a,{href:"https://support.google.com/cloud/answer/10311615",children:"Google's OAuth consent screen documentation"})," for the full verification requirements."]}),"\n",(0,i.jsxs)(n.p,{children:["This connection uses OAuth 2.0, a common authentication mechanism for integrations.\nRead about how OAuth 2.0 works ",(0,i.jsx)(n.a,{href:"/oauth2",children:"here"}),"."]}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Scopes"}),(0,i.jsxs)(n.td,{children:["Space-delimited list of OAuth 2.0 scopes. See ",(0,i.jsx)(n.a,{href:"https://developers.google.com/identity/protocols/oauth2/scopes#pubsub",children:"OAuth 2.0 Scopes for Google APIs"})," for more information."]}),(0,i.jsxs)(n.td,{children:[(0,i.jsx)(n.a,{href:"https://www.googleapis.com/auth/cloud-platform",children:"https://www.googleapis.com/auth/cloud-platform"})," ",(0,i.jsx)(n.a,{href:"https://www.googleapis.com/auth/pubsub",children:"https://www.googleapis.com/auth/pubsub"})]})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Client ID"}),(0,i.jsx)(n.td,{children:"The Client ID from the Google Cloud OAuth 2.0 credentials."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Client Secret"}),(0,i.jsx)(n.td,{children:"The Client Secret from the Google Cloud OAuth 2.0 credentials."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h2,{id:"triggers",children:"Triggers"}),"\n",(0,i.jsx)(n.h3,{id:"mytrigger",children:"PubSub Notification"}),"\n",(0,i.jsx)(n.p,{children:"PubSub Notification Trigger Settings"}),"\n",(0,i.jsx)(n.h2,{id:"actions",children:"Actions"}),"\n",(0,i.jsx)(n.h3,{id:"createsubscription",children:"Create Subscription"}),"\n",(0,i.jsx)(n.p,{children:"Creates a subscription to a given topic."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription"}),(0,i.jsx)(n.td,{children:"The name of the subscription to create."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic"}),(0,i.jsxs)(n.td,{children:["The name of the topic from which this
1subscription is receiving messages. The value of this field will be ",(0,i.jsx)(n.em,{children:"deleted-topic"})," if the topic has been deleted."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the topic input is a full resource path (e.g., 'projects/my-project/topics/my-topic') or just the topic name (e.g., 'my-topic')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Additional Fields"}),(0,i.jsx)(n.td,{children:"Additional optional fields: includes Push Config, BigQuery Config, Ack Deadline Seconds, Retain Acked Messages, Message Retention Duration, Labels, Enable Message Ordering, Expiration Policy, Filter, Dead Letter Policy, Retry Policy, Detached, Enable Exactly Once Delivery, Topic Message Retention Duration, and State."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Push Config"}),(0,i.jsxs)(n.td,{children:["Configuration for push delivery. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#PushConfig",children:"PushConfig"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"BigQuery Config"}),(0,i.jsxs)(n.td,{children:["Configuration for BigQuery delivery. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#BigQueryConfig",children:"BigQueryConfig"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Ack Deadline Seconds"}),(0,i.jsx)(n.td,{children:"The time (in seconds) Pub/Sub waits for acknowledgment before resending the message. Must be between 10 and 600 seconds. Default is 10 seconds
1if not specified."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Retain Acked Messages"}),(0,i.jsx)(n.td,{children:"When true, acknowledged messages are retained in the subscription's backlog until they fall outside the messageRetentionDuration window. Required for seeking to past timestamps."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Message Retention Duration"}),(0,i.jsx)(n.td,{children:"The minimum duration to retain a message after publication. Must be between 10 minutes (600s) and 31 days (2678400s). Format: duration in seconds with up to nine fractional digits, ending with 's' (e.g., '3600s' for 1 hour)."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Labels"}),(0,i.jsxs)(n.td,{children:["Labels to organize and group resources. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/labels",children:"Creating and Updating Labels"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Enable Message Ordering"}),(0,i.jsx)(n.td,{children:"When true, messages with the same orderingKey are delivered to subscribers in the order they are received by Pub/Sub."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Expiration Policy"}),(0,i.jsxs)(n.td,{children:["Policy specifying when the subscription expires. Default TTL is 31 days if not set. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#ExpirationPolicy",children:"ExpirationPolicy"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Filter"}),(0,i.jsxs)(n.td,{children:["A filter expression to select which messages are delivered. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/filtering",children:"Filtering Messages"})," for syntax."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Dead Letter Policy"}),(0,i.jsxs)(n.td,{children:["Policy for dead lettering undeliverable messages. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/dead-letter-topics",children:"Dead Letter Topics"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Retry Policy"}),(0,i.jsxs)(n.td,{children:["Policy for retrying message delivery. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#RetryPolicy",children:"RetryPolicy"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Detached"}),(0,i.jsx)(n.td,{children:"When true, the subscription is detached from its topic and will not receive messages or retain backlog."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Enable Exactly Once Delivery"}),(0,i.jsx)(n.td,{children:"When true, Pub/Sub guarantees exactly-once delivery semantics for messages on this subscription."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic Message Retention Duration"}),(0,i.jsx)(n.td,{children:"Output-only field indicating the minimum duration messages are retained in the topic. Format: duration in seconds ending with 's' (e.g., '86400s')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"State"}),(0,i.jsx)(n.td,{children:"Output-only field indicating whether the subscription can receive messages."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"createtopic",children:"Create Topic"}),"\n",(0,i.jsx)(n.p,{children:"Creates the given topic with the given name."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic"}),(0,i.jsx)(n.td,{children:"Name of the new topic"}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Additional Fields"}),(0,i.jsx)(n.td,{children:"Additional optional fields: includes Labels, Message Storage Policy, KMS Key Name, Schema Settings, Satisfies PZS, and Message Retention Duration."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Labels"}),(0,i.jsxs)(n.td,{children:["Labels to organize and group resources. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/labels",children:"Creating and Upd
1ating Labels"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Message Storage Policy"}),(0,i.jsxs)(n.td,{children:["Policy constraining the Google Cloud regions where messages may be stored. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics#MessageStoragePolicy",children:"Message Storage Policy"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"KMS Key Name"}),(0,i.jsxs)(n.td,{children:["The resource name of the Cloud KMS CryptoKey used to protect access to messages published on this topic. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/cmek",children:"Customer-Managed Encryption Keys"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Schema Settings"}),(0,i.jsxs)(n.td,{children:["Settings for validating messages against a schema. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics#SchemaSettings",children:"Schema Settings"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Satisfies PZS"}),(0,i.jsx)(n.td,{children:"When true, indicates the topic satisfies physical zone separation. This is an output-only field reserved for future use."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Message Retention Duration"}),(0,i.jsx)(n.td,{children:"The minimum duration to retain a message after publication. Must be between 10 minutes (600s) and 31 days (2678400s). Format: duration in seconds with up to nine fractional digits, ending with 's' (e.g., '3600s' for 1 hour)."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"createwebhooksubscription",children:"Create Webhook Subscription"}),"\n",(0,i.jsx)(n.p,{children:"Creates a webhook subscription to a given topic."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription Name"}),(0,i.jsx)(n.td,{children:"The name of the subscription to create."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic"}),(0,i.jsx)(n.td,{children:"The name of the topic. Can be either the topic name (e.g., 'my-topic') or the full resource path (e.g., 'projects/my-project/topics/my-topic')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the topic input is a full resource path (e.g., 'projects/my-project/topics/my-topic') or just the topic name (e.g., 'my-topic')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Webhook URL"}),(0,i.jsx)(n.td,{children:"The URL endpoint to which messages are sent. This is typically the webhook URL of a sibling flow."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"deletesubscription",children:"Delete Subscription"}),"\n",(0,i.jsx)(n.p,{children:"Deletes an existing subscription."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription"}),(0,i.jsx)(n.td,{children:"The name of the subscription. Can be either the subscription name (e.g., 'my-subscription') or the full resource path (e.g., 'projects/my-project/subscriptions/my-subscription')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the subscription input is a full resource path (e.g., 'projects/my-project/subscriptions/my-subscription') or just the subscription name (e.g., 'my-subscription')."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"deletetopic",children:"Delete Topic"}),"\n",(0,i.jsx)(n.p,{children:"Deletes the topic with the given name."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic"}),(0,i.jsx)(n.td,{children:"The name of the topic. Can be either the topic name (e.g., 'my-topic') or the full resource path (e.g., 'projects/my-project/topics/my-topic')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the topic input is a full resource path (e.g., 'projects/my-project/topics/my-topic') or just the topic name (e.g., 'my-topic')."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"getpolicy",children:"Get Policy"}),"\n",(0,i.jsx)(n.p,{children:"Gets the access control policy for a resource."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Resource"}),(0,i.jsxs)(n.td,{children:["The resource name for which the policy is being requested. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/apis/design/resource_names",children:"Resource Names"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Requested Policy Version"}),(0,i.jsx)(n.td,{children:"The maximum policy version to use for formatting the policy. Valid values are 0, 1, and 3. Policies with conditional bindings must use version 3."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"getsubscription",children:"Get Subscription"}),"\n",(0,i.jsx)(n.p,{children:"Gets the configuration details of a subscription."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription"}),(0,i.jsx)(n.td,{children:"The name of the subscription. Can be either the subscription name (e.g., 'my-subscription') or the full resource path (e.g., 'projects/my-project/subscriptions/my-subscription')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the subscription input is a full resource path (e.g., 'projects/my-project/subscriptions/my-subscription') or just the subscription name (e.g., 'my-subscription')."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"gettopic",children:"Get Topic"}),"\n",(0,i.jsx)(n.p,{children:"Gets the configuration of a topic."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic"}),(0,i.jsx)(n.td,{children:"The name of the topic. Can be either the topic name (e.g., 'my-topic') or the full resource path (e.g., 'projects/my-project/topics/my-topic')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the topic input is a full resource path (e.g., 'projects/my-project/topics/my-topic') or just the topic name (e.g., 'my-topic')."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"listsubscriptions",children:"List Subscriptions"}),"\n",(0,i.jsx)(n.p,{children:"Lists matching Subscriptions."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Fetch All"}),(0,i.jsx)(n.td,{children:"When true, fetches all pages of results using pagination."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Pagination"}),(0,i.jsx)(n.td,{children:"Page token and page size to page through results."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Page Token"}),(0,i.jsx)(n.td,{children:"The value returned by the last ListSubscriptionsResponse; indicates that this is a continuation of a prior subscriptions.list call, and that the system should return the next page of data."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Page Size"}),(0,i.jsx)(n.td,{children:"Maximum number of subscriptions to return."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"listtopics",children:"List Topics"}),"\n",(0,i.jsx)(n.p,{children:"Lists matching topics."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Fetch All"}),(0,i.jsx)(n.td,{children:"When true, fetches all pages of results using pagination."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Pagination"}),(0,i.jsx)(n.td,{children:"Page token and page size to page through results."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Page Token"}),(0,i.jsx)(n.td,{children:"The page token returned by a previous list call to request the next page of results."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Page Size"}),(0,i.jsx)(n.td,{children:"The maximum number of results to return per page."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"pullmessages",children:"Pull Messages"}),"\n",(0,i.jsx)(n.p,{children:"Pulls messages from the server."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription"}),(0,i.jsx)(n.td,{children:"The name of the subscription. Can be either the subscription name (e.g., 'my-subscription') or the full resource path (e.g., 'projects/my-project/subscriptions/my-subscription')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the subscription input is a full resource path (e.g., 'projects/my-project/subscriptions/my-subscription') or just the subscription name (e.g., 'my-subscription')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Max Messages"}),(0,i.jsx)(n.td,{children:"The maximum number of messages to return. Must be a positive integer. Pub/Sub may return fewer messages than specified."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Return Immediately"}),(0,i.jsxs)(n.td,{children:["When true, the system responds immediately even if no messages are available. ",(0,i.jsx)(n.strong,{children:"Warning:"})," Setting this to true adversely impacts performance and is discouraged."]}),(0,i.jsx)(n.td,{children:"false"})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"rawrequest",children:"Raw Request"}),"\n",(0,i.jsx)(n.p,{children:"Send raw HTTP request to Google Cloud Pub/Sub"}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"API Version
1"}),(0,i.jsx)(n.td,{children:"The API version to use for constructing the base URL for requests."}),(0,i.jsx)(n.td,{children:"v1"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"URL"}),(0,i.jsxs)(n.td,{children:["Input the path only (/projects/{projectId}/topics), The base URL is already included (",(0,i.jsx)(n.a,{href:"https://pubsub.googleapis.com/%7Bversion%7D",children:"https://pubsub.googleapis.com/{version}"}),"). For example, to connect to ",(0,i.jsx)(n.a,{href:"https://pubsub.googleapis.com/v1/projects/%7BprojectId%7D/topics",children:"https://pubsub.googleapis.com/v1/projects/{projectId}/topics"}),", only /projects/{projectId}/topics is entered in this field."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Method"}),(0,i.jsx)(n.td,{children:"The HTTP method to use."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Data"}),(0,i.jsx)(n.td,{children:"The HTTP body payload to send to the URL."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Form Data"}),(0,i.jsx)(n.td,{children:"The Form Data to be sent as a multipart form upload."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"File Data"}),(0,i.jsx)(n.td,{children:"File Data to be sent as a multipart form upload."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"File Data File Names"}),(0,i.jsx)(n.td,{children:"File names to apply to the file data inputs. Keys must match the file data keys above."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Query Parameter"}),(0,i.jsx)(n.td,{children:"A list of query parameters to send with the request. This is the portion at the end of the URL similar to ?key1=value1&key2=value2."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Header"}),(0,i.jsx)(n.td,{children:"A list of headers to send with the request."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Response Type"}),(0,i.jsx)(n.td,{children:"The type of data you expect in the response. You can request json, text, or binary data."}),(0,i.jsx)(n.td,{children:"json"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Timeout"}),(0,i.jsx)(n.td,{children:"The maximum time that a client will await a response to its request"}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Retry Delay (ms)"}),(0,i.jsx)(n.td,{children:"The delay in milliseconds between retries. This is used when 'Use Exponential Backoff' is disabled."}),(0,i.jsx)(n.td,{children:"0"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Retry On All Errors"}),(0,i.jsx)(n.td,{children:"If true, retries on all erroneous responses regardless of type. This is helpful when retrying after HTTP 429 or other 3xx or 4xx errors. Otherwise, only retries on HTTP 5xx and network errors."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Max Retry Count"}),(0,i.jsx)(n.td,{children:"The maximum number of retries to attempt. Specify 0 for no retries."}),(0,i.jsx)(n.td,{children:"0"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Use Exponential Backoff"}),(0,i.jsx)(n.td,{children:"Specifies whether to use a pre-defined exponential backoff strategy for retries. When enabled, 'Retry Delay (ms)' is ignored."}),(0,i.jsx)(n.td,{children:"false"})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"settopiciampolicy",children:"Set Gmail IAM Policy for Topic"}),"\n",(0,i.jsx)(n.p,{children:"Configure a topic to allow publish notifications from Gmail."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic"}),(0,i.jsx)(n.td,{children:"The full name of the topic to set the IAM policy for"}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"setpolicy",children:"Set Policy"}),"\n",(0,i.jsx)(n.p,{children:"Sets the access control policy on the specified resource."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Resource"}),(0,i.jsxs)(n.td,{children:["The resource name for which the policy is being requested. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/apis/design/resource_names",children:"Resource Names"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Policy"}),(0,i.jsxs)(n.td,{children:["The complete IAM policy to apply to the resource. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/Policy",children:"Policy"})," for more information."]}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"updatepushconfig",children:"Update Push Config"}),"\n",(0,i.jsx)(n.p,{children:"This may be used to change a push subscription to a pull one (signified by an empty PushConfig) or vice versa, or change the endpoint URL and other attributes of a push subscription."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription"}),(0,i.jsx)(n.td,{children:"The name of the subscription. Can be either the subscription name (e.g., 'my-subscription') or the full resource path (e.g., 'projects/my-project/subscriptions/my-subscription')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the subscription input is a full resource path (e.g., 'projects/my-project/subscriptions/my-subscription') or just the subscription name (e.g., 'my-subscription')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Push Configuration"}),(0,i.jsx)(n.td,{children:"Endpoint, attributes, and OIDC token settings for push delivery."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Push Endpoint"}),(0,i.jsx)(n.td,{children:"The URL endpoint to which messages should be pushed."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Attributes"}),(0,i.jsxs)(n.td,{children:["Endpoint configuration attributes for message delivery. The x-goog-version attribute controls the push message format. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/push",children:"Push Delivery"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"OIDC Token"}),(0,i.jsxs)(n.td,{children:["Configuration for generating an OIDC JWT token as an Authorization header for push requests. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/push#setting_up_for_push_authentication",children:"Authentication"})," for more information."]}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"updatesubscription",children:"Update Subscription"}),"\n",(0,i.jsx)(n.p,{children:"Updates an existing subscription."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription"}),(0,i.jsx)(n.td,{children:"The name of the subscription. Can be either the subscription name (e.g., 'my-subscription') or the full resource path (e.g., 'projects/my-project/subscriptions/my-subscription')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic"}),(0,i.jsxs)(n.td,{children:["The name of the topic from which this
1subscription is receiving messages. The value of this field will be ",(0,i.jsx)(n.em,{children:"deleted-topic"})," if the topic has been deleted."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Subscription Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the subscription input is a full resource path (e.g., 'projects/my-project/subscriptions/my-subscription') or just the subscription name (e.g., 'my-subscription')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Update Mask"}),(0,i.jsxs)(n.td,{children:["Comma-separated list of field paths to update. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/patch#query-parameters",children:"Field Masks"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Additional Fields"}),(0,i.jsx)(n.td,{children:"Additional optional fields: includes Push Config, BigQuery Config, Ack Deadline Seconds, Retain Acked Messages, Message Retention Duration, Labels, Enable Message Ordering, Expiration Policy, Filter, Dead Letter Policy, Retry Policy, Detached, Enable Exactly Once Delivery, Topic Message Retention Duration, and State."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Push Config"}),(0,i.jsxs)(n.td,{children:["Configuration for push delivery. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#PushConfig",children:"PushConfig"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"BigQuery Config"}),(0,i.jsxs)(n.td,{children:["Configuration for BigQuery delivery. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#BigQueryConfig",children:"BigQueryConfig"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Ack Deadline Seconds"}),(0,i.jsx)(n.td,{children:"The time (in seconds) Pub/Sub waits for acknowledgment before resending the message. Must be between 10 and 600 seconds. Default is 10 seconds
1if not specified."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Retain Acked Messages"}),(0,i.jsx)(n.td,{children:"When true, acknowledged messages are retained in the subscription's backlog until they fall outside the messageRetentionDuration window. Required for seeking to past timestamps."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Message Retention Duration"}),(0,i.jsx)(n.td,{children:"The minimum duration to retain a message after publication. Must be between 10 minutes (600s) and 31 days (2678400s). Format: duration in seconds with up to nine fractional digits, ending with 's' (e.g., '3600s' for 1 hour)."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Labels"}),(0,i.jsxs)(n.td,{children:["Labels to organize and group resources. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/labels",children:"Creating and Updating Labels"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Enable Message Ordering"}),(0,i.jsx)(n.td,{children:"When true, messages with the same orderingKey are delivered to subscribers in the order they are received by Pub/Sub."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Expiration Policy"}),(0,i.jsxs)(n.td,{children:["Policy specifying when the subscription expires. Default TTL is 31 days if not set. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#ExpirationPolicy",children:"ExpirationPolicy"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Filter"}),(0,i.jsxs)(n.td,{children:["A filter expression to select which messages are delivered. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/filtering",children:"Filtering Messages"})," for syntax."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Dead Letter Policy"}),(0,i.jsxs)(n.td,{children:["Policy for dead lettering undeliverable messages. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/dead-letter-topics",children:"Dead Letter Topics"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Retry Policy"}),(0,i.jsxs)(n.td,{children:["Policy for retrying message delivery. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#RetryPolicy",children:"RetryPolicy"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Detached"}),(0,i.jsx)(n.td,{children:"When true, the subscription is detached from its topic and will not receive messages or retain backlog."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Enable Exactly Once Delivery"}),(0,i.jsx)(n.td,{children:"When true, Pub/Sub guarantees exactly-once delivery semantics for messages on this subscription."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic Message Retention Duration"}),(0,i.jsx)(n.td,{children:"Output-only field indicating the minimum duration messages are retained in the topic. Format: duration in seconds ending with 's' (e.g., '86400s')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"State"}),(0,i.jsx)(n.td,{children:"Output-only field indicating whether the subscription can receive messages."}),(0,i.jsx)(n.td,{})]})]})]}),"\n",(0,i.jsx)(n.h3,{id:"updatetopic",children:"Update Topic"}),"\n",(0,i.jsx)(n.p,{children:"Updates an existing topic."}),"\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",(0,i.jsxs)(n.table,{children:[(0,i.jsx)(n.thead,{children:(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.th,{children:"Input"}),(0,i.jsx)(n.th,{children:"Comments"}),(0,i.jsx)(n.th,{children:"Default"})]})}),(0,i.jsxs)(n.tbody,{children:[(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Connection"}),(0,i.jsx)(n.td,{children:"The connection to use for authenticating requests to Google Cloud Pub/Sub."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Project ID"}),(0,i.jsx)(n.td,{children:"The Google Cloud project ID containing the Pub/Sub resources."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic"}),(0,i.jsx)(n.td,{children:"Name of the topic"}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Topic Name or Full Format"}),(0,i.jsx)(n.td,{children:"Select whether the topic input is a full resource path (e.g., 'projects/my-project/topics/my-topic') or just the topic name (e.g., 'my-topic')."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Update Mask"}),(0,i.jsxs)(n.td,{children:["Comma-separated list of field paths to update. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/patch#query-parameters",children:"Field Masks"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Additional Fields"}),(0,i.jsx)(n.td,{children:"Additional optional fields: includes Labels, Message Storage Policy, KMS Key Name, Schema Settings, Satisfies PZS, and Message Retention Duration."}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Labels"}),(0,i.jsxs)(n.td,{children:["Labels to organize and group resources. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/labels",children:"Creating and Upd
1ating Labels"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Message Storage Policy"}),(0,i.jsxs)(n.td,{children:["Policy constraining the Google Cloud regions where messages may be stored. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics#MessageStoragePolicy",children:"Message Storage Policy"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"KMS Key Name"}),(0,i.jsxs)(n.td,{children:["The resource name of the Cloud KMS CryptoKey used to protect access to messages published on this topic. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/cmek",children:"Customer-Managed Encryption Keys"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Schema Settings"}),(0,i.jsxs)(n.td,{children:["Settings for validating messages against a schema. See ",(0,i.jsx)(n.a,{href:"https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics#SchemaSettings",children:"Schema Settings"})," for more information."]}),(0,i.jsx)(n.td,{})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Satisfies PZS"}),(0,i.jsx)(n.td,{children:"When true, indicates the topic satisfies physical zone separation. This is an output-only field reserved for future use."}),(0,i.jsx)(n.td,{children:"false"})]}),(0,i.jsxs)(n.tr,{children:[(0,i.jsx)(n.td,{children:"Message Retention Duration"}),(0,i.jsx)(n.td,{children:"The minimum duration to retain a message after publication. Must be between 10 minutes (600s) and 31 days (2678400s). Format: duration in seconds with up to nine fractional digits, ending with 's' (e.g., '3600s' for 1 hour)."}),(0,i.jsx)(n.td,{})]})]})]})]})}function a(e={}){let{wrapper:n}={...(0,r.R)(),...e.components};return n?(0,i.jsx)(n,{...e,children:(0,i.jsx)(h,{...e})}):h(e)}},90559(e,n,s){s.d(n,{A:()=>t});let t="data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAACAAAAAgCAYAAABzenr0AAAACXBIWXMAAAsSAAALEgHS3X78AAAIaklEQVRYhaVWbUxb5xUm6bpN29R2Un5sP6b9qdKoi9I24C+wMf4AEwwkQJykI1lShWZTu2WtunwSYjclJU3VrO3UalOqZd0mraPLqmZNaYGYEkJCAwZjX9tgMCYOYMz9MgYDduz7TO81JiSDjDRHevTa9+o95znPe855b0bG/zFTff1DanPLt74JyN6MBzOsekAHD+ID4sZfvdm+Y8/Jtnd217a+tbu29cwK8dae2tZ3956+ahI94T5JmOal2/N66+5dp2yorLMJlXXiej8QdtZ1YeeJr36x2OcKEofI9vD7jh9W1rZ7TZYrKD9mjVUcs966H5A9ZO+zJ9oH95lb1iz2fe/sTSmmu062W35+shMVx6yJrTUtIDAdXyFqrClUX0pUnuzErtq2k4t9L2tms3k1Watev7x2u6WN23q8FVtrrEI6eNlRKzYfuXRPbKluQZnlCsrMbSgzXxbI74rXrk1te9O+PhUDq+9BAOLLSsvlc9tfvbaQvammBeXVVjx/uh0vvfs19r/TsSR++4freLHOiqqX/4mqA+dR9bt/oeqVjxMvVH+Olw5/XL84yWWlf+5Vq7riSHOy7HATKqovCSTzLUeteP6NdgyP0OA4HjTNgWHuAs2C5Scx7h9GZ4URNtVG2LRy2DQydOVJBYc+B46iPCOJUW8yLXkUq4CMVTuONjdVHP0KZYe+TJQfbca24y0wHrqETy8PIjYzCZZlwfMceI4Dx7ICgfifJ/9pROJx+D76GzolT8CjzYJLvRFU7sbkkDYL3gJFh/c3hd9Jx7ud/XyL1L39x51bDzWh9OWLyS0HvkDFkSYUH2zCgfeug+d5cCQoRzJmkxzHCVNTU4hEpsizJMuKz8T3fDiMzn270CVfD49OBpcmC868zGSgQI6BYtWLJBbSKgApJvDvfizWXeR55bWzyP/1l8myA5+j7FAjSg824ao9gJnpMBiWBGeEubk5TE5OCqFQiBkfH+ej0ShmZmbEdxzDIDwzi5G2VlxRPg2HVoJ+rQQurUQY1EnhMygC7krDj8WYGRmrMlCfYhK3l5oRyMXV87sS+b+8gPKDF2HYfxGnPrQhOk2kvx08FApd9nq9aoqifuD3+x8LBAJbWJb1zM7OkiNKEhKTs3NwWw7jqnQdXPlyePVS9GklifFCBYaMqjN31AIc5esEh56HXQP0KoUTp05Ds68B2480oM8XxFQkDJpmkrFYjEjcfO7cue+m1MOq9Jh1Op0/YVl2gKjBMkySn5oC3e+BrSgXnbnPwKOXYkAvFQb1UgwZsmcGirUbF2pAcBr+Dq8eya68BBxK+K0V0Ff9A2fP9yI2GwHNsIJYdByH0dHRHLKHoqhvpwl4vV6xsILB4N60CixNYzIWh//se+iUrEOPXoY+nRQDOkkiWKjAcJHqk1T2buN62LUx9OQB3XmC0K0F7DL8p74Og4EpTE2yovTT09NkHR4dHf1eOvu7B9jIyMhalmXnwuEwISFwfBhcKATXHhO6lU+hVyclJIQBvRT+Ann8ZpnmqQw4CjegVxtDd4oAujUQbEokqQrw9A2xt9nbBALBYPD7yxGgafoJlmVjIgGGEfjJSdCBAJzPlsCe+zQcOikpSoHUw1CBbHa4VPtkSgXK8BE5AsGmTqSI6IBOCaLeM2DDMdLfApGfOA4Gg5q7jmC1IAjiEdA0vY8UqXgEDI3wXByDv69Dj3QdHHo5nDoJnNqsRMAgx1CR6s8LNQC7cT0c+gjseYAtpQK61RC6dQiP9YANk8Kik8Q5x3HtHR0dj9xdhC6X66ccx/lSRUgn+WgU4/Zu9ObL4SBzQC8lBIR+vQSDBjkzYCp4PBV8vg3hKDyJgfxFKmiBLhnm3AfA8tPgOFbMjJBgGKbT5/MV9/X1raEo6keBQKCS47iBdPYcmZbRKPoP7Ydd8TM482Vw6SSgtFmJEYMC3k2qmoVhhPQg6ipeA0o/CIpkn5dMkdAAXdmIBBrBhmfBc8zCLCA1EQqFpicmJqKk8qPRqLAwiGbnMNLUALtyg5g5pRMHUdKXL8OgIdvjM5keXRhExIB5FZxFe9GfD9jU8wS0gE2BuGM3WJYGR+a9qARDRq8QiUQQiYj3w/woZsVWZWkG7ue2w6HcANd89m5tVjJgUMBXpN4pxlrqQgLMq+EsaIVHB6F78VFIMT30IbjJW6lLh7QXAccLIvgweAKWQziewPBfP4BD/qQ4Ad1icEniZoEC/sLsJjHO4osobQu1QJVo4dAJsIltmToGmwrJns1gx9xg6BCYiVEwE2N3IjQKhptAqJ+Cq0wPKu8ZuPVSQkAgA8iXL0/4NmtVYozlvgmADPEFnIa/YGBxW5K6yMXM10UYa9qMscYSjDWVYPSLEty8WILAhWLc+LcRwxdK4H5BA0qVCXe+FB6dBB5tavL5N2V/kAqeirE0AfM8AfuWtYJDz6I33ZbzJHpyEe/IQbg5G3yjAlyDHMxnctCfyEBfkCLwdhaovEwxczG4TioM5sswZFAwlEn9+LLyL30Uxpo723KehF2DxHUNpq25mGrMRaRBhfBnSvCfKuHdKQOllooXTx+Bjtx+2fAVKatFn8t8Cd1ht9ty36NwGdxwkRpQz6FbHV+ATR2/1Z4bjzYr49MNOfHoJWU8+IYiTqkkcY9eEu/TSQnmbhTIcKMw2+2trHxkRdmnbaEte0pN8BQAfoMAv4GswJAB8BZAfG7XAzY9hEYt6G05GDfkYMKoBF2UA8aYI4wVKdFfqt6x4uyXVMJZboDdWAt7sRm9Rkuyx2i51Wm03LpmtMTaNlli1zZZ6Hd0Fpcmx+Ixqiz9m1QWb1Gu2WtU1foqCorvK/OMuyxN4kHsGwdfcFBveghdmQ/fE3/KfLgr83+xEtn/C9I19ra85b8JAAAAAElFTkSuQmCC"},28453(e,n,s){s.d(n,{R:()=>o,x:()=>d});var t=s(96540);let i={},r=t.createContext(i);function o(e){let n=t.useContext(r);return t.useMemo(function(){return"function"==typeof e?e(n):{...n,...e}},[n,e])}function d(e){let n;return n=e.disableParentContext?"function"==typeof e.components?e.components(i):e.components||i:o(e.components),t.createElement(r.Provider,{value:n},e.children)}}}]);
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.