mlua-kafka 0.1.7

A Rust-native implementation of lua-kafka for mlua.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

mod close;
mod flush;
mod poll;
mod produce;

use mlua::{UserData, UserDataMethods};
use rdkafka::producer::BaseProducer;
use std::sync::Arc;

#[derive(Clone)]
pub(super) struct Producer {
    pub producer: Arc<BaseProducer>,
}

impl UserData for Producer {
    fn add_methods<M: UserDataMethods<Self>>(methods: &mut M) {
        methods.add_method("close", close::handle);
        methods.add_method("flush", flush::handle);
        methods.add_method("poll", poll::handle);
        methods.add_method("produce", produce::handle);
    }
}