Struct TableGatewayStore 

pub struct TableGatewayStore { /* private fields */ }

Gateway store that keeps every record kind in its own SIM Table.

Each slot is a SIM table value guarded by a shared Cx; records are wrapped as opaque table values keyed by content id or string id. Implements GatewayStore, GatewayResponseObjectStore, and GatewayStateStore.

Implementations

impl TableGatewayStore

pub fn new() -> Result<Self>

Creates a store with a fresh table for every record kind.

Returns an error only if SIM table creation fails, which does not happen for the in-memory tables used here.

Trait Implementations

impl Default for TableGatewayStore

fn default() -> Self

Returns the “default value” for a type.

impl GatewayResponseObjectStore for TableGatewayStore

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 TableGatewayStore

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 TableGatewayStore

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.