Struct Redis 

pub struct Redis<F, P = String> {
    pub format: F,
    /* private fields */
}

Fields

format: F

Implementations

impl<F, P> Redis<F, P>

where F: ConfigFormat, P: RedisParam,

pub fn new( param: P, format: F, ) -> Result<Redis<F, P>, Box<dyn Error + Send + Sync>>

pub async fn get_con(&self) -> Result<Connection, Box<dyn Error + Send + Sync>>

Trait Implementations

impl<F> Create for Redis<F>

where F: ConfigFormat + Send + Sync,

async fn create_config_item_gateway( &self, gateway_name: &str, gateway: SgGateway, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn create_config_item_route( &self, gateway_name: &str, route_name: &str, route: SgHttpRoute, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn create_plugin( &self, id: &PluginInstanceId, value: Value, ) -> Result<(), Box<dyn Error + Send + Sync>>

fn create_config_item( &self, name: &str, item: ConfigItem, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

fn create_config( &self, config: Config, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

impl<F> CreateListener for Redis<F>

where F: ConfigFormat + Clone + Send + Sync + 'static,

const CONFIG_LISTENER_NAME: &'static str = "file"

type Listener = RedisListener

async fn create_listener( &self, ) -> Result<(Config, <Redis<F> as CreateListener>::Listener), Box<dyn Error + Send + Sync>>

impl<F> Delete for Redis<F>

where F: ConfigFormat + Send + Sync,

async fn delete_config_item_gateway( &self, gateway_name: &str, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn delete_config_item_route( &self, gateway_name: &str, route_name: &str, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn delete_plugin( &self, id: &PluginInstanceId, ) -> Result<(), Box<dyn Error + Send + Sync>>

fn delete_config_item_all_routes( &self, gateway_name: &str, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

where Self: Retrieve,

fn delete_config_item( &self, name: &str, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

where Self: Retrieve,

impl<F> Retrieve for Redis<F>

where F: ConfigFormat + Send + Sync,

async fn retrieve_config_item_gateway( &self, gateway_name: &str, ) -> Result<Option<SgGateway>, Box<dyn Error + Send + Sync>>

async fn retrieve_config_item_route( &self, gateway_name: &str, route_name: &str, ) -> Result<Option<SgHttpRoute>, Box<dyn Error + Send + Sync>>

async fn retrieve_config_item_route_names( &self, name: &str, ) -> Result<Vec<String>, Box<dyn Error + Send + Sync>>

async fn retrieve_config_names( &self, ) -> Result<Vec<String>, Box<dyn Error + Send + Sync>>

async fn retrieve_all_plugins( &self, ) -> Result<Vec<PluginConfig>, Box<dyn Error + Send + Sync>>

async fn retrieve_plugin( &self, id: &PluginInstanceId, ) -> Result<Option<PluginConfig>, Box<dyn Error + Send + Sync>>

async fn retrieve_plugins_by_code( &self, code: &str, ) -> Result<Vec<PluginConfig>, Box<dyn Error + Send + Sync>>

fn retrieve_config_item_all_routes( &self, name: &str, ) -> impl Future<Output = Result<BTreeMap<String, SgHttpRoute>, Box<dyn Error + Send + Sync>>> + Send

fn retrieve_config_item( &self, name: &str, ) -> impl Future<Output = Result<Option<ConfigItem>, Box<dyn Error + Send + Sync>>> + Send

fn retrieve_config( &self, ) -> impl Future<Output = Result<Config, Box<dyn Error + Send + Sync>>> + Send

where Self: Sync, Box<dyn Error + Send + Sync>: Send,

impl<F> Update for Redis<F>

where F: ConfigFormat + Send + Sync,

async fn update_config_item_gateway( &self, gateway_name: &str, gateway: SgGateway, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn update_config_item_route( &self, gateway_name: &str, route_name: &str, route: SgHttpRoute, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn update_plugin( &self, id: &PluginInstanceId, value: Value, ) -> Result<(), Box<dyn Error + Send + Sync>>

fn update_config_item( &self, name: &str, item: ConfigItem, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

fn update_config( &self, config: Config, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send