Struct PersistencePolicies 

pub struct PersistencePolicies {
    pub bookkeeper_ensemble: i32,
    pub bookkeeper_write_quorum: i32,
    pub bookkeeper_ack_quorum: i32,
    pub managed_ledger_max_mark_delete_rate: f64,
}

Java PersistencePolicies — namespace-level BookKeeper layout + managed-ledger write-shaping knobs. Maps to the broker’s org.apache.pulsar.common.policies.data.PersistencePolicies.

Default::default() returns the broker’s documented default for a new namespace (2/2/2/0.0), NOT all zeros — the broker rejects ensemble values < 1 on set, so an all-zero policy is unusable for a round-trip. Missing fields on decode default the same way: a partial body where the broker omits one field round-trips with the legal default, never with the illegal 0.

Fields

bookkeeper_ensemble: i32

BookKeeper ensemble size — the number of bookies the managed ledger striping is spread across. Default: 2.

bookkeeper_write_quorum: i32

BookKeeper write quorum — the number of bookies each entry is written to. Default: 2.

bookkeeper_ack_quorum: i32

BookKeeper ack quorum — the number of acks required before an add is considered durable. Default: 2.

managed_ledger_max_mark_delete_rate: f64

Managed-ledger mark-delete-rate cap (ops/sec). 0.0 disables the throttle. Default: 0.0 (disabled).

Trait Implementations

impl Clone for PersistencePolicies

fn clone(&self) -> PersistencePolicies

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PersistencePolicies

impl Debug for PersistencePolicies

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

Formats the value using the given formatter.

impl Default for PersistencePolicies

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PersistencePolicies

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PersistencePolicies

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.