Expand description
Per-session command queue with lane-based priority scheduling
Provides session-isolated command queues where each session has its own set of lanes with configurable concurrency limits and priorities.
§External Task Handling
Supports pluggable task handlers allowing SDK users to implement custom processing logic for different lanes:
- Internal: Default, tasks executed within the runtime
- External: Tasks sent to SDK, wait for callback completion
- Hybrid: Internal execution with external notification
§Implementation
The actual queue implementation is in SessionLaneQueue which is backed
by a3s-lane with features like DLQ, metrics, retry policies, and rate limiting.
Structs§
- External
Task - An external task that needs to be processed by SDK
- External
Task Result - Result of external task processing
- Lane
Handler Config - Configuration for a lane’s task handler
- Lane
Status - Status of a single lane
- Priority
Boost Config - Priority boost configuration
- Rate
Limit Config - Rate limit configuration
- Retry
Policy Config - Retry policy configuration
- Session
Queue Config - Configuration for a session command queue
- Session
Queue Stats - Statistics for a session queue
Enums§
- Session
Lane - Session lane for queue priority scheduling and HITL auto-approval
- Task
Handler Mode - Task handler mode determines how tasks in a lane are processed
Traits§
- Session
Command - Command to be executed in a session queue