pub type HummockCompactionEventLoop = CompactionEventLoop<HummockCompactionEventDispatcher, SubscribeCompactionEventRequest>;
Aliased Type§
struct HummockCompactionEventLoop {
hummock_compactor_dispatcher: HummockCompactionEventDispatcher,
metrics: Arc<MetaMetrics>,
compactor_streams_change_rx: UnboundedReceiver<(u32, Streaming<SubscribeCompactionEventRequest>)>,
}
Fields§
§hummock_compactor_dispatcher: HummockCompactionEventDispatcher
§metrics: Arc<MetaMetrics>
§compactor_streams_change_rx: UnboundedReceiver<(u32, Streaming<SubscribeCompactionEventRequest>)>