Struct Lane 

pub struct Lane { /* private fields */ }

Lane

Implementations

impl Lane

pub fn new( id: impl Into<String>, config: LaneConfig, priority: Priority, ) -> Self

Create a new lane

pub fn with_storage( id: impl Into<String>, config: LaneConfig, priority: Priority, storage: Arc<dyn Storage>, ) -> Self

Create a new lane with storage

pub fn id(&self) -> &str

Get lane ID

pub async fn priority(&self) -> Priority

Get lane priority

pub async fn effective_priority(&self) -> Priority

Get effective priority, applying boost based on the front command’s age

pub async fn enqueue( &self, command: Box<dyn Command>, ) -> Receiver<Result<Value>>

Enqueue a command

pub async fn status(&self) -> LaneStatus

Get lane status