Struct InMemoryTaskStore 

pub struct InMemoryTaskStore<Req, Res>
where
    Req: Clone + Send + Sync + 'static,
    Res: Clone + Send + Sync + 'static,
{ /* private fields */ }

Implementations

impl<Req, Res> InMemoryTaskStore<Req, Res>

where Req: Debug + Clone + Send + Sync + Deserialize<'static> + Serialize + 'static, Res: Debug + Clone + Send + Sync + Deserialize<'static> + Serialize + 'static,

pub fn new(page_size: Option<usize>) -> Self

Trait Implementations

impl<Req, Res> TaskStatusSignal for InMemoryTaskStore<Req, Res>

where Req: Clone + Debug + Send + Sync + 'static + Deserialize<'static> + Serialize, Res: Clone + Debug + Send + Sync + 'static + Deserialize<'static> + Serialize,

fn publish_status_change<'life0, 'life1, 'async_trait>( &'life0 self, event: TaskStatusNotificationParams, session_id: Option<&'life1 String>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Publish a status change event

fn subscribe( &self, ) -> Option<Pin<Box<dyn Stream<Item = (TaskStatusNotificationParams, Option<String>)> + Send + 'static>>>

Return a new independent stream of events

impl<Req, Res> TaskStore<Req, Res> for InMemoryTaskStore<Req, Res>

where Req: Clone + Debug + Send + Sync + 'static + Deserialize<'static> + Serialize, Res: Clone + Debug + Send + Sync + 'static + Deserialize<'static> + Serialize,

fn create_task<'life0, 'async_trait>( &'life0 self, task_params: CreateTaskOptions, _request_id: RequestId, request: Req, session_id: Option<String>, ) -> Pin<Box<dyn Future<Output = Task> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Creates a new task with the given creation parameters and original request. The implementation must generate a unique taskId and createdAt timestamp.

fn start_task_polling( &self, get_task_callback: TaskStatusPoller, ) -> SdkResult<()>

Begins active polling for task status updates in requestor mode. This method spawns a long-running background task that drives the polling schedule for all tasks managed by this store. It repeatedly invokes the provided get_task_callback to query the receiver for the current status of pending tasks.

fn wait_for_task_result<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, session_id: Option<String>, ) -> Pin<Box<dyn Future<Output = SdkResult<(TaskStatus, Option<Res>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Waits asynchronously for the result of a task.

fn get_task<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, session_id: Option<String>, ) -> Pin<Box<dyn Future<Output = Option<Task>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets the current status of a task.

fn store_task_result<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, status: TaskStatus, result: Res, session_id: Option<&'life2 String>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Stores the result of a task and sets its final status.

fn get_task_result<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, session_id: Option<String>, ) -> Pin<Box<dyn Future<Output = Option<Res>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves the stored result of a task.

fn update_task_status<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, status: TaskStatus, status_message: Option<String>, session_id: Option<String>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Updates a task’s status (e.g., to ‘cancelled’, ‘failed’, ‘completed’).

fn list_tasks<'life0, 'async_trait>( &'life0 self, cursor: Option<String>, session_id: Option<String>, ) -> Pin<Box<dyn Future<Output = ListTasksResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lists tasks, optionally starting from a pagination cursor.