batpak 0.8.0

Event sourcing with causal graphs and caller-defined gates. Sync API, no async runtime.
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

use crate::store::segment::scan::FrameScanTailPolicy;
use crate::store::StoreError;
use std::io::{Error, ErrorKind};

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub(super) enum PayloadReadFailure {
    RecoverTornTail,
}

pub(super) fn classify_payload_read_error(
    segment_id: u64,
    error: Error,
    tail_policy: FrameScanTailPolicy,
) -> Result<PayloadReadFailure, StoreError> {
    if error.kind() == ErrorKind::UnexpectedEof {
        if tail_policy.can_recover_torn_tail() {
            Ok(PayloadReadFailure::RecoverTornTail)
        } else {
            Err(StoreError::corrupt_segment_with_detail(
                segment_id,
                "frame payload ended before requested length",
            ))
        }
    } else {
        Err(StoreError::Io(error))
    }
}