dynomite/conf/

enums.rs

//! Typed enums for configuration values that arrive as free-form
//! strings or small integer codes.

use std::fmt;

use serde::de::{self, Deserializer, Visitor};
use serde::{Deserialize, Serialize};

use super::error::ConfError;

macro_rules! string_enum_serde {
    ($t:ty) => {
        impl Serialize for $t {
            fn serialize<S: serde::Serializer>(&self, ser: S) -> Result<S::Ok, S::Error> {
                ser.serialize_str(self.as_str())
            }
        }

        impl<'de> Deserialize<'de> for $t {
            fn deserialize<D: Deserializer<'de>>(de: D) -> Result<Self, D::Error> {
                struct V;
                impl Visitor<'_> for V {
                    type Value = $t;
                    fn expecting(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
                        f.write_str(concat!("a string naming a ", stringify!($t)))
                    }
                    fn visit_str<E: de::Error>(self, v: &str) -> Result<Self::Value, E> {
                        <$t>::parse(v).map_err(|e| E::custom(e.to_string()))
                    }
                    fn visit_string<E: de::Error>(self, v: String) -> Result<Self::Value, E> {
                        self.visit_str(&v)
                    }
                }
                de.deserialize_str(V)
            }
        }
    };
}

string_enum_serde!(SecureServerOption);
string_enum_serde!(HashType);
string_enum_serde!(Distribution);
string_enum_serde!(Transport);
string_enum_serde!(Membership);

/// Membership / failure-detection backend selected by the pool's
/// `membership:` directive.
///
/// `Gossip` is the historical default: Dynamo-style peer-state
/// dissemination with a phi-accrual failure detector
/// ([`crate::cluster::gossip`], [`crate::cluster::failure_detector`]).
/// `Swim` selects the opt-in SWIM + Lifeguard backend
/// ([`crate::cluster::swim`]), which trades all-to-all heartbeating
/// for a randomised probe with indirect (PING-REQ) probes,
/// incarnation-number refutation, and Lifeguard local health
/// awareness -- aimed at faster convergence and fewer false peer-down
/// verdicts as clusters grow and churn. SWIM is opt-in until the
/// large-scale churn data justifies making it the default.
///
/// # Examples
///
/// ```
/// use dynomite::conf::Membership;
/// assert_eq!(Membership::parse("gossip").unwrap(), Membership::Gossip);
/// assert_eq!(Membership::parse("swim").unwrap(), Membership::Swim);
/// assert_eq!(Membership::default(), Membership::Gossip);
/// ```
#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash, Default)]
pub enum Membership {
    /// Dynamo-style gossip plus phi-accrual. The historical
    /// default.
    #[default]
    Gossip,
    /// SWIM + Lifeguard probe-based membership. Opt-in.
    Swim,
}

impl Membership {
    /// Parse a `membership:` value (case-insensitive).
    ///
    /// # Errors
    /// Returns [`ConfError::BadServer`] when the value is not a
    /// recognised backend.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::Membership;
    /// assert_eq!(Membership::parse("SWIM").unwrap(), Membership::Swim);
    /// assert!(Membership::parse("raft").is_err());
    /// ```
    pub fn parse(s: &str) -> Result<Self, ConfError> {
        match s.to_ascii_lowercase().as_str() {
            "gossip" => Ok(Membership::Gossip),
            "swim" => Ok(Membership::Swim),
            other => Err(ConfError::BadServer {
                field: "membership",
                value: other.to_string(),
                reason: "membership must be 'gossip' or 'swim'".to_string(),
            }),
        }
    }

    /// Render back to the canonical YAML name.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::Membership;
    /// assert_eq!(Membership::Gossip.as_str(), "gossip");
    /// assert_eq!(Membership::Swim.as_str(), "swim");
    /// ```
    #[must_use]
    pub const fn as_str(self) -> &'static str {
        match self {
            Membership::Gossip => "gossip",
            Membership::Swim => "swim",
        }
    }
}

