Struct KvRedisProvider

pub struct KvRedisProvider { /* private fields */ }

Redis wrpc:keyvalue provider implementation.

Implementations

impl KvRedisProvider

pub fn name() -> &'static str

pub async fn run() -> Result<()>

pub fn new(initial_config: HashMap<String, String>) -> Self

Trait Implementations

impl Clone for KvRedisProvider

fn clone(&self) -> KvRedisProvider

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Provider for KvRedisProvider

Handle provider control commands

async fn receive_link_config_as_target( &self, __arg1: LinkConfig<'_>, ) -> Result<()>

Provider should perform any operations needed for a new link, including setting up per-component resources, and checking authorization. If the link is allowed, return true, otherwise return false to deny the link.

async fn delete_link_as_target(&self, info: impl LinkDeleteInfo) -> Result<()>

Handle notification that a link is dropped - close the connection

async fn shutdown(&self) -> Result<()>

Handle shutdown request by closing all connections

fn init( &self, init_config: impl ProviderInitConfig, ) -> impl Future<Output = Result<(), E>> + Send

Initialize the provider

fn on_config_update( &self, update: impl ProviderConfigUpdate, ) -> impl Future<Output = Result<(), E>> + Send

Process a configuration update for the provider

fn receive_link_config_as_source( &self, config: LinkConfig<'_>, ) -> impl Future<Output = Result<(), E>> + Send

Receive and handle a link that has been established on the lattice where this provider is the source.

fn delete_link_as_source( &self, _info: impl LinkDeleteInfo, ) -> impl Future<Output = Result<(), E>> + Send

Notify the provider that the link is dropped where the provider is the source

fn health_request( &self, _arg: &HealthCheckRequest, ) -> impl Future<Output = Result<HealthCheckResponse, E>> + Send

Perform health check. Called at regular intervals by host Default implementation always returns healthy