pub struct StoreSynchronousProxy { /* private fields */ }
Implementations§
source§impl StoreSynchronousProxy
impl StoreSynchronousProxy
pub fn new(channel: Channel) -> Self
pub fn into_channel(self) -> Channel
sourcepub fn wait_for_event(&self, deadline: Time) -> Result<StoreEvent, Error>
pub fn wait_for_event(&self, deadline: Time) -> Result<StoreEvent, Error>
Waits until an event arrives and returns it. It is safe for other threads to make concurrent requests while waiting for an event.
sourcepub fn write_item(
&self,
payload: StoreWriteItemRequest,
___deadline: Time
) -> Result<StoreWriteItemResult, Error>
pub fn write_item( &self, payload: StoreWriteItemRequest, ___deadline: Time ) -> Result<StoreWriteItemResult, Error>
Writes an item to the store.
Since the value stored in the key-value store can now be different from the input (if the
WriteOptions.CONCAT
flag is set), we need to return the resulting Value
to the
requester.
We use an (anonymous) table
and a (named) flexible union
as the request and response
payload, respectively, to allow for easier future evolution. Both of these types are
flexible
, meaning that adding or removing members is binary-compatible. This makes them
much easier to evolve that the struct
types that were previously used, which cannot be
changed after release without breaking ABI.