Enum nakadion::CommitStrategy

pub enum CommitStrategy {
    AllBatches,
    Latest,
    AfterSeconds {
        seconds: u16,
    },
    Batches {
        after_batches: u32,
        after_seconds: Option<u16>,
    },
    Events {
        after_events: u32,
        after_seconds: Option<u16>,
    },
}

Strategy for committing cursors

Variants

AllBatches

Commit all cursors immediately

Serialization(JSON)

"AllBatches"

Latest

Commit as late as possible

Serialization(JSON)

"Latest"

AfterSeconds

Commit latest after seconds seconds since a batch was received.

Serialization(JSON)

{
    "AfterSeconds": {
        "seconds": 42
    }
}

Fields of AfterSeconds

seconds: u16

Batches

Commit latest after after_batches batches have been received or after after_seconds seconds have elapsed since a batch was received.

Serialization(JSON)

{
    "Batches": {
        "after_batches": 12,
        "after_seconds": 13
    }
}

Fields of Batches

after_batches: u32after_seconds: Option<u16>

Events

Commit latest after after_events events have been received or after after_seconds seconds have elapsed since a batch was received.

This requires the BatchHandler to return the number of processed events to work properly.

Serialization(JSON)

{
    "Events": {
        "after_events": 12,
        "after_seconds": 13
    }
}

Fields of Events

after_events: u32after_seconds: Option<u16>

Trait Implementations

impl Clone for CommitStrategy

fn clone(&self) -> CommitStrategy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for CommitStrategy

impl Debug for CommitStrategy

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

Formats the value using the given formatter.

impl Serialize for CommitStrategy

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

Serialize this value into the given Serde serializer.

impl<'de> Deserialize<'de> for CommitStrategy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.