Struct Config

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

Адрес сервера Redis

Примеры

url: Url::parse("redis://redis:6379").unwrap(),

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

impl<TMsg, TMessageChannel> Clone for Config<TMsg, TMessageChannel>

where TMsg: Clone, TMessageChannel: Clone + IMessageChannel,

fn clone(&self) -> Config<TMsg, TMessageChannel>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<TMsg, TMessageChannel> Debug for Config<TMsg, TMessageChannel>

where TMsg: Debug, TMessageChannel: Debug + IMessageChannel,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.