Struct Agent 

pub struct Agent(/* private fields */);

Implementations

impl Agent

pub fn new(config: AgentConfig) -> Self

pub fn actor<C: Into<Option<ClusterId>>>(&self, cluster_id: C) -> Actor

pub fn pool(&self) -> &SplitPool

Return a borrowed SqlitePool

pub fn actor_id(&self) -> ActorId

pub fn clock(&self) -> &Arc<HLC>

pub fn gossip_addr(&self) -> SocketAddr

pub fn external_addr(&self) -> Option<SocketAddr>

pub fn api_addr(&self) -> SocketAddr

pub fn tx_bcast(&self) -> &CorroSender<BroadcastInput>

pub fn tx_apply(&self) -> &CorroSender<(ActorId, CrsqlDbVersion)>

pub fn tx_changes(&self) -> &CorroSender<(ChangeV1, ChangeSource)>

pub fn tx_clear_buf(&self) -> &CorroSender<(ActorId, CrsqlDbVersionRange)>

pub fn tx_foca(&self) -> &CorroSender<FocaInput>

pub fn write_sema(&self) -> &Arc<Semaphore>

pub async fn write_permit(&self) -> Result<OwnedSemaphorePermit, AcquireError>

pub fn write_permit_blocking( &self, ) -> Result<OwnedSemaphorePermit, AcquireError>

pub fn booked(&self) -> &Booked

pub fn members(&self) -> &RwLock<Members>

pub fn schema(&self) -> &RwLock<Schema>

pub fn db_path(&self) -> Utf8PathBuf

pub fn config(&self) -> Guard<Arc<Config>, DefaultStrategy>

pub fn set_config(&self, new_conf: Config)

pub fn limits(&self) -> &Limits

pub fn subs_manager(&self) -> &SubsManager

pub fn updates_manager(&self) -> &UpdatesManager

pub fn set_cluster_id(&self, cluster_id: ClusterId)

pub fn cluster_id(&self) -> ClusterId

pub fn update_clock_with_timestamp( &self, actor_id: ActorId, ts: Timestamp, ) -> Result<(), String>

Trait Implementations

impl Clone for Agent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.