risingwave_meta::hummock

Type Alias IcebergCompactionEventLoop

Source 
pub type IcebergCompactionEventLoop = CompactionEventLoop<IcebergCompactionEventDispatcher, SubscribeIcebergCompactionEventRequest>;

Aliased Type§

struct IcebergCompactionEventLoop {
    hummock_compactor_dispatcher: IcebergCompactionEventDispatcher,
    metrics: Arc<MetaMetrics>,
    compactor_streams_change_rx: UnboundedReceiver<(u32, Streaming<SubscribeIcebergCompactionEventRequest>)>,
}

Fields§

§hummock_compactor_dispatcher: IcebergCompactionEventDispatcher§metrics: Arc<MetaMetrics>§compactor_streams_change_rx: UnboundedReceiver<(u32, Streaming<SubscribeIcebergCompactionEventRequest>)>