Struct GridManager 

pub struct GridManager { /* private fields */ }

그리드 중앙 제어기 (Thin Dispatcher)

네트워크 채널로부터 오는 메시지를 분류하여 도메인별 핸들러로 배달합니다.

Implementations

impl GridManager

pub fn new( quic_channel: Arc<QuicChannel>, ec_store: Arc<DistributedErasureCodingStore>, receiver: Receiver<GridMessageWrapper>, ) -> Self

pub fn with_node_id( quic_channel: Arc<QuicChannel>, ec_store: Arc<DistributedErasureCodingStore>, receiver: Receiver<GridMessageWrapper>, node_id: u32, ) -> Self

pub fn with_local_executor(self, executor: Arc<LocalExecutor>) -> Self

워커 노드 로컬 실행기 설정

pub fn get_query_streams( &self, ) -> Arc<DashMap<(String, usize), Sender<DbxResult<Option<Vec<u8>>>>>>

pub fn get_stage_barriers( &self, ) -> Arc<DashMap<(String, usize, SocketAddr), Sender<()>>>

pub async fn run(self)

수신 루프 시작