impl fmt::Display for Membership {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str(self.as_str())
    }
}

/// Transport selected by the pool's `transport:` directive.
///
/// Controls which network stack the proxy listener binds.
/// `Tcp` is the historical default and the only option a build
/// without the `quic` Cargo feature can satisfy.
///
/// # Examples
///
/// ```
/// use dynomite::conf::Transport;
/// assert_eq!(Transport::parse("tcp").unwrap(), Transport::Tcp);
/// assert_eq!(Transport::parse("quic").unwrap(), Transport::Quic);
/// assert_eq!(Transport::default(), Transport::Tcp);
/// ```
#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash, Default)]
pub enum Transport {
    /// TCP transport. The historical default and the only
    /// option compiled in when the `quic` Cargo feature is
    /// off.
    #[default]
    Tcp,
    /// QUIC transport. Requires the `quic` Cargo feature on
    /// the engine and a server cert / key pair supplied via
    /// the pool's `quic_cert_file:` and `quic_key_file:`
    /// directives.
    Quic,
}

impl Transport {
    /// Parse a `transport:` value (case-insensitive).
    ///
    /// # Errors
    /// Returns [`ConfError::BadServer`] when the value is
    /// not a recognised transport.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::Transport;
    /// assert_eq!(Transport::parse("TCP").unwrap(), Transport::Tcp);
    /// assert!(Transport::parse("http").is_err());
    /// ```
    pub fn parse(s: &str) -> Result<Self, ConfError> {
        match s.to_ascii_lowercase().as_str() {
            "tcp" => Ok(Transport::Tcp),
            "quic" => Ok(Transport::Quic),
            other => Err(ConfError::BadServer {
                field: "transport",
                value: other.to_string(),
                reason: "transport must be 'tcp' or 'quic'".to_string(),
            }),
        }
    }

    /// Render back to the canonical YAML name.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::Transport;
    /// assert_eq!(Transport::Tcp.as_str(), "tcp");
    /// assert_eq!(Transport::Quic.as_str(), "quic");
    /// ```
    #[must_use]
    pub const fn as_str(self) -> &'static str {
        match self {
            Transport::Tcp => "tcp",
            Transport::Quic => "quic",
        }
    }
}

impl fmt::Display for Transport {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str(self.as_str())
    }
}

/// Distribution algorithm selected by the pool's `distribution:`
/// directive.
///
/// `Vnode` is the historical default and was the only mode
/// supported until `RandomSlicing` was added. `Ketama`, `Modula`,
/// and `Random` are accepted for backward compatibility with the
/// older configuration vocabulary; they collapse to `Vnode` at
/// runtime and emit a deprecation warning at config-load time.
///
/// # Examples
///
/// ```
/// use dynomite::conf::Distribution;
/// assert_eq!(Distribution::parse("vnode").unwrap(), Distribution::Vnode);
/// assert_eq!(
///     Distribution::parse("random_slicing").unwrap(),
///     Distribution::RandomSlicing
/// );
/// ```
#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash, Default)]
pub enum Distribution {
    /// Per-rack continuum keyed by per-peer token lists. The
    /// historical default.
    #[default]
    Vnode,
    /// Compatibility alias; collapsed
    /// to [`Self::Vnode`] at runtime with a deprecation warning.
    Ketama,
    /// Compatibility alias; collapsed
    /// to [`Self::Vnode`] at runtime with a deprecation warning.
    Modula,
    /// Compatibility alias; collapsed
    /// to [`Self::Vnode`] at runtime with a deprecation warning.
    Random,
    /// Random-slicing distribution: a small, gap-free `(name,
    /// size)` partition table over the 64-bit hash space. See
    /// [`crate::hashkit::random_slicing`].
    RandomSlicing,
}

