#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OperationProgress {
#[prost(int32, tag = "1")]
pub progress_percent: i32,
#[prost(message, optional, tag = "2")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum StorageType {
Unspecified = 0,
Ssd = 1,
Hdd = 2,
}
impl StorageType {
pub fn as_str_name(&self) -> &'static str {
match self {
StorageType::Unspecified => "STORAGE_TYPE_UNSPECIFIED",
StorageType::Ssd => "SSD",
StorageType::Hdd => "HDD",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STORAGE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
"SSD" => Some(Self::Ssd),
"HDD" => Some(Self::Hdd),
_ => None,
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Instance {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub display_name: ::prost::alloc::string::String,
#[prost(enumeration = "instance::State", tag = "3")]
pub state: i32,
#[prost(enumeration = "instance::Type", tag = "4")]
pub r#type: i32,
#[prost(btree_map = "string, string", tag = "5")]
pub labels: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
#[prost(message, optional, tag = "7")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(bool, optional, tag = "8")]
pub satisfies_pzs: ::core::option::Option<bool>,
}
pub mod instance {
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum State {
NotKnown = 0,
Ready = 1,
Creating = 2,
}
impl State {
pub fn as_str_name(&self) -> &'static str {
match self {
State::NotKnown => "STATE_NOT_KNOWN",
State::Ready => "READY",
State::Creating => "CREATING",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STATE_NOT_KNOWN" => Some(Self::NotKnown),
"READY" => Some(Self::Ready),
"CREATING" => Some(Self::Creating),
_ => None,
}
}
}
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum Type {
Unspecified = 0,
Production = 1,
Development = 2,
}
impl Type {
pub fn as_str_name(&self) -> &'static str {
match self {
Type::Unspecified => "TYPE_UNSPECIFIED",
Type::Production => "PRODUCTION",
Type::Development => "DEVELOPMENT",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"TYPE_UNSPECIFIED" => Some(Self::Unspecified),
"PRODUCTION" => Some(Self::Production),
"DEVELOPMENT" => Some(Self::Development),
_ => None,
}
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutoscalingTargets {
#[prost(int32, tag = "2")]
pub cpu_utilization_percent: i32,
#[prost(int32, tag = "3")]
pub storage_utilization_gib_per_node: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutoscalingLimits {
#[prost(int32, tag = "1")]
pub min_serve_nodes: i32,
#[prost(int32, tag = "2")]
pub max_serve_nodes: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Cluster {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub location: ::prost::alloc::string::String,
#[prost(enumeration = "cluster::State", tag = "3")]
pub state: i32,
#[prost(int32, tag = "4")]
pub serve_nodes: i32,
#[prost(enumeration = "StorageType", tag = "5")]
pub default_storage_type: i32,
#[prost(message, optional, tag = "6")]
pub encryption_config: ::core::option::Option<cluster::EncryptionConfig>,
#[prost(oneof = "cluster::Config", tags = "7")]
pub config: ::core::option::Option<cluster::Config>,
}
pub mod cluster {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClusterAutoscalingConfig {
#[prost(message, optional, tag = "1")]
pub autoscaling_limits: ::core::option::Option<super::AutoscalingLimits>,
#[prost(message, optional, tag = "2")]
pub autoscaling_targets: ::core::option::Option<super::AutoscalingTargets>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClusterConfig {
#[prost(message, optional, tag = "1")]
pub cluster_autoscaling_config: ::core::option::Option<ClusterAutoscalingConfig>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EncryptionConfig {
#[prost(string, tag = "1")]
pub kms_key_name: ::prost::alloc::string::String,
}
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum State {
NotKnown = 0,
Ready = 1,
Creating = 2,
Resizing = 3,
Disabled = 4,
}
impl State {
pub fn as_str_name(&self) -> &'static str {
match self {
State::NotKnown => "STATE_NOT_KNOWN",
State::Ready => "READY",
State::Creating => "CREATING",
State::Resizing => "RESIZING",
State::Disabled => "DISABLED",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STATE_NOT_KNOWN" => Some(Self::NotKnown),
"READY" => Some(Self::Ready),
"CREATING" => Some(Self::Creating),
"RESIZING" => Some(Self::Resizing),
"DISABLED" => Some(Self::Disabled),
_ => None,
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Config {
#[prost(message, tag = "7")]
ClusterConfig(ClusterConfig),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AppProfile {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub etag: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub description: ::prost::alloc::string::String,
#[prost(oneof = "app_profile::RoutingPolicy", tags = "5, 6")]
pub routing_policy: ::core::option::Option<app_profile::RoutingPolicy>,
#[prost(oneof = "app_profile::Isolation", tags = "7, 11, 10")]
pub isolation: ::core::option::Option<app_profile::Isolation>,
}
pub mod app_profile {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MultiClusterRoutingUseAny {
#[prost(string, repeated, tag = "1")]
pub cluster_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SingleClusterRouting {
#[prost(string, tag = "1")]
pub cluster_id: ::prost::alloc::string::String,
#[prost(bool, tag = "2")]
pub allow_transactional_writes: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StandardIsolation {
#[prost(enumeration = "Priority", tag = "1")]
pub priority: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataBoostIsolationReadOnly {
#[prost(
enumeration = "data_boost_isolation_read_only::ComputeBillingOwner",
optional,
tag = "1"
)]
pub compute_billing_owner: ::core::option::Option<i32>,
}
pub mod data_boost_isolation_read_only {
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum ComputeBillingOwner {
Unspecified = 0,
HostPays = 1,
}
impl ComputeBillingOwner {
pub fn as_str_name(&self) -> &'static str {
match self {
ComputeBillingOwner::Unspecified => {
"COMPUTE_BILLING_OWNER_UNSPECIFIED"
}
ComputeBillingOwner::HostPays => "HOST_PAYS",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"COMPUTE_BILLING_OWNER_UNSPECIFIED" => Some(Self::Unspecified),
"HOST_PAYS" => Some(Self::HostPays),
_ => None,
}
}
}
}
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum Priority {
Unspecified = 0,
Low = 1,
Medium = 2,
High = 3,
}
impl Priority {
pub fn as_str_name(&self) -> &'static str {
match self {
Priority::Unspecified => "PRIORITY_UNSPECIFIED",
Priority::Low => "PRIORITY_LOW",
Priority::Medium => "PRIORITY_MEDIUM",
Priority::High => "PRIORITY_HIGH",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"PRIORITY_UNSPECIFIED" => Some(Self::Unspecified),
"PRIORITY_LOW" => Some(Self::Low),
"PRIORITY_MEDIUM" => Some(Self::Medium),
"PRIORITY_HIGH" => Some(Self::High),
_ => None,
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum RoutingPolicy {
#[prost(message, tag = "5")]
MultiClusterRoutingUseAny(MultiClusterRoutingUseAny),
#[prost(message, tag = "6")]
SingleClusterRouting(SingleClusterRouting),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Isolation {
#[prost(enumeration = "Priority", tag = "7")]
Priority(i32),
#[prost(message, tag = "11")]
StandardIsolation(StandardIsolation),
#[prost(message, tag = "10")]
DataBoostIsolationReadOnly(DataBoostIsolationReadOnly),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HotTablet {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub table_name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "4")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(string, tag = "5")]
pub start_key: ::prost::alloc::string::String,
#[prost(string, tag = "6")]
pub end_key: ::prost::alloc::string::String,
#[prost(float, tag = "7")]
pub node_cpu_usage_percent: f32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Type {
#[prost(oneof = "r#type::Kind", tags = "1, 5, 6")]
pub kind: ::core::option::Option<r#type::Kind>,
}
pub mod r#type {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Bytes {
#[prost(message, optional, tag = "1")]
pub encoding: ::core::option::Option<bytes::Encoding>,
}
pub mod bytes {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Encoding {
#[prost(oneof = "encoding::Encoding", tags = "1")]
pub encoding: ::core::option::Option<encoding::Encoding>,
}
pub mod encoding {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Raw {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Encoding {
#[prost(message, tag = "1")]
Raw(Raw),
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Int64 {
#[prost(message, optional, tag = "1")]
pub encoding: ::core::option::Option<int64::Encoding>,
}
pub mod int64 {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Encoding {
#[prost(oneof = "encoding::Encoding", tags = "1")]
pub encoding: ::core::option::Option<encoding::Encoding>,
}
pub mod encoding {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BigEndianBytes {
#[prost(message, optional, tag = "1")]
pub bytes_type: ::core::option::Option<super::super::Bytes>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Encoding {
#[prost(message, tag = "1")]
BigEndianBytes(BigEndianBytes),
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Aggregate {
#[prost(message, optional, boxed, tag = "1")]
pub input_type: ::core::option::Option<::prost::alloc::boxed::Box<super::Type>>,
#[prost(message, optional, boxed, tag = "2")]
pub state_type: ::core::option::Option<::prost::alloc::boxed::Box<super::Type>>,
#[prost(oneof = "aggregate::Aggregator", tags = "4")]
pub aggregator: ::core::option::Option<aggregate::Aggregator>,
}
pub mod aggregate {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Sum {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Aggregator {
#[prost(message, tag = "4")]
Sum(Sum),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "1")]
BytesType(Bytes),
#[prost(message, tag = "5")]
Int64Type(Int64),
#[prost(message, tag = "6")]
AggregateType(::prost::alloc::boxed::Box<Aggregate>),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RestoreInfo {
#[prost(enumeration = "RestoreSourceType", tag = "1")]
pub source_type: i32,
#[prost(oneof = "restore_info::SourceInfo", tags = "2")]
pub source_info: ::core::option::Option<restore_info::SourceInfo>,
}
pub mod restore_info {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum SourceInfo {
#[prost(message, tag = "2")]
BackupInfo(super::BackupInfo),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ChangeStreamConfig {
#[prost(message, optional, tag = "1")]
pub retention_period: ::core::option::Option<::prost_types::Duration>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Table {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(btree_map = "string, message", tag = "2")]
pub cluster_states: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
table::ClusterState,
>,
#[prost(btree_map = "string, message", tag = "3")]
pub column_families: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
ColumnFamily,
>,
#[prost(enumeration = "table::TimestampGranularity", tag = "4")]
pub granularity: i32,
#[prost(message, optional, tag = "6")]
pub restore_info: ::core::option::Option<RestoreInfo>,
#[prost(message, optional, tag = "8")]
pub change_stream_config: ::core::option::Option<ChangeStreamConfig>,
#[prost(bool, tag = "9")]
pub deletion_protection: bool,
#[prost(oneof = "table::AutomatedBackupConfig", tags = "13")]
pub automated_backup_config: ::core::option::Option<table::AutomatedBackupConfig>,
}
pub mod table {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClusterState {
#[prost(enumeration = "cluster_state::ReplicationState", tag = "1")]
pub replication_state: i32,
#[prost(message, repeated, tag = "2")]
pub encryption_info: ::prost::alloc::vec::Vec<super::EncryptionInfo>,
}
pub mod cluster_state {
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum ReplicationState {
StateNotKnown = 0,
Initializing = 1,
PlannedMaintenance = 2,
UnplannedMaintenance = 3,
Ready = 4,
ReadyOptimizing = 5,
}
impl ReplicationState {
pub fn as_str_name(&self) -> &'static str {
match self {
ReplicationState::StateNotKnown => "STATE_NOT_KNOWN",
ReplicationState::Initializing => "INITIALIZING",
ReplicationState::PlannedMaintenance => "PLANNED_MAINTENANCE",
ReplicationState::UnplannedMaintenance => "UNPLANNED_MAINTENANCE",
ReplicationState::Ready => "READY",
ReplicationState::ReadyOptimizing => "READY_OPTIMIZING",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STATE_NOT_KNOWN" => Some(Self::StateNotKnown),
"INITIALIZING" => Some(Self::Initializing),
"PLANNED_MAINTENANCE" => Some(Self::PlannedMaintenance),
"UNPLANNED_MAINTENANCE" => Some(Self::UnplannedMaintenance),
"READY" => Some(Self::Ready),
"READY_OPTIMIZING" => Some(Self::ReadyOptimizing),
_ => None,
}
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomatedBackupPolicy {
#[prost(message, optional, tag = "1")]
pub retention_period: ::core::option::Option<::prost_types::Duration>,
#[prost(message, optional, tag = "2")]
pub frequency: ::core::option::Option<::prost_types::Duration>,
}
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum TimestampGranularity {
Unspecified = 0,
Millis = 1,
}
impl TimestampGranularity {
pub fn as_str_name(&self) -> &'static str {
match self {
TimestampGranularity::Unspecified => "TIMESTAMP_GRANULARITY_UNSPECIFIED",
TimestampGranularity::Millis => "MILLIS",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"TIMESTAMP_GRANULARITY_UNSPECIFIED" => Some(Self::Unspecified),
"MILLIS" => Some(Self::Millis),
_ => None,
}
}
}
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum View {
Unspecified = 0,
NameOnly = 1,
SchemaView = 2,
ReplicationView = 3,
EncryptionView = 5,
Full = 4,
}
impl View {
pub fn as_str_name(&self) -> &'static str {
match self {
View::Unspecified => "VIEW_UNSPECIFIED",
View::NameOnly => "NAME_ONLY",
View::SchemaView => "SCHEMA_VIEW",
View::ReplicationView => "REPLICATION_VIEW",
View::EncryptionView => "ENCRYPTION_VIEW",
View::Full => "FULL",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"VIEW_UNSPECIFIED" => Some(Self::Unspecified),
"NAME_ONLY" => Some(Self::NameOnly),
"SCHEMA_VIEW" => Some(Self::SchemaView),
"REPLICATION_VIEW" => Some(Self::ReplicationView),
"ENCRYPTION_VIEW" => Some(Self::EncryptionView),
"FULL" => Some(Self::Full),
_ => None,
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum AutomatedBackupConfig {
#[prost(message, tag = "13")]
AutomatedBackupPolicy(AutomatedBackupPolicy),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AuthorizedView {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub etag: ::prost::alloc::string::String,
#[prost(bool, tag = "4")]
pub deletion_protection: bool,
#[prost(oneof = "authorized_view::AuthorizedView", tags = "2")]
pub authorized_view: ::core::option::Option<authorized_view::AuthorizedView>,
}
pub mod authorized_view {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FamilySubsets {
#[prost(bytes = "bytes", repeated, tag = "1")]
pub qualifiers: ::prost::alloc::vec::Vec<::prost::bytes::Bytes>,
#[prost(bytes = "bytes", repeated, tag = "2")]
pub qualifier_prefixes: ::prost::alloc::vec::Vec<::prost::bytes::Bytes>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SubsetView {
#[prost(bytes = "bytes", repeated, tag = "1")]
pub row_prefixes: ::prost::alloc::vec::Vec<::prost::bytes::Bytes>,
#[prost(btree_map = "string, message", tag = "2")]
pub family_subsets: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
FamilySubsets,
>,
}
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum ResponseView {
Unspecified = 0,
NameOnly = 1,
Basic = 2,
Full = 3,
}
impl ResponseView {
pub fn as_str_name(&self) -> &'static str {
match self {
ResponseView::Unspecified => "RESPONSE_VIEW_UNSPECIFIED",
ResponseView::NameOnly => "NAME_ONLY",
ResponseView::Basic => "BASIC",
ResponseView::Full => "FULL",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"RESPONSE_VIEW_UNSPECIFIED" => Some(Self::Unspecified),
"NAME_ONLY" => Some(Self::NameOnly),
"BASIC" => Some(Self::Basic),
"FULL" => Some(Self::Full),
_ => None,
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum AuthorizedView {
#[prost(message, tag = "2")]
SubsetView(SubsetView),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ColumnFamily {
#[prost(message, optional, tag = "1")]
pub gc_rule: ::core::option::Option<GcRule>,
#[prost(message, optional, tag = "3")]
pub value_type: ::core::option::Option<Type>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GcRule {
#[prost(oneof = "gc_rule::Rule", tags = "1, 2, 3, 4")]
pub rule: ::core::option::Option<gc_rule::Rule>,
}
pub mod gc_rule {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Intersection {
#[prost(message, repeated, tag = "1")]
pub rules: ::prost::alloc::vec::Vec<super::GcRule>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Union {
#[prost(message, repeated, tag = "1")]
pub rules: ::prost::alloc::vec::Vec<super::GcRule>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Rule {
#[prost(int32, tag = "1")]
MaxNumVersions(i32),
#[prost(message, tag = "2")]
MaxAge(::prost_types::Duration),
#[prost(message, tag = "3")]
Intersection(Intersection),
#[prost(message, tag = "4")]
Union(Union),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EncryptionInfo {
#[prost(enumeration = "encryption_info::EncryptionType", tag = "3")]
pub encryption_type: i32,
#[prost(message, optional, tag = "4")]
pub encryption_status: ::core::option::Option<super::super::super::rpc::Status>,
#[prost(string, tag = "2")]
pub kms_key_version: ::prost::alloc::string::String,
}
pub mod encryption_info {
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum EncryptionType {
Unspecified = 0,
GoogleDefaultEncryption = 1,
CustomerManagedEncryption = 2,
}
impl EncryptionType {
pub fn as_str_name(&self) -> &'static str {
match self {
EncryptionType::Unspecified => "ENCRYPTION_TYPE_UNSPECIFIED",
EncryptionType::GoogleDefaultEncryption => "GOOGLE_DEFAULT_ENCRYPTION",
EncryptionType::CustomerManagedEncryption => {
"CUSTOMER_MANAGED_ENCRYPTION"
}
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"ENCRYPTION_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
"GOOGLE_DEFAULT_ENCRYPTION" => Some(Self::GoogleDefaultEncryption),
"CUSTOMER_MANAGED_ENCRYPTION" => Some(Self::CustomerManagedEncryption),
_ => None,
}
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Snapshot {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub source_table: ::core::option::Option<Table>,
#[prost(int64, tag = "3")]
pub data_size_bytes: i64,
#[prost(message, optional, tag = "4")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "5")]
pub delete_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(enumeration = "snapshot::State", tag = "6")]
pub state: i32,
#[prost(string, tag = "7")]
pub description: ::prost::alloc::string::String,
}
pub mod snapshot {
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum State {
NotKnown = 0,
Ready = 1,
Creating = 2,
}
impl State {
pub fn as_str_name(&self) -> &'static str {
match self {
State::NotKnown => "STATE_NOT_KNOWN",
State::Ready => "READY",
State::Creating => "CREATING",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STATE_NOT_KNOWN" => Some(Self::NotKnown),
"READY" => Some(Self::Ready),
"CREATING" => Some(Self::Creating),
_ => None,
}
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Backup {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub source_table: ::prost::alloc::string::String,
#[prost(string, tag = "10")]
pub source_backup: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub expire_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "4")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "5")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(int64, tag = "6")]
pub size_bytes: i64,
#[prost(enumeration = "backup::State", tag = "7")]
pub state: i32,
#[prost(message, optional, tag = "9")]
pub encryption_info: ::core::option::Option<EncryptionInfo>,
}
pub mod backup {
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum State {
Unspecified = 0,
Creating = 1,
Ready = 2,
}
impl State {
pub fn as_str_name(&self) -> &'static str {
match self {
State::Unspecified => "STATE_UNSPECIFIED",
State::Creating => "CREATING",
State::Ready => "READY",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STATE_UNSPECIFIED" => Some(Self::Unspecified),
"CREATING" => Some(Self::Creating),
"READY" => Some(Self::Ready),
_ => None,
}
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BackupInfo {
#[prost(string, tag = "1")]
pub backup: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(string, tag = "4")]
pub source_table: ::prost::alloc::string::String,
#[prost(string, tag = "10")]
pub source_backup: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum RestoreSourceType {
Unspecified = 0,
Backup = 1,
}
impl RestoreSourceType {
pub fn as_str_name(&self) -> &'static str {
match self {
RestoreSourceType::Unspecified => "RESTORE_SOURCE_TYPE_UNSPECIFIED",
RestoreSourceType::Backup => "BACKUP",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"RESTORE_SOURCE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
"BACKUP" => Some(Self::Backup),
_ => None,
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateInstanceRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub instance_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub instance: ::core::option::Option<Instance>,
#[prost(btree_map = "string, message", tag = "4")]
pub clusters: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
Cluster,
>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetInstanceRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListInstancesRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListInstancesResponse {
#[prost(message, repeated, tag = "1")]
pub instances: ::prost::alloc::vec::Vec<Instance>,
#[prost(string, repeated, tag = "2")]
pub failed_locations: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, tag = "3")]
pub next_page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PartialUpdateInstanceRequest {
#[prost(message, optional, tag = "1")]
pub instance: ::core::option::Option<Instance>,
#[prost(message, optional, tag = "2")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteInstanceRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateClusterRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub cluster_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub cluster: ::core::option::Option<Cluster>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetClusterRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListClustersRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListClustersResponse {
#[prost(message, repeated, tag = "1")]
pub clusters: ::prost::alloc::vec::Vec<Cluster>,
#[prost(string, repeated, tag = "2")]
pub failed_locations: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, tag = "3")]
pub next_page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteClusterRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateInstanceMetadata {
#[prost(message, optional, tag = "1")]
pub original_request: ::core::option::Option<CreateInstanceRequest>,
#[prost(message, optional, tag = "2")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateInstanceMetadata {
#[prost(message, optional, tag = "1")]
pub original_request: ::core::option::Option<PartialUpdateInstanceRequest>,
#[prost(message, optional, tag = "2")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateClusterMetadata {
#[prost(message, optional, tag = "1")]
pub original_request: ::core::option::Option<CreateClusterRequest>,
#[prost(message, optional, tag = "2")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(btree_map = "string, message", tag = "4")]
pub tables: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
create_cluster_metadata::TableProgress,
>,
}
pub mod create_cluster_metadata {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableProgress {
#[prost(int64, tag = "2")]
pub estimated_size_bytes: i64,
#[prost(int64, tag = "3")]
pub estimated_copied_bytes: i64,
#[prost(enumeration = "table_progress::State", tag = "4")]
pub state: i32,
}
pub mod table_progress {
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum State {
Unspecified = 0,
Pending = 1,
Copying = 2,
Completed = 3,
Cancelled = 4,
}
impl State {
pub fn as_str_name(&self) -> &'static str {
match self {
State::Unspecified => "STATE_UNSPECIFIED",
State::Pending => "PENDING",
State::Copying => "COPYING",
State::Completed => "COMPLETED",
State::Cancelled => "CANCELLED",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STATE_UNSPECIFIED" => Some(Self::Unspecified),
"PENDING" => Some(Self::Pending),
"COPYING" => Some(Self::Copying),
"COMPLETED" => Some(Self::Completed),
"CANCELLED" => Some(Self::Cancelled),
_ => None,
}
}
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateClusterMetadata {
#[prost(message, optional, tag = "1")]
pub original_request: ::core::option::Option<Cluster>,
#[prost(message, optional, tag = "2")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PartialUpdateClusterMetadata {
#[prost(message, optional, tag = "1")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "2")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub original_request: ::core::option::Option<PartialUpdateClusterRequest>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PartialUpdateClusterRequest {
#[prost(message, optional, tag = "1")]
pub cluster: ::core::option::Option<Cluster>,
#[prost(message, optional, tag = "2")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateAppProfileRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub app_profile_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub app_profile: ::core::option::Option<AppProfile>,
#[prost(bool, tag = "4")]
pub ignore_warnings: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAppProfileRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListAppProfilesRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(int32, tag = "3")]
pub page_size: i32,
#[prost(string, tag = "2")]
pub page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListAppProfilesResponse {
#[prost(message, repeated, tag = "1")]
pub app_profiles: ::prost::alloc::vec::Vec<AppProfile>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "3")]
pub failed_locations: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateAppProfileRequest {
#[prost(message, optional, tag = "1")]
pub app_profile: ::core::option::Option<AppProfile>,
#[prost(message, optional, tag = "2")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
#[prost(bool, tag = "3")]
pub ignore_warnings: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteAppProfileRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(bool, tag = "2")]
pub ignore_warnings: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateAppProfileMetadata {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListHotTabletsRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(int32, tag = "4")]
pub page_size: i32,
#[prost(string, tag = "5")]
pub page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListHotTabletsResponse {
#[prost(message, repeated, tag = "1")]
pub hot_tablets: ::prost::alloc::vec::Vec<HotTablet>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
}
pub mod bigtable_instance_admin_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct BigtableInstanceAdminClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> BigtableInstanceAdminClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<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_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> BigtableInstanceAdminClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
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,
{
BigtableInstanceAdminClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn create_instance(
&mut self,
request: impl tonic::IntoRequest<super::CreateInstanceRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableInstanceAdmin/CreateInstance",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"CreateInstance",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_instance(
&mut self,
request: impl tonic::IntoRequest<super::GetInstanceRequest>,
) -> std::result::Result<tonic::Response<super::Instance>, 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.bigtable.admin.v2.BigtableInstanceAdmin/GetInstance",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"GetInstance",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_instances(
&mut self,
request: impl tonic::IntoRequest<super::ListInstancesRequest>,
) -> std::result::Result<
tonic::Response<super::ListInstancesResponse>,
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.bigtable.admin.v2.BigtableInstanceAdmin/ListInstances",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"ListInstances",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_instance(
&mut self,
request: impl tonic::IntoRequest<super::Instance>,
) -> std::result::Result<tonic::Response<super::Instance>, 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.bigtable.admin.v2.BigtableInstanceAdmin/UpdateInstance",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"UpdateInstance",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn partial_update_instance(
&mut self,
request: impl tonic::IntoRequest<super::PartialUpdateInstanceRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableInstanceAdmin/PartialUpdateInstance",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"PartialUpdateInstance",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_instance(
&mut self,
request: impl tonic::IntoRequest<super::DeleteInstanceRequest>,
) -> std::result::Result<tonic::Response<()>, 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.bigtable.admin.v2.BigtableInstanceAdmin/DeleteInstance",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"DeleteInstance",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_cluster(
&mut self,
request: impl tonic::IntoRequest<super::CreateClusterRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableInstanceAdmin/CreateCluster",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"CreateCluster",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_cluster(
&mut self,
request: impl tonic::IntoRequest<super::GetClusterRequest>,
) -> std::result::Result<tonic::Response<super::Cluster>, 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.bigtable.admin.v2.BigtableInstanceAdmin/GetCluster",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"GetCluster",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_clusters(
&mut self,
request: impl tonic::IntoRequest<super::ListClustersRequest>,
) -> std::result::Result<
tonic::Response<super::ListClustersResponse>,
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.bigtable.admin.v2.BigtableInstanceAdmin/ListClusters",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"ListClusters",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_cluster(
&mut self,
request: impl tonic::IntoRequest<super::Cluster>,
) -> std::result::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.bigtable.admin.v2.BigtableInstanceAdmin/UpdateCluster",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"UpdateCluster",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn partial_update_cluster(
&mut self,
request: impl tonic::IntoRequest<super::PartialUpdateClusterRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableInstanceAdmin/PartialUpdateCluster",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"PartialUpdateCluster",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_cluster(
&mut self,
request: impl tonic::IntoRequest<super::DeleteClusterRequest>,
) -> std::result::Result<tonic::Response<()>, 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.bigtable.admin.v2.BigtableInstanceAdmin/DeleteCluster",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"DeleteCluster",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_app_profile(
&mut self,
request: impl tonic::IntoRequest<super::CreateAppProfileRequest>,
) -> std::result::Result<tonic::Response<super::AppProfile>, 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.bigtable.admin.v2.BigtableInstanceAdmin/CreateAppProfile",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"CreateAppProfile",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_app_profile(
&mut self,
request: impl tonic::IntoRequest<super::GetAppProfileRequest>,
) -> std::result::Result<tonic::Response<super::AppProfile>, 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.bigtable.admin.v2.BigtableInstanceAdmin/GetAppProfile",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"GetAppProfile",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_app_profiles(
&mut self,
request: impl tonic::IntoRequest<super::ListAppProfilesRequest>,
) -> std::result::Result<
tonic::Response<super::ListAppProfilesResponse>,
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.bigtable.admin.v2.BigtableInstanceAdmin/ListAppProfiles",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"ListAppProfiles",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_app_profile(
&mut self,
request: impl tonic::IntoRequest<super::UpdateAppProfileRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableInstanceAdmin/UpdateAppProfile",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"UpdateAppProfile",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_app_profile(
&mut self,
request: impl tonic::IntoRequest<super::DeleteAppProfileRequest>,
) -> std::result::Result<tonic::Response<()>, 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.bigtable.admin.v2.BigtableInstanceAdmin/DeleteAppProfile",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"DeleteAppProfile",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_iam_policy(
&mut self,
request: impl tonic::IntoRequest<
super::super::super::super::iam::v1::GetIamPolicyRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::super::super::iam::v1::Policy>,
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.bigtable.admin.v2.BigtableInstanceAdmin/GetIamPolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"GetIamPolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn set_iam_policy(
&mut self,
request: impl tonic::IntoRequest<
super::super::super::super::iam::v1::SetIamPolicyRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::super::super::iam::v1::Policy>,
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.bigtable.admin.v2.BigtableInstanceAdmin/SetIamPolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"SetIamPolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn test_iam_permissions(
&mut self,
request: impl tonic::IntoRequest<
super::super::super::super::iam::v1::TestIamPermissionsRequest,
>,
) -> std::result::Result<
tonic::Response<
super::super::super::super::iam::v1::TestIamPermissionsResponse,
>,
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.bigtable.admin.v2.BigtableInstanceAdmin/TestIamPermissions",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"TestIamPermissions",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_hot_tablets(
&mut self,
request: impl tonic::IntoRequest<super::ListHotTabletsRequest>,
) -> std::result::Result<
tonic::Response<super::ListHotTabletsResponse>,
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.bigtable.admin.v2.BigtableInstanceAdmin/ListHotTablets",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableInstanceAdmin",
"ListHotTablets",
),
);
self.inner.unary(req, path, codec).await
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RestoreTableRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub table_id: ::prost::alloc::string::String,
#[prost(oneof = "restore_table_request::Source", tags = "3")]
pub source: ::core::option::Option<restore_table_request::Source>,
}
pub mod restore_table_request {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Source {
#[prost(string, tag = "3")]
Backup(::prost::alloc::string::String),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RestoreTableMetadata {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(enumeration = "RestoreSourceType", tag = "2")]
pub source_type: i32,
#[prost(string, tag = "4")]
pub optimize_table_operation_name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "5")]
pub progress: ::core::option::Option<OperationProgress>,
#[prost(oneof = "restore_table_metadata::SourceInfo", tags = "3")]
pub source_info: ::core::option::Option<restore_table_metadata::SourceInfo>,
}
pub mod restore_table_metadata {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum SourceInfo {
#[prost(message, tag = "3")]
BackupInfo(super::BackupInfo),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OptimizeRestoredTableMetadata {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub progress: ::core::option::Option<OperationProgress>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateTableRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub table_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub table: ::core::option::Option<Table>,
#[prost(message, repeated, tag = "4")]
pub initial_splits: ::prost::alloc::vec::Vec<create_table_request::Split>,
}
pub mod create_table_request {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Split {
#[prost(bytes = "bytes", tag = "1")]
pub key: ::prost::bytes::Bytes,
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateTableFromSnapshotRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub table_id: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub source_snapshot: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DropRowRangeRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(oneof = "drop_row_range_request::Target", tags = "2, 3")]
pub target: ::core::option::Option<drop_row_range_request::Target>,
}
pub mod drop_row_range_request {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Target {
#[prost(bytes, tag = "2")]
RowKeyPrefix(::prost::bytes::Bytes),
#[prost(bool, tag = "3")]
DeleteAllDataFromTable(bool),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListTablesRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(enumeration = "table::View", tag = "2")]
pub view: i32,
#[prost(int32, tag = "4")]
pub page_size: i32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListTablesResponse {
#[prost(message, repeated, tag = "1")]
pub tables: ::prost::alloc::vec::Vec<Table>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetTableRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(enumeration = "table::View", tag = "2")]
pub view: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateTableRequest {
#[prost(message, optional, tag = "1")]
pub table: ::core::option::Option<Table>,
#[prost(message, optional, tag = "2")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateTableMetadata {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteTableRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UndeleteTableRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UndeleteTableMetadata {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ModifyColumnFamiliesRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub modifications: ::prost::alloc::vec::Vec<
modify_column_families_request::Modification,
>,
#[prost(bool, tag = "3")]
pub ignore_warnings: bool,
}
pub mod modify_column_families_request {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Modification {
#[prost(string, tag = "1")]
pub id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "6")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
#[prost(oneof = "modification::Mod", tags = "2, 3, 4")]
pub r#mod: ::core::option::Option<modification::Mod>,
}
pub mod modification {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Mod {
#[prost(message, tag = "2")]
Create(super::super::ColumnFamily),
#[prost(message, tag = "3")]
Update(super::super::ColumnFamily),
#[prost(bool, tag = "4")]
Drop(bool),
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GenerateConsistencyTokenRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GenerateConsistencyTokenResponse {
#[prost(string, tag = "1")]
pub consistency_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckConsistencyRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub consistency_token: ::prost::alloc::string::String,
#[prost(oneof = "check_consistency_request::Mode", tags = "3, 4")]
pub mode: ::core::option::Option<check_consistency_request::Mode>,
}
pub mod check_consistency_request {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Mode {
#[prost(message, tag = "3")]
StandardReadRemoteWrites(super::StandardReadRemoteWrites),
#[prost(message, tag = "4")]
DataBoostReadLocalWrites(super::DataBoostReadLocalWrites),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StandardReadRemoteWrites {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataBoostReadLocalWrites {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckConsistencyResponse {
#[prost(bool, tag = "1")]
pub consistent: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SnapshotTableRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub cluster: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub snapshot_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub ttl: ::core::option::Option<::prost_types::Duration>,
#[prost(string, tag = "5")]
pub description: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetSnapshotRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListSnapshotsRequest {
#[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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListSnapshotsResponse {
#[prost(message, repeated, tag = "1")]
pub snapshots: ::prost::alloc::vec::Vec<Snapshot>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteSnapshotRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SnapshotTableMetadata {
#[prost(message, optional, tag = "1")]
pub original_request: ::core::option::Option<SnapshotTableRequest>,
#[prost(message, optional, tag = "2")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateTableFromSnapshotMetadata {
#[prost(message, optional, tag = "1")]
pub original_request: ::core::option::Option<CreateTableFromSnapshotRequest>,
#[prost(message, optional, tag = "2")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateBackupRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub backup_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub backup: ::core::option::Option<Backup>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateBackupMetadata {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub source_table: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "4")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateBackupRequest {
#[prost(message, optional, tag = "1")]
pub backup: ::core::option::Option<Backup>,
#[prost(message, optional, tag = "2")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetBackupRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteBackupRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListBackupsRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub filter: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub order_by: ::prost::alloc::string::String,
#[prost(int32, tag = "4")]
pub page_size: i32,
#[prost(string, tag = "5")]
pub page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListBackupsResponse {
#[prost(message, repeated, tag = "1")]
pub backups: ::prost::alloc::vec::Vec<Backup>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CopyBackupRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub backup_id: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub source_backup: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub expire_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CopyBackupMetadata {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub source_backup_info: ::core::option::Option<BackupInfo>,
#[prost(message, optional, tag = "3")]
pub progress: ::core::option::Option<OperationProgress>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateAuthorizedViewRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub authorized_view_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub authorized_view: ::core::option::Option<AuthorizedView>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateAuthorizedViewMetadata {
#[prost(message, optional, tag = "1")]
pub original_request: ::core::option::Option<CreateAuthorizedViewRequest>,
#[prost(message, optional, tag = "2")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListAuthorizedViewsRequest {
#[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(enumeration = "authorized_view::ResponseView", tag = "4")]
pub view: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListAuthorizedViewsResponse {
#[prost(message, repeated, tag = "1")]
pub authorized_views: ::prost::alloc::vec::Vec<AuthorizedView>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAuthorizedViewRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(enumeration = "authorized_view::ResponseView", tag = "2")]
pub view: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateAuthorizedViewRequest {
#[prost(message, optional, tag = "1")]
pub authorized_view: ::core::option::Option<AuthorizedView>,
#[prost(message, optional, tag = "2")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
#[prost(bool, tag = "3")]
pub ignore_warnings: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateAuthorizedViewMetadata {
#[prost(message, optional, tag = "1")]
pub original_request: ::core::option::Option<UpdateAuthorizedViewRequest>,
#[prost(message, optional, tag = "2")]
pub request_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "3")]
pub finish_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteAuthorizedViewRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub etag: ::prost::alloc::string::String,
}
pub mod bigtable_table_admin_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct BigtableTableAdminClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> BigtableTableAdminClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<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_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> BigtableTableAdminClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
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,
{
BigtableTableAdminClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn create_table(
&mut self,
request: impl tonic::IntoRequest<super::CreateTableRequest>,
) -> std::result::Result<tonic::Response<super::Table>, 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.bigtable.admin.v2.BigtableTableAdmin/CreateTable",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"CreateTable",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_table_from_snapshot(
&mut self,
request: impl tonic::IntoRequest<super::CreateTableFromSnapshotRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/CreateTableFromSnapshot",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"CreateTableFromSnapshot",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_tables(
&mut self,
request: impl tonic::IntoRequest<super::ListTablesRequest>,
) -> std::result::Result<
tonic::Response<super::ListTablesResponse>,
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.bigtable.admin.v2.BigtableTableAdmin/ListTables",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"ListTables",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_table(
&mut self,
request: impl tonic::IntoRequest<super::GetTableRequest>,
) -> std::result::Result<tonic::Response<super::Table>, 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.bigtable.admin.v2.BigtableTableAdmin/GetTable",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"GetTable",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_table(
&mut self,
request: impl tonic::IntoRequest<super::UpdateTableRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/UpdateTable",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"UpdateTable",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_table(
&mut self,
request: impl tonic::IntoRequest<super::DeleteTableRequest>,
) -> std::result::Result<tonic::Response<()>, 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.bigtable.admin.v2.BigtableTableAdmin/DeleteTable",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"DeleteTable",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn undelete_table(
&mut self,
request: impl tonic::IntoRequest<super::UndeleteTableRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/UndeleteTable",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"UndeleteTable",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_authorized_view(
&mut self,
request: impl tonic::IntoRequest<super::CreateAuthorizedViewRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/CreateAuthorizedView",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"CreateAuthorizedView",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_authorized_views(
&mut self,
request: impl tonic::IntoRequest<super::ListAuthorizedViewsRequest>,
) -> std::result::Result<
tonic::Response<super::ListAuthorizedViewsResponse>,
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.bigtable.admin.v2.BigtableTableAdmin/ListAuthorizedViews",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"ListAuthorizedViews",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_authorized_view(
&mut self,
request: impl tonic::IntoRequest<super::GetAuthorizedViewRequest>,
) -> std::result::Result<tonic::Response<super::AuthorizedView>, 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.bigtable.admin.v2.BigtableTableAdmin/GetAuthorizedView",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"GetAuthorizedView",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_authorized_view(
&mut self,
request: impl tonic::IntoRequest<super::UpdateAuthorizedViewRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/UpdateAuthorizedView",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"UpdateAuthorizedView",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_authorized_view(
&mut self,
request: impl tonic::IntoRequest<super::DeleteAuthorizedViewRequest>,
) -> std::result::Result<tonic::Response<()>, 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.bigtable.admin.v2.BigtableTableAdmin/DeleteAuthorizedView",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"DeleteAuthorizedView",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn modify_column_families(
&mut self,
request: impl tonic::IntoRequest<super::ModifyColumnFamiliesRequest>,
) -> std::result::Result<tonic::Response<super::Table>, 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.bigtable.admin.v2.BigtableTableAdmin/ModifyColumnFamilies",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"ModifyColumnFamilies",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn drop_row_range(
&mut self,
request: impl tonic::IntoRequest<super::DropRowRangeRequest>,
) -> std::result::Result<tonic::Response<()>, 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.bigtable.admin.v2.BigtableTableAdmin/DropRowRange",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"DropRowRange",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn generate_consistency_token(
&mut self,
request: impl tonic::IntoRequest<super::GenerateConsistencyTokenRequest>,
) -> std::result::Result<
tonic::Response<super::GenerateConsistencyTokenResponse>,
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.bigtable.admin.v2.BigtableTableAdmin/GenerateConsistencyToken",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"GenerateConsistencyToken",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn check_consistency(
&mut self,
request: impl tonic::IntoRequest<super::CheckConsistencyRequest>,
) -> std::result::Result<
tonic::Response<super::CheckConsistencyResponse>,
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.bigtable.admin.v2.BigtableTableAdmin/CheckConsistency",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"CheckConsistency",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn snapshot_table(
&mut self,
request: impl tonic::IntoRequest<super::SnapshotTableRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/SnapshotTable",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"SnapshotTable",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_snapshot(
&mut self,
request: impl tonic::IntoRequest<super::GetSnapshotRequest>,
) -> std::result::Result<tonic::Response<super::Snapshot>, 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.bigtable.admin.v2.BigtableTableAdmin/GetSnapshot",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"GetSnapshot",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_snapshots(
&mut self,
request: impl tonic::IntoRequest<super::ListSnapshotsRequest>,
) -> std::result::Result<
tonic::Response<super::ListSnapshotsResponse>,
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.bigtable.admin.v2.BigtableTableAdmin/ListSnapshots",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"ListSnapshots",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_snapshot(
&mut self,
request: impl tonic::IntoRequest<super::DeleteSnapshotRequest>,
) -> std::result::Result<tonic::Response<()>, 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.bigtable.admin.v2.BigtableTableAdmin/DeleteSnapshot",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"DeleteSnapshot",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_backup(
&mut self,
request: impl tonic::IntoRequest<super::CreateBackupRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/CreateBackup",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"CreateBackup",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_backup(
&mut self,
request: impl tonic::IntoRequest<super::GetBackupRequest>,
) -> std::result::Result<tonic::Response<super::Backup>, 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.bigtable.admin.v2.BigtableTableAdmin/GetBackup",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"GetBackup",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_backup(
&mut self,
request: impl tonic::IntoRequest<super::UpdateBackupRequest>,
) -> std::result::Result<tonic::Response<super::Backup>, 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.bigtable.admin.v2.BigtableTableAdmin/UpdateBackup",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"UpdateBackup",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_backup(
&mut self,
request: impl tonic::IntoRequest<super::DeleteBackupRequest>,
) -> std::result::Result<tonic::Response<()>, 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.bigtable.admin.v2.BigtableTableAdmin/DeleteBackup",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"DeleteBackup",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_backups(
&mut self,
request: impl tonic::IntoRequest<super::ListBackupsRequest>,
) -> std::result::Result<
tonic::Response<super::ListBackupsResponse>,
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.bigtable.admin.v2.BigtableTableAdmin/ListBackups",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"ListBackups",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn restore_table(
&mut self,
request: impl tonic::IntoRequest<super::RestoreTableRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/RestoreTable",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"RestoreTable",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn copy_backup(
&mut self,
request: impl tonic::IntoRequest<super::CopyBackupRequest>,
) -> std::result::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.bigtable.admin.v2.BigtableTableAdmin/CopyBackup",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"CopyBackup",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_iam_policy(
&mut self,
request: impl tonic::IntoRequest<
super::super::super::super::iam::v1::GetIamPolicyRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::super::super::iam::v1::Policy>,
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.bigtable.admin.v2.BigtableTableAdmin/GetIamPolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"GetIamPolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn set_iam_policy(
&mut self,
request: impl tonic::IntoRequest<
super::super::super::super::iam::v1::SetIamPolicyRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::super::super::iam::v1::Policy>,
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.bigtable.admin.v2.BigtableTableAdmin/SetIamPolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"SetIamPolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn test_iam_permissions(
&mut self,
request: impl tonic::IntoRequest<
super::super::super::super::iam::v1::TestIamPermissionsRequest,
>,
) -> std::result::Result<
tonic::Response<
super::super::super::super::iam::v1::TestIamPermissionsResponse,
>,
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.bigtable.admin.v2.BigtableTableAdmin/TestIamPermissions",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.bigtable.admin.v2.BigtableTableAdmin",
"TestIamPermissions",
),
);
self.inner.unary(req, path, codec).await
}
}
}