risingwave_pb/
source.rs

1// This file is @generated by prost-build.
2#[derive(prost_helpers::AnyPB)]
3#[derive(Clone, PartialEq, ::prost::Message)]
4pub struct ConnectorSplit {
5    #[prost(string, tag = "1")]
6    pub split_type: ::prost::alloc::string::String,
7    #[prost(bytes = "vec", tag = "2")]
8    pub encoded_split: ::prost::alloc::vec::Vec<u8>,
9}
10#[derive(prost_helpers::AnyPB)]
11#[derive(Clone, PartialEq, ::prost::Message)]
12pub struct ConnectorSplits {
13    #[prost(message, repeated, tag = "1")]
14    pub splits: ::prost::alloc::vec::Vec<ConnectorSplit>,
15}
16#[derive(prost_helpers::AnyPB)]
17#[derive(Clone, PartialEq, ::prost::Message)]
18pub struct SourceActorInfo {
19    #[prost(uint32, tag = "1")]
20    pub actor_id: u32,
21    #[prost(message, optional, tag = "2")]
22    pub splits: ::core::option::Option<ConnectorSplits>,
23}
24#[derive(prost_helpers::AnyPB)]
25#[derive(Clone, PartialEq, ::prost::Message)]
26pub struct CdcTableSnapshotSplits {
27    #[prost(message, repeated, tag = "1")]
28    pub splits: ::prost::alloc::vec::Vec<CdcTableSnapshotSplit>,
29}
30#[derive(prost_helpers::AnyPB)]
31#[derive(Clone, PartialEq, ::prost::Message)]
32pub struct CdcTableSnapshotSplit {
33    #[prost(int64, tag = "1")]
34    pub split_id: i64,
35    #[prost(bytes = "vec", tag = "2")]
36    pub left_bound_inclusive: ::prost::alloc::vec::Vec<u8>,
37    #[prost(bytes = "vec", tag = "3")]
38    pub right_bound_exclusive: ::prost::alloc::vec::Vec<u8>,
39}
risingwave_pb/source.rs

risingwave_pb/
source.rs
