pulumi-google-native-kotlin/com.pulumi.googlenative.datastream.v1.kotlin.outputs

Package-level declarations

Types

AVRO file format configuration.

data class BackfillAllStrategyResponse(val mysqlExcludedObjects: MysqlRdbmsResponse, val oracleExcludedObjects: OracleRdbmsResponse, val postgresqlExcludedObjects: PostgresqlRdbmsResponse)

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

BackfillNoneStrategyResponse

class BackfillNoneStrategyResponse

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

BigQueryDestinationConfigResponse

data class BigQueryDestinationConfigResponse(val dataFreshness: String, val singleTargetDataset: SingleTargetDatasetResponse, val sourceHierarchyDatasets: SourceHierarchyDatasetsResponse)

BigQuery destination configuration

BigQueryProfileResponse

class BigQueryProfileResponse

BigQuery warehouse profile.

DatasetTemplateResponse

data class DatasetTemplateResponse(val datasetIdPrefix: String, val kmsKeyName: String, val location: String)

Dataset template used for dynamic dataset creation.

DestinationConfigResponse

data class DestinationConfigResponse(val bigqueryDestinationConfig: BigQueryDestinationConfigResponse, val destinationConnectionProfile: String, val gcsDestinationConfig: GcsDestinationConfigResponse)

The configuration of the stream destination.

DropLargeObjectsResponse

class DropLargeObjectsResponse

Configuration to drop large object values.

ErrorResponse

data class ErrorResponse(val details: Map<String, String>, val errorTime: String, val errorUuid: String, val message: String, val reason: String)

Represent a user-facing Error.

ForwardSshTunnelConnectivityResponse

data class ForwardSshTunnelConnectivityResponse(val hostname: String, val password: String, val port: Int, val privateKey: String, val username: String)

Forward SSH Tunnel connectivity.

GcsDestinationConfigResponse

data class GcsDestinationConfigResponse(val avroFileFormat: AvroFileFormatResponse, val fileRotationInterval: String, val fileRotationMb: Int, val jsonFileFormat: JsonFileFormatResponse, val path: String)

Google Cloud Storage destination configuration

GcsProfileResponse

data class GcsProfileResponse(val bucket: String, val rootPath: String)

Cloud Storage bucket profile.

GetConnectionProfileResult

data class GetConnectionProfileResult(val bigqueryProfile: BigQueryProfileResponse, val createTime: String, val displayName: String, val forwardSshConnectivity: ForwardSshTunnelConnectivityResponse, val gcsProfile: GcsProfileResponse, val labels: Map<String, String>, val mysqlProfile: MysqlProfileResponse, val name: String, val oracleProfile: OracleProfileResponse, val postgresqlProfile: PostgresqlProfileResponse, val privateConnectivity: PrivateConnectivityResponse, val staticServiceIpConnectivity: StaticServiceIpConnectivityResponse, val updateTime: String)

GetPrivateConnectionResult

data class GetPrivateConnectionResult(val createTime: String, val displayName: String, val error: ErrorResponse, val labels: Map<String, String>, val name: String, val state: String, val updateTime: String, val vpcPeeringConfig: VpcPeeringConfigResponse)

GetRouteResult

data class GetRouteResult(val createTime: String, val destinationAddress: String, val destinationPort: Int, val displayName: String, val labels: Map<String, String>, val name: String, val updateTime: String)

GetStreamResult

data class GetStreamResult(val backfillAll: BackfillAllStrategyResponse, val backfillNone: BackfillNoneStrategyResponse, val createTime: String, val customerManagedEncryptionKey: String, val destinationConfig: DestinationConfigResponse, val displayName: String, val errors: List<ErrorResponse>, val labels: Map<String, String>, val name: String, val sourceConfig: SourceConfigResponse, val state: String, val updateTime: String)

JsonFileFormatResponse

data class JsonFileFormatResponse(val compression: String, val schemaFileFormat: String)

JSON file format configuration.

MysqlColumnResponse

data class MysqlColumnResponse(val collation: String, val column: String, val dataType: String, val length: Int, val nullable: Boolean, val ordinalPosition: Int, val primaryKey: Boolean)

MySQL Column.

MysqlDatabaseResponse

data class MysqlDatabaseResponse(val database: String, val mysqlTables: List<MysqlTableResponse>)

MySQL database.

MysqlProfileResponse

data class MysqlProfileResponse(val hostname: String, val password: String, val port: Int, val sslConfig: MysqlSslConfigResponse, val username: String)

