ozzy-journal 0.3.0

Journal contracts and local durability evidence for Ozzy.
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

//! Bounded canonical body validation failures.

use ozzy_proto::layout::LayoutError;
use thiserror::Error;

/// Canonical operation body codec failure.
#[derive(Debug, Clone, PartialEq, Eq, Error)]
pub enum OperationCodecError {
    /// Unsupported coordinator intent format.
    #[error("invalid consumer group plan format")]
    InvalidGroupPlan,
    /// The assignment body format is unsupported.
    #[error("unsupported consumer assignment format {0}")]
    UnsupportedAssignmentFormat(u8),
    /// Attempt counts, outcome mappings, or duplicate retry proofs disagree.
    #[error("invalid append results")]
    InvalidAppendResults,
    #[error("unsupported operation kind {0}")]
    /// The canonical operation discriminator is unsupported.
    UnsupportedOperationKind(u16),
    #[error("truncated operation body: need {needed} bytes, have {available}")]
    /// Canonical body bytes end before a complete field.
    Truncated {
        /// Required bytes for this field.
        needed: usize,
        /// Available bytes in the input suffix.
        available: usize,
    },
    #[error("operation body has {0} trailing bytes")]
    /// Bytes remain after a complete canonical operation body.
    TrailingBytes(usize),
    #[error("invalid UTF-8 in {0}")]
    /// A stream or topic name is not valid UTF-8.
    InvalidUtf8(&'static str),
    #[error("{0} must not be empty")]
    /// A required name or value is empty.
    EmptyValue(&'static str),
    #[error("invalid optional-value tag {0}")]
    /// An optional field has an unsupported presence tag.
    InvalidOptionTag(u8),
    #[error("invalid progress-owner tag {0}")]
    /// The progress owner discriminator is unsupported.
    InvalidProgressOwnerTag(u8),
    #[error("retention policy version or flags are unsupported")]
    /// Retention-policy version or flags are unsupported.
    InvalidRetention,
    #[error("append operation must contain a batch and each batch a record")]
    /// An APPEND has no batches or a batch has no records.
    EmptyAppend,
    #[error("append record must contain at least one message part")]
    /// A record has no payload parts.
    EmptyRecordParts,
    #[error("prepared append payload is invalid or does not match its raw record view")]
    /// The prepared payload is invalid or conflicts with the raw view.
    InvalidPreparedPayload,
    #[error("APPEND payload compression failed")]
    /// Whole-APPEND payload compression failed.
    AppendCompression,
    #[error("append sequence or offset range overflows")]
    /// A producer sequence or record offset range overflows.
    AppendPositionOverflow,
    #[error("consumer-group progress requires a member and assignment epoch")]
    /// Consumer-group progress lacks an assignment fence.
    MissingProgressAssignment,
    #[error("standalone subscription progress cannot carry an assignment")]
    /// Standalone subscription progress carries an assignment fence.
    UnexpectedProgressAssignment,
    #[error("integer or length arithmetic overflow")]
    /// Encoded integer or byte-count arithmetic overflows.
    LengthOverflow,
    #[error("operation output allocation failed")]
    /// Canonical output storage could not grow.
    OutputAllocation,
    #[error("{kind} limit exceeded: {actual} > {limit}")]
    /// Canonical metadata or payload exceeds a configured resource bound.
    LimitExceeded {
        /// Resource bound that rejected the operation.
        kind: &'static str,
        /// Observed size or count.
        actual: usize,
        /// Configured maximum size or count.
        limit: usize,
    },
    #[error("record range is outside its batch")]
    /// A selected record range is reversed or ends past its batch.
    RecordRange,
    #[error("record list cannot extend another representation")]
    /// An extension does not match the record list representation.
    RecordListKind,
}

impl From<LayoutError> for OperationCodecError {
    fn from(error: LayoutError) -> Self {
        match error {
            LayoutError::Truncated { needed, available } => Self::Truncated { needed, available },
            LayoutError::Trailing(bytes) => Self::TrailingBytes(bytes),
            LayoutError::Overflow { .. } => Self::LengthOverflow,
        }
    }
}