pub struct DebugCommandRouter { /* private fields */ }Expand description
Debug command router that delegates to specific processors
Implementations§
Source§impl DebugCommandRouter
impl DebugCommandRouter
Sourcepub async fn register_processor(
&self,
name: String,
processor: Arc<dyn DebugCommandProcessor>,
)
pub async fn register_processor( &self, name: String, processor: Arc<dyn DebugCommandProcessor>, )
Register a command processor
Sourcepub async fn queue_command(&self, request: DebugCommandRequest) -> Result<()>
pub async fn queue_command(&self, request: DebugCommandRequest) -> Result<()>
Queue a debug command for processing
Sourcepub async fn process_next(&self) -> Option<Result<(String, DebugResponse)>>
pub async fn process_next(&self) -> Option<Result<(String, DebugResponse)>>
Process the next command in the queue
Sourcepub async fn get_response(&self, correlation_id: &str) -> Option<DebugResponse>
pub async fn get_response(&self, correlation_id: &str) -> Option<DebugResponse>
Get a response by correlation ID
Sourcepub async fn cleanup_expired_responses(&self)
pub async fn cleanup_expired_responses(&self)
Clean up expired responses
Sourcepub async fn get_metrics(&self) -> DebugMetrics
pub async fn get_metrics(&self) -> DebugMetrics
Get current metrics
Sourcepub async fn route(&self, request: DebugCommandRequest) -> Result<DebugResponse>
pub async fn route(&self, request: DebugCommandRequest) -> Result<DebugResponse>
Route a debug command request for processing
Sourcepub async fn validate_command(&self, command: &DebugCommand) -> Result<()>
pub async fn validate_command(&self, command: &DebugCommand) -> Result<()>
Validate a debug command
Auto Trait Implementations§
impl Freeze for DebugCommandRouter
impl !RefUnwindSafe for DebugCommandRouter
impl Send for DebugCommandRouter
impl Sync for DebugCommandRouter
impl Unpin for DebugCommandRouter
impl !UnwindSafe for DebugCommandRouter
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more