bevy_event_bus 1.1.3

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

use bevy::prelude::Resource;

use crate::config::{kafka::KafkaTopologyConfig, redis::RedisTopologyConfig};

/// Tracks the provisioned backend topologies so readers can validate configuration without
/// touching backend internals. Only one backend of each type is expected to be active.
#[derive(Resource, Clone, Debug, Default)]
pub struct ProvisionedTopology {
    kafka: Option<KafkaTopologyConfig>,
    redis: Option<RedisTopologyConfig>,
}

impl ProvisionedTopology {
    /// Stores the provisioned Kafka topology, replacing any previous value.
    pub fn record_kafka(&mut self, topology: KafkaTopologyConfig) {
        self.kafka = Some(topology);
    }

    /// Stores the provisioned Redis topology, replacing any previous value.
    pub fn record_redis(&mut self, topology: RedisTopologyConfig) {
        self.redis = Some(topology);
    }

    /// Returns the provisioned Kafka topology, if available.
    pub fn kafka(&self) -> Option<&KafkaTopologyConfig> {
        self.kafka.as_ref()
    }

    /// Returns the provisioned Redis topology, if available.
    pub fn redis(&self) -> Option<&RedisTopologyConfig> {
        self.redis.as_ref()
    }
}