Struct FlareNode

pub struct FlareNode<T>
where
    T: KvShard,
{
    pub metadata_manager: Arc<dyn MetadataManager>,
    pub addr: String,
    pub node_id: NodeId,
    pub control_pool: Arc<ControlPool>,
    pub data_pool: Arc<DataPool>,
    pub shard_manager: Arc<ShardManager<T>>,
    /* private fields */
}

Fields

metadata_manager: Arc<dyn MetadataManager>

addr: String

node_id: NodeId

control_pool: Arc<ControlPool>

data_pool: Arc<DataPool>

shard_manager: Arc<ShardManager<T>>

Implementations

impl<T> FlareNode<T>

where T: KvShard + 'static,

pub async fn new( addr: String, node_id: NodeId, metadata_manager: Arc<dyn MetadataManager>, shard_manager: Arc<ShardManager<T>>, control_pool: Arc<ControlPool>, data_pool: Arc<DataPool>, ) -> Self

pub fn start_watch_stream(self: Arc<Self>)

pub async fn join(&self, peer_addr: &str) -> Result<(), Box<dyn Error>>

pub async fn leave(&self)

pub async fn close(&self)

pub async fn get_shard( &self, collection: &str, key: &[u8], ) -> Result<Arc<T>, FlareError>