Struct MemoryGatewayStore 

pub struct MemoryGatewayStore { /* private fields */ }

In-memory gateway store backed by BTreeMaps.

Implements GatewayStore, GatewayResponseObjectStore, and GatewayStateStore. Intended for tests and single-process use; nothing is persisted beyond the process.

Implementations

impl MemoryGatewayStore

pub fn new() -> Self

Creates an empty in-memory store.

pub fn put_request_content( &mut self, request: GatewayRequest, ) -> Result<ContentId>

Stores a request under its derived content id and returns that id.

pub fn put_run_content(&mut self, run: GatewayRun) -> Result<ContentId>

Stores a run under its derived content id and returns that id.

pub fn put_event_content(&mut self, event: GatewayEvent) -> Result<ContentId>

Stores an event under its derived content id and returns that id.

pub fn put_response_content( &mut self, response: GatewayResponse, ) -> Result<ContentId>

Stores a response under its derived content id and returns that id.

pub fn counts(&self) -> GatewayStoreCounts

Returns a snapshot of the current record counts.

pub fn requests(&self) -> Vec<(ContentId, GatewayRequest)>

Returns all stored requests paired with their content ids.

pub fn runs(&self) -> Vec<(ContentId, GatewayRun)>

Returns all stored runs paired with their content ids.

pub fn run_by_id(&self, run_id: &str) -> Option<(ContentId, GatewayRun)>

Returns the run (with its content id) whose run id matches run_id.

pub fn events(&self) -> Vec<(ContentId, GatewayEvent)>

Returns all stored events paired with their content ids.

Trait Implementations

impl Clone for MemoryGatewayStore

fn clone(&self) -> MemoryGatewayStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MemoryGatewayStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MemoryGatewayStore

fn default() -> MemoryGatewayStore

Returns the “default value” for a type.

impl GatewayResponseObjectStore for MemoryGatewayStore

fn put_response_object(&mut self, response: StoredGatewayResponse) -> Result<()>

Stores a response object, replacing any existing entry with the same id.

fn response_object(&self, response_id: &str) -> Option<StoredGatewayResponse>

Returns the response object with the given id, if present.

impl GatewayStateStore for MemoryGatewayStore

fn put_file(&mut self, file: GatewayFile, bytes: Vec<u8>) -> Result<()>

Stores a file record together with its raw bytes.

fn file(&self, file_id: &str) -> Option<GatewayFile>

Returns the file record with the given id, if present.

fn file_bytes(&self, file_id: &str) -> Option<Vec<u8>>

Returns the raw bytes for the given file id, if present.

fn put_batch(&mut self, batch: GatewayBatch) -> Result<()>

Stores a batch record, replacing any existing entry with the same id.

fn batch(&self, batch_id: &str) -> Option<GatewayBatch>

Returns the batch with the given id, if present.

fn put_thread(&mut self, thread: GatewayThread) -> Result<()>

Stores a thread record, replacing any existing entry with the same id.

fn thread(&self, thread_id: &str) -> Option<GatewayThread>

Returns the thread with the given id, if present.

fn put_thread_message(&mut self, message: GatewayThreadMessage) -> Result<()>

Appends a message to its thread.

fn thread_messages(&self, thread_id: &str) -> Vec<GatewayThreadMessage>

Returns the messages for the given thread id, in insertion order.

fn put_vector_store(&mut self, vector_store: GatewayVectorStore) -> Result<()>

Stores a vector store, replacing any existing entry with the same id.

fn vector_store(&self, vector_store_id: &str) -> Option<GatewayVectorStore>

Returns the vector store with the given id, if present.

impl GatewayStore for MemoryGatewayStore

fn put_request(&mut self, id: ContentId, request: GatewayRequest) -> Result<()>

Stores a request under its content id.

fn request(&self, id: &ContentId) -> Option<GatewayRequest>

Returns the request stored under id, if present.

fn put_run(&mut self, id: ContentId, run: GatewayRun) -> Result<()>

Stores a run under its content id.

fn run(&self, id: &ContentId) -> Option<GatewayRun>

Returns the run stored under id, if present.

fn put_event(&mut self, id: ContentId, event: GatewayEvent) -> Result<()>

Stores an event under its content id.

fn event(&self, id: &ContentId) -> Option<GatewayEvent>

Returns the event stored under id, if present.

fn put_response( &mut self, id: ContentId, response: GatewayResponse, ) -> Result<()>

Stores a response under its content id.

fn response(&self, id: &ContentId) -> Option<GatewayResponse>

Returns the response stored under id, if present.