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}
risingwave_pb/source.rs

risingwave_pb/
source.rs
