Struct FlowStoreService

pub struct FlowStoreService { /* private fields */ }

Struct representing a service for managing flows in a Redis.

Trait Implementations

impl Clone for FlowStoreService

fn clone(&self) -> FlowStoreService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FlowStoreServiceBase for FlowStoreService

Implementation of a service for managing flows in a Redis.

fn insert_flow<'life0, 'async_trait>( &'life0 mut self, flow: Flow, ) -> Pin<Box<dyn Future<Output = Result<i64, FlowStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Insert a list of flows into Redis

fn insert_flows<'life0, 'async_trait>( &'life0 mut self, flows: Flows, ) -> Pin<Box<dyn Future<Output = Result<i64, FlowStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Insert a flows into Redis

fn delete_flow<'life0, 'async_trait>( &'life0 mut self, flow_id: i64, ) -> Pin<Box<dyn Future<Output = Result<i64, RedisError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Deletes a flow

fn delete_flows<'life0, 'async_trait>( &'life0 mut self, flow_ids: Vec<i64>, ) -> Pin<Box<dyn Future<Output = Result<i64, RedisError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Deletes a list of flows

fn get_all_flow_ids<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Vec<i64>, RedisError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Queries for all ids in the redis Returns Result<Vec<i64>, RedisError>: Result of the flow ids currently in Redis

fn new<'async_trait>( redis_client_arc: FlowStore, ) -> Pin<Box<dyn Future<Output = FlowStoreService> + Send + 'async_trait>>

fn query_flows<'life0, 'async_trait>( &'life0 mut self, pattern: String, ) -> Pin<Box<dyn Future<Output = Result<Flows, FlowStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,