impl Distribution {
    /// Parse a `distribution:` value (case-insensitive).
    ///
    /// # Errors
    /// Returns [`ConfError::BadDistribution`] when the value is
    /// not a recognised mode.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::Distribution;
    /// assert_eq!(Distribution::parse("VNODE").unwrap(), Distribution::Vnode);
    /// assert!(Distribution::parse("sphere").is_err());
    /// ```
    pub fn parse(s: &str) -> Result<Self, ConfError> {
        Ok(match s.to_ascii_lowercase().as_str() {
            "vnode" => Distribution::Vnode,
            "ketama" => Distribution::Ketama,
            "modula" => Distribution::Modula,
            "random" => Distribution::Random,
            "random_slicing" | "random-slicing" => Distribution::RandomSlicing,
            _ => return Err(ConfError::BadDistribution(s.to_string())),
        })
    }

    /// Render back to the canonical YAML name.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::Distribution;
    /// assert_eq!(Distribution::Vnode.as_str(), "vnode");
    /// assert_eq!(Distribution::RandomSlicing.as_str(), "random_slicing");
    /// ```
    #[must_use]
    pub const fn as_str(self) -> &'static str {
        match self {
            Distribution::Vnode => "vnode",
            Distribution::Ketama => "ketama",
            Distribution::Modula => "modula",
            Distribution::Random => "random",
            Distribution::RandomSlicing => "random_slicing",
        }
    }

    /// True for the modes honoured directly; `Ketama`, `Modula`,
    /// and `Random` are accepted
    /// for backward compatibility but collapse to `Vnode` at
    /// runtime.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::Distribution;
    /// assert!(Distribution::Vnode.is_supported());
    /// assert!(Distribution::RandomSlicing.is_supported());
    /// assert!(!Distribution::Ketama.is_supported());
    /// ```
    #[must_use]
    pub const fn is_supported(self) -> bool {
        matches!(self, Distribution::Vnode | Distribution::RandomSlicing)
    }
}

impl fmt::Display for Distribution {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str(self.as_str())
    }
}

/// Datastore family selected by `data_store:`.
///
/// # Examples
///
/// ```
/// use dynomite::conf::DataStore;
/// assert_eq!(DataStore::from_int(0).unwrap(), DataStore::Valkey);
/// assert_eq!(DataStore::Valkey.as_int(), 0);
/// assert_eq!(DataStore::from_name("valkey").unwrap(), DataStore::Valkey);
/// assert_eq!(DataStore::from_name("dyniak").unwrap(), DataStore::Dyniak);
/// ```
#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash)]
pub enum DataStore {
    /// Valkey backend, spoken over RESP (the protocol Valkey
    /// speaks). Encoded as `0` in YAML. The historical name
    /// `redis` is accepted as a back-compat alias on the YAML
    /// side and maps to this variant.
    Valkey,
    /// Memcached ASCII datastore. Encoded as `1` in YAML.
    Memcache,
    /// In-process dyniak datastore (Riak-shaped, backed by a
    /// transactional Noxu environment). Encoded as `2` in YAML,
    /// or as the string `dyniak`. Selecting this variant
    /// requires `dynomited` to be built with `--features riak`
    /// and a sibling `noxu_path:` knob. A dyniak pool serves the
    /// Riak PBC / HTTP surface; it does not run a RESP client
    /// proxy.
    Dyniak,
}

impl DataStore {
    /// Parse a `data_store:` value as it appears in YAML.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::DataStore;
    /// assert_eq!(DataStore::from_int(1).unwrap(), DataStore::Memcache);
    /// assert_eq!(DataStore::from_int(2).unwrap(), DataStore::Dyniak);
    /// assert!(DataStore::from_int(7).is_err());
    /// ```
    pub fn from_int(v: i64) -> Result<Self, ConfError> {
        match v {
            0 => Ok(DataStore::Valkey),
            1 => Ok(DataStore::Memcache),
            2 => Ok(DataStore::Dyniak),
            n => Err(ConfError::BadDataStore(n)),
        }
    }

