Struct Service 

pub struct Service {
    sessions: RwLock<BTreeMap<SessionId, Session>>,
    ratelimiter: Mutex<HashMap<IpAddr, (Instant, f64)>>,
    services: Arc<OnceServices>,
}

Stores bounded rendezvous sessions and request rate-limit state.

Both stores are process-local and shared through locks. Expired sessions are removed lazily during creation, retrieval, or conditional mutation.

Fields

sessions: RwLock<BTreeMap<SessionId, Session>>

ratelimiter: Mutex<HashMap<IpAddr, (Instant, f64)>>

services: Arc<OnceServices>

Implementations

impl Service

pub fn check_rate_limit(&self, client: IpAddr) -> Result

Charges one request against a client’s rendezvous rate-limit bucket.

Buckets refill at the configured rate up to the configured burst size. A depleted bucket returns a limit-exceeded request error, and the per-client table remains bounded.

impl Service

pub fn create(&self, data: Bytes) -> (SessionId, Meta)

Creates a rendezvous session for an opaque payload.

Expired sessions are pruned first, then the oldest live sessions are evicted to honor the configured capacity, with an effective minimum of one. The returned metadata describes the newly stored representation.

Panics

Panics if the session lock has been poisoned.

impl Service

fn create_at( &self, data: Bytes, now: SystemTime, ttl: Duration, max_sessions: usize, ) -> (SessionId, Meta)

impl Service

pub fn get(&self, id: &str, if_none_match: Option<&str>) -> Get

Retrieves a rendezvous payload with optional entity-tag validation.

A matching tag or wildcard returns Get::NotModified; otherwise a live session returns its data. Expired sessions are removed and reported as not found.

Panics

Panics if the session lock has been poisoned.

impl Service

fn get_at(&self, id: &str, if_none_match: Option<&str>, now: SystemTime) -> Get

impl Service

pub fn put(&self, id: &str, if_match: &str, data: Bytes) -> Put

Conditionally replaces a rendezvous payload using a quoted entity tag.

A matching validator stores the new payload and advances its metadata. A stale validator accepts identical data as a retry but rejects different data with the current metadata.

Panics

Panics if the session lock has been poisoned.

impl Service

fn put_at( &self, id: &str, if_match: &str, data: Bytes, now: SystemTime, ttl: Duration, ) -> Put

impl Service

pub fn put_token(&self, id: &str, sequence_token: &str, data: Bytes) -> Put

Conditionally replaces a rendezvous payload using an unquoted sequence token.

Update and retry behavior matches Self::put, but the validator is compared with the entity tag’s unquoted value.

Panics

Panics if the session lock has been poisoned.

impl Service

fn put_token_at( &self, id: &str, sequence_token: &str, data: Bytes, now: SystemTime, ttl: Duration, ) -> Put

impl Service

fn put_with_at( &self, id: &str, validator: Validator<'_>, data: Bytes, now: SystemTime, ttl: Duration, ) -> Put

Applies the shared conditional-update state machine at a supplied time.

Expired sessions are removed before validation. Successful replacements advance modification time monotonically, while identical stale retries only refresh expiration.

impl Service

pub fn delete(&self, id: &str) -> bool

Deletes a rendezvous session regardless of expiration.

The return value reports whether any stored session was removed, including an expired one.

Panics

Panics if the session lock has been poisoned.

impl Service

pub fn delete_if_active(&self, id: &str) -> bool

Deletes a rendezvous session and reports whether it was active.

Expired sessions are still removed but return false. An absent session also returns false.

Panics

Panics if the session lock has been poisoned.

impl Service

fn delete_if_active_at(&self, id: &str, now: SystemTime) -> bool

Trait Implementations

impl Service for Service

fn build(args: &Args<'_>) -> Result<Arc<Self>>

Implement the construction of the service instance. Services are generally singletons so expect this to only be called once for a service type. Note that it may be called again after a server reload, but the prior instance will have been dropped first. Failure will shutdown the server with an error.

fn name(&self) -> &str

Return the name of the service. i.e. crate::service::make_name(std::module_path!())

fn worker<'async_trait>( self: Arc<Self>, ) -> Pin<Box<dyn Future<Output = Result> + Send + 'async_trait>>

where Self: 'async_trait,

Implement the service’s worker loop. The service manager spawns a task and calls this function after all services have been built.

fn interrupt<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Interrupt the service. This is sent to initiate a graceful shutdown. The service worker should return from its work loop.

fn clear_cache<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Clear any caches or similar runtime state.

fn memory_usage<'life0, 'life1, 'async_trait>( &'life0 self, _out: &'life1 mut (dyn Write + Send), ) -> Pin<Box<dyn Future<Output = Result> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Memory usage report in a markdown string.

fn unconstrained(&self) -> bool

Return true if the service worker opts out of the tokio cooperative budgeting. This can reduce tail latency at the risk of event loop starvation.