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

#[derive(serde::Serialize, serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoBatch {
    #[prost(string, tag = "1")]
    pub shard_id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub version: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "3")]
    pub batch: ::core::option::Option<super::internal::state::ProtoHollowBatch>,
}
/// This is only to impl ExchangeData, and so used between processes running the
/// same version of code. It's not durably written down anywhere.
#[derive(serde::Serialize, serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoLeasedBatchPart {
    #[prost(string, tag = "1")]
    pub shard_id: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub filter: ::core::option::Option<ProtoFetchBatchFilter>,
    #[prost(message, optional, tag = "3")]
    pub desc: ::core::option::Option<super::internal::state::ProtoU64Description>,
    #[prost(message, optional, tag = "4")]
    pub part: ::core::option::Option<super::internal::state::ProtoHollowBatchPart>,
    #[prost(message, optional, tag = "5")]
    pub lease: ::core::option::Option<ProtoLease>,
    #[prost(bool, tag = "6")]
    pub filter_pushdown_audit: bool,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoFetchBatchFilter {
    #[prost(oneof = "proto_fetch_batch_filter::Kind", tags = "1, 2")]
    pub kind: ::core::option::Option<proto_fetch_batch_filter::Kind>,
}
/// Nested message and enum types in `ProtoFetchBatchFilter`.
pub mod proto_fetch_batch_filter {
    #[derive(serde::Serialize, serde::Deserialize)]
    #[allow(missing_docs)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        /// Apply snapshot-style semantics to the fetched batch part.
        ///
        /// Return all values with time leq `as_of`.
        #[prost(message, tag = "1")]
        Snapshot(super::super::internal::state::ProtoU64Antichain),
        /// Apply listen-style semantics to the fetched batch part.
        #[prost(message, tag = "2")]
        Listen(super::ProtoFetchBatchFilterListen),
    }
}
#[derive(serde::Serialize, serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoFetchBatchFilterListen {
    /// Return all values with time in advance of `as_of`.
    #[prost(message, optional, tag = "1")]
    pub as_of: ::core::option::Option<super::internal::state::ProtoU64Antichain>,
    /// Return all values with `lower` leq time.
    #[prost(message, optional, tag = "2")]
    pub lower: ::core::option::Option<super::internal::state::ProtoU64Antichain>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoLease {
    #[prost(string, tag = "1")]
    pub reader_id: ::prost::alloc::string::String,
    #[prost(uint64, optional, tag = "2")]
    pub seqno: ::core::option::Option<u64>,
}