pub struct Cache { /* private fields */ }Expand description
Cache models the shared Gestalt cache-provider protocol.
Client for the gestalt.provider.v1.Cache service.
Implementations§
Source§impl Cache
impl Cache
Sourcepub fn with_timeout(self, timeout: Duration) -> Self
pub fn with_timeout(self, timeout: Duration) -> Self
Sets a deadline applied to every unary call; calls that run past it fail with DEADLINE_EXCEEDED. Streaming calls are unaffected.
Sourcepub async fn connect() -> Result<Self, GestaltError>
pub async fn connect() -> Result<Self, GestaltError>
Connects to the cache host service described by the environment.
Sourcepub async fn connect_named(name: &str) -> Result<Self, GestaltError>
pub async fn connect_named(name: &str) -> Result<Self, GestaltError>
Connects to the named cache host-service binding.
Sourcepub async fn get(
&mut self,
key: String,
) -> Result<Option<Vec<u8>>, GestaltError>
pub async fn get( &mut self, key: String, ) -> Result<Option<Vec<u8>>, GestaltError>
Calls gestalt.provider.v1.Cache.Get.
Sourcepub async fn get_raw(
&mut self,
request: CacheGetRequest,
) -> Result<CacheGetResponse, GestaltError>
pub async fn get_raw( &mut self, request: CacheGetRequest, ) -> Result<CacheGetResponse, GestaltError>
Calls gestalt.provider.v1.Cache.Get with the full request and response messages.
Sourcepub async fn get_many(
&mut self,
keys: Vec<String>,
) -> Result<BTreeMap<String, Vec<u8>>, GestaltError>
pub async fn get_many( &mut self, keys: Vec<String>, ) -> Result<BTreeMap<String, Vec<u8>>, GestaltError>
Calls gestalt.provider.v1.Cache.GetMany.
Sourcepub async fn get_many_raw(
&mut self,
request: CacheGetManyRequest,
) -> Result<CacheGetManyResponse, GestaltError>
pub async fn get_many_raw( &mut self, request: CacheGetManyRequest, ) -> Result<CacheGetManyResponse, GestaltError>
Calls gestalt.provider.v1.Cache.GetMany with the full request and response messages.
Sourcepub async fn set(
&mut self,
key: String,
value: Vec<u8>,
ttl: Option<Duration>,
) -> Result<(), GestaltError>
pub async fn set( &mut self, key: String, value: Vec<u8>, ttl: Option<Duration>, ) -> Result<(), GestaltError>
Calls gestalt.provider.v1.Cache.Set.
Sourcepub async fn set_raw(
&mut self,
request: CacheSetRequest,
) -> Result<(), GestaltError>
pub async fn set_raw( &mut self, request: CacheSetRequest, ) -> Result<(), GestaltError>
Calls gestalt.provider.v1.Cache.Set with the full request and response messages.
Sourcepub async fn set_many(
&mut self,
entries: Vec<CacheSetEntry>,
ttl: Option<Duration>,
) -> Result<(), GestaltError>
pub async fn set_many( &mut self, entries: Vec<CacheSetEntry>, ttl: Option<Duration>, ) -> Result<(), GestaltError>
Calls gestalt.provider.v1.Cache.SetMany.
Sourcepub async fn set_many_raw(
&mut self,
request: CacheSetManyRequest,
) -> Result<(), GestaltError>
pub async fn set_many_raw( &mut self, request: CacheSetManyRequest, ) -> Result<(), GestaltError>
Calls gestalt.provider.v1.Cache.SetMany with the full request and response messages.
Sourcepub async fn delete(&mut self, key: String) -> Result<bool, GestaltError>
pub async fn delete(&mut self, key: String) -> Result<bool, GestaltError>
Calls gestalt.provider.v1.Cache.Delete.
Sourcepub async fn delete_raw(
&mut self,
request: CacheDeleteRequest,
) -> Result<CacheDeleteResponse, GestaltError>
pub async fn delete_raw( &mut self, request: CacheDeleteRequest, ) -> Result<CacheDeleteResponse, GestaltError>
Calls gestalt.provider.v1.Cache.Delete with the full request and response messages.
Sourcepub async fn delete_many(
&mut self,
keys: Vec<String>,
) -> Result<i64, GestaltError>
pub async fn delete_many( &mut self, keys: Vec<String>, ) -> Result<i64, GestaltError>
Calls gestalt.provider.v1.Cache.DeleteMany.
Sourcepub async fn delete_many_raw(
&mut self,
request: CacheDeleteManyRequest,
) -> Result<CacheDeleteManyResponse, GestaltError>
pub async fn delete_many_raw( &mut self, request: CacheDeleteManyRequest, ) -> Result<CacheDeleteManyResponse, GestaltError>
Calls gestalt.provider.v1.Cache.DeleteMany with the full request and response messages.
Sourcepub async fn touch(
&mut self,
key: String,
ttl: Option<Duration>,
) -> Result<bool, GestaltError>
pub async fn touch( &mut self, key: String, ttl: Option<Duration>, ) -> Result<bool, GestaltError>
Calls gestalt.provider.v1.Cache.Touch.
Sourcepub async fn touch_raw(
&mut self,
request: CacheTouchRequest,
) -> Result<CacheTouchResponse, GestaltError>
pub async fn touch_raw( &mut self, request: CacheTouchRequest, ) -> Result<CacheTouchResponse, GestaltError>
Calls gestalt.provider.v1.Cache.Touch with the full request and response messages.
Auto Trait Implementations§
impl !Freeze for Cache
impl !RefUnwindSafe for Cache
impl !UnwindSafe for Cache
impl Send for Cache
impl Sync for Cache
impl Unpin for Cache
impl UnsafeUnpin for Cache
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request