    /// Parse the textual form of a `data_store:` value, as
    /// accepted in YAML alongside the integer form.
    ///
    /// Comparison is case-insensitive. `valkey` is the canonical
    /// name for the RESP backend; `redis` is accepted as a
    /// back-compat alias for the same variant so configs written
    /// before the Valkey rename keep working. `memcache` and
    /// `memcached` select [`DataStore::Memcache`]; `dyniak`
    /// selects [`DataStore::Dyniak`].
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::DataStore;
    /// assert_eq!(DataStore::from_name("VALKEY").unwrap(), DataStore::Valkey);
    /// assert_eq!(DataStore::from_name("redis").unwrap(), DataStore::Valkey);
    /// assert!(DataStore::from_name("sql").is_err());
    /// ```
    pub fn from_name(s: &str) -> Result<Self, ConfError> {
        if s.eq_ignore_ascii_case("valkey") || s.eq_ignore_ascii_case("redis") {
            Ok(DataStore::Valkey)
        } else if s.eq_ignore_ascii_case("memcache") || s.eq_ignore_ascii_case("memcached") {
            Ok(DataStore::Memcache)
        } else if s.eq_ignore_ascii_case("dyniak") {
            Ok(DataStore::Dyniak)
        } else {
            Err(ConfError::BadDataStore(-1))
        }
    }

    /// Encode back to the small integer used in YAML.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::DataStore;
    /// assert_eq!(DataStore::Memcache.as_int(), 1);
    /// assert_eq!(DataStore::Dyniak.as_int(), 2);
    /// ```
    pub fn as_int(self) -> i64 {
        match self {
            DataStore::Valkey => 0,
            DataStore::Memcache => 1,
            DataStore::Dyniak => 2,
        }
    }

    /// Return the canonical lower-case textual name.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::DataStore;
    /// assert_eq!(DataStore::Valkey.as_name(), "valkey");
    /// assert_eq!(DataStore::Dyniak.as_name(), "dyniak");
    /// ```
    pub fn as_name(self) -> &'static str {
        match self {
            DataStore::Valkey => "valkey",
            DataStore::Memcache => "memcache",
            DataStore::Dyniak => "dyniak",
        }
    }
}

/// Inter-node security mode selected by `secure_server_option:`.
///
/// # Examples
///
/// ```
/// use dynomite::conf::SecureServerOption;
/// assert_eq!(
///     SecureServerOption::parse("datacenter").unwrap(),
///     SecureServerOption::Datacenter,
/// );
/// ```
#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash)]
pub enum SecureServerOption {
    /// No inter-node TLS.
    None,
    /// TLS only between racks (within a DC).
    Rack,
    /// TLS only between datacenters.
    Datacenter,
    /// TLS between all nodes.
    All,
}

impl SecureServerOption {
    /// Parse a `secure_server_option:` value, case-sensitively.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::SecureServerOption;
    /// assert_eq!(SecureServerOption::parse("none").unwrap(), SecureServerOption::None);
    /// assert!(SecureServerOption::parse("NONE").is_err());
    /// ```
    pub fn parse(s: &str) -> Result<Self, ConfError> {
        match s {
            "none" => Ok(SecureServerOption::None),
            "rack" => Ok(SecureServerOption::Rack),
            "datacenter" => Ok(SecureServerOption::Datacenter),
            "all" => Ok(SecureServerOption::All),
            other => Err(ConfError::BadSecure(other.to_string())),
        }
    }

    /// Render back to the YAML string form.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::SecureServerOption;
    /// assert_eq!(SecureServerOption::All.as_str(), "all");
    /// ```
    pub fn as_str(self) -> &'static str {
        match self {
            SecureServerOption::None => "none",
            SecureServerOption::Rack => "rack",
            SecureServerOption::Datacenter => "datacenter",
            SecureServerOption::All => "all",
        }
    }
}

impl fmt::Display for SecureServerOption {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str(self.as_str())
    }
}

