Struct rsiot_redis_client::cmp_redis_client::Config
source · pub struct Config<TMessage, TMessageChannel>where
TMessage: IMessage,
TMessageChannel: IMessageChannel,{
pub service_id: ServiceId,
pub url: Url,
pub subscription_channel: TMessageChannel,
pub fn_input: fn(_: &TMessage) -> Vec<TMessageChannel>,
}
Fields§
§service_id: ServiceId
Идентификатор сервиса
url: Url
Адрес сервера Redis
subscription_channel: TMessageChannel
Название канала для подписки Pub/Sub и хеша, где хранятся сообщения
fn_input: fn(_: &TMessage) -> Vec<TMessageChannel>
Функция определения канала Pub/Sub, в который отсылаются сообщения
Если все сообщения нужно отправлять только в один канал, то можно задать:
|_| vec![MessageChannel::Output]
Возможность рассылки в несколько каналов нужна для организации роутинга сообщений
Trait Implementations§
Auto Trait Implementations§
impl<TMessage, TMessageChannel> RefUnwindSafe for Config<TMessage, TMessageChannel>where
TMessageChannel: RefUnwindSafe,
impl<TMessage, TMessageChannel> Send for Config<TMessage, TMessageChannel>
impl<TMessage, TMessageChannel> Sync for Config<TMessage, TMessageChannel>where
TMessageChannel: Sync,
impl<TMessage, TMessageChannel> Unpin for Config<TMessage, TMessageChannel>where
TMessageChannel: Unpin,
impl<TMessage, TMessageChannel> UnwindSafe for Config<TMessage, TMessageChannel>where
TMessageChannel: UnwindSafe,
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
Mutably borrows from an owned value. Read more