Rulvar API reference

---

Rulvar API reference / @rulvar/core / MemoryAdmissionScheduler

Class: MemoryAdmissionScheduler

Defined in: packages/core/src/admission/memory.ts:165

Implements

• AdmissionScheduler

Constructors

Constructor

new MemoryAdmissionScheduler(options): MemoryAdmissionScheduler;

Defined in: packages/core/src/admission/memory.ts:173

Parameters

Parameter	Type
options	MemoryAdmissionOptions

Returns

MemoryAdmissionScheduler

Methods

cancel()

cancel(
   unitId, 
   generation, 
opId): Promise<void>;

Defined in: packages/core/src/admission/memory.ts:710

Cancels a queued ticket (nothing to refund); granted ones release; an EXPIRED one returns the concurrency slot expiry parked under it (RV4910), which is the operator's release by identity once the holder is known dead.

Parameters

Parameter	Type
unitId	string
generation	string
opId	string

Returns

Promise<void>

Implementation of

AdmissionScheduler.cancel

---

checkpointCover()

checkpointCover(
   unitId, 
   generation, 
   cover, 
opId): Promise<void>;

Defined in: packages/core/src/admission/memory.ts:651

Durably checkpoints a consumption cover BEFORE the covered batch (the intent-before-effect doctrine applied to capacity): monotone high-water, idempotent by opId, and lease-carried: a fenced store rejects an expired lease's cover write, which is what makes the conservative expiry refund provable rather than optimistic.

Parameters

Parameter	Type
unitId	string
generation	string
cover	AdmissionReservation
opId	string

Returns

Promise<void>

Implementation of

AdmissionScheduler.checkpointCover

---

enqueue()

enqueue(request, opId): Promise<AdmissionTicketDecision>;

Defined in: packages/core/src/admission/memory.ts:467

Conditional create by (unitId, generation) plus immediate grant when every matched level admits; opId makes retries idempotent.

Parameters

Parameter	Type
request	AdmissionRequest
opId	string

Returns

Promise<AdmissionTicketDecision>

Implementation of

AdmissionScheduler.enqueue

---

pump()

pump(_opId): Promise<AdmissionTicket[]>;

Defined in: packages/core/src/admission/memory.ts:785

Advances the scheduler: expires stale leases (conservative settlement: the provably unused wires refund, the concurrency slot parks under the possibly live holder, RV4910), then grants queued tickets in SFQ order while every matched level admits. Returns the newly granted tickets.

Parameters

Parameter	Type
_opId	string

Returns

Promise<AdmissionTicket[]>

Implementation of

AdmissionScheduler.pump

---

rebind()

rebind(
   unitId, 
   generation, 
   target, 
opId): Promise<AdmissionTicketDecision>;

Defined in: packages/core/src/admission/memory.ts:733

The failover transfer (RFC section 4.2, item 4): atomically acquires the TARGET hierarchy's capacity and level-2 slot and releases the source hierarchy in the same transition, BEFORE the target dispatches. A failed transfer leaves the source binding unchanged and the target undispatchable: no window exists in which work runs on a provider account whose slot it never held.

Parameters

Parameter	Type
unitId	string
generation	string
target	{ scope: AdmissionScopeDimensions; }
target.scope	AdmissionScopeDimensions
opId	string

Returns

Promise<AdmissionTicketDecision>

Implementation of

AdmissionScheduler.rebind

---

recover()

recover(
   unitId, 
   generation, 
opId): Promise<AdmissionRecovery>;

Defined in: packages/core/src/admission/memory.ts:626

The resumed unit's recovery: granted renews the lease, a queued ticket reports its surviving position, and unknown means re-enqueue (the conservative direction).

Parameters

Parameter	Type
unitId	string
generation	string
opId	string

Returns

Promise<AdmissionRecovery>

Implementation of

AdmissionScheduler.recover

---

release()

release(
   unitId, 
   generation, 
   actuals, 
opId): Promise<void>;

Defined in: packages/core/src/admission/memory.ts:673

Release with actuals: the unused remainder refunds to each level, over-consumption beyond the reservation lands as bucket debt (it never denies retroactively), and a late settlement after expiry is accepted idempotently as debt rather than discarded, returning the concurrency slot that expiry parked (RV4910).

Parameters

Parameter	Type
unitId	string
generation	string
actuals	AdmissionReservation
opId	string

Returns

Promise<void>

Implementation of

AdmissionScheduler.release

---

renew()

renew(
   unitId, 
   generation, 
_opId): Promise<void>;

Defined in: packages/core/src/admission/memory.ts:643

Renews a granted ticket's lease; unknown tickets are no-ops.

Parameters

Parameter	Type
unitId	string
generation	string
_opId	string

Returns

Promise<void>

Implementation of

AdmissionScheduler.renew

---

snapshot()

snapshot(): AdmissionState;

Defined in: packages/core/src/admission/memory.ts:217

The whole state as a plain-JSON document (deep-copied).

Returns

AdmissionState