Struct oomclient::Client

pub struct Client { /* private fields */ }

Implementations

impl Client

pub async fn connect<D>(dst: D) -> Result<Self, OomError> where
    D: TryInto<Endpoint>,
    D::Error: Into<StdError>, 

pub async fn health_check(&mut self) -> Result<(), OomError>

pub async fn online_get_raw(
    &mut self,
    entity_key: impl Into<String>,
    features: Vec<String>
) -> Result<FeatureValueMap, OomError>

pub async fn online_get(
    &mut self,
    key: impl Into<String>,
    features: Vec<String>
) -> Result<HashMap<String, Option<Value>>, OomError>

pub async fn online_multi_get_raw(
    &mut self,
    entity_keys: Vec<String>,
    features: Vec<String>
) -> Result<HashMap<String, FeatureValueMap>, OomError>

pub async fn online_multi_get(
    &mut self,
    keys: Vec<String>,
    features: Vec<String>
) -> Result<HashMap<String, HashMap<String, Option<Value>>>, OomError>

pub async fn sync(
    &mut self,
    revision_id: u32,
    purge_delay: u32
) -> Result<(), OomError>

pub async fn channel_import(
    &mut self,
    group: impl Into<String>,
    revision: impl Into<Option<i64>>,
    description: impl Into<Option<String>>,
    rows: impl Stream<Item = Vec<u8>> + Send + 'static
) -> Result<u32, OomError>

pub async fn import(
    &mut self,
    group: impl Into<String>,
    description: impl Into<Option<String>>,
    revision: impl Into<Option<i64>>,
    input_file: impl AsRef<Path>,
    delimiter: impl Into<Option<char>>
) -> Result<u32, OomError>

pub async fn push(
    &mut self,
    entity_key: impl Into<String>,
    group: impl Into<String>,
    kv_pairs: Vec<(impl Into<String>, impl Into<Value>)>
) -> Result<(), OomError>

pub async fn channel_join(
    &mut self,
    join_features: Vec<String>,
    existed_features: Vec<String>,
    entity_rows: impl Stream<Item = EntityRow> + Send + 'static
) -> Result<(Vec<String>, impl Stream<Item = Result<Vec<Option<Value>>, OomError>>), OomError>

pub async fn join(
    &mut self,
    features: Vec<String>,
    input_file: impl AsRef<Path>,
    output_file: impl AsRef<Path>
) -> Result<(), OomError>

pub async fn channel_export(
    &mut self,
    features: Vec<String>,
    unix_milli: u64,
    limit: impl Into<Option<usize>>
) -> Result<(Vec<String>, impl Stream<Item = Result<Vec<Option<Value>>, OomError>>), OomError>

pub async fn export(
    &mut self,
    features: Vec<String>,
    unix_milli: u64,
    output_file: impl AsRef<Path>,
    limit: impl Into<Option<usize>>
) -> Result<(), OomError>

pub async fn snapshot(
    &mut self,
    group: impl Into<String>
) -> Result<(), OomError>

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.