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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoDataflowDescription {
    #[prost(message, repeated, tag="1")]
    pub source_imports: ::prost::alloc::vec::Vec<proto_dataflow_description::ProtoSourceImport>,
    #[prost(message, repeated, tag="2")]
    pub index_imports: ::prost::alloc::vec::Vec<proto_dataflow_description::ProtoIndex>,
    #[prost(message, repeated, tag="3")]
    pub objects_to_build: ::prost::alloc::vec::Vec<ProtoBuildDesc>,
    #[prost(message, repeated, tag="4")]
    pub index_exports: ::prost::alloc::vec::Vec<proto_dataflow_description::ProtoIndex>,
    #[prost(message, repeated, tag="5")]
    pub sink_exports: ::prost::alloc::vec::Vec<proto_dataflow_description::ProtoSinkExport>,
    #[prost(message, optional, tag="6")]
    pub as_of: ::core::option::Option<::mz_persist::gen::persist::ProtoU64Antichain>,
    #[prost(string, tag="7")]
    pub debug_name: ::prost::alloc::string::String,
    #[prost(message, optional, tag="8")]
    pub id: ::core::option::Option<::mz_repr::proto::ProtoU128>,
}
/// Nested message and enum types in `ProtoDataflowDescription`.
pub mod proto_dataflow_description {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoSourceImport {
        #[prost(message, optional, tag="1")]
        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
        #[prost(message, optional, tag="2")]
        pub source_instance_desc: ::core::option::Option<super::ProtoSourceInstanceDesc>,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoIndex {
        #[prost(message, optional, tag="1")]
        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
        #[prost(message, optional, tag="2")]
        pub index_desc: ::core::option::Option<super::ProtoIndexDesc>,
        #[prost(message, optional, tag="3")]
        pub typ: ::core::option::Option<::mz_repr::ProtoRelationType>,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoSinkExport {
        #[prost(message, optional, tag="1")]
        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
        #[prost(message, optional, tag="2")]
        pub sink_desc: ::core::option::Option<super::sinks::ProtoSinkDesc>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoIndexDesc {
    #[prost(message, optional, tag="1")]
    pub on_id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
    #[prost(message, repeated, tag="3")]
    pub key: ::prost::alloc::vec::Vec<::mz_expr::ProtoMirScalarExpr>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoBuildDesc {
    #[prost(message, optional, tag="1")]
    pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
    #[prost(message, optional, tag="2")]
    pub plan: ::core::option::Option<super::plan::ProtoPlan>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceInstanceDesc {
    #[prost(message, optional, tag="1")]
    pub description: ::core::option::Option<sources::ProtoSourceDesc>,
    #[prost(message, optional, tag="2")]
    pub arguments: ::core::option::Option<ProtoSourceInstanceArguments>,
    #[prost(message, optional, tag="3")]
    pub storage_metadata: ::core::option::Option<super::client::controller::storage::ProtoCollectionMetadata>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceInstanceArguments {
    #[prost(message, optional, tag="1")]
    pub operators: ::core::option::Option<ProtoLinearOperator>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoLinearOperator {
    #[prost(message, repeated, tag="1")]
    pub predicates: ::prost::alloc::vec::Vec<::mz_expr::ProtoMirScalarExpr>,
    #[prost(uint64, repeated, tag="2")]
    pub projection: ::prost::alloc::vec::Vec<u64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPeekResponse {
    #[prost(oneof="proto_peek_response::Kind", tags="1, 2, 3")]
    pub kind: ::core::option::Option<proto_peek_response::Kind>,
}
/// Nested message and enum types in `ProtoPeekResponse`.
pub mod proto_peek_response {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoRow {
        #[prost(message, optional, tag="1")]
        pub row: ::core::option::Option<::mz_repr::ProtoRow>,
        #[prost(uint64, tag="2")]
        pub diff: u64,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoRows {
        #[prost(message, repeated, tag="1")]
        pub rows: ::prost::alloc::vec::Vec<ProtoRow>,
    }
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag="1")]
        Rows(ProtoRows),
        #[prost(string, tag="2")]
        Error(::prost::alloc::string::String),
        #[prost(message, tag="3")]
        Canceled(()),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoTailBatch {
    #[prost(message, optional, tag="1")]
    pub lower: ::core::option::Option<::mz_persist::gen::persist::ProtoU64Antichain>,
    #[prost(message, optional, tag="2")]
    pub upper: ::core::option::Option<::mz_persist::gen::persist::ProtoU64Antichain>,
    #[prost(message, repeated, tag="3")]
    pub updates: ::prost::alloc::vec::Vec<proto_tail_batch::ProtoUpdate>,
}
/// Nested message and enum types in `ProtoTailBatch`.
pub mod proto_tail_batch {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoUpdate {
        #[prost(uint64, tag="1")]
        pub timestamp: u64,
        #[prost(message, optional, tag="2")]
        pub row: ::core::option::Option<::mz_repr::ProtoRow>,
        #[prost(int64, tag="3")]
        pub diff: i64,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoTailResponse {
    #[prost(oneof="proto_tail_response::Kind", tags="1, 2")]
    pub kind: ::core::option::Option<proto_tail_response::Kind>,
}
/// Nested message and enum types in `ProtoTailResponse`.
pub mod proto_tail_response {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag="1")]
        Batch(super::ProtoTailBatch),
        #[prost(message, tag="2")]
        DroppedAt(::mz_persist::gen::persist::ProtoU64Antichain),
    }
}