DataStream v1 API - Namespace Google.Cloud.Datastream.V1 (2.10.0)

Classes

AvroFileFormat

AVRO file format configuration.

BackfillJob

Represents a backfill job on a specific stream object.

BackfillJob.Types

Container for nested types declared in the BackfillJob message type.

BigQueryDestinationConfig

BigQuery destination configuration

BigQueryDestinationConfig.Types

Container for nested types declared in the BigQueryDestinationConfig message type.

BigQueryDestinationConfig.Types.AppendOnly

AppendOnly mode defines that all changes to a table will be written to the destination table.

BigQueryDestinationConfig.Types.BlmtConfig

The configuration for BLMT.

BigQueryDestinationConfig.Types.BlmtConfig.Types

Container for nested types declared in the BlmtConfig message type.

BigQueryDestinationConfig.Types.Merge

Merge mode defines that all changes to a table will be merged at the destination table.

BigQueryDestinationConfig.Types.SingleTargetDataset

A single target dataset to which all data will be streamed.

BigQueryDestinationConfig.Types.SourceHierarchyDatasets

Destination datasets are created so that hierarchy of the destination data objects matches the source hierarchy.

BigQueryDestinationConfig.Types.SourceHierarchyDatasets.Types

Container for nested types declared in the SourceHierarchyDatasets message type.

BigQueryDestinationConfig.Types.SourceHierarchyDatasets.Types.DatasetTemplate

Dataset template used for dynamic dataset creation.

BigQueryProfile

BigQuery warehouse profile.

CdcStrategy

The strategy that the stream uses for CDC replication.

CdcStrategy.Types

Container for nested types declared in the CdcStrategy message type.

CdcStrategy.Types.MostRecentStartPosition

CDC strategy to start replicating from the most recent position in the source.

CdcStrategy.Types.NextAvailableStartPosition

CDC strategy to resume replication from the next available position in the source.

CdcStrategy.Types.SpecificStartPosition

CDC strategy to start replicating from a specific position in the source.

ConnectionProfile

A set of reusable connection configurations to be used as a source or destination for a stream.

ConnectionProfileName

Resource name for the ConnectionProfile resource.

CreateConnectionProfileRequest

Request message for creating a connection profile.

CreatePrivateConnectionRequest

Request for creating a private connection.

CreateRouteRequest

Route creation request.

CreateStreamRequest

Request message for creating a stream.

Datastream

Datastream service

Datastream.DatastreamBase

Base class for server-side implementations of Datastream

Datastream.DatastreamClient

Client for Datastream

DatastreamClient

Datastream client wrapper, for convenient use.

DatastreamClientBuilder

Builder class for DatastreamClient to provide simple configuration of credentials, endpoint etc.

DatastreamClientImpl

Datastream client wrapper implementation, for convenient use.

DatastreamSettings

Settings for DatastreamClient instances.

DeleteConnectionProfileRequest

Request message for deleting a connection profile.

DeletePrivateConnectionRequest

Request to delete a private connection.

DeleteRouteRequest

Route deletion request.

DeleteStreamRequest

Request message for deleting a stream.

DestinationConfig

The configuration of the stream destination.

DiscoverConnectionProfileRequest

Request message for 'discover' ConnectionProfile request.

DiscoverConnectionProfileResponse

Response from a discover request.

Error

Represent a user-facing Error.

FetchStaticIpsRequest

Request message for 'FetchStaticIps' request.

FetchStaticIpsResponse

Response message for a 'FetchStaticIps' response.

ForwardSshTunnelConnectivity

Forward SSH Tunnel connectivity.

GcsDestinationConfig

Google Cloud Storage destination configuration

GcsProfile

Cloud Storage bucket profile.

GetConnectionProfileRequest

Request message for getting a connection profile.

GetPrivateConnectionRequest

Request to get a private connection configuration.

GetRouteRequest

Route get request.

GetStreamObjectRequest

Request for fetching a specific stream object.

GetStreamRequest

Request message for getting a stream.

JsonFileFormat

JSON file format configuration.

JsonFileFormat.Types

Container for nested types declared in the JsonFileFormat message type.

ListConnectionProfilesRequest

Request message for listing connection profiles.

ListConnectionProfilesResponse

Response message for listing connection profiles.

ListPrivateConnectionsRequest

Request for listing private connections.

ListPrivateConnectionsResponse

Response containing a list of private connection configurations.

ListRoutesRequest

Route list request.

ListRoutesResponse

Route list response.

ListStreamObjectsRequest

Request for listing all objects for a specific stream.

ListStreamObjectsResponse

Response containing the objects for a stream.

ListStreamsRequest

Request message for listing streams.

ListStreamsResponse

Response message for listing streams.

LookupStreamObjectRequest

Request for looking up a specific stream object by its source object identifier.

MysqlColumn

MySQL Column.

MysqlDatabase

MySQL database.

MysqlGtidPosition

MySQL GTID position

MysqlLogPosition

MySQL log position

MysqlProfile

MySQL database profile.

MysqlRdbms

