Struct quilkin::xds::config::cluster::v3::Cluster

pub struct Cluster {

    pub transport_socket_matches: Vec<TransportSocketMatch>,
    pub name: String,
    pub alt_stat_name: String,
    pub eds_cluster_config: Option<EdsClusterConfig>,
    pub connect_timeout: Option<Duration>,
    pub per_connection_buffer_limit_bytes: Option<u32>,
    pub lb_policy: i32,
    pub load_assignment: Option<ClusterLoadAssignment>,
    pub health_checks: Vec<HealthCheck>,
    pub max_requests_per_connection: Option<u32>,
    pub circuit_breakers: Option<CircuitBreakers>,
    pub upstream_http_protocol_options: Option<UpstreamHttpProtocolOptions>,
    pub common_http_protocol_options: Option<HttpProtocolOptions>,
    pub http_protocol_options: Option<Http1ProtocolOptions>,
    pub http2_protocol_options: Option<Http2ProtocolOptions>,
    pub typed_extension_protocol_options: HashMap<String, Any>,
    pub dns_refresh_rate: Option<Duration>,
    pub dns_failure_refresh_rate: Option<RefreshRate>,
    pub respect_dns_ttl: bool,
    pub dns_lookup_family: i32,
    pub dns_resolvers: Vec<Address>,
    pub use_tcp_for_dns_lookups: bool,
    pub dns_resolution_config: Option<DnsResolutionConfig>,
    pub typed_dns_resolver_config: Option<TypedExtensionConfig>,
    pub wait_for_warm_on_init: Option<bool>,
    pub outlier_detection: Option<OutlierDetection>,
    pub cleanup_interval: Option<Duration>,
    pub upstream_bind_config: Option<BindConfig>,
    pub lb_subset_config: Option<LbSubsetConfig>,
    pub common_lb_config: Option<CommonLbConfig>,
    pub transport_socket: Option<TransportSocket>,
    pub metadata: Option<Metadata>,
    pub protocol_selection: i32,
    pub upstream_connection_options: Option<UpstreamConnectionOptions>,
    pub close_connections_on_host_health_failure: bool,
    pub ignore_health_on_host_removal: bool,
    pub filters: Vec<Filter>,
    pub load_balancing_policy: Option<LoadBalancingPolicy>,
    pub lrs_server: Option<ConfigSource>,
    pub track_timeout_budgets: bool,
    pub upstream_config: Option<TypedExtensionConfig>,
    pub track_cluster_stats: Option<TrackClusterStats>,
    pub preconnect_policy: Option<PreconnectPolicy>,
    pub connection_pool_per_downstream_connection: bool,
    pub cluster_discovery_type: Option<ClusterDiscoveryType>,
    pub lb_config: Option<LbConfig>,
}

Fields

transport_socket_matches: Vec<TransportSocketMatch>

name: String

alt_stat_name: String

eds_cluster_config: Option<EdsClusterConfig>

connect_timeout: Option<Duration>

per_connection_buffer_limit_bytes: Option<u32>

lb_policy: i32

load_assignment: Option<ClusterLoadAssignment>

health_checks: Vec<HealthCheck>

max_requests_per_connection: Option<u32>

👎Deprecated

circuit_breakers: Option<CircuitBreakers>

upstream_http_protocol_options: Option<UpstreamHttpProtocolOptions>

👎Deprecated

common_http_protocol_options: Option<HttpProtocolOptions>

👎Deprecated

http_protocol_options: Option<Http1ProtocolOptions>

👎Deprecated

http2_protocol_options: Option<Http2ProtocolOptions>

👎Deprecated

typed_extension_protocol_options: HashMap<String, Any>

dns_refresh_rate: Option<Duration>

dns_failure_refresh_rate: Option<RefreshRate>

respect_dns_ttl: bool

dns_lookup_family: i32

dns_resolvers: Vec<Address>

👎Deprecated

use_tcp_for_dns_lookups: bool

👎Deprecated

dns_resolution_config: Option<DnsResolutionConfig>

👎Deprecated

typed_dns_resolver_config: Option<TypedExtensionConfig>

wait_for_warm_on_init: Option<bool>

outlier_detection: Option<OutlierDetection>

cleanup_interval: Option<Duration>

upstream_bind_config: Option<BindConfig>

lb_subset_config: Option<LbSubsetConfig>

common_lb_config: Option<CommonLbConfig>

transport_socket: Option<TransportSocket>

metadata: Option<Metadata>

protocol_selection: i32

👎Deprecated

upstream_connection_options: Option<UpstreamConnectionOptions>

close_connections_on_host_health_failure: bool

ignore_health_on_host_removal: bool

filters: Vec<Filter>

load_balancing_policy: Option<LoadBalancingPolicy>

lrs_server: Option<ConfigSource>

track_timeout_budgets: bool

👎Deprecated

upstream_config: Option<TypedExtensionConfig>

track_cluster_stats: Option<TrackClusterStats>

preconnect_policy: Option<PreconnectPolicy>

connection_pool_per_downstream_connection: bool

cluster_discovery_type: Option<ClusterDiscoveryType>

lb_config: Option<LbConfig>

Implementations

impl Cluster

pub fn lb_policy(&self) -> LbPolicy

Returns the enum value of lb_policy, or the default if the field is set to an invalid enum value.

pub fn set_lb_policy(&mut self, value: LbPolicy)

Sets lb_policy to the provided enum value.

pub fn dns_lookup_family(&self) -> DnsLookupFamily

Returns the enum value of dns_lookup_family, or the default if the field is set to an invalid enum value.

pub fn set_dns_lookup_family(&mut self, value: DnsLookupFamily)

Sets dns_lookup_family to the provided enum value.

pub fn protocol_selection(&self) -> ClusterProtocolSelection

Returns the enum value of protocol_selection, or the default if the field is set to an invalid enum value.

pub fn set_protocol_selection(&mut self, value: ClusterProtocolSelection)

Sets protocol_selection to the provided enum value.

Trait Implementations

impl Clone for Cluster

fn clone(&self) -> Cluster

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Cluster

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Cluster

fn default() -> Self

Returns the “default value” for a type.

impl Message for Cluster

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
    B: BufMut,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8, Global>

Encodes the message to a newly allocated buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
    B: BufMut,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8, Global>

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError>where
    B: Buf,
    Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>where
    B: Buf,
    Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>where
    B: Buf,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>where
    B: Buf,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq<Cluster> for Cluster

fn eq(&self, other: &Cluster) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Cluster