Struct mz_balancerd::BalancerConfig
source · pub struct BalancerConfig {Show 18 fields
pub(crate) build_version: Version,
pub(crate) internal_http_listen_addr: SocketAddr,
pub(crate) pgwire_listen_addr: SocketAddr,
pub(crate) https_listen_addr: SocketAddr,
pub(crate) cancellation_resolver_dir: Option<PathBuf>,
pub(crate) resolver: Resolver,
pub(crate) https_addr_template: String,
pub(crate) tls: Option<TlsCertConfig>,
pub(crate) internal_tls: bool,
pub(crate) metrics_registry: MetricsRegistry,
pub(crate) reload_certs: BoxStream<'static, Option<Sender<Result<(), Error>>>>,
pub(crate) launchdarkly_sdk_key: Option<String>,
pub(crate) config_sync_timeout: Duration,
pub(crate) config_sync_loop_interval: Option<Duration>,
pub(crate) cloud_provider: Option<String>,
pub(crate) cloud_provider_region: Option<String>,
pub(crate) tracing_handle: TracingHandle,
pub(crate) default_configs: Vec<(String, String)>,
}
Fields§
§build_version: Version
Info about which version of the code is running.
internal_http_listen_addr: SocketAddr
Listen address for internal HTTP health and metrics server.
pgwire_listen_addr: SocketAddr
Listen address for pgwire connections.
https_listen_addr: SocketAddr
Listen address for HTTPS connections.
cancellation_resolver_dir: Option<PathBuf>
Cancellation resolver configmap directory.
resolver: Resolver
DNS resolver.
https_addr_template: String
§tls: Option<TlsCertConfig>
§internal_tls: bool
§metrics_registry: MetricsRegistry
§reload_certs: BoxStream<'static, Option<Sender<Result<(), Error>>>>
§launchdarkly_sdk_key: Option<String>
§config_sync_timeout: Duration
§config_sync_loop_interval: Option<Duration>
§cloud_provider: Option<String>
§cloud_provider_region: Option<String>
§tracing_handle: TracingHandle
§default_configs: Vec<(String, String)>
Implementations§
source§impl BalancerConfig
impl BalancerConfig
pub fn new( build_info: &BuildInfo, internal_http_listen_addr: SocketAddr, pgwire_listen_addr: SocketAddr, https_listen_addr: SocketAddr, cancellation_resolver_dir: Option<PathBuf>, resolver: Resolver, https_addr_template: String, tls: Option<TlsCertConfig>, internal_tls: bool, metrics_registry: MetricsRegistry, reload_certs: ReloadTrigger, launchdarkly_sdk_key: Option<String>, config_sync_timeout: Duration, config_sync_loop_interval: Option<Duration>, cloud_provider: Option<String>, cloud_provider_region: Option<String>, tracing_handle: TracingHandle, default_configs: Vec<(String, String)>, ) -> Self
Auto Trait Implementations§
impl Freeze for BalancerConfig
impl !RefUnwindSafe for BalancerConfig
impl Send for BalancerConfig
impl !Sync for BalancerConfig
impl Unpin for BalancerConfig
impl !UnwindSafe for BalancerConfig
Blanket Implementations§
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
Mutably borrows from an owned value. Read more
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<Source, Target> OctetsInto<Target> for Sourcewhere
Target: OctetsFrom<Source>,
impl<Source, Target> OctetsInto<Target> for Sourcewhere
Target: OctetsFrom<Source>,
type Error = <Target as OctetsFrom<Source>>::Error
source§fn try_octets_into(
self,
) -> Result<Target, <Source as OctetsInto<Target>>::Error>
fn try_octets_into( self, ) -> Result<Target, <Source as OctetsInto<Target>>::Error>
Performs the conversion.
source§fn octets_into(self) -> Target
fn octets_into(self) -> Target
Performs an infallible conversion.
source§impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.