/// Quorum policy for read or write paths.
///
/// # Examples
///
/// ```
/// use dynomite::conf::ConsistencyLevel;
/// let lvl = ConsistencyLevel::parse("read_consistency", "DC_QUORUM").unwrap();
/// assert_eq!(lvl, ConsistencyLevel::DcQuorum);
/// ```
#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash)]
pub enum ConsistencyLevel {
    /// Single replica acknowledgement.
    DcOne,
    /// Majority within a single datacenter.
    DcQuorum,
    /// Majority within a single datacenter with checksum repair.
    DcSafeQuorum,
    /// Majority within every datacenter, with checksum repair.
    DcEachSafeQuorum,
}

impl ConsistencyLevel {
    /// Parse a `read_consistency` or `write_consistency` value.
    ///
    /// Comparison is case-insensitive against the canonical names
    /// `DC_ONE`, `DC_QUORUM`, `DC_SAFE_QUORUM`, and
    /// `DC_EACH_SAFE_QUORUM`.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::ConsistencyLevel;
    /// assert_eq!(
    ///     ConsistencyLevel::parse("read_consistency", "dc_one").unwrap(),
    ///     ConsistencyLevel::DcOne,
    /// );
    /// assert!(ConsistencyLevel::parse("read_consistency", "nope").is_err());
    /// ```
    pub fn parse(field: &'static str, s: &str) -> Result<Self, ConfError> {
        if s.eq_ignore_ascii_case("dc_one") {
            Ok(ConsistencyLevel::DcOne)
        } else if s.eq_ignore_ascii_case("dc_quorum") {
            Ok(ConsistencyLevel::DcQuorum)
        } else if s.eq_ignore_ascii_case("dc_safe_quorum") {
            Ok(ConsistencyLevel::DcSafeQuorum)
        } else if s.eq_ignore_ascii_case("dc_each_safe_quorum") {
            Ok(ConsistencyLevel::DcEachSafeQuorum)
        } else {
            Err(ConfError::BadConsistency {
                field,
                value: s.to_string(),
            })
        }
    }

    /// Render back to the canonical YAML name.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::ConsistencyLevel;
    /// assert_eq!(ConsistencyLevel::DcSafeQuorum.as_str(), "DC_SAFE_QUORUM");
    /// ```
    pub fn as_str(self) -> &'static str {
        match self {
            ConsistencyLevel::DcOne => "DC_ONE",
            ConsistencyLevel::DcQuorum => "DC_QUORUM",
            ConsistencyLevel::DcSafeQuorum => "DC_SAFE_QUORUM",
            ConsistencyLevel::DcEachSafeQuorum => "DC_EACH_SAFE_QUORUM",
        }
    }
}

impl fmt::Display for ConsistencyLevel {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str(self.as_str())
    }
}

/// Hash algorithm selected by `hash:`.
///
/// The names mirror the algorithm tags accepted by the YAML parser.
/// The [`crate::hashkit`] module owns the hashing math; this enum
/// models only the configured choice so the parser can echo it back
/// without depending on the
/// hashkit module.
///
/// # Examples
///
/// ```
/// use dynomite::conf::HashType;
/// assert_eq!(HashType::parse("murmur3").unwrap(), HashType::Murmur3);
/// assert_eq!(HashType::Md5.as_str(), "md5");
/// ```
#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash)]
pub enum HashType {
    /// One-at-a-time hash.
    OneAtATime,
    /// MD5 (truncated for ketama).
    Md5,
    /// CRC-16.
    Crc16,
    /// CRC-32.
    Crc32,
    /// CRC-32 ARM.
    Crc32a,
    /// 64-bit FNV-1.
    Fnv1_64,
    /// 64-bit FNV-1a.
    Fnv1a64,
    /// 32-bit FNV-1.
    Fnv1_32,
    /// 32-bit FNV-1a.
    Fnv1a32,
    /// Paul Hsieh's hash.
    Hsieh,
    /// Murmur hash (32-bit, version 1).
    Murmur,
    /// Bob Jenkins's hash.
    Jenkins,
    /// Murmur hash 3 (128-bit).
    Murmur3,
    /// MurmurHash3 truncated to 64 bits (used by random
    /// slicing).
    #[allow(non_camel_case_types)]
    Murmur3X64_64,
}

