Struct Checkpointer 

pub struct Checkpointer<'a, W: OutputWriter, R: InputReader> { /* private fields */ }

Implementations

impl<'a, W: OutputWriter, R: InputReader> Checkpointer<'a, W, R>

pub fn checkpoint( &mut self, sequence_number: Option<String>, sub_sequence_number: Option<u64>, ) -> Result<(), CheckpointError>

Checkpoints at a particular sequence number you provide or if no sequence number is given, the checkpoint will be at the end of the most recently delivered list of records.

Arguments

• sequence_number: the sequence number to checkpoint
• sub_sequence_number: the sub sequence number generated by KPL

returns: Result<(), Report>

Examples found in repository

examples/example_consumer/main.rs (line 29)

    fn process_records(
        &mut self,
        data: &[Record],
        checkpointer: &mut Checkpointer<StdoutWriter, StdinReader>,
    ) {
        for record in data {
            match record.json::<MyPayload>() {
                Ok(data) => println!("{:?}", data.event_field),
                Err(e) => println!("{:?}", e),
            }
        }
        checkpointer
            .checkpoint(None, None)
            .expect("Checkpoint to succeed.");
    }
    fn lease_lost(&mut self) {}
    fn shard_ended(&mut self, checkpointer: &mut Checkpointer<StdoutWriter, StdinReader>) {
        checkpointer
            .checkpoint(None, None)
            .expect("Checkpoint to succeed.");
    }
    fn shutdown_requested(&mut self, checkpointer: &mut Checkpointer<StdoutWriter, StdinReader>) {
        checkpointer
            .checkpoint(None, None)
            .expect("Checkpoint to succeed.");
    }