MySQL database structure

MysqlSourceConfig

MySQL source configuration

MysqlSourceConfig.Types

Container for nested types declared in the MysqlSourceConfig message type.

MysqlSourceConfig.Types.BinaryLogPosition

Use Binary log position based replication.

MysqlSourceConfig.Types.Gtid

Use GTID based replication.

MysqlSslConfig

MySQL SSL configuration information.

MysqlTable

MySQL table.

NetworksName

Resource name for the Networks resource.

OperationMetadata

Represents the metadata of the long-running operation.

OracleAsmConfig

Configuration for Oracle Automatic Storage Management (ASM) connection.

OracleColumn

Oracle Column.

OracleProfile

Oracle database profile.

OracleRdbms

Oracle database structure.

OracleSchema

Oracle schema.

OracleScnPosition

Oracle SCN position

OracleSourceConfig

Oracle data source configuration

OracleSourceConfig.Types

Container for nested types declared in the OracleSourceConfig message type.

OracleSourceConfig.Types.BinaryLogParser

Configuration to use Binary Log Parser CDC technique.

OracleSourceConfig.Types.BinaryLogParser.Types

Container for nested types declared in the BinaryLogParser message type.

OracleSourceConfig.Types.BinaryLogParser.Types.LogFileDirectories

Configuration to specify the Oracle directories to access the log files.

OracleSourceConfig.Types.BinaryLogParser.Types.OracleAsmLogFileAccess

Configuration to use Oracle ASM to access the log files.

OracleSourceConfig.Types.DropLargeObjects

Configuration to drop large object values.

OracleSourceConfig.Types.LogMiner

Configuration to use LogMiner CDC method.

OracleSourceConfig.Types.StreamLargeObjects

Configuration to stream large object values.

OracleSslConfig

Oracle SSL configuration information.

OracleTable

Oracle table.

PostgresqlColumn

PostgreSQL Column.

PostgresqlProfile

PostgreSQL database profile.

PostgresqlRdbms

PostgreSQL database structure.

PostgresqlSchema

PostgreSQL schema.

PostgresqlSourceConfig

PostgreSQL data source configuration

PostgresqlSslConfig

PostgreSQL SSL configuration information.

PostgresqlSslConfig.Types

Container for nested types declared in the PostgresqlSslConfig message type.

PostgresqlSslConfig.Types.ServerAndClientVerification

Message represents the option where Datastream will enforce the encryption and authenticate the server identity as well as the client identity. ca_certificate, client_certificate and client_key must be set if user selects this option.

PostgresqlSslConfig.Types.ServerVerification

Message represents the option where Datastream will enforce the encryption and authenticate the server identity. ca_certificate must be set if user selects this option.

PostgresqlTable

PostgreSQL table.

PrivateConnection

The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network.

PrivateConnection.Types

Container for nested types declared in the PrivateConnection message type.

PrivateConnectionName

Resource name for the PrivateConnection resource.

PrivateConnectivity

Private Connectivity

Route

The route resource is the child of the private connection resource, used for defining a route for a private connection.

RouteName

Resource name for the Route resource.

RunStreamRequest

Request message for running a stream.

SalesforceField

Salesforce field.

SalesforceObject

Salesforce object.

SalesforceOrg

Salesforce organization structure.

SalesforceProfile

Salesforce profile

SalesforceProfile.Types

Container for nested types declared in the SalesforceProfile message type.

SalesforceProfile.Types.Oauth2ClientCredentials

OAuth2 Client Credentials.

SalesforceProfile.Types.UserCredentials

Username-password credentials.

SalesforceSourceConfig

Salesforce source configuration

SourceConfig

The configuration of the stream source.

SourceObjectIdentifier

Represents an identifier of an object in the data source.

SourceObjectIdentifier.Types

Container for nested types declared in the SourceObjectIdentifier message type.

SourceObjectIdentifier.Types.MysqlObjectIdentifier

Mysql data source object identifier.

SourceObjectIdentifier.Types.OracleObjectIdentifier

Oracle data source object identifier.

SourceObjectIdentifier.Types.PostgresqlObjectIdentifier

PostgreSQL data source object identifier.

SourceObjectIdentifier.Types.SalesforceObjectIdentifier

Salesforce data source object identifier.

SourceObjectIdentifier.Types.SqlServerObjectIdentifier

SQLServer data source object identifier.

SqlServerChangeTables

Configuration to use Change Tables CDC read method.

SqlServerColumn

SQLServer Column.

SqlServerLsnPosition

SQL Server LSN position

SqlServerProfile

SQLServer database profile.

SqlServerRdbms

SQLServer database structure.

SqlServerSchema

SQLServer schema.

SqlServerSourceConfig

SQLServer data source configuration

SqlServerTable

SQLServer table.

SqlServerTransactionLogs

Configuration to use Transaction Logs CDC read method.

StartBackfillJobRequest

Request for manually initiating a backfill job for a specific stream object.

StartBackfillJobResponse

Response for manually initiating a backfill job for a specific stream object.

StaticServiceIpConnectivity

