krabka-protocol 0.7.0

Apache Kafka wire-protocol codec (4.3.0), with typed RecordBatch and zero-copy borrowed decode
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

//! Sample cut values for the barrier codec tests.

use crate::{
    UnknownTaggedFields,
    krabka::{
        barrier::cut::{BarrierCutPartition, BarrierCutTopic, BarrierMissingPartition},
        test_support::sample_tagged_fields,
    },
};

/// A cut over two topics, one of them with two partitions.
pub(crate) fn sample_cut_topics() -> Vec<BarrierCutTopic> {
    vec![
        BarrierCutTopic {
            topic: "orders".to_string(),
            partitions: vec![
                BarrierCutPartition {
                    partition: 0,
                    offset: 1_024,
                    unknown_tagged_fields: UnknownTaggedFields::default(),
                },
                BarrierCutPartition {
                    partition: 1,
                    offset: 2_048,
                    unknown_tagged_fields: sample_tagged_fields(),
                },
            ],
            unknown_tagged_fields: sample_tagged_fields(),
        },
        BarrierCutTopic {
            topic: "payments".to_string(),
            partitions: Vec::new(),
            unknown_tagged_fields: UnknownTaggedFields::default(),
        },
    ]
}

/// One partition that took no marker.
pub(crate) fn sample_missing_partitions() -> Vec<BarrierMissingPartition> {
    vec![BarrierMissingPartition {
        topic: "payments".to_string(),
        partition: 4,
        unknown_tagged_fields: sample_tagged_fields(),
    }]
}