pub struct BigTableDbSettings {Show 17 fields
pub table_name: String,
pub app_profile_id: String,
pub router_family: String,
pub message_family: String,
pub message_topic_family: String,
pub database_pool_max_size: Option<u32>,
pub grpc_channel_count: Option<u32>,
pub database_pool_create_timeout: Option<Duration>,
pub database_pool_wait_timeout: Option<Duration>,
pub grpc_connect_timeout: Duration,
pub grpc_point_attempt_timeout: Duration,
pub grpc_scan_attempt_timeout: Duration,
pub grpc_point_total_timeout: Duration,
pub grpc_scan_total_timeout: Duration,
pub route_to_leader: bool,
pub retry_count: usize,
pub max_router_ttl: Option<Duration>,
}Expand description
The settings for accessing the BigTable contents.
Fields§
§table_name: StringThe Table name matches the GRPC template for table paths.
e.g. projects/{projectid}/instances/{instanceid}/tables/{tablename}
NOTE There is no leading /
By default, this (may?) use the * variant which translates to
projects/*/instances/*/tables/* which searches all data stored in
bigtable.
app_profile_id: StringRouting replication profile id.
Should be used everywhere we set table_name when creating requests
router_family: String§message_family: String§message_topic_family: String§database_pool_max_size: Option<u32>§grpc_channel_count: Option<u32>Number of shared tonic channels used for Bigtable RPCs. Defaults to four.
Size it from peak concurrent operations for this workload on one pod,
rather than from the maximum logical operation-pool size. See
DEFAULT_GRPC_CHANNEL_COUNT for the arithmetic and its caveats.
database_pool_create_timeout: Option<Duration>Max time (in seconds) to create a pooled client handle.
database_pool_wait_timeout: Option<Duration>Max time (in seconds) to wait for a logical operation slot.
grpc_connect_timeout: DurationMax time (in seconds) for DNS, TCP, and TLS connection establishment.
grpc_point_attempt_timeout: DurationPer-attempt deadline (in seconds) for point reads and writes.
grpc_scan_attempt_timeout: DurationPer-attempt deadline (in seconds) for message range scans.
grpc_point_total_timeout: DurationEnd-to-end retry budget (in seconds) for point reads and writes.
grpc_scan_total_timeout: DurationEnd-to-end retry budget (in seconds) for message range scans.
route_to_leader: boolInclude route to leader header in metadata
retry_count: usizeNumber of retries after the initial gRPC data operation. Defaults to two. Health checks use this same configured value.
max_router_ttl: Option<Duration>Max lifetime (in seconds) for a router entry
Implementations§
Source§impl BigTableDbSettings
impl BigTableDbSettings
pub fn metadata(&self) -> Result<MetadataMap, BigTableError>
pub fn get_instance_name(&self) -> Result<String, BigTableError>
Trait Implementations§
Source§impl Clone for BigTableDbSettings
impl Clone for BigTableDbSettings
Source§fn clone(&self) -> BigTableDbSettings
fn clone(&self) -> BigTableDbSettings
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for BigTableDbSettings
impl Debug for BigTableDbSettings
Source§impl<'de> Deserialize<'de> for BigTableDbSettings
impl<'de> Deserialize<'de> for BigTableDbSettings
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Auto Trait Implementations§
impl Freeze for BigTableDbSettings
impl RefUnwindSafe for BigTableDbSettings
impl Send for BigTableDbSettings
impl Sync for BigTableDbSettings
impl Unpin for BigTableDbSettings
impl UnsafeUnpin for BigTableDbSettings
impl UnwindSafe for BigTableDbSettings
Blanket Implementations§
§impl<T> AnySync for T
impl<T> AnySync for T
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Layered].