Static 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.

StopBackfillJobRequest

Request for manually stopping a running backfill job for a specific stream object.

StopBackfillJobResponse

Response for manually stop a backfill job for a specific stream object.

Stream

A resource representing streaming data from a source to a destination.

Stream.Types

Container for nested types declared in the Stream message type.

Stream.Types.BackfillAllStrategy

Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded.

Stream.Types.BackfillNoneStrategy

Backfill strategy to disable automatic backfill for the Stream's objects.

StreamName

Resource name for the Stream resource.

StreamObject

A specific stream object (e.g a specific DB table).

StreamObjectName

Resource name for the StreamObject resource.

UpdateConnectionProfileRequest

Connection profile update message.

UpdateStreamRequest

Request message for updating a stream.

Validation

A validation to perform on a stream.

Validation.Types

Container for nested types declared in the Validation message type.

ValidationMessage

Represent user-facing validation result message.

ValidationMessage.Types

Container for nested types declared in the ValidationMessage message type.

ValidationResult

Contains the current validation results.

VpcPeeringConfig

The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC.

Enums

BackfillJob.Types.State

State of the stream object's backfill job.

BackfillJob.Types.Trigger

Triggering reason for a backfill job.

BigQueryDestinationConfig.DatasetConfigOneofCase

Enum of possible cases for the "dataset_config" oneof.

BigQueryDestinationConfig.Types.BlmtConfig.Types.FileFormat

Supported file formats for BigLake managed tables.

BigQueryDestinationConfig.Types.BlmtConfig.Types.TableFormat

Supported table formats for BigLake managed tables.

BigQueryDestinationConfig.WriteModeOneofCase

Enum of possible cases for the "write_mode" oneof.

CdcStrategy.StartPositionOneofCase

Enum of possible cases for the "start_position" oneof.

CdcStrategy.Types.SpecificStartPosition.PositionOneofCase

Enum of possible cases for the "position" oneof.

ConnectionProfile.ConnectivityOneofCase

Enum of possible cases for the "connectivity" oneof.

ConnectionProfile.ProfileOneofCase

Enum of possible cases for the "profile" oneof.

ConnectionProfileName.ResourceNameType

The possible contents of ConnectionProfileName.

DestinationConfig.DestinationStreamConfigOneofCase

Enum of possible cases for the "destination_stream_config" oneof.

DiscoverConnectionProfileRequest.DataObjectOneofCase

Enum of possible cases for the "data_object" oneof.

DiscoverConnectionProfileRequest.HierarchyOneofCase

Enum of possible cases for the "hierarchy" oneof.

DiscoverConnectionProfileRequest.TargetOneofCase

Enum of possible cases for the "target" oneof.

DiscoverConnectionProfileResponse.DataObjectOneofCase

Enum of possible cases for the "data_object" oneof.

ForwardSshTunnelConnectivity.AuthenticationMethodOneofCase

Enum of possible cases for the "authentication_method" oneof.

GcsDestinationConfig.FileFormatOneofCase

Enum of possible cases for the "file_format" oneof.

JsonFileFormat.Types.JsonCompression

Json file compression.

JsonFileFormat.Types.SchemaFileFormat

Schema file format.

MysqlSourceConfig.CdcMethodOneofCase

Enum of possible cases for the "cdc_method" oneof.

NetworksName.ResourceNameType

The possible contents of NetworksName.

OracleSourceConfig.CdcMethodOneofCase

Enum of possible cases for the "cdc_method" oneof.

OracleSourceConfig.LargeObjectsHandlingOneofCase

Enum of possible cases for the "large_objects_handling" oneof.

OracleSourceConfig.Types.BinaryLogParser.LogFileAccessOneofCase

Enum of possible cases for the "log_file_access" oneof.

PostgresqlSslConfig.EncryptionSettingOneofCase

Enum of possible cases for the "encryption_setting" oneof.

PrivateConnection.Types.State

Private Connection state.

PrivateConnectionName.ResourceNameType

The possible contents of PrivateConnectionName.

RouteName.ResourceNameType

The possible contents of RouteName.

SalesforceProfile.CredentialsOneofCase

Enum of possible cases for the "credentials" oneof.

SourceConfig.SourceStreamConfigOneofCase

Enum of possible cases for the "source_stream_config" oneof.

SourceObjectIdentifier.SourceIdentifierOneofCase

Enum of possible cases for the "source_identifier" oneof.

SqlServerSourceConfig.CdcMethodOneofCase

Enum of possible cases for the "cdc_method" oneof.

Stream.BackfillStrategyOneofCase

Enum of possible cases for the "backfill_strategy" oneof.

Stream.Types.BackfillAllStrategy.ExcludedObjectsOneofCase

Enum of possible cases for the "excluded_objects" oneof.

Stream.Types.State

Stream state.

StreamName.ResourceNameType

The possible contents of StreamName.

StreamObjectName.ResourceNameType

The possible contents of StreamObjectName.

Validation.Types.State

Validation execution state.

ValidationMessage.Types.Level

Validation message level.