risingwave_pb/
iceberg_compaction.rs

1// This file is @generated by prost-build.
2#[derive(prost_helpers::AnyPB)]
3#[derive(Clone, Copy, PartialEq, ::prost::Message)]
4pub struct SubscribeIcebergCompactionEventRequest {
5    #[prost(uint64, tag = "3")]
6    pub create_at: u64,
7    #[prost(oneof = "subscribe_iceberg_compaction_event_request::Event", tags = "1, 2")]
8    pub event: ::core::option::Option<subscribe_iceberg_compaction_event_request::Event>,
9}
10/// Nested message and enum types in `SubscribeIcebergCompactionEventRequest`.
11pub mod subscribe_iceberg_compaction_event_request {
12    /// Register provides the context_id of the corresponding Compactor.
13    #[derive(prost_helpers::AnyPB)]
14    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
15    pub struct Register {
16        #[prost(uint32, tag = "1")]
17        pub context_id: u32,
18    }
19    /// PullTask provides the number of tasks needed for the Compactor.
20    #[derive(prost_helpers::AnyPB)]
21    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
22    pub struct PullTask {
23        #[prost(uint32, tag = "1")]
24        pub pull_task_count: u32,
25    }
26    #[derive(prost_helpers::AnyPB)]
27    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
28    pub enum Event {
29        /// Compactor will register its own context_id with Meta via Register and establish a bi-directional streaming rpc.
30        #[prost(message, tag = "1")]
31        Register(Register),
32        /// Compactor will recalculate the number of tasks needed locally after receiving the PullTaskAck and get the next batch of tasks from Meta via PullTask.
33        #[prost(message, tag = "2")]
34        PullTask(PullTask),
35    }
36}
37#[derive(prost_helpers::AnyPB)]
38#[derive(Clone, PartialEq, ::prost::Message)]
39pub struct IcebergCompactionTask {
40    /// Now we only support iceberg table full compaction.
41    /// compactor will get the information of the iceberg table from the properties
42    #[prost(btree_map = "string, string", tag = "1")]
43    pub props: ::prost::alloc::collections::BTreeMap<
44        ::prost::alloc::string::String,
45        ::prost::alloc::string::String,
46    >,
47}
48#[derive(prost_helpers::AnyPB)]
49#[derive(Clone, PartialEq, ::prost::Message)]
50pub struct SubscribeIcebergCompactionEventResponse {
51    #[prost(uint64, tag = "7")]
52    pub create_at: u64,
53    #[prost(oneof = "subscribe_iceberg_compaction_event_response::Event", tags = "1, 2")]
54    pub event: ::core::option::Option<
55        subscribe_iceberg_compaction_event_response::Event,
56    >,
57}
58/// Nested message and enum types in `SubscribeIcebergCompactionEventResponse`.
59pub mod subscribe_iceberg_compaction_event_response {
60    /// PullTaskAck is a response, the meta will return a PullTaskAck after distributing the task requested by the PullTask.
61    /// The Compactor receives the PullTaskAck and remakes its state and tries to initiate the next PullTask.
62    #[derive(prost_helpers::AnyPB)]
63    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
64    pub struct PullTaskAck {}
65    #[derive(prost_helpers::AnyPB)]
66    #[derive(Clone, PartialEq, ::prost::Oneof)]
67    pub enum Event {
68        #[prost(message, tag = "1")]
69        CompactTask(super::IcebergCompactionTask),
70        #[prost(message, tag = "2")]
71        PullTaskAck(PullTaskAck),
72    }
73}
risingwave_pb/iceberg_compaction.rs

risingwave_pb/
iceberg_compaction.rs
