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: u32
after_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: u32
after_seconds: Option<u16>

Trait Implementations

impl Debug for CommitStrategy

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

Formats the value using the given formatter.

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