Documentation / guides
Limits and Lanes
Describe bounded Hustle limits and scheduler lanes.
Rig registration supplies all lane and lifecycle bounds. WithHustleLimits is
required when at least one Hustle is registered and rejected when no Hustle
needs it.
Rig limits
limits := rig.HustleLimits{
BlockingConcurrent: 1,
BlockingQueued: 4,
BackgroundConcurrent: 2,
BackgroundQueued: 8,
AuditTimeout: time.Second,
FinalizationTimeout: time.Second,
WorkerDrainTimeout: 2 * time.Second,
}
runtime, err := rig.Define(
rig.WithHustles(compactor),
rig.WithHustleLimits(limits),
)
_ = runtime
_ = errThe exact public fields are BlockingConcurrent, BlockingQueued,
BackgroundConcurrent, BackgroundQueued, AuditTimeout,
FinalizationTimeout, and WorkerDrainTimeout. Concurrent values and all
timeouts must be positive. Queued values are from zero through
rig.MaxHustleQueued, which is 10_000.
Proof: Rig Hustle limits and limit validation tests.
Lane ownership
The internal hustleruntime.LaneLimits has Concurrent and Queued; their
sum is the total ownership cap. A queued run owns a slot before it executes,
so a caller cannot create more work than the configured bound. FIFO ordering is
preserved within each lane, and closing a lane rejects new admission while
finishing owned queue nodes through their finalizers.
%%{init: {"theme":"dark"}}%%
flowchart TD
Q[admit] --> C{lane closed?}
C -->|yes| R[AdmissionClosed]
C -->|no| F{capacity available?}
F -->|no| R2[AdmissionFull]
F -->|yes| O[owned queue node]
O --> W[worker slot]
W --> T[terminal audit and finalizer]Proof: lane limits and controller contract and lane tests.
Queue and run failures
Pre-ownership failures use AdmissionError or RequestError, so they have no
RunID and do not invoke a finalizer. Owned queue failures use
QueueFailureError with RunID, Participation, Stage, and a reason of
canceled, timeout, closed, or poisoned. Owned execution failures use
RunError; both preserve finalizer and cleanup errors through unwrapping.
Proof: Hustle runtime error types and preflight tests.