kcl-async 0.1.0

Async KCL MultiLang Daemon library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use async_trait::async_trait;

use crate::{
    message::input::{
        InitializeMessage, LeaseLostMessage, ProcessRecordsMessage, ShardEndedMessage,
        ShutdownMessage, ShutdownRequestedMessage,
    },
    transport::Transport,
};

use super::checkpoint::Checkpointer;

#[async_trait]
pub trait Processor<T>
where
    T: Transport + Send,
{
    type Error;

    async fn initialize(&mut self, msg: InitializeMessage) -> Result<(), Self::Error>;

    async fn process_records(
        &mut self,
        msg: ProcessRecordsMessage,
        checkpointer: &mut Checkpointer<'_, T>,
    ) -> Result<(), Self::Error>;

    async fn shutdown(
        &mut self,
        msg: ShutdownMessage,
        checkpointer: &mut Checkpointer<'_, T>,
    ) -> Result<(), Self::Error>;

    async fn shutdown_requested(
        &mut self,
        msg: ShutdownRequestedMessage,
        checkpointer: &mut Checkpointer<'_, T>,
    ) -> Result<(), Self::Error>;

    async fn lease_lost(&mut self, msg: LeaseLostMessage) -> Result<(), Self::Error>;

    async fn shard_ended(&mut self, msg: ShardEndedMessage) -> Result<(), Self::Error>;
}