risingwave_pb/
source.rs

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
// This file is @generated by prost-build.
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConnectorSplit {
    #[prost(string, tag = "1")]
    pub split_type: ::prost::alloc::string::String,
    #[prost(bytes = "vec", tag = "2")]
    pub encoded_split: ::prost::alloc::vec::Vec<u8>,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConnectorSplits {
    #[prost(message, repeated, tag = "1")]
    pub splits: ::prost::alloc::vec::Vec<ConnectorSplit>,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SourceActorInfo {
    #[prost(uint32, tag = "1")]
    pub actor_id: u32,
    #[prost(message, optional, tag = "2")]
    pub splits: ::core::option::Option<ConnectorSplits>,
}