MySQL database profile.

MysqlRdbmsResponse

data class MysqlRdbmsResponse(val mysqlDatabases: List<MysqlDatabaseResponse>)

MySQL database structure

MysqlSourceConfigResponse

data class MysqlSourceConfigResponse(val excludeObjects: MysqlRdbmsResponse, val includeObjects: MysqlRdbmsResponse, val maxConcurrentBackfillTasks: Int, val maxConcurrentCdcTasks: Int)

MySQL source configuration

MysqlSslConfigResponse

data class MysqlSslConfigResponse(val caCertificate: String, val caCertificateSet: Boolean, val clientCertificate: String, val clientCertificateSet: Boolean, val clientKey: String, val clientKeySet: Boolean)

MySQL SSL configuration information.

MysqlTableResponse

data class MysqlTableResponse(val mysqlColumns: List<MysqlColumnResponse>, val table: String)

MySQL table.

OracleColumnResponse

data class OracleColumnResponse(val column: String, val dataType: String, val encoding: String, val length: Int, val nullable: Boolean, val ordinalPosition: Int, val precision: Int, val primaryKey: Boolean, val scale: Int)

Oracle Column.

OracleProfileResponse

data class OracleProfileResponse(val connectionAttributes: Map<String, String>, val databaseService: String, val hostname: String, val password: String, val port: Int, val username: String)

Oracle database profile.

OracleRdbmsResponse

data class OracleRdbmsResponse(val oracleSchemas: List<OracleSchemaResponse>)

Oracle database structure.

OracleSchemaResponse

data class OracleSchemaResponse(val oracleTables: List<OracleTableResponse>, val schema: String)

Oracle schema.

OracleSourceConfigResponse

data class OracleSourceConfigResponse(val dropLargeObjects: DropLargeObjectsResponse, val excludeObjects: OracleRdbmsResponse, val includeObjects: OracleRdbmsResponse, val maxConcurrentBackfillTasks: Int, val maxConcurrentCdcTasks: Int, val streamLargeObjects: StreamLargeObjectsResponse)

Oracle data source configuration

OracleTableResponse

data class OracleTableResponse(val oracleColumns: List<OracleColumnResponse>, val table: String)

Oracle table.

PostgresqlColumnResponse

data class PostgresqlColumnResponse(val column: String, val dataType: String, val length: Int, val nullable: Boolean, val ordinalPosition: Int, val precision: Int, val primaryKey: Boolean, val scale: Int)

PostgreSQL Column.

PostgresqlProfileResponse

data class PostgresqlProfileResponse(val database: String, val hostname: String, val password: String, val port: Int, val username: String)

PostgreSQL database profile.

PostgresqlRdbmsResponse

data class PostgresqlRdbmsResponse(val postgresqlSchemas: List<PostgresqlSchemaResponse>)

PostgreSQL database structure.

PostgresqlSchemaResponse

data class PostgresqlSchemaResponse(val postgresqlTables: List<PostgresqlTableResponse>, val schema: String)

PostgreSQL schema.

PostgresqlSourceConfigResponse

data class PostgresqlSourceConfigResponse(val excludeObjects: PostgresqlRdbmsResponse, val includeObjects: PostgresqlRdbmsResponse, val maxConcurrentBackfillTasks: Int, val publication: String, val replicationSlot: String)

PostgreSQL data source configuration

PostgresqlTableResponse

data class PostgresqlTableResponse(val postgresqlColumns: List<PostgresqlColumnResponse>, val table: String)

PostgreSQL table.

PrivateConnectivityResponse

data class PrivateConnectivityResponse(val privateConnection: String)

Private Connectivity

SingleTargetDatasetResponse

data class SingleTargetDatasetResponse(val datasetId: String)

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

SourceConfigResponse

data class SourceConfigResponse(val mysqlSourceConfig: MysqlSourceConfigResponse, val oracleSourceConfig: OracleSourceConfigResponse, val postgresqlSourceConfig: PostgresqlSourceConfigResponse, val sourceConnectionProfile: String)

The configuration of the stream source.

SourceHierarchyDatasetsResponse

data class SourceHierarchyDatasetsResponse(val datasetTemplate: DatasetTemplateResponse)

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

StaticServiceIpConnectivityResponse

class StaticServiceIpConnectivityResponse

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.

StreamLargeObjectsResponse

class StreamLargeObjectsResponse

Configuration to stream large object values.

VpcPeeringConfigResponse

data class VpcPeeringConfigResponse(val subnet: String, val vpc: String)

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