Struct StorageClient

pub struct StorageClient<MT = AsyncTransport<Compat<TcpStream>, Sleep, MetaTransportResponseHandler>, ST = AsyncTransport<Compat<TcpStream>, Sleep, StorageTransportResponseHandler>>
where
    MT: Transport + Framing<DecBuf = Cursor<Bytes>, EncBuf = BytesMut>,
    ST: Transport + Framing<DecBuf = Cursor<Bytes>, EncBuf = BytesMut>,
    Bytes: Framing<DecBuf = <MT as Framing>::DecBuf> + Framing<DecBuf = <ST as Framing>::DecBuf>,
    <<BinaryProtocol<MT> as Protocol>::Frame as Framing>::EncBuf: BufMutExt<Final = <<MT as Framing>::EncBuf as BufMutExt>::Final>,
    <<BinaryProtocol<ST> as Protocol>::Frame as Framing>::EncBuf: BufMutExt<Final = <<ST as Framing>::EncBuf as BufMutExt>::Final>,
{ /* private fields */ }

Implementations

impl<MT> StorageClient<MT>

where MT: Transport + Framing<DecBuf = Cursor<Bytes>, EncBuf = BytesMut>, Bytes: Framing<DecBuf = <MT as Framing>::DecBuf>, <<BinaryProtocol<MT> as Protocol>::Frame as Framing>::EncBuf: BufMutExt<Final = <<MT as Framing>::EncBuf as BufMutExt>::Final>,

pub async fn new(mclient: MetaClient<MT>) -> Self

pub async fn scan_vertex( &mut self, space_name: &str, tag_name: &str, prop_names: Option<Vec<&str>>, ) -> Result<Vec<StorageQueryOutput>, StorageClientError>

prop_names is None means return all properties

pub async fn scan_edge( &mut self, space_name: &str, edge_name: &str, prop_names: Option<Vec<&str>>, ) -> Result<Vec<StorageQueryOutput>, StorageClientError>

prop_names is None means return all properties