bevy_event_bus 1.2.0

A Bevy plugin that connects Bevy's event system to external message brokers like Kafka
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
27
28
29
30
31
32
33
34
35

use bevy::prelude::Resource;

use crate::backends::event_bus_backend::{
    BackendInstallSnapshot, LagReportingDescriptor, ManualCommitDescriptor,
};

#[derive(Resource, Clone)]
pub(crate) struct BackendReadyInfo {
    pub backend: String,
    pub topics: Vec<String>,
}

#[derive(Resource, Debug, Clone, Copy, Default)]
pub struct BackendStatus {
    pub ready: bool,
}

#[derive(Resource, Debug, Clone)]
pub struct BackendCapabilities {
    pub backend: String,
    pub message_stream: bool,
    pub manual_commit: Option<ManualCommitDescriptor>,
    pub lag_reporting: Option<LagReportingDescriptor>,
}

impl BackendCapabilities {
    pub(crate) fn from_install(backend: impl Into<String>, snapshot: BackendInstallSnapshot) -> Self {
        Self {
            backend: backend.into(),
            message_stream: snapshot.message_stream,
            manual_commit: snapshot.manual_commit,
            lag_reporting: snapshot.lag_reporting,
        }
    }
}