impl HashType {
    /// Parse a `hash:` value (case-sensitive).
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::HashType;
    /// assert_eq!(HashType::parse("fnv1a_64").unwrap(), HashType::Fnv1a64);
    /// assert!(HashType::parse("FNV1A_64").is_err());
    /// ```
    pub fn parse(s: &str) -> Result<Self, ConfError> {
        Ok(match s {
            "one_at_a_time" => HashType::OneAtATime,
            "md5" => HashType::Md5,
            "crc16" => HashType::Crc16,
            "crc32" => HashType::Crc32,
            "crc32a" => HashType::Crc32a,
            "fnv1_64" => HashType::Fnv1_64,
            "fnv1a_64" => HashType::Fnv1a64,
            "fnv1_32" => HashType::Fnv1_32,
            "fnv1a_32" => HashType::Fnv1a32,
            "hsieh" => HashType::Hsieh,
            "murmur" => HashType::Murmur,
            "jenkins" => HashType::Jenkins,
            "murmur3" => HashType::Murmur3,
            "murmur3_x64_64" => HashType::Murmur3X64_64,
            other => return Err(ConfError::BadHash(other.to_string())),
        })
    }

    /// Render back to the canonical YAML name.
    ///
    /// # Examples
    ///
    /// ```
    /// use dynomite::conf::HashType;
    /// assert_eq!(HashType::Crc32a.as_str(), "crc32a");
    /// ```
    pub fn as_str(self) -> &'static str {
        match self {
            HashType::OneAtATime => "one_at_a_time",
            HashType::Md5 => "md5",
            HashType::Crc16 => "crc16",
            HashType::Crc32 => "crc32",
            HashType::Crc32a => "crc32a",
            HashType::Fnv1_64 => "fnv1_64",
            HashType::Fnv1a64 => "fnv1a_64",
            HashType::Fnv1_32 => "fnv1_32",
            HashType::Fnv1a32 => "fnv1a_32",
            HashType::Hsieh => "hsieh",
            HashType::Murmur => "murmur",
            HashType::Jenkins => "jenkins",
            HashType::Murmur3 => "murmur3",
            HashType::Murmur3X64_64 => "murmur3_x64_64",
        }
    }
}

impl fmt::Display for HashType {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str(self.as_str())
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn data_store_round_trip() {
        assert_eq!(DataStore::from_int(0).unwrap(), DataStore::Valkey);
        assert_eq!(DataStore::from_int(1).unwrap(), DataStore::Memcache);
        assert_eq!(DataStore::from_int(2).unwrap(), DataStore::Dyniak);
        assert!(matches!(
            DataStore::from_int(7),
            Err(ConfError::BadDataStore(7))
        ));
        assert_eq!(DataStore::from_name("dyniak").unwrap(), DataStore::Dyniak);
        assert_eq!(DataStore::from_name("VALKEY").unwrap(), DataStore::Valkey);
        // `redis` stays accepted as a back-compat alias for the
        // Valkey variant so pre-rename configs keep loading.
        assert_eq!(DataStore::from_name("redis").unwrap(), DataStore::Valkey);
        assert!(DataStore::from_name("sql").is_err());
        assert_eq!(DataStore::Valkey.as_name(), "valkey");
        assert_eq!(DataStore::Dyniak.as_name(), "dyniak");
    }

    #[test]
    fn secure_round_trip() {
        for s in ["none", "rack", "datacenter", "all"] {
            assert_eq!(SecureServerOption::parse(s).unwrap().as_str(), s);
        }
        assert!(SecureServerOption::parse("nope").is_err());
    }

