Struct flare_dht::cluster::FlareNode

pub struct FlareNode {
    pub metadata_manager: Arc<FlareMetadataManager>,
    pub shards: Arc<DashMap<ShardId, Arc<dyn KvShard>>>,
    pub addr: String,
    pub node_id: u64,
    pub shard_factory: Arc<dyn ShardFactory>,
    pub client_pool: ClientPool,
    /* private fields */
}

Fields

metadata_manager: Arc<FlareMetadataManager>

shards: Arc<DashMap<ShardId, Arc<dyn KvShard>>>

addr: String

node_id: u64

shard_factory: Arc<dyn ShardFactory>

client_pool: ClientPool

Implementations

impl FlareNode

pub async fn new(options: ServerArgs) -> Self

pub fn start_watch_stream(self: Arc<Self>)

pub async fn init_leader(&self) -> Result<(), Box<dyn Error>>

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 sync_shard(&self)

pub async fn get_shard( &self, collection: &str, key: &str, ) -> Result<Arc<dyn KvShard>, FlareError>

pub async fn create_collection( &self, request: CreateCollectionRequest, ) -> Result<CreateCollectionResponse, FlareError>

Trait Implementations

impl Clone for FlareNode

fn clone(&self) -> FlareNode

Returns a copy of the value.

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

Performs copy-assignment from source.