Struct quilkin::net::cluster::ClusterMap

pub struct ClusterMap<S = RandomState> { /* private fields */ }

Represents a full snapshot of all clusters.

Implementations

impl ClusterMap<RandomState>

pub fn new() -> Self

pub fn new_default(cluster: BTreeSet<Endpoint>) -> Self

impl<S> ClusterMap<S>

pub fn version(&self) -> u64

impl<S> ClusterMap<S>

where S: Default + BuildHasher + Clone,

pub fn benchmarking(capacity: usize, hasher: S) -> Self

pub fn insert( &self, locality: Option<Locality>, cluster: BTreeSet<Endpoint> ) -> Option<BTreeSet<Endpoint>>

pub fn apply( &self, locality: Option<Locality>, cluster: EndpointSet ) -> Option<BTreeSet<Endpoint>>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn get( &self, key: &Option<Locality> ) -> Option<Ref<'_, Option<Locality>, EndpointSet, S>>

pub fn get_mut( &self, key: &Option<Locality> ) -> Option<RefMut<'_, Option<Locality>, EndpointSet, S>>

pub fn get_default(&self) -> Option<Ref<'_, Option<Locality>, EndpointSet, S>>

pub fn get_default_mut( &self ) -> Option<RefMut<'_, Option<Locality>, EndpointSet, S>>

pub fn insert_default(&self, endpoints: BTreeSet<Endpoint>)

pub fn remove_endpoint(&self, needle: &Endpoint) -> bool

pub fn remove_endpoint_if(&self, closure: impl Fn(&Endpoint) -> bool) -> bool

pub fn iter(&self) -> Iter<'_, Option<Locality>, EndpointSet, S>

pub fn entry( &self, key: Option<Locality> ) -> Entry<'_, Option<Locality>, EndpointSet, S>

pub fn replace( &self, locality: Option<Locality>, endpoint: Endpoint ) -> Option<Endpoint>

pub fn endpoints(&self) -> Vec<Endpoint>

pub fn nth_endpoint(&self, index: usize) -> Option<Endpoint>

pub fn filter_endpoints(&self, f: impl Fn(&Endpoint) -> bool) -> Vec<Endpoint>

pub fn num_of_endpoints(&self) -> usize

pub fn has_endpoints(&self) -> bool

pub fn update_unlocated_endpoints(&self, locality: Locality)

pub fn remove_locality( &self, locality: &Option<Locality> ) -> Option<EndpointSet>

Trait Implementations

impl Clone for ClusterMap

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S> Debug for ClusterMap<S>

where S: Default + BuildHasher + Clone,

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

Formats the value using the given formatter.

impl<S> Default for ClusterMap<S>

where S: Default + BuildHasher + Clone,

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ClusterMap

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<S> From<ClusterMapDeser> for ClusterMap<S>

where S: Default + BuildHasher + Clone,

fn from(cmd: ClusterMapDeser) -> Self

Converts to this type from the input type.

impl<S> From<DashMap<Option<Locality>, EndpointSet, S>> for ClusterMap<S>

where S: Default + BuildHasher + Clone,

fn from(map: DashMap<Option<Locality>, EndpointSet, S>) -> Self

Converts to this type from the input type.

impl JsonSchema for ClusterMap

fn schema_name() -> String

The name of the generated JSON Schema.

fn json_schema(gen: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn is_referenceable() -> bool

Whether JSON Schemas generated for this type should be re-used where possible using the $ref keyword.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

impl Serialize for ClusterMap

fn serialize<S>(&self, ser: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.

impl<S> Watchable for ClusterMap<S>

fn mark(&self) -> Marker

fn has_changed(&self, marker: Marker) -> bool