Struct BasicActionClient 

pub struct BasicActionClient<G, F, R> { /* private fields */ }

Implementations

impl<G, F, R> BasicActionClient<G, F, R>

pub fn new(action_name: impl Into<String>, schema: ActionSchema) -> Self

pub fn with_channel( action_name: impl Into<String>, schema: ActionSchema, channel: Arc<ActionChannel<G, F, R>>, ) -> Self

pub fn with_heartbeat_timeout(self, timeout: Option<RtDuration>) -> Self

pub fn with_stalled_threshold(self, stalled_after: Option<RtDuration>) -> Self

Trait Implementations

impl<G, F, R> ActionClient<G, F, R> for BasicActionClient<G, F, R>

where G: Send + 'static, F: Send + 'static, R: Send + 'static,

fn action_name(&self) -> &str

fn schema(&self) -> &ActionSchema

fn send_goal(&mut self, goal: G) -> Result<(ActionGoalId, GoalAck), RtError>

Send a goal and immediately receive the server’s accept/reject acknowledgement.

fn poll_feedback(&mut self, goal_id: ActionGoalId) -> Option<ActionFeedback<F>>

Non-blocking poll: dequeue the next feedback item for the given goal, or None if empty.

fn poll_result(&mut self, goal_id: ActionGoalId) -> Option<ActionResult<R>>

Non-blocking poll: take the final result for the given goal, or None if not ready.

fn cancel(&mut self, goal_id: ActionGoalId) -> Result<(), RtError>

Request cancellation of a goal.

fn goal_status(&self, goal_id: ActionGoalId) -> Option<GoalStatus>

Query the current status of a goal without consuming any feedback or result.

fn tick_timeouts(&mut self, now: Timestamp) -> usize

Evaluate heartbeat timeouts for executing goals.

fn goal_health(&self, goal_id: ActionGoalId) -> Option<ActionSessionHealth>

Return health state of a specific goal.

fn active_goal_health(&self) -> Vec<ActionSessionHealth>

Return health states for all known goals.

fn close(&mut self) -> Result<(), RtError>