#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OracleProfile {
#[prost(string, tag = "1")]
pub hostname: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub port: i32,
#[prost(string, tag = "3")]
pub username: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub password: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub database_service: ::prost::alloc::string::String,
#[prost(map = "string, string", tag = "6")]
pub connection_attributes:
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MysqlProfile {
#[prost(string, tag = "1")]
pub hostname: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub port: i32,
#[prost(string, tag = "3")]
pub username: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub password: ::prost::alloc::string::String,
#[prost(message, optional, tag = "5")]
pub ssl_config: ::core::option::Option<MysqlSslConfig>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GcsProfile {
#[prost(string, tag = "1")]
pub bucket_name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub root_path: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct NoConnectivitySettings {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StaticServiceIpConnectivity {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ForwardSshTunnelConnectivity {
#[prost(string, tag = "1")]
pub hostname: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub username: ::prost::alloc::string::String,
#[prost(int32, tag = "3")]
pub port: i32,
#[prost(oneof = "forward_ssh_tunnel_connectivity::AuthenticationMethod", tags = "100, 101")]
pub authentication_method:
::core::option::Option<forward_ssh_tunnel_connectivity::AuthenticationMethod>,
}
pub mod forward_ssh_tunnel_connectivity {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum AuthenticationMethod {
#[prost(string, tag = "100")]
Password(::prost::alloc::string::String),
#[prost(string, tag = "101")]
PrivateKey(::prost::alloc::string::String),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VpcPeeringConfig {
#[prost(string, tag = "1")]
pub vpc_name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub subnet: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PrivateConnection {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub update_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(map = "string, string", tag = "4")]
pub labels:
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
#[prost(string, tag = "5")]
pub display_name: ::prost::alloc::string::String,
#[prost(enumeration = "private_connection::State", tag = "6")]
pub state: i32,
#[prost(message, optional, tag = "7")]
pub error: ::core::option::Option<Error>,
#[prost(message, optional, tag = "100")]
pub vpc_peering_config: ::core::option::Option<VpcPeeringConfig>,
}
pub mod private_connection {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum State {
Unspecified = 0,
Creating = 1,
Created = 2,
Failed = 3,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PrivateConnectivity {
#[prost(string, tag = "1")]
pub private_connection_name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Route {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub update_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(map = "string, string", tag = "4")]
pub labels:
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
#[prost(string, tag = "5")]
pub display_name: ::prost::alloc::string::String,
#[prost(string, tag = "6")]
pub destination_address: ::prost::alloc::string::String,
#[prost(int32, tag = "7")]
pub destination_port: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MysqlSslConfig {
#[prost(string, tag = "11")]
pub client_key: ::prost::alloc::string::String,
#[prost(bool, tag = "12")]
pub client_key_set: bool,
#[prost(string, tag = "13")]
pub client_certificate: ::prost::alloc::string::String,
#[prost(bool, tag = "14")]
pub client_certificate_set: bool,
#[prost(string, tag = "15")]
pub ca_certificate: ::prost::alloc::string::String,
#[prost(bool, tag = "16")]
pub ca_certificate_set: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConnectionProfile {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub update_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(map = "string, string", tag = "4")]
pub labels:
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
#[prost(string, tag = "5")]
pub display_name: ::prost::alloc::string::String,
#[prost(oneof = "connection_profile::Profile", tags = "100, 101, 102")]
pub profile: ::core::option::Option<connection_profile::Profile>,
#[prost(oneof = "connection_profile::Connectivity", tags = "200, 201, 202, 203")]
pub connectivity: ::core::option::Option<connection_profile::Connectivity>,
}
pub mod connection_profile {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Profile {
#[prost(message, tag = "100")]
OracleProfile(super::OracleProfile),
#[prost(message, tag = "101")]
GcsProfile(super::GcsProfile),
#[prost(message, tag = "102")]
MysqlProfile(super::MysqlProfile),
}
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Connectivity {
#[prost(message, tag = "200")]
NoConnectivity(super::NoConnectivitySettings),
#[prost(message, tag = "201")]
StaticServiceIpConnectivity(super::StaticServiceIpConnectivity),
#[prost(message, tag = "202")]
ForwardSshConnectivity(super::ForwardSshTunnelConnectivity),
#[prost(message, tag = "203")]
PrivateConnectivity(super::PrivateConnectivity),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OracleColumn {
#[prost(string, tag = "1")]
pub column_name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub data_type: ::prost::alloc::string::String,
#[prost(int32, tag = "3")]
pub length: i32,
#[prost(int32, tag = "4")]
pub precision: i32,
#[prost(int32, tag = "5")]
pub scale: i32,
#[prost(string, tag = "6")]
pub encoding: ::prost::alloc::string::String,
#[prost(bool, tag = "7")]
pub primary_key: bool,
#[prost(bool, tag = "8")]
pub nullable: bool,
#[prost(int32, tag = "9")]
pub ordinal_position: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OracleTable {
#[prost(string, tag = "1")]
pub table_name: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub oracle_columns: ::prost::alloc::vec::Vec<OracleColumn>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OracleSchema {
#[prost(string, tag = "1")]
pub schema_name: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub oracle_tables: ::prost::alloc::vec::Vec<OracleTable>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OracleRdbms {
#[prost(message, repeated, tag = "1")]
pub oracle_schemas: ::prost::alloc::vec::Vec<OracleSchema>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OracleSourceConfig {
#[prost(message, optional, tag = "1")]
pub allowlist: ::core::option::Option<OracleRdbms>,
#[prost(message, optional, tag = "2")]
pub rejectlist: ::core::option::Option<OracleRdbms>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MysqlColumn {
#[prost(string, tag = "1")]
pub column_name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub data_type: ::prost::alloc::string::String,
#[prost(int32, tag = "3")]
pub length: i32,
#[prost(string, tag = "4")]
pub collation: ::prost::alloc::string::String,
#[prost(bool, tag = "5")]
pub primary_key: bool,
#[prost(bool, tag = "6")]
pub nullable: bool,
#[prost(int32, tag = "7")]
pub ordinal_position: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MysqlTable {
#[prost(string, tag = "1")]
pub table_name: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub mysql_columns: ::prost::alloc::vec::Vec<MysqlColumn>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MysqlDatabase {
#[prost(string, tag = "1")]
pub database_name: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub mysql_tables: ::prost::alloc::vec::Vec<MysqlTable>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MysqlRdbms {
#[prost(message, repeated, tag = "1")]
pub mysql_databases: ::prost::alloc::vec::Vec<MysqlDatabase>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MysqlSourceConfig {
#[prost(message, optional, tag = "1")]
pub allowlist: ::core::option::Option<MysqlRdbms>,
#[prost(message, optional, tag = "2")]
pub rejectlist: ::core::option::Option<MysqlRdbms>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SourceConfig {
#[prost(string, tag = "1")]
pub source_connection_profile_name: ::prost::alloc::string::String,
#[prost(oneof = "source_config::SourceStreamConfig", tags = "100, 101")]
pub source_stream_config: ::core::option::Option<source_config::SourceStreamConfig>,
}
pub mod source_config {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum SourceStreamConfig {
#[prost(message, tag = "100")]
OracleSourceConfig(super::OracleSourceConfig),
#[prost(message, tag = "101")]
MysqlSourceConfig(super::MysqlSourceConfig),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AvroFileFormat {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct JsonFileFormat {
#[prost(enumeration = "SchemaFileFormat", tag = "1")]
pub schema_file_format: i32,
#[prost(enumeration = "json_file_format::JsonCompression", tag = "2")]
pub compression: i32,
}
pub mod json_file_format {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum JsonCompression {
Unspecified = 0,
NoCompression = 1,
Gzip = 2,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GcsDestinationConfig {
#[prost(string, tag = "1")]
pub path: ::prost::alloc::string::String,
#[deprecated]
#[prost(enumeration = "GcsFileFormat", tag = "2")]
pub gcs_file_format: i32,
#[prost(int32, tag = "3")]
pub file_rotation_mb: i32,
#[prost(message, optional, tag = "4")]
pub file_rotation_interval: ::core::option::Option<::prost_types::Duration>,
#[prost(oneof = "gcs_destination_config::FileFormat", tags = "100, 101")]
pub file_format: ::core::option::Option<gcs_destination_config::FileFormat>,
}
pub mod gcs_destination_config {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum FileFormat {
#[prost(message, tag = "100")]
AvroFileFormat(super::AvroFileFormat),
#[prost(message, tag = "101")]
JsonFileFormat(super::JsonFileFormat),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DestinationConfig {
#[prost(string, tag = "1")]
pub destination_connection_profile_name: ::prost::alloc::string::String,
#[prost(oneof = "destination_config::DestinationStreamConfig", tags = "100")]
pub destination_stream_config:
::core::option::Option<destination_config::DestinationStreamConfig>,
}
pub mod destination_config {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DestinationStreamConfig {
#[prost(message, tag = "100")]
GcsDestinationConfig(super::GcsDestinationConfig),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Stream {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub update_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(map = "string, string", tag = "4")]
pub labels:
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
#[prost(string, tag = "5")]
pub display_name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "6")]
pub source_config: ::core::option::Option<SourceConfig>,
#[prost(message, optional, tag = "7")]
pub destination_config: ::core::option::Option<DestinationConfig>,
#[prost(enumeration = "stream::State", tag = "8")]
pub state: i32,
#[prost(message, repeated, tag = "9")]
pub errors: ::prost::alloc::vec::Vec<Error>,
#[prost(oneof = "stream::BackfillStrategy", tags = "101, 102")]
pub backfill_strategy: ::core::option::Option<stream::BackfillStrategy>,
}
pub mod stream {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BackfillAllStrategy {
#[prost(oneof = "backfill_all_strategy::ExcludedObjects", tags = "1, 2")]
pub excluded_objects: ::core::option::Option<backfill_all_strategy::ExcludedObjects>,
}
pub mod backfill_all_strategy {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ExcludedObjects {
#[prost(message, tag = "1")]
OracleExcludedObjects(super::super::OracleRdbms),
#[prost(message, tag = "2")]
MysqlExcludedObjects(super::super::MysqlRdbms),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BackfillNoneStrategy {}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum State {
Unspecified = 0,
Created = 1,
Running = 2,
Paused = 3,
Maintenance = 4,
Failed = 5,
FailedPermanently = 6,
Starting = 7,
Draining = 8,
}
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum BackfillStrategy {
#[prost(message, tag = "101")]
BackfillAll(BackfillAllStrategy),
#[prost(message, tag = "102")]
BackfillNone(BackfillNoneStrategy),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Error {
#[prost(string, tag = "1")]
pub reason: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub error_uuid: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub message: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub error_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(map = "string, string", tag = "5")]
pub details:
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ValidationResult {
#[prost(message, repeated, tag = "1")]
pub validations: ::prost::alloc::vec::Vec<Validation>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Validation {
#[prost(string, tag = "1")]
pub description: ::prost::alloc::string::String,
#[prost(enumeration = "validation::Status", tag = "2")]
pub status: i32,
#[prost(message, repeated, tag = "3")]
pub message: ::prost::alloc::vec::Vec<ValidationMessage>,
#[prost(string, tag = "4")]
pub code: ::prost::alloc::string::String,
}
pub mod validation {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum Status {
Unspecified = 0,
NotExecuted = 1,
Failed = 2,
Passed = 3,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ValidationMessage {
#[prost(string, tag = "1")]
pub message: ::prost::alloc::string::String,
#[prost(enumeration = "validation_message::Level", tag = "2")]
pub level: i32,
#[prost(map = "string, string", tag = "3")]
pub metadata:
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
#[prost(string, tag = "4")]
pub code: ::prost::alloc::string::String,
}
pub mod validation_message {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum Level {
Unspecified = 0,
Warning = 1,
Error = 2,
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum GcsFileFormat {
Unspecified = 0,
Avro = 1,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SchemaFileFormat {
Unspecified = 0,
NoSchemaFile = 1,
AvroSchemaFile = 2,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiscoverConnectionProfileRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(oneof = "discover_connection_profile_request::Target", tags = "200, 201")]
pub target: ::core::option::Option<discover_connection_profile_request::Target>,
#[prost(oneof = "discover_connection_profile_request::Depth", tags = "3, 4")]
pub depth: ::core::option::Option<discover_connection_profile_request::Depth>,
#[prost(oneof = "discover_connection_profile_request::DataObject", tags = "100, 101")]
pub data_object: ::core::option::Option<discover_connection_profile_request::DataObject>,
}
pub mod discover_connection_profile_request {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Target {
#[prost(message, tag = "200")]
ConnectionProfile(super::ConnectionProfile),
#[prost(string, tag = "201")]
ConnectionProfileName(::prost::alloc::string::String),
}
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Depth {
#[prost(bool, tag = "3")]
Recursive(bool),
#[prost(int32, tag = "4")]
RecursionDepth(i32),
}
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DataObject {
#[prost(message, tag = "100")]
OracleRdbms(super::OracleRdbms),
#[prost(message, tag = "101")]
MysqlRdbms(super::MysqlRdbms),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiscoverConnectionProfileResponse {
#[prost(oneof = "discover_connection_profile_response::DataObject", tags = "100, 101")]
pub data_object: ::core::option::Option<discover_connection_profile_response::DataObject>,
}
pub mod discover_connection_profile_response {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DataObject {
#[prost(message, tag = "100")]
OracleRdbms(super::OracleRdbms),
#[prost(message, tag = "101")]
MysqlRdbms(super::MysqlRdbms),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FetchStaticIpsRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub page_size: i32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FetchStaticIpsResponse {
#[prost(string, repeated, tag = "1")]
pub static_ips: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FetchErrorsRequest {
#[prost(string, tag = "1")]
pub stream: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FetchErrorsResponse {
#[prost(message, repeated, tag = "1")]
pub errors: ::prost::alloc::vec::Vec<Error>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListConnectionProfilesRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub page_size: i32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub filter: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub order_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListConnectionProfilesResponse {
#[prost(message, repeated, tag = "1")]
pub connection_profiles: ::prost::alloc::vec::Vec<ConnectionProfile>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "3")]
pub unreachable: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetConnectionProfileRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateConnectionProfileRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub connection_profile_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub connection_profile: ::core::option::Option<ConnectionProfile>,
#[prost(string, tag = "4")]
pub request_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateConnectionProfileRequest {
#[prost(message, optional, tag = "1")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
#[prost(message, optional, tag = "2")]
pub connection_profile: ::core::option::Option<ConnectionProfile>,
#[prost(string, tag = "3")]
pub request_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteConnectionProfileRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub request_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListStreamsRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub page_size: i32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub filter: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub order_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListStreamsResponse {
#[prost(message, repeated, tag = "1")]
pub streams: ::prost::alloc::vec::Vec<Stream>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "3")]
pub unreachable: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetStreamRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateStreamRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub stream_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub stream: ::core::option::Option<Stream>,
#[prost(string, tag = "4")]
pub request_id: ::prost::alloc::string::String,
#[prost(bool, tag = "5")]
pub validate_only: bool,
#[prost(bool, tag = "6")]
pub force: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateStreamRequest {
#[prost(message, optional, tag = "1")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
#[prost(message, optional, tag = "2")]
pub stream: ::core::option::Option<Stream>,
#[prost(string, tag = "3")]
pub request_id: ::prost::alloc::string::String,
#[prost(bool, tag = "4")]
pub validate_only: bool,
#[prost(bool, tag = "5")]
pub force: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteStreamRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub request_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OperationMetadata {
#[prost(message, optional, tag = "1")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "2")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(string, tag = "3")]
pub target: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub verb: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub status_message: ::prost::alloc::string::String,
#[prost(bool, tag = "6")]
pub requested_cancellation: bool,
#[prost(string, tag = "7")]
pub api_version: ::prost::alloc::string::String,
#[prost(message, optional, tag = "8")]
pub validation_result: ::core::option::Option<ValidationResult>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreatePrivateConnectionRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub private_connection_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub private_connection: ::core::option::Option<PrivateConnection>,
#[prost(string, tag = "4")]
pub request_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListPrivateConnectionsRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub page_size: i32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub filter: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub order_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListPrivateConnectionsResponse {
#[prost(message, repeated, tag = "1")]
pub private_connections: ::prost::alloc::vec::Vec<PrivateConnection>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "3")]
pub unreachable: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeletePrivateConnectionRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub request_id: ::prost::alloc::string::String,
#[prost(bool, tag = "3")]
pub force: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetPrivateConnectionRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateRouteRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub route_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub route: ::core::option::Option<Route>,
#[prost(string, tag = "4")]
pub request_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListRoutesRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub page_size: i32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub filter: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub order_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListRoutesResponse {
#[prost(message, repeated, tag = "1")]
pub routes: ::prost::alloc::vec::Vec<Route>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "3")]
pub unreachable: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteRouteRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub request_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRouteRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[doc = r" Generated client implementations."]
pub mod datastream_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[doc = " Datastream service"]
#[derive(Debug, Clone)]
pub struct DatastreamClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> DatastreamClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> DatastreamClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
DatastreamClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " Use this method to list connection profiles created in a project and"]
#[doc = " location."]
pub async fn list_connection_profiles(
&mut self,
request: impl tonic::IntoRequest<super::ListConnectionProfilesRequest>,
) -> Result<tonic::Response<super::ListConnectionProfilesResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/ListConnectionProfiles",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to get details about a connection profile."]
pub async fn get_connection_profile(
&mut self,
request: impl tonic::IntoRequest<super::GetConnectionProfileRequest>,
) -> Result<tonic::Response<super::ConnectionProfile>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/GetConnectionProfile",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to create a connection profile in a project and location."]
pub async fn create_connection_profile(
&mut self,
request: impl tonic::IntoRequest<super::CreateConnectionProfileRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/CreateConnectionProfile",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to update the parameters of a connection profile."]
pub async fn update_connection_profile(
&mut self,
request: impl tonic::IntoRequest<super::UpdateConnectionProfileRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/UpdateConnectionProfile",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to delete a connection profile.."]
pub async fn delete_connection_profile(
&mut self,
request: impl tonic::IntoRequest<super::DeleteConnectionProfileRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/DeleteConnectionProfile",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to discover a connection profile."]
#[doc = " The discover API call exposes the data objects and metadata belonging to"]
#[doc = " the profile. Typically, a request returns children data objects under a"]
#[doc = " parent data object that's optionally supplied in the request."]
pub async fn discover_connection_profile(
&mut self,
request: impl tonic::IntoRequest<super::DiscoverConnectionProfileRequest>,
) -> Result<tonic::Response<super::DiscoverConnectionProfileResponse>, tonic::Status>
{
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/DiscoverConnectionProfile",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to list streams in a project and location."]
pub async fn list_streams(
&mut self,
request: impl tonic::IntoRequest<super::ListStreamsRequest>,
) -> Result<tonic::Response<super::ListStreamsResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/ListStreams",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to get details about a stream."]
pub async fn get_stream(
&mut self,
request: impl tonic::IntoRequest<super::GetStreamRequest>,
) -> Result<tonic::Response<super::Stream>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/GetStream",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to create a stream."]
pub async fn create_stream(
&mut self,
request: impl tonic::IntoRequest<super::CreateStreamRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/CreateStream",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to update the configuration of a stream."]
pub async fn update_stream(
&mut self,
request: impl tonic::IntoRequest<super::UpdateStreamRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/UpdateStream",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to delete a stream."]
pub async fn delete_stream(
&mut self,
request: impl tonic::IntoRequest<super::DeleteStreamRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/DeleteStream",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to fetch any errors associated with a stream."]
pub async fn fetch_errors(
&mut self,
request: impl tonic::IntoRequest<super::FetchErrorsRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/FetchErrors",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " The FetchStaticIps API call exposes the static ips used by Datastream."]
#[doc = " Typically, a request returns children data objects under"]
#[doc = " a parent data object that's optionally supplied in the request."]
pub async fn fetch_static_ips(
&mut self,
request: impl tonic::IntoRequest<super::FetchStaticIpsRequest>,
) -> Result<tonic::Response<super::FetchStaticIpsResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/FetchStaticIps",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to create a private connectivity configuration."]
pub async fn create_private_connection(
&mut self,
request: impl tonic::IntoRequest<super::CreatePrivateConnectionRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/CreatePrivateConnection",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to get details about a private connectivity configuration."]
pub async fn get_private_connection(
&mut self,
request: impl tonic::IntoRequest<super::GetPrivateConnectionRequest>,
) -> Result<tonic::Response<super::PrivateConnection>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/GetPrivateConnection",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to list private connectivity configurations in a project"]
#[doc = " and location."]
pub async fn list_private_connections(
&mut self,
request: impl tonic::IntoRequest<super::ListPrivateConnectionsRequest>,
) -> Result<tonic::Response<super::ListPrivateConnectionsResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/ListPrivateConnections",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to delete a private connectivity configuration."]
pub async fn delete_private_connection(
&mut self,
request: impl tonic::IntoRequest<super::DeletePrivateConnectionRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/DeletePrivateConnection",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to create a route for a private connectivity in a project"]
#[doc = " and location."]
pub async fn create_route(
&mut self,
request: impl tonic::IntoRequest<super::CreateRouteRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/CreateRoute",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to get details about a route."]
pub async fn get_route(
&mut self,
request: impl tonic::IntoRequest<super::GetRouteRequest>,
) -> Result<tonic::Response<super::Route>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/GetRoute",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to list routes created for a private connectivity in a"]
#[doc = " project and location."]
pub async fn list_routes(
&mut self,
request: impl tonic::IntoRequest<super::ListRoutesRequest>,
) -> Result<tonic::Response<super::ListRoutesResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/ListRoutes",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Use this method to delete a route."]
pub async fn delete_route(
&mut self,
request: impl tonic::IntoRequest<super::DeleteRouteRequest>,
) -> Result<
tonic::Response<super::super::super::super::longrunning::Operation>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.datastream.v1alpha1.Datastream/DeleteRoute",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}