Rulvar API reference / @rulvar/core / AdmissionScheduler
Interface: AdmissionScheduler
Defined in: packages/core/src/l0/spi/admission.ts:128
Methods
cancel()
cancel(
unitId,
generation,
opId): Promise<void>;Defined in: packages/core/src/l0/spi/admission.ts:174
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>
checkpointCover()
checkpointCover(
unitId,
generation,
cover,
opId): Promise<void>;Defined in: packages/core/src/l0/spi/admission.ts:149
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>
enqueue()
enqueue(request, opId): Promise<AdmissionTicketDecision>;Defined in: packages/core/src/l0/spi/admission.ts:133
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>
pump()
pump(opId): Promise<AdmissionTicket[]>;Defined in: packages/core/src/l0/spi/admission.ts:196
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[]>
rebind()
rebind(
unitId,
generation,
target,
opId): Promise<AdmissionTicketDecision>;Defined in: packages/core/src/l0/spi/admission.ts:183
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>
recover()
recover(
unitId,
generation,
opId): Promise<AdmissionRecovery>;Defined in: packages/core/src/l0/spi/admission.ts:139
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>
release()
release(
unitId,
generation,
actuals,
opId): Promise<void>;Defined in: packages/core/src/l0/spi/admission.ts:162
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>
renew()
renew(
unitId,
generation,
opId): Promise<void>;Defined in: packages/core/src/l0/spi/admission.ts:141
Renews a granted ticket's lease; unknown tickets are no-ops.
Parameters
| Parameter | Type |
|---|---|
unitId | string |
generation | string |
opId | string |
Returns
Promise<void>