kmailbox 0.1.6

A simple kafka mailbox
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use crate::KafkaError;
use crate::mail::SendMail;
use crate::util::smail_to_kafka_record;
use rdkafka::producer::FutureProducer;
use std::time::Duration;

/// 写邮箱
pub struct Writer {
    producer: FutureProducer,
}

impl Writer {
    pub(crate) fn new(producer: FutureProducer) -> Self {
        Writer { producer }
    }

    /// 写邮件
    pub async fn write<'a>(&self, name: &str, mut mail: SendMail<'a>) -> Result<(), KafkaError> {
        let record = smail_to_kafka_record(name, &mut mail);
        self.producer
            .send(record, Duration::from_secs(3))
            .await
            .map(|_| ())
            .map_err(|e| e.0)
    }
}