Struct IPCClient 

pub struct IPCClient {
    pub ipc_socket: String,
    pub rpc_endpoint: String,
    pub instance_id: InstanceID,
    pub server_version: String,
    pub support_rpc_compression: bool,
    /* private fields */
}

Fields

ipc_socket: String

rpc_endpoint: String

instance_id: InstanceID

server_version: String

support_rpc_compression: bool

Implementations

impl IPCClient

pub fn default() -> Result<IPCClient>

pub fn connect(socket: &str) -> Result<IPCClient>

pub fn create_blob(&mut self, size: usize) -> Result<BlobWriter>

pub fn get_blob(&mut self, id: ObjectID) -> Result<Blob>

pub fn get<T: Object + Create>(&mut self, id: ObjectID) -> Result<Box<T>>

pub fn fetch_and_get<T: Object + Create>( &mut self, id: ObjectID, ) -> Result<Box<dyn Object>>

Trait Implementations

impl Client for IPCClient

fn disconnect(&mut self)

Disconnect this client.

fn connected(&mut self) -> bool

fn ensure_connect(&mut self) -> Result<ReentrantMutexGuard<'_, ()>>

fn do_read(&mut self) -> Result<String>

fn do_write(&mut self, message_out: &str) -> Result<()>

fn instance_id(&self) -> InstanceID

fn create_metadata(&mut self, metadata: &ObjectMeta) -> Result<ObjectMeta>

fn get_metadata(&mut self, id: ObjectID) -> Result<ObjectMeta>

fn get_metadata_batch(&mut self, ids: &[ObjectID]) -> Result<Vec<ObjectMeta>>

fn fetch_and_get_metadata(&mut self, id: ObjectID) -> Result<ObjectMeta>

fn fetch_and_get_metadata_batch( &mut self, ids: &[ObjectID], ) -> Result<Vec<ObjectMeta>>

fn drop_buffer(&mut self, id: ObjectID) -> Result<()>

fn seal_buffer(&mut self, id: ObjectID) -> Result<()>

fn get_data( &mut self, id: ObjectID, sync_remote: bool, wait: bool, ) -> Result<JSON>

fn get_data_batch(&mut self, ids: &[ObjectID]) -> Result<Vec<JSON>>

fn create_data( &mut self, data: &JSON, ) -> Result<(ObjectID, Signature, InstanceID)>

fn sync_metadata(&mut self) -> Result<()>

fn delete(&mut self, id: ObjectID, force: bool, deep: bool) -> Result<()>

fn delete_batch( &mut self, ids: &[ObjectID], force: bool, deep: bool, ) -> Result<()>

fn list_data( &mut self, pattern: &str, regex: bool, limit: usize, ) -> Result<Vec<JSON>>

@param pattern: The pattern of typename.

fn list_name( &mut self, pattern: &str, regex: bool, limit: usize, ) -> Result<HashMap<String, ObjectID>>

@param pattern: The pattern of object name.

fn persist(&mut self, id: ObjectID) -> Result<()>

fn if_persist(&mut self, id: ObjectID) -> Result<bool>

fn exists(&mut self, id: ObjectID) -> Result<bool>

fn put_name(&mut self, id: ObjectID, name: &str) -> Result<()>

fn get_name(&mut self, name: &str, wait: bool) -> Result<ObjectID>

fn drop_name(&mut self, name: &str) -> Result<()>

fn migrate(&mut self, id: ObjectID) -> Result<ObjectID>

fn clear(&mut self) -> Result<()>

fn label(&mut self, id: ObjectID, key: &str, value: &str) -> Result<()>

fn evict(&mut self, id: ObjectID) -> Result<()>

fn evict_batch(&mut self, ids: &[ObjectID]) -> Result<()>

fn load(&mut self, id: ObjectID, pin: bool) -> Result<()>

fn load_batch(&mut self, ids: &[ObjectID], pin: bool) -> Result<()>

fn unpin(&mut self, id: ObjectID) -> Result<()>

fn unpin_batch(&mut self, ids: &[ObjectID]) -> Result<()>

impl Debug for IPCClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for IPCClient

fn drop(&mut self)

Executes the destructor for this type.

impl Send for IPCClient

impl Sync for IPCClient