zSrSSKJr SSKJr SSKJr SSKJr Sr "SS\R5r "S S \R5r "S S \R5r "S S\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS \R5r"S!S"\R5r"S#S$\R5r"S%S&\R5r"S'S(\R5r"S)S*\R5r"S+S,\R5r"S-S.\R5r"S/S0\R5r"S1S2\R5r "S3S4\R5r!"S5S6\R5r""S7S8\R5r#"S9S:\R5r$"S;S<\R5r%"S=S>\R5r&"S?S@\R5r'"SASB\R5r("SCSD\R5r)"SESF\R5r*"SGSH\R5r+"SISJ\R5r,"SKSL\R5r-"SMSN\R5r."SOSP\R5r/"SQSR\R5r0"SSST\R5r1"SUSV\R5r2"SWSX\R5r3"SYSZ\R5r4"S[S\\R5r5"S]S^\R5r6"S_S`\R5r7"SaSb\R5r8"ScSd\R5r9"SeSf\R5r:"SgSh\R5r;"SiSj\R5r<"SkSl\R5r="SmSn\R5r>"SoSp\R5r?"SqSr\R5r@"SsSt\R5rA"SuSv\R5rB"SwSx\R5rC"SySz\R5rD"S{S|\R5rE"S}S~\R5rF"SS\R5rG"SS\R5rH"SS\R5rI"SS\R5rJ"SS\R5rK"SS\R5rL"SS\R5rM"SS\R5rN"SS\R5rO"SS\R5rP"SS\R5rQ"SS\R5rR"SS\R5rS"SS\R5rT"SS\R5rU"SS\R5rV"SS\R5rW"SS\R5rX"SS\R5rY"SS\R5rZ"SS\R5r["SS\R5r\"SS\R5r]"SS\R5r^"SS\R5r_"SS\R5r`"SS\R5ra"SS\R5rb"SS\R5rc"SS\R5rd"SS\R5re"SS\R5rf"SS\R5rg"SS\R5rh"SS\R5ri"SS\R5rj"SS\R5rk"SS\R5rl"SS\R5rm"SS\R5rn"SS\R5ro"SS\R5rp"SS\R5rq"SS\R5rr"SS\R5rs"SS\R5rt"SS\R5ru"SS\R5rv"SS\R5rw"SS\R5rx"SS\R5ry"SS\R5rz"SS\R5r{"SS\R5r|"SS\R5r}"SS\R5r~"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GS GS \R5r"GS GS \R5r"GS GS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS \R5r"GS!GS"\R5r"GS#GS$\R5r"GS%GS&\R5r"GS'GS(\R5r"GS)GS*\R5r"GS+GS,\R5r"GS-GS.\R5r"GS/GS0\R5r"GS1GS2\R5r"GS3GS4\R5r"GS5GS6\R5r"GS7GS8\R5r"GS9GS:\R5r"GS;GS<\R5r"GS=GS>\R5r"GS?GS@\R5r"GSAGSB\R5r"GSCGSD\R5r"GSEGSF\R5r"GSGGSH\R5r"GSIGSJ\R5r"GSKGSL\R5r"GSMGSN\R5r\GR^"\GSOGSP5 \GR`"\GRbGSQGSR5 \GR`"\GRbGSSGST5 GgU(Vz6Generated message classes for datastream version v1. )absolute_import)messages)encoding) extra_types datastreamc\rSrSrSrSrg) AppendOnlyz^AppendOnly mode defines that all changes to a table will be written to the destination table. N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r Qlib/googlecloudsdk/generated_clients/apis/datastream/v1/datastream_v1_messages.pyr r rr c\rSrSrSrSrg)AvroFileFormatzAVRO file format configuration.r Nr r rrrrs(rrc\rSrSrSr\R "SS5r\R "SS5r\R "SS5r \R "S S 5r \R "S S 5r \R "S S5r Sr g)BackfillAllStrategyaHBackfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded. Fields: mongodbExcludedObjects: MongoDB data source objects to avoid backfilling mysqlExcludedObjects: MySQL data source objects to avoid backfilling. oracleExcludedObjects: Oracle data source objects to avoid backfilling. postgresqlExcludedObjects: PostgreSQL data source objects to avoid backfilling. salesforceExcludedObjects: Salesforce data source objects to avoid backfilling sqlServerExcludedObjects: SQLServer data source objects to avoid backfilling MongodbCluster MysqlRdbms OracleRdbmsPostgresqlRdbms SalesforceOrgSqlServerRdbmsr N)r rrrr _messages MessageFieldmongodbExcludedObjectsmysqlExcludedObjectsoracleExcludedObjectspostgresqlExcludedObjectssalesforceExcludedObjectssqlServerExcludedObjectsrr rrrrs~ %112BAF"// a@#00B'445FJ'44_aH&334DaHrrc$\rSrSrSr"SS\R 5r"SS\R 5r\R"SSS S 9r \R"S 5r \R"S 5r \R"SS 5r\R"SS5rSrg) BackfillJob3aRepresents a backfill job on a specific stream object. Enums: StateValueValuesEnum: Output only. Backfill job state. TriggerValueValuesEnum: Backfill job's triggering reason. Fields: errors: Output only. Errors which caused the backfill job to fail. lastEndTime: Output only. Backfill job's end time. lastStartTime: Output only. Backfill job's start time. state: Output only. Backfill job state. trigger: Backfill job's triggering reason. c8\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) BackfillJob.StateValueValuesEnumBazOutput only. Backfill job state. Values: STATE_UNSPECIFIED: Default value. NOT_STARTED: Backfill job was never started for the stream object (stream has backfill strategy defined as manual or object was explicitly excluded from automatic backfill). PENDING: Backfill job will start pending available resources. ACTIVE: Backfill job is running. STOPPED: Backfill job stopped (next job run will start from beginning). FAILED: Backfill job failed (due to an error). COMPLETED: Backfill completed successfully. UNSUPPORTED: Backfill job failed since the table structure is currently unsupported for backfill. rrrr!r#r%r'r N)r rrrrSTATE_UNSPECIFIED NOT_STARTEDPENDINGACTIVESTOPPEDFAILED COMPLETED UNSUPPORTEDrr rrStateValueValuesEnumr4Bs2KG FG FIKrr?c$\rSrSrSrSrSrSrSrg)"BackfillJob.TriggerValueValuesEnum[aBackfill job's triggering reason. Values: TRIGGER_UNSPECIFIED: Default value. AUTOMATIC: Object backfill job was triggered automatically according to the stream's backfill strategy. MANUAL: Object backfill job was triggered manually using the dedicated API. rrrr N) r rrrrTRIGGER_UNSPECIFIED AUTOMATICMANUALrr rrTriggerValueValuesEnumrA[sI FrrFErrorrTrepeatedrr!r#r%r N)r rrrrr(Enumr?rFr)errors StringField lastEndTime lastStartTime EnumFieldstatetriggerrr rrr1r13s Y^^2 y~~   ! !'1t <&%%a(+''*-   4a 8%    8! <'rr1c\rSrSrSrSrg)BackfillNoneStrategypzJBackfill strategy to disable automatic backfill for the Stream's objects. r Nr r rrrSrSprrrSc\rSrSrSrSrg)BasicEncryptionwzMessage to represent the option where Datastream will enforce encryption without authenticating server identity. Server certificates will be trusted by default. r Nr r rrrVrVwrrVc\rSrSrSr\R "SS5r\R "SS5r\R"S5r \R "SS 5r \R "S S 5r \R "S S 5r Srg)BigQueryDestinationConfigaUBigQuery destination configuration Fields: appendOnly: Append only mode blmtConfig: Optional. Big Lake Managed Tables (BLMT) configuration. dataFreshness: The guaranteed data freshness (in seconds) when querying tables created by the stream. Editing this field will only affect new tables created in the future, but existing tables will not be impacted. Lower values mean that queries will return fresher data, but may result in higher cost. merge: The standard mode singleTargetDataset: Single destination dataset. sourceHierarchyDatasets: Source hierarchy datasets. r r BlmtConfigrr!Merger#SingleTargetDatasetr%SourceHierarchyDatasetsr'r N)r rrrrr(r) appendOnly blmtConfigrL dataFreshnessmergesingleTargetDatasetsourceHierarchyDatasetsrr rrrZrZsw %%lA6*%%lA6*''*-  ! ,%!../DaH%223LaPrrZc\rSrSrSrSrg)BigQueryProfilezBigQuery warehouse profile.r Nr r rrrgrg$rrgcd\rSrSrSr\R "SS5r\R "SS5rSr g) BinaryLogParserzConfiguration to use Binary Log Parser CDC technique. Fields: logFileDirectories: Use Oracle directories. oracleAsmLogFileAccess: Use Oracle ASM. LogFileDirectoriesrOracleAsmLogFileAccessrr N) r rrrrr(r)logFileDirectoriesoracleAsmLogFileAccessrr rrrkrks1!--.BAF$112JANrrkc\rSrSrSrSrg)BinaryLogPositionz*Use Binary log position based replication.r Nr r rrrrrr3rrrc$\rSrSrSr"SS\R 5r"SS\R 5r\R"S5r \R"S5r \R"SS 5r \R"S 5r\R"SS 5rS rg )r\aThe configuration for BLMT. Enums: FileFormatValueValuesEnum: Required. The file format. TableFormatValueValuesEnum: Required. The table format. Fields: bucket: Required. The Cloud Storage bucket name. connectionName: Required. The bigquery connection. Format: `{project}.{location}.{name}` fileFormat: Required. The file format. rootPath: The root path inside the Cloud Storage bucket. tableFormat: Required. The table format. c \rSrSrSrSrSrSrg)$BlmtConfig.FileFormatValueValuesEnumznRequired. The file format. Values: FILE_FORMAT_UNSPECIFIED: Default value. PARQUET: Parquet file format. rrr N)r rrrrFILE_FORMAT_UNSPECIFIEDPARQUETrr rrFileFormatValueValuesEnumrxs  Grr|c \rSrSrSrSrSrSrg)%BlmtConfig.TableFormatValueValuesEnumzqRequired. The table format. Values: TABLE_FORMAT_UNSPECIFIED: Default value. ICEBERG: Iceberg table format. rrr N)r rrrrTABLE_FORMAT_UNSPECIFIEDICEBERGrr rrTableFormatValueValuesEnumr~s !Grrrrr!r#r%r N)r rrrrr(rJr|rrLbucketconnectionNamerO fileFormatrootPath tableFormatrr rrr\r\s )..9>>   #&((+.""#>B*  " "1 %(##$@!D+rr\c\rSrSrSrSrg)CancelOperationRequestz3The request message for Operations.CancelOperation.r Nr r rrrr.'':,   q !$(("=-,,-@"E!../DbI,,-@"E''+,''+,++,>C ) 6 67TVX Y$$R(*rrc\rSrSrSr\R "S5r\R "S5r\R "S5r Sr g)DatasetTemplatei3a/Dataset template used for dynamic dataset creation. Fields: datasetIdPrefix: If supplied, every created dataset will have its name prefixed by the provided value. The prefix and name will be separated by an underscore. i.e. _. kmsKeyName: Describes the Cloud KMS encryption key that will be used to protect destination BigQuery table. The BigQuery Service Account associated with your project requires access to this encryption key. i.e. projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoK eys/{cryptoKey}. See https://cloud.google.com/bigquery/docs/customer- managed-encryption for more information. location: Required. The geographic location where the dataset should reside. See https://cloud.google.com/bigquery/docs/locations for supported locations. rrr!r N) r rrrrr(rLdatasetIdPrefix kmsKeyNamelocationrr rrrr3s9"))!,/$$Q'*  " "1 %(rrc\rSrSrSr\R "SS5r\R"S5r \R"S5r \R"SSS 9r \R"S 5r \R"S 5rS rg ):DatastreamProjectsLocationsConnectionProfilesCreateRequestiJaA DatastreamProjectsLocationsConnectionProfilesCreateRequest object. Fields: connectionProfile: A ConnectionProfile resource to be passed as the request body. connectionProfileId: Required. The connection profile identifier. force: Optional. Create the connection profile without validating it. parent: Required. The parent that owns the collection of ConnectionProfiles. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). validateOnly: Optional. Only validate the connection profile, but don't create any resources. The default is false. rrrr!r#Trequiredr%r'r N)r rrrrr(r)connectionProfilerLconnectionProfileIdrforceparent requestId validateOnlyrr rrrrJsp0 ,,-@!D!--a0   #%  T 2&##A&)''*,rrc^\rSrSrSr\R "SSS9r\R "S5rSr g) :DatastreamProjectsLocationsConnectionProfilesDeleteRequestikaA DatastreamProjectsLocationsConnectionProfilesDeleteRequest object. Fields: name: Required. The name of the connection profile resource to delete. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes after the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). rTrrr N r rrrrr(rLrrrr rrrrk+"   q4 0$##A&)rrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g )    #&   q4 0$  # #Ay/@/@/F/F G(##A&)rrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) 2DatastreamProjectsLocationsOperationsCancelRequestizA DatastreamProjectsLocationsOperationsCancelRequest object. Fields: cancelOperationRequest: A CancelOperationRequest resource to be passed as the request body. name: The name of the operation resource to be cancelled. rrrTrr N) r rrrrr(r)cancelOperationRequestrLrrr rrrrs/%112JAN   q4 0$rrc:\rSrSrSr\R "SSS9rSrg)2DatastreamProjectsLocationsOperationsDeleteRequestizA DatastreamProjectsLocationsOperationsDeleteRequest object. Fields: name: The name of the operation resource to be deleted. rTrr Nrr rrrrrrrc:\rSrSrSr\R "SSS9rSrg)/DatastreamProjectsLocationsOperationsGetRequestizoA DatastreamProjectsLocationsOperationsGetRequest object. Fields: name: The name of the operation resource. rTrr Nrr rrrrrrrc\rSrSrSr\R "S5r\R "SSS9r\R"S\RRS9r \R "S 5r \R"S 5rS rg ) 0DatastreamProjectsLocationsOperationsListRequesti(aA DatastreamProjectsLocationsOperationsListRequest object. Fields: filter: The standard list filter. name: The name of the operation's parent resource. pageSize: The standard list page size. pageToken: The standard list page token. returnPartialSuccess: When set to `true`, operations that are reachable are returned as normal, and those that are unreachable are returned in the [ListOperationsResponse.unreachable] field. This can only be `true` when reading across collections e.g. when `parent` is set to `"projects/example/locations/-"`. This field is not by default supported and will result in an `UNIMPLEMENTED` error if set unless explicitly documented otherwise in service or product specific documentation. rrTrr!rr#r%r N)r rrrrr(rLrrrrrrrrreturnPartialSuccessrr rrr r (sj   #&   q4 0$  # #Ay/@/@/F/F G(##A&)"//2rr c\rSrSrSr\R "S5r\R"SSS9r \R"SS5r \R"S 5r \R"S 5r \R "S 5rS rg ):DatastreamProjectsLocationsPrivateConnectionsCreateRequesti@a_A DatastreamProjectsLocationsPrivateConnectionsCreateRequest object. Fields: force: Optional. If set to true, will skip validations. parent: Required. The parent that owns the collection of PrivateConnections. privateConnection: A PrivateConnection resource to be passed as the request body. privateConnectionId: Required. The private connectivity identifier. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). validateOnly: Optional. When supplied with PSC Interface config, will get/create the tenant project required for the customer to allow list and won't actually create the private connection. rrTrPrivateConnectionr!r#r%r'r N)r rrrrr(rrrLrr)privateConnectionprivateConnectionIdrrrr rrr r @sp2   #%  T 2&,,-@!D!--a0##A&)''*,rr c\rSrSrSr\R "S5r\R"SSS9r \R"S5r Sr g ) :DatastreamProjectsLocationsPrivateConnectionsDeleteRequestiba4A DatastreamProjectsLocationsPrivateConnectionsDeleteRequest object. Fields: force: Optional. If set to true, any child routes that belong to this PrivateConnection will also be deleted. name: Required. The name of the private connectivity configuration to delete. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes after the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). rrTrr!r N) r rrrrr(rrrLrrrr rrrrbs;(   #%   q4 0$##A&)rrc:\rSrSrSr\R "SSS9rSrg)7DatastreamProjectsLocationsPrivateConnectionsGetRequesti|zA DatastreamProjectsLocationsPrivateConnectionsGetRequest object. Fields: name: Required. The name of the private connectivity configuration to get. rTrr Nrr rrrr|rrrc\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r \R "S5r \R "SS S 9rS rg ) 8DatastreamProjectsLocationsPrivateConnectionsListRequestiaA DatastreamProjectsLocationsPrivateConnectionsListRequest object. Fields: filter: Filter request. orderBy: Order by fields for the result. pageSize: Maximum number of private connectivity configurations to return. If unspecified, at most 50 private connectivity configurations that will be returned. The maximum value is 1000; values above 1000 will be coerced to 1000. pageToken: Page token received from a previous `ListPrivateConnections` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListPrivateConnections` must match the call that provided the page token. parent: Required. The parent that owns the collection of private connectivity configurations. rrr!rr#r%Trr Nrr rrrrsi"   #&  ! !! $'  # #Ay/@/@/F/F G(##A&)  T 2&rrc\rSrSrSr\R "SSS9r\R "S5r\R"SS5r \R "S 5r S r g ) @DatastreamProjectsLocationsPrivateConnectionsRoutesCreateRequestiaA DatastreamProjectsLocationsPrivateConnectionsRoutesCreateRequest object. Fields: parent: Required. The parent that owns the collection of Routes. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). route: A Route resource to be passed as the request body. routeId: Required. The Route identifier. rTrrRouter!r#r N) r rrrrr(rLrrr)routerouteIdrr rrrrsM(  T 2&##A&)  ! ,%  ! !! $'rrc^\rSrSrSr\R "SSS9r\R "S5rSr g) @DatastreamProjectsLocationsPrivateConnectionsRoutesDeleteRequestiaA DatastreamProjectsLocationsPrivateConnectionsRoutesDeleteRequest object. Fields: name: Required. The name of the Route resource to delete. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes after the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). rTrrr Nrr rrrrs+$   q4 0$##A&)rrc:\rSrSrSr\R "SSS9rSrg)=DatastreamProjectsLocationsPrivateConnectionsRoutesGetRequestizA DatastreamProjectsLocationsPrivateConnectionsRoutesGetRequest object. Fields: name: Required. The name of the Route resource to get. rTrr Nrr rrrrrrrc\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r \R "S5r \R "SS S 9rS rg ) >DatastreamProjectsLocationsPrivateConnectionsRoutesListRequestiaA DatastreamProjectsLocationsPrivateConnectionsRoutesListRequest object. Fields: filter: Filter request. orderBy: Order by fields for the result. pageSize: Maximum number of Routes to return. The service may return fewer than this value. If unspecified, at most 50 Routes will be returned. The maximum value is 1000; values above 1000 will be coerced to 1000. pageToken: Page token received from a previous `ListRoutes` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListRoutes` must match the call that provided the page token. parent: Required. The parent that owns the collection of Routess. rrr!rr#r%Trr Nrr rrr r i    #&  ! !! $'  # #Ay/@/@/F/F G(##A&)  T 2&rr c\rSrSrSr\R "S5r\R"SSS9r \R"S5r \R"SS 5r \R"S 5r \R "S 5rS rg )/DatastreamProjectsLocationsStreamsCreateRequestiaA DatastreamProjectsLocationsStreamsCreateRequest object. Fields: force: Optional. Create the stream without validating it. parent: Required. The parent that owns the collection of streams. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). stream: A Stream resource to be passed as the request body. streamId: Required. The stream identifier. validateOnly: Optional. Only validate the stream, but don't create any resources. The default is false. rrTrr!Streamr#r%r'r N)r rrrrr(rrrLrrr)streamstreamIdrrr rrr#r#sm,   #%  T 2&##A&)  ! !(A .&  " "1 %(''*,rr#c^\rSrSrSr\R "SSS9r\R "S5rSr g) /DatastreamProjectsLocationsStreamsDeleteRequestiaA DatastreamProjectsLocationsStreamsDeleteRequest object. Fields: name: Required. The name of the stream resource to delete. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes after the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). rTrrr Nrr rrr(r(rrr(c:\rSrSrSr\R "SSS9rSrg),DatastreamProjectsLocationsStreamsGetRequesti'zzA DatastreamProjectsLocationsStreamsGetRequest object. Fields: name: Required. The name of the stream resource to get. rTrr Nrr rrr*r*'rrr*c\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r \R "S5r \R "SS S 9rS rg ) -DatastreamProjectsLocationsStreamsListRequesti1aoA DatastreamProjectsLocationsStreamsListRequest object. Fields: filter: Filter request. orderBy: Order by fields for the result. pageSize: Maximum number of streams to return. If unspecified, at most 50 streams will be returned. The maximum value is 1000; values above 1000 will be coerced to 1000. pageToken: Page token received from a previous `ListStreams` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListStreams` must match the call that provided the page token. parent: Required. The parent that owns the collection of streams. rrr!rr#r%Trr Nrr rrr,r,1r!rr,c:\rSrSrSr\R "SSS9rSrg)3DatastreamProjectsLocationsStreamsObjectsGetRequestiHzA DatastreamProjectsLocationsStreamsObjectsGetRequest object. Fields: name: Required. The name of the stream object resource to get. rTrr Nrr rrr.r.Hrrr.c\rSrSrSr\R "S\RRS9r \R"S5r \R"SSS9r S r g ) 4DatastreamProjectsLocationsStreamsObjectsListRequestiRa(A DatastreamProjectsLocationsStreamsObjectsListRequest object. Fields: pageSize: Maximum number of objects to return. Default is 50. The maximum value is 1000; values above 1000 will be coerced to 1000. pageToken: Page token received from a previous `ListStreamObjectsRequest` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListStreamObjectsRequest` must match the call that provided the page token. parent: Required. The parent stream that owns the collection of objects. rrrr!Trr N)r rrrrr(rrrrrLrrrr rrr0r0RsI  # #Ay/@/@/F/F G(##A&)  T 2&rr0c`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) 6DatastreamProjectsLocationsStreamsObjectsLookupRequestidzA DatastreamProjectsLocationsStreamsObjectsLookupRequest object. Fields: lookupStreamObjectRequest: A LookupStreamObjectRequest resource to be passed as the request body. parent: Required. The parent stream that owns the collection of objects. LookupStreamObjectRequestrrTrr N) r rrrrr(r)lookupStreamObjectRequestrLrrr rrr2r2ds0(445PRST  T 2&rr2c`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) @DatastreamProjectsLocationsStreamsObjectsStartBackfillJobRequestiqaA DatastreamProjectsLocationsStreamsObjectsStartBackfillJobRequest object. Fields: object: Required. The name of the stream object resource to start a backfill job for. startBackfillJobRequest: A StartBackfillJobRequest resource to be passed as the request body. rTrStartBackfillJobRequestrr N) r rrrrr(rLobjectr)startBackfillJobRequestrr rrr6r6qs/  T 2&%223LaPrr6c`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) ?DatastreamProjectsLocationsStreamsObjectsStopBackfillJobRequestiaA DatastreamProjectsLocationsStreamsObjectsStopBackfillJobRequest object. Fields: object: Required. The name of the stream object resource to stop the backfill job for. stopBackfillJobRequest: A StopBackfillJobRequest resource to be passed as the request body. rTrStopBackfillJobRequestrr N) r rrrrr(rLr8r)stopBackfillJobRequestrr rrr;r;s/  T 2&$112JANrr;c\rSrSrSr\R "S5r\R"SSS9r \R"S5r \R"SS 5r \R"S 5r \R "S 5rS rg ).DatastreamProjectsLocationsStreamsPatchRequestiaA DatastreamProjectsLocationsStreamsPatchRequest object. Fields: force: Optional. Update the stream without validating it. name: Output only. Identifier. The stream's name. requestId: Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000). stream: A Stream resource to be passed as the request body. updateMask: Optional. Field mask is used to specify the fields to be overwritten in the stream resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten. validateOnly: Optional. Only validate the stream with the changes, without actually updating it. The default is false. rrTrr!r$r#r%r'r N)r rrrrr(rrrLrrr)r%rrrr rrr?r?sm4   #%   q4 0$##A&)  ! !(A .&$$Q'*''*,rr?c`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) ,DatastreamProjectsLocationsStreamsRunRequestia"A DatastreamProjectsLocationsStreamsRunRequest object. Fields: name: Required. Name of the stream resource to start, in the format: projects/{project_id}/locations/{location}/streams/{stream_name} runStreamRequest: A RunStreamRequest resource to be passed as the request body. rTrRunStreamRequestrr N) r rrrrr(rLrr)runStreamRequestrr rrrArAs/   q4 0$++,>BrrAc\rSrSrSr\R "SS5r\R"S5r \R "SS5r Sr g ) DestinationConfigiazThe configuration of the stream destination. Fields: bigqueryDestinationConfig: BigQuery destination configuration. destinationConnectionProfile: Required. Destination connection profile resource. Format: `projects/{project}/locations/{location}/connectionProfiles/{name}` gcsDestinationConfig: A configuration for how data should be loaded to Cloud Storage. rZrrGcsDestinationConfigr!r N) r rrrrr(r)bigqueryDestinationConfigrLdestinationConnectionProfilegcsDestinationConfigrr rrrErEsC (445PRST!*!6!6q!9"//0FJrrEc\rSrSrSr\R "SS5r\R"S5r \R"S5r \R"S\RRS9r\R "S S 5r\R "S S 5r\R "S S5r\R "SS5r\R "SS5r\R "SS5rSrg)riaRequest message for 'discover' ConnectionProfile request. Fields: connectionProfile: An ad-hoc connection profile configuration. connectionProfileName: A reference to an existing connection profile. fullHierarchy: Whether to retrieve the full hierarchy of data objects (TRUE) or only the current level (FALSE). hierarchyDepth: The number of hierarchy levels below the current level to be retrieved. mongodbCluster: MongoDB cluster to enrich with child data objects and metadata. mysqlRdbms: MySQL RDBMS to enrich with child data objects and metadata. oracleRdbms: Oracle RDBMS to enrich with child data objects and metadata. postgresqlRdbms: PostgreSQL RDBMS to enrich with child data objects and metadata. salesforceOrg: Salesforce organization to enrich with child data objects and metadata. sqlServerRdbms: SQLServer RDBMS to enrich with child data objects and metadata. rrrr!r#rrr%rr'r r6r"rr$rr&rr N)r rrrrr(r)rrLconnectionProfileNamer fullHierarchyrrrhierarchyDepthmongodbCluster mysqlRdbms oracleRdbmspostgresqlRdbms salesforceOrgsqlServerRdbmsrr rrrrs* ,,-@!D#//2((+-))!Y5F5F5L5LM.))*:A>.%%lA6*&&}a8+**+.%%lA6*&&}a8+**+.rrUc\rSrSrSrSrg)DropLargeObjectsiz*Configuration to drop large object values.r Nr r rrrWrWrtrrWc\rSrSrSrSrg)Emptyi aA generic empty message that you can re-use to avoid defining duplicated empty messages in your APIs. A typical example is to use it as the request or the response type of an API method. For instance: service Foo { rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); } r Nr r rrrYrY srrYc`\rSrSrSr\R "S5r\R "S5rSr g)EncryptionAndServerValidationiaZMessage to represent the option where Datastream will enforce encryption and authenticate server identity. ca_certificate must be set if user selects this option. Fields: caCertificate: Optional. Input only. PEM-encoded certificate of the CA that signed the source database server's certificate. serverCertificateHostname: Optional. The hostname mentioned in the Subject or SAN extension of the server certificate. This field is used for bypassing the hostname validation while verifying server certificate. This is required for scenarios where the host name that datastream connects to is different from the certificate's subject. This specifically happens for private connectivity. It could also happen when the customer provides a public IP in connection profile but the same is not present in the server certificate. rrr N r rrrrr(rL caCertificateserverCertificateHostnamerr rrr[r[s*"''*-'33A6rr[c\rSrSrSrSrg)EncryptionNotEnforcedi*z|Message to represent the option where encryption is not enforced. An empty message right now to allow future extensibility. r Nr r rrr`r`*rrr`c"\rSrSrSr\R "S5"SS\R55r \R"SS5r \R"S5r \R"S5r\R"S 5r\R"S 5rS rg ) rGi1aRepresent a user-facing Error. Messages: DetailsValue: Additional information about the error. Fields: details: Additional information about the error. errorTime: The time when the error occurred. errorUuid: A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. message: A message containing more information about the error that occurred. reason: A title that explains the reason for the error. rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Error.DetailsValueiAzAdditional information about the error. Messages: AdditionalProperty: An additional property for a DetailsValue object. Fields: additionalProperties: Additional properties of type DetailsValue c`\rSrSrSr\R "S5r\R "S5rSr g)%Error.DetailsValue.AdditionalPropertyiLzAn additional property for a DetailsValue object. Fields: key: Name of the additional property. value: A string attribute. rrr Nrr rrrreLrrrrTrHr Nrr rr DetailsValuercArrrfrrr!r#r%r N)r rrrrrrr(rrfr)detailsrL errorTime errorUuidmessagereasonrr rrrGrG1s  !!"89ZY&&Z:Z.  " ">1 5'##A&)##A&)  ! !! $'   #&rrGc<\rSrSrSr\R "S5rSrg) EventFilteri`zRepresents a filter for included data on a stream object. Fields: sqlWhereClause: An SQL-query Where clause selecting which data should be included, not including the "WHERE" keyword. E.g., "t.key1 = 'value1' AND t.key2 = 'value2'". rr N) r rrrrr(rLsqlWhereClauserr rrrmrm`s((+.rrmc^\rSrSrSr\R "S5r\R "SSS9rSr g) FetchStaticIpsResponseilzResponse message for a 'FetchStaticIps' response. Fields: nextPageToken: A token that can be sent as `page_token` to retrieve the next page. If this field is omitted, there are no subsequent pages. staticIps: list of static ips by account rrTrHr N) r rrrrr(rL nextPageToken staticIpsrr rrrprpls+''*-##A5)rrpc\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r \R "S5r \R "S5rS rg ) riyaForward SSH Tunnel connectivity. Fields: hostname: Required. Hostname for the SSH tunnel. password: Input only. SSH password. port: Port for the SSH tunnel, default value is 22. privateKey: Input only. SSH private key. username: Required. Username for the SSH tunnel. rrr!rr#r%r N)r rrrrr(rLhostnamepasswordrrrport privateKeyusernamerr rrrrysg " "1 %(  " "1 %(   9+<+<+B+B C$$$Q'*  " "1 %(rrc\rSrSrSr\R "SS5r\R"S5r \R"S\RRS9r \R "SS 5r\R"S 5rS rg ) rFiaGoogle Cloud Storage destination configuration Fields: avroFileFormat: AVRO file format configuration. fileRotationInterval: The maximum duration for which new events are added before a file is closed and a new file is created. Values within the range of 15-60 seconds are allowed. fileRotationMb: The maximum file size to be saved in the bucket. jsonFileFormat: JSON file format configuration. path: Path inside the Cloud Storage bucket to write data to. rrrr!rJsonFileFormatr#r%r N)r rrrrr(r)avroFileFormatrLfileRotationIntervalrrrfileRotationMbjsonFileFormatpathrr rrrFrFsn ))*:A>."..q1))!Y5F5F5L5LM.))*:A>.   q !$rrFc`\rSrSrSr\R "S5r\R "S5rSr g)rizCloud Storage bucket profile. Fields: bucket: Required. The Cloud Storage bucket name. rootPath: The root path inside the Cloud Storage bucket. rrr N) r rrrrr(rLrrrr rrrrs)   #&  " "1 %(rrc\rSrSrSrSrg)GtidizUse GTID based replication.r Nr r rrrrrirrc\rSrSrSr\R "S5r\R"S\RRS9r Sr g) HostAddressizA HostAddress represents a transport end point, which is the combination of an IP address or hostname and a port number. Fields: hostname: Required. Hostname for the connection. port: Optional. Port for the connection. rrrr N) r rrrrr(rLrtrrrrvrr rrrrs7 " "1 %(   9+<+<+B+B C$rrc\rSrSrSr"SS\R 5r"SS\R 5r\R"SS5r \R"SS5r S r g ) rzia?JSON file format configuration. Enums: CompressionValueValuesEnum: Compression of the loaded JSON file. SchemaFileFormatValueValuesEnum: The schema file format along JSON data files. Fields: compression: Compression of the loaded JSON file. schemaFileFormat: The schema file format along JSON data files. c$\rSrSrSrSrSrSrSrg))JsonFileFormat.CompressionValueValuesEnumizCompression of the loaded JSON file. Values: JSON_COMPRESSION_UNSPECIFIED: Unspecified json file compression. NO_COMPRESSION: Do not compress JSON file. GZIP: Gzip compression. rrrr N) r rrrrJSON_COMPRESSION_UNSPECIFIEDNO_COMPRESSIONGZIPrr rrCompressionValueValuesEnumrs$% N Drrc$\rSrSrSrSrSrSrSrg).JsonFileFormat.SchemaFileFormatValueValuesEnumizThe schema file format along JSON data files. Values: SCHEMA_FILE_FORMAT_UNSPECIFIED: Unspecified schema file format. NO_SCHEMA_FILE: Do not attach schema file. AVRO_SCHEMA_FILE: Avro schema format. rrrr N) r rrrrSCHEMA_FILE_FORMAT_UNSPECIFIEDNO_SCHEMA_FILEAVRO_SCHEMA_FILErr rrSchemaFileFormatValueValuesEnumrs&'"Nrrrrr N) r rrrrr(rJrrrO compressionschemaFileFormatrr rrrzrzsP   9>>     ##$@!D+(()JANrrzc\rSrSrSr\R "SSSS9r\R"S5r \R"SSS9r S r g ) ListConnectionProfilesResponseia6Response message for listing connection profiles. Fields: connectionProfiles: List of connection profiles. nextPageToken: A token, which can be sent as `page_token` to retrieve the next page. If this field is omitted, there are no subsequent pages. unreachable: Locations that could not be reached. rrTrHrr!r N) r rrrrr(r)connectionProfilesrLrq unreachablerr rrrrsA!--.A1tT''*-%%a$7+rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListLocationsResponseizThe response message for Locations.ListLocations. Fields: locations: A list of locations that matches the specified filter in the request. nextPageToken: The standard List next-page token. LocationrTrHrr N) r rrrrr(r) locationsrLrqrr rrrrs-$$ZTB)''*-rrc\rSrSrSr\R "S5r\R"SSSS9r \R "SSS9r S r g ) ListOperationsResponseiaThe response message for Operations.ListOperations. Fields: nextPageToken: The standard List next-page token. operations: A list of operations that matches the specified filter in the request. unreachable: Unordered list. Unreachable resources. Populated when the request sets `ListOperationsRequest.return_partial_success` and reads across collections e.g. when attempting to list all resources across all supported locations. r OperationrTrHr!r N) r rrrrr(rLrqr) operationsrrr rrrrs? ''*-%%k1tD*%%a$7+rrc\rSrSrSr\R "S5r\R"SSSS9r \R "SSS9r S r g ) ListPrivateConnectionsResponseiaUResponse containing a list of private connection configurations. Fields: nextPageToken: A token, which can be sent as `page_token` to retrieve the next page. If this field is omitted, there are no subsequent pages. privateConnections: List of private connectivity configurations. unreachable: Locations that could not be reached. rr rTrHr!r N) r rrrrr(rLrqr)privateConnectionsrrr rrrrsA''*- --.A1tT%%a$7+rrc\rSrSrSr\R "S5r\R"SSSS9r \R "SSS9r S r g ) ListRoutesResponsei"aRoute list response. Fields: nextPageToken: A token, which can be sent as `page_token` to retrieve the next page. If this field is omitted, there are no subsequent pages. routes: List of Routes. unreachable: Locations that could not be reached. rrrTrHr!r N) r rrrrr(rLrqr)routesrrr rrrr"s?''*-  ! !'1t <&%%a$7+rrc`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) ListStreamObjectsResponsei1zResponse containing the objects for a stream. Fields: nextPageToken: A token, which can be sent as `page_token` to retrieve the next page. streamObjects: List of stream objects. r StreamObjectrTrHr N) r rrrrr(rLrqr) streamObjectsrr rrrr1s-''*-((TJ-rrc\rSrSrSr\R "S5r\R"SSSS9r \R "SSS9r S r g ) ListStreamsResponsei>aResponse message for listing streams. Fields: nextPageToken: A token, which can be sent as `page_token` to retrieve the next page. If this field is omitted, there are no subsequent pages. streams: List of streams unreachable: Locations that could not be reached. rr$rTrHr!r N) r rrrrr(rLrqr)streamsrrr rrrr>s?''*-  " "8Q >'%%a$7+rrcx\rSrSrSr\R "S5"SS\R55r \R "S5"SS\R55r \R"S5r \R"SS 5r\R"S 5r\R"SS 5r\R"S 5rS rg)riMaMA resource that represents a Google Cloud location. Messages: LabelsValue: Cross-service attributes for the location. For example {"cloud.googleapis.com/region": "us-east1"} MetadataValue: Service-specific metadata. For example the available capacity at the given location. Fields: displayName: The friendly name for this location, typically a nearby city name. For example, "Tokyo". labels: Cross-service attributes for the location. For example {"cloud.googleapis.com/region": "us-east1"} locationId: The canonical id for this location. For example: `"us-east1"`. metadata: Service-specific metadata. For example the available capacity at the given location. name: Resource name for the location, which may vary between implementations. For example: `"projects/example-project/locations/us- east1"` rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Location.LabelsValueicaCross-service attributes for the location. For example {"cloud.googleapis.com/region": "us-east1"} Messages: AdditionalProperty: An additional property for a LabelsValue object. Fields: additionalProperties: Additional properties of type LabelsValue c`\rSrSrSr\R "S5r\R "S5rSr g)'Location.LabelsValue.AdditionalPropertyiorrrr Nrr rrrrorrrrTrHr Nrr rrrrcs2 'Y.. '%112FTXYrrcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Location.MetadataValuei|a Service-specific metadata. For example the available capacity at the given location. Messages: AdditionalProperty: An additional property for a MetadataValue object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cb\rSrSrSr\R "S5r\R"SS5r Sr g))Location.MetadataValue.AdditionalPropertyiAn additional property for a MetadataValue object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. rextra_types.JsonValuerr N r rrrrr(rLrr)rrr rrrr,   ! !! $c$$%\rSrSrSr\R "SS5rSrg)r3izRequest for looking up a specific stream object by its source object identifier. Fields: sourceObjectIdentifier: Required. The source object identifier which maps to the stream object. SourceObjectIdentifierrr N) r rrrrr(r)sourceObjectIdentifierrr rrr3r3s%112JANrr3c\rSrSrSrSrg)r]izXMerge mode defines that all changes to a table will be merged at the destination table. r Nr r rrr]r]rrr]c<\rSrSrSr\R "S5rSrg)MongodbChangeStreamPositionizjMongoDB change stream position Fields: startTime: Required. The timestamp to start change stream from. rr N) r rrrrr(rL startTimerr rrrrs ##A&)rrc<\rSrSrSr\R "SSSS9rSrg) rizSMongoDB Cluster structure. Fields: databases: MongoDB databases in the cluster. MongodbDatabaserTrHr N) r rrrrr(r) databasesrr rrrrs $$%6DI)rrc`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) MongodbCollectioniz`MongoDB Collection. Fields: collection: Collection name. fields: Fields in the collection. r MongodbFieldrTrHr N) r rrrrr(rL collectionr)fieldsrr rrrrs-$$Q'*  ! !.!d C&rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) rizbMongoDB Database. Fields: collections: Collections in the database. database: Database name. rrTrHrr N) r rrrrr(r) collectionsrLdatabaserr rrrrs.&&':AM+  " "1 %(rrc<\rSrSrSr\R "S5rSrg)riz-MongoDB Field. Fields: field: Field name. rr N) r rrrrr(rLfieldrr rrrrs    "%rrc`\rSrSrSr\R "S5r\R "S5rSr g)MongodbObjectIdentifierizMongoDB data source object identifier. Fields: collection: Required. The collection name. database: Required. The database name. rrr N) r rrrrr(rLrrrr rrrrs)$$Q'*  " "1 %(rrc>\rSrSrSr\R "SSSS9r\R"S5r \R"S5r \R"S 5r \R "S S 5r \R "S S 5r \R "SS5r\R"S5rSrg)riaOMongoDB profile. Fields: hostAddresses: Required. List of host addresses for a MongoDB cluster. For SRV connection format, this list must contain exactly one DNS host without a port. For Standard connection format, this list must contain all the required hosts in the cluster with their respective ports. password: Optional. Password for the MongoDB connection. Mutually exclusive with the `secret_manager_stored_password` field. replicaSet: Optional. Name of the replica set. Only needed for self hosted replica set type MongoDB cluster. For SRV connection format, this field must be empty. For Standard connection format, this field must be specified. secretManagerStoredPassword: Optional. A reference to a Secret Manager resource name storing the SQLServer connection password. Mutually exclusive with the `password` field. srvConnectionFormat: Srv connection format. sslConfig: Optional. SSL configuration for the MongoDB connection. standardConnectionFormat: Standard connection format. username: Required. Username for the MongoDB connection. rrTrHrr!r#SrvConnectionFormatr%MongodbSslConfigr'StandardConnectionFormatr6rr N)r rrrrr(r) hostAddressesrLru replicaSetsecretManagerStoredPasswordsrvConnectionFormat sslConfigstandardConnectionFormatrxrr rrrrs,((DI-  " "1 %($$Q'* ) 5 5a 8!../DaH$$%7;)&334NPQR  " "1 %(rrc\rSrSrSr"SS\R 5r\R"SS5r \R"SS5r \R"SS5r \R"S \RRS 9rS rg ) MongodbSourceConfigi#aMongoDB source configuration. Enums: JsonModeValueValuesEnum: Optional. MongoDB JSON mode to use for the stream. Fields: excludeObjects: MongoDB collections to exclude from the stream. includeObjects: MongoDB collections to include in the stream. jsonMode: Optional. MongoDB JSON mode to use for the stream. maxConcurrentBackfillTasks: Optional. Maximum number of concurrent backfill tasks. The number should be non-negative and less than or equal to 50. If not set (or set to 0), the system's default value is used c$\rSrSrSrSrSrSrSrg)+MongodbSourceConfig.JsonModeValueValuesEnumi3zOptional. MongoDB JSON mode to use for the stream. Values: MONGODB_JSON_MODE_UNSPECIFIED: Unspecified JSON mode. STRICT: Strict JSON mode. CANONICAL: Canonical JSON mode. rrrr N) r rrrrMONGODB_JSON_MODE_UNSPECIFIEDSTRICT CANONICALrr rrJsonModeValueValuesEnumr3s%&! FIrrrrrr!r#rr N)r rrrrr(rJrr)excludeObjectsincludeObjectsrOjsonModerrrmaxConcurrentBackfillTasksrr rrrr#sq    ))*:A>.))*:A>.  !:A >((55aARARAXAXYrrc\rSrSrSr\R "S5r\R"S5r \R "S5r \R"S5r \R "S5r \R"S5r \R "S 5rS rg ) riEaMongoDB SSL configuration information. Fields: caCertificate: Optional. Input only. PEM-encoded certificate of the CA that signed the source database server's certificate. caCertificateSet: Output only. Indicates whether the ca_certificate field is set. clientCertificate: Optional. Input only. PEM-encoded certificate that will be used by the replica to authenticate against the source database server. If this field is used then the 'client_key' and the 'ca_certificate' fields are mandatory. clientCertificateSet: Output only. Indicates whether the client_certificate field is set. clientKey: Optional. Input only. PEM-encoded private key associated with the Client Certificate. If this field is used then the 'client_certificate' and the 'ca_certificate' fields are mandatory. clientKeySet: Output only. Indicates whether the client_key field is set. secretManagerStoredClientKey: Optional. Input only. A reference to a Secret Manager resource name storing the PEM-encoded private key associated with the Client Certificate. If this field is used then the 'client_certificate' and the 'ca_certificate' fields are mandatory. Mutually exclusive with the `client_key` field. rrr!r#r%r'r6r N)r rrrrr(rLr]rcaCertificateSetclientCertificateclientCertificateSet clientKey clientKeySetsecretManagerStoredClientKeyrr rrrrEs}0''*-++A.++A."//2##A&)''*,!*!6!6q!9rrc\rSrSrSrSrg)rigzOCDC strategy to start replicating from the most recent position in the source. r Nr r rrrrgrrrc\rSrSrSr\R "S5r\R "S5r\R "S5r \R"S\RRS9r \R"S5r\R"S \RRS9r\R"S \RRS9r\R"S 5r\R"S \RRS9rS rg) MysqlColumninaMySQL Column. Fields: collation: Column collation. column: Column name. dataType: The MySQL data type. Full data types list can be found here: https://dev.mysql.com/doc/refman/8.0/en/data-types.html length: Column length. nullable: Whether or not the column can accept a null value. ordinalPosition: The ordinal position of the column in the table. precision: Column precision. primaryKey: Whether or not the column represents a primary key. scale: Column scale. rrr!r#rr%r'r6rrr N)r rrrrr(rL collationcolumndataTyperrrlengthrnullableordinalPosition precision primaryKeyscalerr rrrrns ##A&)   #&  " "1 %(  ! !!Y->->-D-D E&  # #A &(**1i6G6G6M6MN/$$Q 0A0A0G0GH)%%a(*  I,=,=,C,C D%rrc`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) MysqlDatabaseiz[MySQL database. Fields: database: Database name. mysqlTables: Tables in the database. r MysqlTablerTrHr N) r rrrrr(rLrr) mysqlTablesrr rrrrs- " "1 %(&&|QF+rrc<\rSrSrSr\R "S5rSrg)MysqlGtidPositionizZMySQL GTID position Fields: gtidSet: Required. The gtid set to start replication from. rr N) r rrrrr(rLgtidSetrr rrrrs  ! !! $'rrc\rSrSrSr\R "S5r\R"S\RRS9r Sr g)MysqlLogPositionizMySQL log position Fields: logFile: Required. The binary log file name. logPosition: Optional. The position within the binary log file. Default is head of file. rrrr N) r rrrrr(rLlogFilerrr logPositionrr rrr r s7  ! !! $'&&q)2C2C2I2IJ+rr c`\rSrSrSr\R "S5r\R "S5rSr g)MysqlObjectIdentifierizzMysql data source object identifier. Fields: database: Required. The database name. table: Required. The table name. rrr N) r rrrrr(rLrtablerr rrrrs) " "1 %(    "%rrc\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r \R "S5r \R"SS 5r\R "S 5rS rg ) riaKMySQL database profile. Fields: hostname: Required. Hostname for the MySQL connection. password: Optional. Input only. Password for the MySQL connection. Mutually exclusive with the `secret_manager_stored_password` field. port: Port for the MySQL connection, default value is 3306. secretManagerStoredPassword: Optional. A reference to a Secret Manager resource name storing the MySQL connection password. Mutually exclusive with the `password` field. sslConfig: SSL configuration for the MySQL connection. username: Required. Username for the MySQL connection. rrr!rr#MysqlSslConfigr%r'r N)r rrrrr(rLrtrurrrrvrr)rrxrr rrrrs{  " "1 %(  " "1 %(   9+<+<+B+B C$ ) 5 5a 8$$%5q9)  " "1 %(rrc<\rSrSrSr\R "SSSS9rSrg) rizRMySQL database structure Fields: mysqlDatabases: Mysql databases on the server rrTrHr N) r rrrrr(r)mysqlDatabasesrr rrrrs ))/1tL.rrcD\rSrSrSr\R "SS5r\R "SS5r\R "SS5r \R "SS 5r \R"S \RRS 9r\R"S \RRS 9rS rg)MysqlSourceConfigiaiMySQL source configuration Fields: binaryLogPosition: Use Binary log position based replication. excludeObjects: MySQL objects to exclude from the stream. gtid: Use GTID based replication. includeObjects: MySQL objects to retrieve from the source. maxConcurrentBackfillTasks: Maximum number of concurrent backfill tasks. The number should be non negative. If not set (or set to 0), the system's default value will be used. maxConcurrentCdcTasks: Maximum number of concurrent CDC tasks. The number should be non negative. If not set (or set to 0), the system's default value will be used. rrrrrrr!r#r%rr'r N)r rrrrr(r)binaryLogPositionrgtidrrrrrmaxConcurrentCdcTasksrr rrrrs  ,,-@!D)),:.    *$)),:.(55aARARAXAXY#00IB   q !$rr1c\rSrSrSr\R "S5"SS\R55r \R"S5r \R"SS5r \R"S5r\R"S S 5r\R"S 5r\R""S \R$R&S 9r\R"S5r\R"S5rSrg)OracleAsmConfigiabConfiguration for Oracle Automatic Storage Management (ASM) connection. Messages: ConnectionAttributesValue: Optional. Connection string attributes Fields: asmService: Required. ASM service name for the Oracle ASM connection. connectionAttributes: Optional. Connection string attributes hostname: Required. Hostname for the Oracle ASM connection. oracleSslConfig: Optional. SSL configuration for the Oracle connection. password: Optional. Password for the Oracle ASM connection. Mutually exclusive with the `secret_manager_stored_password` field. port: Required. Port for the Oracle ASM connection. secretManagerStoredPassword: Optional. A reference to a Secret Manager resource name storing the Oracle ASM connection password. Mutually exclusive with the `password` field. username: Required. Username for the Oracle ASM connection. rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) )OracleAsmConfig.ConnectionAttributesValueizOptional. Connection string attributes Messages: AdditionalProperty: An additional property for a ConnectionAttributesValue object. Fields: additionalProperties: Additional properties of type ConnectionAttributesValue c`\rSrSrSr\R "S5r\R "S5rSr g)->-D-D E&  # #A &(**1i6G6G6M6MN/$$Q 0A0A0G0GH)%%a(*  I,=,=,C,C D%rrIc`\rSrSrSr\R "S5r\R "S5rSr g)OracleObjectIdentifierizwOracle data source object identifier. Fields: schema: Required. The schema name. table: Required. The table name. rrr N r rrrrr(rLschemarrr rrrKrK)   #&    "%rrKc\rSrSrSr\R "S5"SS\R55r \R"SS5r \R"S5r \R"S5r\R"S S 5r\R"S S 5r\R"S 5r\R$"S\R&R(S9r\R"S5r\R"S5rSrg)ri aWOracle database profile. Messages: ConnectionAttributesValue: Connection string attributes Fields: connectionAttributes: Connection string attributes databaseService: Required. Database for the Oracle connection. hostname: Required. Hostname for the Oracle connection. oracleAsmConfig: Optional. Configuration for Oracle ASM connection. oracleSslConfig: Optional. SSL configuration for the Oracle connection. password: Optional. Password for the Oracle connection. Mutually exclusive with the `secret_manager_stored_password` field. port: Port for the Oracle connection, default value is 1521. secretManagerStoredPassword: Optional. A reference to a Secret Manager resource name storing the Oracle connection password. Mutually exclusive with the `password` field. username: Required. Username for the Oracle connection. rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) 'OracleProfile.ConnectionAttributesValuei5zConnection string attributes Messages: AdditionalProperty: An additional property for a ConnectionAttributesValue object. Fields: additionalProperties: Additional properties of type ConnectionAttributesValue c`\rSrSrSr\R "S5r\R "S5rSr g):OracleProfile.ConnectionAttributesValue.AdditionalPropertyiBr@rrr Nrr rrrrSBrrrrTrHr Nrr rrrArQ5rBrrArrr!r;r#rCr%r'r6rrrr N)r rrrrrrr(rrAr)rErLdatabaseServicertoracleAsmConfigrFrurrrrvrrxrr rrrr s( !!"89Z)"3"3Z:Z2#//0KQO))!,/  " "1 %(**+B))-;.))-;.  # #J 2((55aARARAXAXY#00I->-D-D E&  # #A &(**1i6G6G6M6MN/$$Q 0A0A0G0GH)%%a(*  I,=,=,C,C D%rrkc`\rSrSrSr\R "S5r\R "S5rSr g)PostgresqlObjectIdentifieriz{PostgreSQL data source object identifier. Fields: schema: Required. The schema name. table: Required. The table name. rrr NrLr rrrororNrroc<\rSrSrSr\R "S5r\R "S5r\R "S5r \R"S\RRS9r \R "S5r\R"S S 5r\R "S 5rS rg )riaPostgreSQL database profile. Fields: database: Required. Database for the PostgreSQL connection. hostname: Required. Hostname for the PostgreSQL connection. password: Optional. Password for the PostgreSQL connection. Mutually exclusive with the `secret_manager_stored_password` field. port: Port for the PostgreSQL connection, default value is 5432. secretManagerStoredPassword: Optional. A reference to a Secret Manager resource name storing the PostgreSQL connection password. Mutually exclusive with the `password` field. sslConfig: Optional. SSL configuration for the PostgreSQL connection. In case PostgresqlSslConfig is not set, the connection will use the default SSL mode, which is `prefer` (i.e. this mode will only use encryption if enabled from database side, otherwise will use unencrypted communication) username: Required. Username for the PostgreSQL connection. rrr!r#rr%PostgresqlSslConfigr'r6r Nr rrrrr(rLrrtrurrrrvrr)rrxrr rrrrs& " "1 %(  " "1 %(  " "1 %(   9+<+<+B+B C$ ) 5 5a 8$$%:A>)  " "1 %(rrc<\rSrSrSr\R "SSSS9rSrg) r"izhPostgreSQL database structure. Fields: postgresqlSchemas: PostgreSQL schemas in the database server. PostgresqlSchemarTrHr N) r rrrrr(r)postgresqlSchemasrr rrr"r"s  ,,-?TRrr"c`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) rti z]PostgreSQL schema. Fields: postgresqlTables: Tables in the schema. schema: Schema name. PostgresqlTablerTrHrr N) r rrrrr(r)postgresqlTablesrLrMrr rrrtrt s/++,=q4P   #&rrtc\rSrSrSr\R "SS5r\R "SS5r\R"S\RRS9r \R"S5r\R"S 5rS rg ) PostgresqlSourceConfigi awPostgreSQL data source configuration Fields: excludeObjects: PostgreSQL objects to exclude from the stream. includeObjects: PostgreSQL objects to include in the stream. maxConcurrentBackfillTasks: Maximum number of concurrent backfill tasks. The number should be non negative. If not set (or set to 0), the system's default value will be used. publication: Required. The name of the publication that includes the set of all tables that are defined in the stream's include_objects. replicationSlot: Required. Immutable. The name of the logical replication slot that's configured with the pgoutput plugin. r"rrr!rr#r%r N)r rrrrr(r)rrrrrrrL publicationreplicationSlotrr rrrzrz sn ))*;Q?.))*;Q?.(55aARARAXAXY%%a(+))!,/rrzcd\rSrSrSr\R "SS5r\R "SS5rSr g) rqi& aPostgreSQL SSL configuration information. Fields: serverAndClientVerification: If this field is set, the communication will be encrypted with TLS encryption and both the server identity and the client identity will be authenticated. serverVerification: If this field is set, the communication will be encrypted with TLS encryption and the server identity will be authenticated. ServerAndClientVerificationrServerVerificationrr N) r rrrrr(r)serverAndClientVerificationserverVerificationrr rrrqrq& s2 !* 6 67TVW X --.BAFrrqc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) rwi6 zPostgreSQL table. Fields: postgresqlColumns: PostgreSQL columns in the schema. When unspecified as part of include/exclude objects, includes/excludes everything. table: Table name. rkrTrHrr N) r rrrrr(r)postgresqlColumnsrLrrr rrrwrw6 s/ ,,-?TR    "%rrwc,\rSrSrSr"SS\R 5r\R"S5"SS\R55r \R"S5r \R"S 5r\R"S S 5r\R"SS 5r\R"S 5r\R"SS5r\R("S5r\R("S5r\R."SS5r\R"S5r\R"SS5rSrg)r iC a6The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network. Enums: StateValueValuesEnum: Output only. The state of the Private Connection. Messages: LabelsValue: Labels. Fields: createTime: Output only. The create time of the resource. displayName: Required. Display name. error: Output only. In case of error, the details of the error in a user- friendly format. labels: Labels. name: Output only. Identifier. The resource's name. pscInterfaceConfig: PSC Interface Config. satisfiesPzi: Output only. Reserved for future use. satisfiesPzs: Output only. Reserved for future use. state: Output only. The state of the Private Connection. updateTime: Output only. The update time of the resource. vpcPeeringConfig: VPC Peering Config. c0\rSrSrSrSrSrSrSrSr Sr S r g ) &PrivateConnection.StateValueValuesEnumi\ aOutput only. The state of the Private Connection. Values: STATE_UNSPECIFIED: Unspecified state. CREATING: The private connection is in creation state - creating resources. CREATED: The private connection has been created with all of its resources. FAILED: The private connection creation has failed. DELETING: The private connection is being deleted. FAILED_TO_DELETE: Delete request has failed, resource is in invalid state. rrrr!r#r%r N) r rrrrr7CREATINGCREATEDr<DELETINGFAILED_TO_DELETErr rrr?r\ s) HG FHrr?rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) PrivateConnection.LabelsValueiq rc`\rSrSrSr\R "S5r\R "S5rSr g)0PrivateConnection.LabelsValue.AdditionalPropertyi| rrrr Nrr rrrr| rrrrTrHr Nrr rrrrq rrrrrrGr!r#r%PscInterfaceConfigr'r6rrrVpcPeeringConfigrr N)r rrrrr(rJr?rrrrrLrrr)r.rrpscInterfaceConfigrrrrOrPrvpcPeeringConfigrr rrr r C s0Y^^* !!"89ZI%%Z:Z.$$Q'*%%a(+  ! ,%  ! !- 3&   q !$ --.BAF''*,''*,   4a 8%$$R(*++,>Crr c<\rSrSrSr\R "S5rSrg)ri zPrivate Connectivity Fields: privateConnection: Required. A reference to a private connection resource. Format: `projects/{project}/locations/{location}/privateConnections/{name}` rr N) r rrrrr(rLrrr rrrr s ++A.rrc<\rSrSrSr\R "S5rSrg)ri a3The PSC Interface configuration is used to create PSC Interface between Datastream and the consumer's PSC. Fields: networkAttachment: Required. Fully qualified name of the Network Attachment that Datastream will connect to. Format: `projects/{project}/regions/{region}/networkAttachments/{name}` rr N) r rrrrr(rLnetworkAttachmentrr rrrr s ++A.rrc\rSrSrSr\R "S5"SS\R55r \R"S5r \R"S5r \R"S\RRS 9r\R"S 5r\R$"SS 5r\R"S 5r\R"S 5rSrg)ri aThe route resource is the child of the private connection resource, used for defining a route for a private connection. Messages: LabelsValue: Labels. Fields: createTime: Output only. The create time of the resource. destinationAddress: Required. Destination address for connection destinationPort: Destination port for connection displayName: Required. Display name. labels: Labels. name: Output only. Identifier. The resource's name. updateTime: Output only. The update time of the resource. rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Route.LabelsValuei rc`\rSrSrSr\R "S5r\R "S5rSr g)$Route.LabelsValue.AdditionalPropertyi rrrr Nrr rrrr rrrrTrHr Nrr rrrr rrrrrr!rr#r%r'r6r N)r rrrrrrr(rrrLrdestinationAddressrrrdestinationPortrr)rrrrr rrrr s  !!"89ZI%%Z:Z.$$Q'* ,,Q/**1i6G6G6M6MN/%%a(+  ! !- 3&   q !$$$Q'*rrcb\rSrSrSr\R "SS5r\R"S5r Sr g)rBi zRequest message for running a stream. Fields: cdcStrategy: Optional. The CDC strategy of the stream. If not set, the system's default value will be used. force: Optional. Update the stream without validating it. rrrr N) r rrrrr(r) cdcStrategyrrrr rrrBrB s+&&}a8+   #%rrBc\rSrSrSr\R "S5r\R "S5r\R"S5r Sr g)SalesforceFieldi zSalesforce field. Fields: dataType: The data type. name: Field name. nillable: Indicates whether the field can accept nil values. rrr!r N) r rrrrr(rLrrrnillablerr rrrr s9 " "1 %(   q !$  # #A &(rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) SalesforceObjecti zSalesforce object. Fields: fields: Salesforce fields. When unspecified as part of include objects, includes everything, when unspecified as part of exclude objects, excludes nothing. objectName: Object name. rrTrHrr N) r rrrrr(r)rrL objectNamerr rrrr s.  ! !"3Q F&$$Q'*rrc<\rSrSrSr\R "S5rSrg)SalesforceObjectIdentifieri z\Salesforce data source object identifier. Fields: objectName: Required. The object name. rr N) r rrrrr(rLrrr rrrr s $$Q'*rrc<\rSrSrSr\R "SSSS9rSrg) r$i zbSalesforce organization structure. Fields: objects: Salesforce objects in the database server. rrTrHr N) r rrrrr(r)objectsrr rrr$r$ s  " "#5q4 H'rr$c\rSrSrSr\R "S5r\R"SS5r \R"SS5r Sr g ) ri zSalesforce profile Fields: domain: Required. Domain endpoint for the Salesforce connection. oauth2ClientCredentials: Connected app authentication. userCredentials: User-password authentication. rrrUserCredentialsr!r N) r rrrrr(rLdomainr)oauth2ClientCredentialsuserCredentialsrr rrrr s@   #&%223LaP**+B,,-@!D"//0FJrrc\rSrSrSrSrg)SqlServerChangeTablesi z3Configuration to use Change Tables CDC read method.r Nr r rrrr rrrc\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r \R"S5r\R"S\RRS9r\R"S \RRS9r\R"S 5r\R"S \RRS9rS rg )SqlServerColumni akSQLServer Column. Fields: column: Column name. dataType: The SQLServer data type. length: Column length. nullable: Whether or not the column can accept a null value. ordinalPosition: The ordinal position of the column in the table. precision: Column precision. primaryKey: Whether or not the column represents a primary key. scale: Column scale. rrr!rr#r%r'r6rr Nrlr rrrr rmrrc<\rSrSrSr\R "S5rSrg)ri ziSQL Server LSN position Fields: lsn: Required. Log sequence number (LSN) from where Logs will be read rr N) r rrrrr(rLlsnrr rrrr s a #rrc`\rSrSrSr\R "S5r\R "S5rSr g)ri zzSQLServer data source object identifier. Fields: schema: Required. The schema name. table: Required. The table name. rrr NrLr rrrr rNrrc<\rSrSrSr\R "S5r\R "S5r\R "S5r \R"S\RRS9r \R "S5r\R"S S 5r\R "S 5rS rg )ri aSQLServer database profile. Fields: database: Required. Database for the SQLServer connection. hostname: Required. Hostname for the SQLServer connection. password: Optional. Password for the SQLServer connection. Mutually exclusive with the `secret_manager_stored_password` field. port: Port for the SQLServer connection, default value is 1433. secretManagerStoredPassword: Optional. A reference to a Secret Manager resource name storing the SQLServer connection password. Mutually exclusive with the `password` field. sslConfig: Optional. SSL configuration for the SQLServer connection. username: Required. Username for the SQLServer connection. rrr!r#rr%SqlServerSslConfigr'r6r Nrrr rrrr s  " "1 %(  " "1 %(  " "1 %(   9+<+<+B+B C$ ) 5 5a 8$$%91=)  " "1 %(rrc<\rSrSrSr\R "SSSS9rSrg) r&i z\SQLServer database structure. Fields: schemas: SQLServer schemas in the database server. SqlServerSchemarTrHr N) r rrrrr(r)schemasrr rrr&r& s  " "#4a$ G'rr&c`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) ri zRSQLServer schema. Fields: schema: Schema name. tables: Tables in the schema. rSqlServerTablerTrHr N) r rrrrr(rLrMr)tablesrr rrrr s.   #&  ! !"2A E&rrcD\rSrSrSr\R "SS5r\R "SS5r\R "SS5r \R"S\RRS 9r \R"S \RRS 9r\R "S S 5rS rg)ri& aSQLServer data source configuration Fields: changeTables: CDC reader reads from change tables. excludeObjects: SQLServer objects to exclude from the stream. includeObjects: SQLServer objects to include in the stream. maxConcurrentBackfillTasks: Max concurrent backfill tasks. maxConcurrentCdcTasks: Max concurrent CDC tasks. transactionLogs: CDC reader reads from transaction logs. rrr&rr!r#rr%SqlServerTransactionLogsr'r N)r rrrrr(r) changeTablesrrrrrrrtransactionLogsrr rrrr& s ''(?C,))*:A>.))*:A>.(55aARARAXAXY#00I" to include in api requests. uploadType: Legacy upload protocol for media (e.g. "media", "multipart"). upload_protocol: Upload protocol for media (e.g. "raw", "multipart"). c$\rSrSrSrSrSrSrSrg)*StandardQueryParameters.AltValueValuesEnumi zData format for response. Values: json: Responses with Content-Type of application/json media: Media download with context-dependent Content-Type proto: Responses with Content-Type of application/x-protobuf rrrr N) r rrrrjsonmediaprotorr rrAltValueValuesEnumr s D E Errc \rSrSrSrSrSrSrg)-StandardQueryParameters.FXgafvValueValuesEnumi zFV1 error format. Values: _1: v1 error format _2: v2 error format rrr N)r rrrr_1_2rr rrFXgafvValueValuesEnumr s B Brrrrr!r)defaultr#r%r'r6rTrrrrr N)r rrrrr(rJrrrOf__xgafvrL access_tokenaltcallbackrr oauth_tokenr prettyPrint quotaUsertrace uploadTypeupload_protocolrr rrrrm s4 9>>  inn  !8! <(&&q),0!VD#  " "1 %(   #&a #%%a(+&&q$7+##A&)    #%$$R(*))"-/rrc>\rSrSrSr\R "SS5rSrg)r7i a0Request for manually initiating a backfill job for a specific stream object. Fields: eventFilter: Optional. Optional event filter. If not set, or empty, the backfill will be performed on the entire object. This is currently used for partial backfill and only supported for SQL Server sources. rmrr N) r rrrrr(r) eventFilterrr rrr7r7 s&&}a8+rr7c>\rSrSrSr\R "SS5rSrg)StartBackfillJobResponsei zResponse for manually initiating a backfill job for a specific stream object. Fields: object: The stream object resource a backfill job was started for. rrr N r rrrrr(r)r8rr rrr r  s  ! !.! 4&rr c\rSrSrSrSrg)ri zStatic IP address connectivity. Used when the source database is configured to allow incoming connections from the Datastream public IP addresses for the region specified in the connection profile. r Nr r rrrr rXrrc\rSrSrSr\R "S5"SS\R55r \R"S\RRS9r \R"SSS S 9r\R "S 5rS rg )r,i aThe `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [gRPC](https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https://cloud.google.com/apis/design/errors). Messages: DetailsValueListEntry: A DetailsValueListEntry object. Fields: code: The status code, which should be an enum value of google.rpc.Code. details: A list of messages that carry the error details. There is a common set of message types for APIs to use. message: A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the google.rpc.Status.details field, or localized by the client. rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Status.DetailsValueListEntryi zA DetailsValueListEntry object. Messages: AdditionalProperty: An additional property for a DetailsValueListEntry object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cb\rSrSrSr\R "S5r\R"SS5r Sr g)/Status.DetailsValueListEntry.AdditionalPropertyi zAn additional property for a DetailsValueListEntry object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. rrrr Nrr rrrr rrrrTrHr Nrr rrDetailsValueListEntryr rrrrrrTrHr!r N)r rrrrrrr(rrrrrcoder)rgrLrjrr rrr,r, s|& !!"89Zi//Z:Z2   9+<+<+B+B C$  " "#:A M'  ! !! $'rr,c\rSrSrSrSrg)r<i zSRequest for manually stopping a running backfill job for a specific stream object. r Nr r rrr<r< rrr<c>\rSrSrSr\R "SS5rSrg)StopBackfillJobResponsei zResponse for manually stop a backfill job for a specific stream object. Fields: object: The stream object resource the backfill job was stopped for. rrr Nr r rrrr s  ! !.! 4&rrc\rSrSrSr"SS\R 5r\R"S5"SS\R55r \R"SS 5r \R"S S 5r\R"S 5r\R"S 5r\R"SS5r\R"S5r\R"SSSS9r\R"SS5r\R"S5r\R"S5r\R0"S5r\R0"S5r\R"SS5r\R8"SS5r\R"S5rSrg) r$i a%A resource representing streaming data from a source to a destination. Enums: StateValueValuesEnum: The state of the stream. Messages: LabelsValue: Labels. Fields: backfillAll: Automatically backfill objects included in the stream source configuration. Specific objects can be excluded. backfillNone: Do not automatically backfill any objects. createTime: Output only. The creation time of the stream. customerManagedEncryptionKey: Immutable. A reference to a KMS encryption key. If provided, it will be used to encrypt the data. If left blank, data will be encrypted using an internal Stream-specific encryption key provisioned through KMS. destinationConfig: Required. Destination connection profile configuration. displayName: Required. Display name. errors: Output only. Errors on the Stream. labels: Labels. lastRecoveryTime: Output only. If the stream was recovered, the time of the last recovery. Note: This field is currently experimental. name: Output only. Identifier. The stream's name. satisfiesPzi: Output only. Reserved for future use. satisfiesPzs: Output only. Reserved for future use. sourceConfig: Required. Source connection profile configuration. state: The state of the stream. updateTime: Output only. The last update time of the stream. c<\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg )Stream.StateValueValuesEnumi0 aThe state of the stream. Values: STATE_UNSPECIFIED: Unspecified stream state. NOT_STARTED: The stream has been created but has not yet started streaming data. RUNNING: The stream is running. PAUSED: The stream is paused. MAINTENANCE: The stream is in maintenance mode. Updates are rejected on the resource in this state. FAILED: The stream is experiencing an error that is preventing data from being streamed. FAILED_PERMANENTLY: The stream has experienced a terminal failure. STARTING: The stream is starting, but not yet running. DRAINING: The Stream is no longer reading new events, but still writing events in the buffer. rrrr!r#r%r'r6rr N)r rrrrr7r8RUNNINGPAUSED MAINTENANCEr<FAILED_PERMANENTLYSTARTINGDRAININGrr rrr?r0 s8"KG FK FHHrr?rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Stream.LabelsValueiL rc`\rSrSrSr\R "S5r\R "S5rSr g)%Stream.LabelsValue.AdditionalPropertyiW rrrr Nrr rrrr"W rrrrTrHr Nrr rrrr L rrrrrrSrr!r#rEr%r'rGr6TrHrrrrrrrrrr N) r rrrrr(rJr?rrrrr) backfillAll backfillNonerLrcustomerManagedEncryptionKeydestinationConfigrrKrlastRecoveryTimerrrr sourceConfigrOrPrrr rrr$r$ sP>Y^^8 !!"89ZI%%Z:Z.&&'B,$$Q'*!*!6!6q!9,,-@!D%%a(+  ! !'1t <&  ! !- 3&**1-   r "$''+,''+,'';,   4b 9%$$R(*rr$c\rSrSrSrSrg)raiu z,Configuration to stream large object values.r Nr r rrrarau s5rrac\rSrSrSr\R "SS5r\R"S5r \R"S5r \R "SSS S 9r \R"S 5r \R "S S 5r \R"S5rSrg)riy aA specific stream object (e.g a specific DB table). Fields: backfillJob: The latest backfill job that was initiated for the stream object. createTime: Output only. The creation time of the object. displayName: Required. Display name. errors: Output only. Active errors on the object. name: Output only. Identifier. The object resource's name. sourceObject: The object identifier in the data source. updateTime: Output only. The last update time of the object. r1rrr!rGr#TrHr%rr'r6r N)r rrrrr(r) backfillJobrLrrrKr sourceObjectrrr rrrry s &&}a8+$$Q'*%%a(+  ! !'1t <&   q !$''(@!D,$$Q'*rrc\rSrSrSr\R "S5r\R "S5r\R "S5r \R "S5r \R "S5r Sr g ) ri aUsername-password credentials. Fields: password: Optional. Password for the Salesforce connection. Mutually exclusive with the `secret_manager_stored_password` field. secretManagerStoredPassword: Optional. A reference to a Secret Manager resource name storing the Salesforce connection's password. Mutually exclusive with the `password` field. secretManagerStoredSecurityToken: Optional. A reference to a Secret Manager resource name storing the Salesforce connection's security token. Mutually exclusive with the `security_token` field. securityToken: Optional. Security token for the Salesforce connection. Mutually exclusive with the `secret_manager_stored_security_token` field. username: Required. Username for the Salesforce connection. rrr!r#r%r N) r rrrrr(rLrur secretManagerStoredSecurityToken securityTokenrxrr rrrr s[" " "1 %( ) 5 5a 8%.%:%:1%="''*-  " "1 %(rrc\rSrSrSr"SS\R 5r\R"S5r \R"S5r \R"SSS S 9r \R"SS 5rS rg ) Validationi aKA validation to perform on a stream. Enums: StateValueValuesEnum: Output only. Validation execution status. Fields: code: A custom code identifying this validation. description: A short description of the validation. message: Messages reflecting the validation results. state: Output only. Validation execution status. c,\rSrSrSrSrSrSrSrSr Sr g ) Validation.StateValueValuesEnumi zOutput only. Validation execution status. Values: STATE_UNSPECIFIED: Unspecified state. NOT_EXECUTED: Validation did not execute. FAILED: Validation failed. PASSED: Validation passed. WARNING: Validation executed with warnings. rrrr!r#r N) r rrrrr7 NOT_EXECUTEDr<PASSEDWARNINGrr rrr?r3 s#L F FGrr?rrValidationMessager!TrHr#r N)r rrrrr(rJr?rLr descriptionr)rjrOrPrr rrr1r1 sa Y^^   q !$%%a(+  " "#6D I'   4a 8%rr1c*\rSrSrSr"SS\R 5r\R"S5"SS\R55r \R"S5r \R"SS 5r\R"S 5r\R""SS 5rS rg )r7i aRepresent user-facing validation result message. Enums: LevelValueValuesEnum: Message severity level (warning or error). Messages: MetadataValue: Additional metadata related to the result. Fields: code: A custom code identifying this specific message. level: Message severity level (warning or error). message: The result of the validation. metadata: Additional metadata related to the result. c$\rSrSrSrSrSrSrSrg)&ValidationMessage.LevelValueValuesEnumi zMessage severity level (warning or error). Values: LEVEL_UNSPECIFIED: Unspecified level. WARNING: Potentially cause issues with the Stream. ERROR: Definitely cause issues with the Stream. rrrr N) r rrrrLEVEL_UNSPECIFIEDr6ERRORrr rrLevelValueValuesEnumr; sG Err>rcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) ValidationMessage.MetadataValuei zAdditional metadata related to the result. Messages: AdditionalProperty: An additional property for a MetadataValue object. Fields: additionalProperties: Additional properties of type MetadataValue c`\rSrSrSr\R "S5r\R "S5rSr g)2ValidationMessage.MetadataValue.AdditionalPropertyi zAn additional property for a MetadataValue object. Fields: key: Name of the additional property. value: A string attribute. rrr Nrr rrrrB rrrrTrHr Nrr rrrr@ rrrrrr!r#r N)r rrrrr(rJr>rrrrrLrrOlevelrjr)rrr rrr7r7 s  Y^^  !!"89Zi''Z:Z.   q !$   4a 8%  ! !! $'  # #OQ 7(rr7c<\rSrSrSr\R "SSSS9rSrg) r2i zContains the current validation results. Fields: validations: A list of validations (includes both executed as well as not executed validations). r1rTrHr N) r rrrrr(r) validationsrr rrr2r2 s&&|QF+rr2c`\rSrSrSr\R "S5r\R "S5rSr g)ri a6The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC. Fields: subnet: Required. A free subnet for peering. (CIDR of /29) vpc: Required. Fully qualified name of the VPC that Datastream will peer to. Format: `projects/{project}/global/{networks}/{name}` rrr N) r rrrrr(rLsubnetvpcrr rrrr s)   #&a #rrrz$.xgafvr1r2N)r __future__rapitools.base.protorpcliterr(apitools.base.pyrrpackagerr rrr1rSrVrZrgrkrrr\rrrrrrrrrrrrrrrrr r rrrrrrr r#r(r*r,r.r0r2r6r;r?rArErrUrWrYr[r`rGrmrprrFrrrrzrrrrrrrrrmrr3r]rrrrrrrrrrrrrr rrrrrrrrrr1r;rnrIrKrr rWr]r`rCrZrkrorr"rtrzrqrwr rrrrBrrrr$rrr~rr^rr_rrrrrrrr&rrrrrrrrr7r rr,r<rr$rarrr1r7r2rAddCustomJsonFieldMappingAddCustomJsonEnumMappingrr rrrQsl  '<%( "")Y&&)I)++I0:=)##:=z9,,i''Q 1 1Q0%i''% Oi'' O4 ))4(E""(EV=Y..=M)##M"E) ))E)P&i''&.+ARAR+B'ARAR', 39CTCT 31i>O>O13y?P?P30!+ @Q@Q!+H 'y7H7H ' 1I,=,=1'Y->->'0 19J9J 119J9J11i6G6G13y7H7H30+ARAR+D'ARAR'41i>O>O13y?P?P32%yGXGX%6'yGXGX'.1IDUDU13YEVEV3.+i6G6G+>'i6G6G',193D3D13I4E4E3.1):K:K139;L;L3$ 3Y=N=N 3 QyGXGX Q OiFWFW O +Y5F5F +F C93D3D CK ))K"@y'8'8@D? (9(9?(4y((4I  7I$5$57,I--,$I  ,$^ ,)## , 6Y.. 6&9#4#4&$"9,,"( &"" &%9  % D)## D&OY&&&OR 8Y%6%6 8 +I-- +8Y..8$ 8Y%6%6 8 8** 8 K 1 1 K 8)++ 8M"y  M"` 0** 03y  3 O 1 1 OI  ')"3"3'JY&&J D )) D &i'' &#9$$# &i// &&Y&&&BZ)++ZD:y((:Di//E)##E6 GI%% G% ))% Ky(( K #I-- #&9$$&.M""MU ))U0+Y&&+8 #"" #!2!2=i//=$i8 !!i8X" ))">5&i''5&pBY..BE9$$E4 #Y.. #7&I%%7&tK)##K $9$$ $" ))"G**G8@i''@, #)## #Ey((E0 #!2!2 #& ))&:Si''S $y(( $-Y..-, G)++ G #i'' #PD ))PDf /)++ / /** //(I  /(d $y(( $ 'i'' ' (y(( ((!2!2(II%%I A )) A -Y.. - 7)"3"37<7**7" ')++ 'M9$$M0 'i// 'OY..O(KI--K(=I--=Ei''E0!9,,! # 1 1 #&y((&2HY&&H Fi'' FJI--J(M**M& #Y&& #@y00@ )++ /y00/<.i//<.~ 9i// 95y005)"3"30%Y  0%fY..5i//5b)Y  b)J6**6(9$$(.&i''&2 9"" 9F78 ))78tGy((G !y(( ! ""Z4!!114>!!114>r