pub struct Config<TMsg, TMessageChannel>where
TMessageChannel: IMessageChannel,{
pub url: Url,
pub subscription_channel: TMessageChannel,
pub fn_input: fn(&Message<TMsg>) -> Result<Option<Vec<ConfigFnInputItem<TMessageChannel>>>, Error>,
pub fn_output: fn(&str) -> Result<Option<Vec<Message<TMsg>>>, Error>,
}
Fields§
§url: Url
§subscription_channel: TMessageChannel
Название канала для подписки Pub/Sub и хеша, где хранятся сообщения
§Примеры
subscription_channel: ExampleMessageChannel::Output,
fn_input: fn(&Message<TMsg>) -> Result<Option<Vec<ConfigFnInputItem<TMessageChannel>>>, Error>
Функция преобразования входящего потока сообщений в данные для отправки в Redis
§Примеры
§Заглушка
fn_input: |_| Ok(None),
§Сериализация в json
fn_input: |msg: &Message<Custom>| {
let channel = ExampleMessageChannel::Output;
let key = msg.key.clone();
let value = msg.serialize()?;
Ok(Some(vec![cmp_redis_client::ConfigFnInputItem {
channel,
key,
value,
}]))
},
Возможность рассылки в несколько каналов нужна для организации роутинга сообщений
fn_output: fn(&str) -> Result<Option<Vec<Message<TMsg>>>, Error>
Функция преобразования данных из Redis в исходящий поток сообщений
§Примеры
§Заглушка
fn_output: |_| Ok(None),
§Десериализация из json
fn_output: |text: &str| {
let msg = Message::deserialize(text)?;
Ok(Some(vec![msg]))
},
Trait Implementations§
Auto Trait Implementations§
impl<TMsg, TMessageChannel> Freeze for Config<TMsg, TMessageChannel>where
TMessageChannel: Freeze,
impl<TMsg, TMessageChannel> RefUnwindSafe for Config<TMsg, TMessageChannel>where
TMessageChannel: RefUnwindSafe,
impl<TMsg, TMessageChannel> Send for Config<TMsg, TMessageChannel>
impl<TMsg, TMessageChannel> Sync for Config<TMsg, TMessageChannel>where
TMessageChannel: Sync,
impl<TMsg, TMessageChannel> Unpin for Config<TMsg, TMessageChannel>where
TMessageChannel: Unpin,
impl<TMsg, TMessageChannel> UnwindSafe for Config<TMsg, 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