Struct QuicChannel 

pub struct QuicChannel {
    pub local_addr: SocketAddr,
    /* private fields */
}

QUIC 통신을 담당하는 채널 인스턴스

Fields

local_addr: SocketAddr

Implementations

impl QuicChannel

pub async fn new( local_addr: SocketAddr, cert_pem: &str, key_pem: &str, tx: Sender<GridMessageWrapper>, ) -> DbxResult<Self>

새로운 QUIC 채널 개설 TODO: 상용화 단계에서는 cert_pem과 key_pem 경로를 Config에서 주입받아야 합니다.

pub async fn send_message( &self, peer_addr: SocketAddr, msg: GridMessage, ) -> DbxResult<()>

다른 Grid 노드에 데이터 단방향 전송 (방치)

pub async fn send_request_and_wait( &self, peer_addr: SocketAddr, msg: GridMessage, ) -> DbxResult<GridMessage>

Request-Response 방식 비동기 통신 (FetchShard 등)

pub async fn send_response( stream: &mut BidirectionalStream, msg: GridMessage, ) -> DbxResult<()>

정적 메서드로 스트림에 메시지 응답 전송