distributed-topic-tracker 0.3.2

automagically find peers interested in a topic + iroh-gossip integration
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
42
43
44
45
46
47
48

#![doc = include_str!("../README.md")]

mod config;
mod crypto;
mod dht;

#[cfg(feature = "iroh-gossip")]
mod gossip;
#[cfg(feature = "iroh-gossip")]
pub use gossip::{
    AutoDiscoveryGossip, Bootstrap, BubbleMerge, GossipReceiver, GossipRecordContent, GossipSender,
    MessageOverlapMerge, Publisher, Topic,
};

pub use config::{
    BootstrapConfig, BootstrapConfigBuilder, BubbleMergeConfig, BubbleMergeConfigBuilder, Config,
    ConfigBuilder, DhtConfig, DhtConfigBuilder, MergeConfig, MergeConfigBuilder,
    MessageOverlapMergeConfig, MessageOverlapMergeConfigBuilder, PublisherConfig,
    PublisherConfigBuilder, TimeoutConfig, TimeoutConfigBuilder, 
};
pub use crypto::{
    DefaultSecretRotation, EncryptedRecord, Record, RecordPublisher, RotationHandle,
    SecretRotation, TopicId, encryption_keypair, salt, signing_keypair,
};
pub use dht::Dht;

/// These are part of the on-wire format: DO NOT CHANGE without increasing protocol version.
pub const MAX_RECORD_PEERS: usize = 5;
pub const MAX_MESSAGE_HASHES: usize = 5;

/// Get the current Unix minute timestamp, optionally offset.
///
/// # Arguments
///
/// * `minute_offset` - Offset in minutes from now (can be negative)
///
/// # Example
///
/// ```ignore
/// let now = unix_minute(0);
/// let prev_minute = unix_minute(-1);
/// ```
#[doc(hidden)]
pub fn unix_minute(minute_offset: i64) -> u64 {
    ((chrono::Utc::now().timestamp() / 60).saturating_add(minute_offset))
        .try_into()
        .expect("timestamp overflow")
}