Struct DataPlaneServerImpl 

pub struct DataPlaneServerImpl { /* private fields */ }

Implementations

impl DataPlaneServerImpl

pub fn new(session_secret: Vec<u8>, provider_did: impl Into<String>) -> Self

Trait Implementations

impl Clone for DataPlaneServerImpl

fn clone(&self) -> DataPlaneServerImpl

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl DataPlane for DataPlaneServerImpl

type ResultStream = Pin<Box<dyn Stream<Item = Result<EncryptedChunk, Status>> + Send>>

Server streaming response type for the Result method.

type StreamingTaskStream = Pin<Box<dyn Stream<Item = Result<EncryptedChunk, Status>> + Send>>

Server streaming response type for the StreamingTask method.

fn handshake<'life0, 'async_trait>( &'life0 self, req: Request<HandshakeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HandshakeResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handshake — troca de chaves efêmeras (ou no MVP apenas validação de session_token).

fn transfer<'life0, 'async_trait>( &'life0 self, req: Request<Streaming<EncryptedChunk>>, ) -> Pin<Box<dyn Future<Output = Result<Response<TransferAck>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Transfer — envio de payload (cifrado em E2E ou em claro sobre TLS no MVP).

fn result<'life0, 'async_trait>( &'life0 self, req: Request<ResultRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ResultStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Result — recebimento de resultado.

fn streaming_task<'life0, 'async_trait>( &'life0 self, _req: Request<Streaming<EncryptedChunk>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamingTaskStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Streaming bidirecional para tasks longas (opcional no MVP).