Enum eventstore::SystemConsumerStrategy

pub enum SystemConsumerStrategy {
    DispatchToSingle,
    RoundRobin,
    Pinned,
}

System supported consumer strategies for use with persistent subscriptions.

Variants

DispatchToSingle

Distributes events to a single client until the bufferSize is reached. After which the next client is selected in a round robin style, and the process is repeated.

RoundRobin

Distributes events to all clients evenly. If the client buffer-size is reached the client is ignored until events are acknowledged/not acknowledged.

Pinned

For use with an indexing projection such as the system $by_category projection. Event Store inspects event for its source stream id, hashing the id to one of 1024 buckets assigned to individual clients. When a client disconnects it's buckets are assigned to other clients. When a client connects, it is assigned some of the existing buckets. This naively attempts to maintain a balanced workload. The main aim of this strategy is to decrease the likelihood of concurrency and ordering issues while maintaining load balancing. This is not a guarantee, and you should handle the usual ordering and concurrency issues.

Trait Implementations

impl Clone for SystemConsumerStrategy

pub fn clone(&self) -> SystemConsumerStrategy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for SystemConsumerStrategy

impl Debug for SystemConsumerStrategy

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

Formats the value using the given formatter.

impl Eq for SystemConsumerStrategy

impl PartialEq<SystemConsumerStrategy> for SystemConsumerStrategy

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

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

#[must_use]pub fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl StructuralEq for SystemConsumerStrategy

impl StructuralPartialEq for SystemConsumerStrategy