Struct GrpcKv 

pub struct GrpcKv { /* private fields */ }

gRPC-based KV implementation that forwards calls to a remote KV service

Implementations

impl GrpcKv

pub async fn new( binding_name: String, grpc_endpoint: String, ) -> Result<GrpcKv, AlienError<ErrorData>>

Create a new gRPC KV client

pub async fn new_from_channel( channel: Channel, binding_name: String, ) -> Result<GrpcKv, AlienError<ErrorData>>

Create a new gRPC KV client from an existing channel

Trait Implementations

impl Binding for GrpcKv

impl Debug for GrpcKv

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

Formats the value using the given formatter.

impl Kv for GrpcKv

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, AlienError<ErrorData>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, GrpcKv: 'async_trait,

Get a value by key. Returns None if key doesn’t exist or has expired.

fn put<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: Vec<u8>, options: Option<PutOptions>, ) -> Pin<Box<dyn Future<Output = Result<bool, AlienError<ErrorData>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, GrpcKv: 'async_trait,

Put a value with optional options. When options.if_not_exists is true, returns true if created, false if already exists. When options.if_not_exists is false or options is None, always returns true.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), AlienError<ErrorData>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, GrpcKv: 'async_trait,

Delete a key. No error if key doesn’t exist.

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, AlienError<ErrorData>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, GrpcKv: 'async_trait,

Check if a key exists without retrieving the value.

fn scan_prefix<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, limit: Option<usize>, cursor: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<ScanResult, AlienError<ErrorData>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, GrpcKv: 'async_trait,

Scan keys with a prefix, with pagination support.