eventure 0.0.17

Event-Driven messaging library for Rust
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
36
37
38
39
40
41

// -----------------------------------------------------------------------------------------------------------------------------------------
// Rust-Lang Libs/Eventure 2024
// -----------------------------------------------------------------------------------------------------------------------------------------

// -----------------------------------------------------------------------------------------------------------------------------------------
// Public structs
// -----------------------------------------------------------------------------------------------------------------------------------------

/// Iggy message channel definition.
pub struct MessageChannel {
    pub stream_id: u32,
    pub topic_id: u32,
    pub partition_id: u32,
}

/// Iggy message broker configuration.
pub struct MessageBrokerConfiguration {
    pub message_channel: MessageChannel,
    pub server: &'static str,
}

// -----------------------------------------------------------------------------------------------------------------------------------------
// Public functions
// -----------------------------------------------------------------------------------------------------------------------------------------

/// Creates Iggy message channel.
pub fn message_channel(stream_id: u32, topic_id: u32, partition_id: u32) -> MessageChannel {
    MessageChannel {
        stream_id,
        topic_id,
        partition_id
    }
}

/// Creates Iggy message broker configuration.
pub fn configuration(server: &'static str, message_channel: MessageChannel) -> MessageBrokerConfiguration {
    MessageBrokerConfiguration {
        message_channel,
        server,
    }
}