    #[test]
    fn consistency_case_insensitive() {
        assert_eq!(
            ConsistencyLevel::parse("read_consistency", "dc_one").unwrap(),
            ConsistencyLevel::DcOne
        );
        assert_eq!(
            ConsistencyLevel::parse("read_consistency", "DC_SAFE_QUORUM").unwrap(),
            ConsistencyLevel::DcSafeQuorum
        );
        assert!(ConsistencyLevel::parse("read_consistency", "garbage").is_err());
    }

    #[test]
    fn hash_round_trip() {
        for &name in &[
            "one_at_a_time",
            "md5",
            "crc16",
            "crc32",
            "crc32a",
            "fnv1_64",
            "fnv1a_64",
            "fnv1_32",
            "fnv1a_32",
            "hsieh",
            "murmur",
            "jenkins",
            "murmur3",
            "murmur3_x64_64",
        ] {
            assert_eq!(HashType::parse(name).unwrap().as_str(), name);
        }
    }

    #[test]
    fn distribution_round_trip() {
        for &name in &["vnode", "ketama", "modula", "random", "random_slicing"] {
            assert_eq!(Distribution::parse(name).unwrap().as_str(), name);
        }
        // Case-insensitive parse for back-compat with the C
        // reference, which accepts upper-case.
        assert_eq!(Distribution::parse("VNODE").unwrap(), Distribution::Vnode);
        // Hyphenated alias accepted.
        assert_eq!(
            Distribution::parse("random-slicing").unwrap(),
            Distribution::RandomSlicing
        );
        assert!(matches!(
            Distribution::parse("sphere"),
            Err(ConfError::BadDistribution(_))
        ));
        assert!(Distribution::Vnode.is_supported());
        assert!(Distribution::RandomSlicing.is_supported());
        assert!(!Distribution::Ketama.is_supported());
    }

    #[test]
    fn distribution_default_is_vnode() {
        assert_eq!(Distribution::default(), Distribution::Vnode);
    }

    #[test]
    fn distribution_yaml_round_trip() {
        // Serialise via serde, then parse back.
        let raw = serde_yaml::to_string(&Distribution::RandomSlicing).unwrap();
        let parsed: Distribution = serde_yaml::from_str(&raw).unwrap();
        assert_eq!(parsed, Distribution::RandomSlicing);
    }

    #[test]
    fn transport_round_trip() {
        for &name in &["tcp", "quic"] {
            assert_eq!(Transport::parse(name).unwrap().as_str(), name);
        }
        // Case-insensitive parse.
        assert_eq!(Transport::parse("QUIC").unwrap(), Transport::Quic);
        assert_eq!(Transport::parse("Tcp").unwrap(), Transport::Tcp);
        assert!(Transport::parse("http").is_err());
    }

    #[test]
    fn transport_default_is_tcp() {
        assert_eq!(Transport::default(), Transport::Tcp);
    }

    #[test]
    fn transport_yaml_round_trip() {
        let raw = serde_yaml::to_string(&Transport::Quic).unwrap();
        let parsed: Transport = serde_yaml::from_str(&raw).unwrap();
        assert_eq!(parsed, Transport::Quic);
    }

    #[test]
    fn membership_round_trip() {
        for &name in &["gossip", "swim"] {
            assert_eq!(Membership::parse(name).unwrap().as_str(), name);
        }
        // Case-insensitive parse.
        assert_eq!(Membership::parse("SWIM").unwrap(), Membership::Swim);
        assert_eq!(Membership::parse("Gossip").unwrap(), Membership::Gossip);
        assert!(Membership::parse("raft").is_err());
    }

    #[test]
    fn membership_default_is_gossip() {
        assert_eq!(Membership::default(), Membership::Gossip);
    }

    #[test]
    fn membership_yaml_round_trip() {
        let raw = serde_yaml::to_string(&Membership::Swim).unwrap();
        let parsed: Membership = serde_yaml::from_str(&raw).unwrap();
        assert_eq!(parsed, Membership::Swim);
    }
}