Struct StorageScanEdgeOutput

pub struct StorageScanEdgeOutput<'a, MT = AsyncTransport<TokioTcpStream, TokioSleep, MetaTransportResponseHandler>, ST = AsyncTransport<TokioTcpStream, TokioSleep, StorageTransportResponseHandler>>
where
    MT: Transport + Framing<DecBuf = Cursor<Bytes>, EncBuf = BytesMut>,
    ST: Transport + Framing<DecBuf = Cursor<Bytes>, EncBuf = BytesMut>,
    Bytes: Framing<DecBuf = FramingDecoded<MT>> + Framing<DecBuf = FramingDecoded<ST>>,
    ProtocolEncoded<BinaryProtocol<MT>>: BufMutExt<Final = FramingEncodedFinal<MT>>,
    ProtocolEncoded<BinaryProtocol<ST>>: BufMutExt<Final = FramingEncodedFinal<ST>>,
{ /* private fields */ }

Implementations

impl<'a, MT, ST> StorageScanEdgeOutput<'a, MT, ST>

where MT: Transport + Framing<DecBuf = Cursor<Bytes>, EncBuf = BytesMut>, ST: Transport + Framing<DecBuf = Cursor<Bytes>, EncBuf = BytesMut>, Bytes: Framing<DecBuf = FramingDecoded<MT>> + Framing<DecBuf = FramingDecoded<ST>>, ProtocolEncoded<BinaryProtocol<MT>>: BufMutExt<Final = FramingEncodedFinal<MT>>, ProtocolEncoded<BinaryProtocol<ST>>: BufMutExt<Final = FramingEncodedFinal<ST>>,

pub fn new( space_id: i32, edge_prop: Option<EdgeProp>, leader_map: HashMap<i32, HostAddr>, sclient: &'a StorageClient<MT, ST>, ) -> Self

pub async fn execute( &mut self, ) -> Result<Vec<StorageQueryOutput>, StorageQueryError>