shrike 0.1.0

AT Protocol library for Rust
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

use std::future::Future;
use std::pin::Pin;

use crate::backfill::BackfillError;

pub type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;

/// Persist cursor position for crash recovery
pub trait Checkpoint: Send + Sync {
    fn save(&self, cursor: &str) -> BoxFuture<'_, Result<(), BackfillError>>;
    fn load(&self) -> BoxFuture<'_, Result<Option<String>, BackfillError>>;
}

/// No-op checkpoint for testing
pub struct NoopCheckpoint;

impl Checkpoint for NoopCheckpoint {
    fn save(&self, _cursor: &str) -> BoxFuture<'_, Result<(), BackfillError>> {
        Box::pin(async { Ok(()) })
    }
    fn load(&self) -> BoxFuture<'_, Result<Option<String>, BackfillError>> {
        Box::pin(async { Ok(None) })
    }
}