Enum ExpectedVersion 

pub enum ExpectedVersion {
    Any,
    Exists,
    Empty,
    Exact(u64),
}

The expected version before the event is inserted.

Variants

Any

Accept any version, whether the stream/partition exists or not.

Exists

The stream/partition must exist (have at least one event).

Empty

The stream/partition must be empty (have no events yet).

Exact(u64)

The stream/partition must be exactly at this version.

Implementations

impl ExpectedVersion

pub fn from_next_version(version: u64) -> Self

pub fn into_next_version(self) -> Option<u64>

pub fn gap_from(self, current: CurrentVersion) -> VersionGap

Calculate the gap between expected and current version. Returns VersionGap::None if the expectation is satisfied.

pub fn is_satisfied_by(self, current: CurrentVersion) -> bool

Check if the current version satisfies the expectation

Trait Implementations

impl Clone for ExpectedVersion

fn clone(&self) -> ExpectedVersion

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExpectedVersion

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

Formats the value using the given formatter.

impl Default for ExpectedVersion

fn default() -> ExpectedVersion

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExpectedVersion

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for ExpectedVersion

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

Formats the value using the given formatter.

impl FromStr for ExpectedVersion

type Err = ParseIntError

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl PartialEq for ExpectedVersion

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for ExpectedVersion

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for ExpectedVersion

impl Eq for ExpectedVersion

impl StructuralPartialEq for ExpectedVersion