Package-level declarations

Types

Link copied to clipboard

AVRO file format configuration.

Link copied to clipboard
data class BackfillAllStrategyResponse(val mysqlExcludedObjects: MysqlRdbmsResponse, val oracleExcludedObjects: OracleRdbmsResponse)

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

Link copied to clipboard

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

Link copied to clipboard
data class DestinationConfigResponse(val destinationConnectionProfileName: String, val gcsDestinationConfig: GcsDestinationConfigResponse)

The configuration of the stream destination.

Link copied to clipboard

Configuration to drop large object values.

Link copied to clipboard
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.

Link copied to clipboard
data class ForwardSshTunnelConnectivityResponse(val hostname: String, val password: String, val port: Int, val privateKey: String, val username: String)

Forward SSH Tunnel connectivity.

Link copied to clipboard
data class GcsDestinationConfigResponse(val avroFileFormat: AvroFileFormatResponse, val fileRotationInterval: String, val fileRotationMb: Int, val gcsFileFormat: String, val jsonFileFormat: JsonFileFormatResponse, val path: String)

Google Cloud Storage destination configuration

Link copied to clipboard
data class GcsProfileResponse(val bucketName: String, val rootPath: String)

Cloud Storage bucket profile.

Link copied to clipboard
data class GetConnectionProfileResult(val createTime: String, val displayName: String, val forwardSshConnectivity: ForwardSshTunnelConnectivityResponse, val gcsProfile: GcsProfileResponse, val labels: Map<String, String>, val mysqlProfile: MysqlProfileResponse, val name: String, val noConnectivity: NoConnectivitySettingsResponse, val oracleProfile: OracleProfileResponse, val privateConnectivity: PrivateConnectivityResponse, val staticServiceIpConnectivity: StaticServiceIpConnectivityResponse, val updateTime: String)
Link copied to clipboard
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)
Link copied to clipboard
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)
Link copied to clipboard
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)
Link copied to clipboard
data class JsonFileFormatResponse(val compression: String, val schemaFileFormat: String)

JSON file format configuration.

Link copied to clipboard
data class MysqlColumnResponse(val collation: String, val columnName: String, val dataType: String, val length: Int, val nullable: Boolean, val ordinalPosition: Int, val primaryKey: Boolean)

MySQL Column.

Link copied to clipboard
data class MysqlDatabaseResponse(val databaseName: String, val mysqlTables: List<MysqlTableResponse>)

MySQL database.

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

MySQL database profile.

Link copied to clipboard
data class MysqlRdbmsResponse(val mysqlDatabases: List<MysqlDatabaseResponse>)

MySQL database structure

Link copied to clipboard
data class MysqlSourceConfigResponse(val allowlist: MysqlRdbmsResponse, val rejectlist: MysqlRdbmsResponse)

MySQL source configuration

Link copied to clipboard
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.

Link copied to clipboard
data class MysqlTableResponse(val mysqlColumns: List<MysqlColumnResponse>, val tableName: String)

MySQL table.

Link copied to clipboard

No connectivity settings.

Link copied to clipboard
data class OracleColumnResponse(val columnName: 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.

Link copied to clipboard
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.

Link copied to clipboard
data class OracleRdbmsResponse(val oracleSchemas: List<OracleSchemaResponse>)

Oracle database structure.

Link copied to clipboard
data class OracleSchemaResponse(val oracleTables: List<OracleTableResponse>, val schemaName: String)

Oracle schema.

Link copied to clipboard
data class OracleSourceConfigResponse(val allowlist: OracleRdbmsResponse, val dropLargeObjects: DropLargeObjectsResponse, val rejectlist: OracleRdbmsResponse)

Oracle data source configuration

Link copied to clipboard
data class OracleTableResponse(val oracleColumns: List<OracleColumnResponse>, val tableName: String)

Oracle table.

Link copied to clipboard
data class PrivateConnectivityResponse(val privateConnectionName: String)

Private Connectivity

Link copied to clipboard
data class SourceConfigResponse(val mysqlSourceConfig: MysqlSourceConfigResponse, val oracleSourceConfig: OracleSourceConfigResponse, val sourceConnectionProfileName: String)

The configuration of the stream source.

Link copied to clipboard

Static IP address connectivity.

Link copied to clipboard
data class VpcPeeringConfigResponse(val subnet: String, val vpcName: String)

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