linkrs-sync 0.1.0

Synchronization primitives for Linkrs
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

use async_trait::async_trait;
use std::sync::Arc;

use super::error::BatchResult;
use crate::types::IndexOperation;

#[async_trait]
pub trait BatchProcessor {
    async fn add(&self, operation: IndexOperation) -> BatchResult<()>;
    async fn add_batch(&self, operations: Vec<IndexOperation>) -> BatchResult<()>;
    async fn commit_all(&self) -> BatchResult<()>;
    async fn commit_timeout(&self) -> BatchResult<()>;
    async fn start_background_task(self: Arc<Self>);
    async fn stop_background_task(&self);
}

pub trait BatchBuffer<K, V> {
    fn add(&self, key: &K, value: V);
    fn drain(&self, key: &K) -> Vec<V>;
    fn peek(&self, key: &K) -> Vec<V>;
    fn count(&self, key: &K) -> usize;
    fn is_empty(&self, key: &K) -> bool;
    fn keys(&self) -> Vec<K>;
    fn clear(&self);
    fn total_count(&self) -> usize;
}