mrcon 0.1.0

MongoDB to RabbitMQ connector library for streaming change events
Documentation 
1
2
3
4
5
6
7
8
9
10

use async_trait::async_trait;
use mongodb::{bson::Document, change_stream::event::ChangeStreamEvent};

#[async_trait]
pub trait Publish: Send + Sync + 'static {
    async fn publish(
        &self,
        event: &ChangeStreamEvent<Document>,
    ) -> Result<(), crate::rabbitmq::Error>;
}