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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoDecodeError {
    #[prost(message, optional, tag = "1")]
    pub kind: ::core::option::Option<ProtoDecodeErrorKind>,
    #[prost(bytes = "vec", optional, tag = "2")]
    pub raw: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoDecodeErrorKind {
    #[prost(oneof = "proto_decode_error_kind::Kind", tags = "1, 2")]
    pub kind: ::core::option::Option<proto_decode_error_kind::Kind>,
}
/// Nested message and enum types in `ProtoDecodeErrorKind`.
pub mod proto_decode_error_kind {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(string, tag = "1")]
        Text(::prost::alloc::string::String),
        #[prost(string, tag = "2")]
        Bytes(::prost::alloc::string::String),
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceErrorDetails {
    #[prost(oneof = "proto_source_error_details::Kind", tags = "1, 2, 3, 4")]
    pub kind: ::core::option::Option<proto_source_error_details::Kind>,
}
/// Nested message and enum types in `ProtoSourceErrorDetails`.
pub mod proto_source_error_details {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(string, tag = "1")]
        Initialization(::prost::alloc::string::String),
        #[prost(string, tag = "2")]
        DeprecatedFileIo(::prost::alloc::string::String),
        #[prost(string, tag = "3")]
        DeprecatedPersistence(::prost::alloc::string::String),
        #[prost(string, tag = "4")]
        Other(::prost::alloc::string::String),
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceError {
    #[prost(message, optional, tag = "1")]
    pub source_id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
    #[prost(message, optional, tag = "2")]
    pub error: ::core::option::Option<ProtoSourceErrorDetails>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoUpsertValueError {
    #[prost(message, optional, boxed, tag = "1")]
    pub inner: ::core::option::Option<::prost::alloc::boxed::Box<ProtoDataflowError>>,
    #[prost(message, optional, tag = "2")]
    pub for_key: ::core::option::Option<::mz_repr::ProtoRow>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoUpsertNullKeyError {
    #[prost(message, optional, tag = "1")]
    pub partition_id: ::core::option::Option<::mz_expr::ProtoPartitionId>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoUpsertError {
    #[prost(oneof = "proto_upsert_error::Kind", tags = "1, 2, 3")]
    pub kind: ::core::option::Option<proto_upsert_error::Kind>,
}
/// Nested message and enum types in `ProtoUpsertError`.
pub mod proto_upsert_error {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        KeyDecode(super::ProtoDecodeError),
        #[prost(message, tag = "2")]
        Value(::prost::alloc::boxed::Box<super::ProtoUpsertValueError>),
        #[prost(message, tag = "3")]
        NullKey(super::ProtoUpsertNullKeyError),
    }
}
/// The "V1" suffix was requested by the storage team,
/// since they might want to repurpose/modify this field
/// in the future.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoEnvelopeErrorV1 {
    #[prost(oneof = "proto_envelope_error_v1::Kind", tags = "1, 2, 3")]
    pub kind: ::core::option::Option<proto_envelope_error_v1::Kind>,
}
/// Nested message and enum types in `ProtoEnvelopeErrorV1`.
pub mod proto_envelope_error_v1 {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(string, tag = "1")]
        Debezium(::prost::alloc::string::String),
        #[prost(message, tag = "2")]
        Upsert(::prost::alloc::boxed::Box<super::ProtoUpsertError>),
        #[prost(string, tag = "3")]
        Flat(::prost::alloc::string::String),
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoDataflowError {
    #[prost(oneof = "proto_dataflow_error::Kind", tags = "1, 2, 3, 4")]
    pub kind: ::core::option::Option<proto_dataflow_error::Kind>,
}
/// Nested message and enum types in `ProtoDataflowError`.
pub mod proto_dataflow_error {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        DecodeError(super::ProtoDecodeError),
        #[prost(message, tag = "2")]
        EvalError(::mz_expr::ProtoEvalError),
        #[prost(message, tag = "3")]
        SourceError(super::ProtoSourceError),
        #[prost(message, tag = "4")]
        EnvelopeErrorV1(::prost::alloc::boxed::Box<super::ProtoEnvelopeErrorV1>),
    }
}