Skip to main content

infraqueue_lib/
lib.rs

1pub mod cli;
2pub mod config;
3pub mod model;
4pub mod queue;
5pub mod client;
6
7pub use model::InfraQueueMessage;
8pub use queue::{DequeueWithReceipt, InfraQueueQueue, NackOutcome, RetryPolicy};
9pub use client::{
10    AckRequest, DequeueRequest, DequeueResponse, EnqueueRequest, HeartbeatRequest,
11    InfraQueueClient, NackRequest,
12};
13
14/// Initialize logging for binaries using env_logger; idempotent.
15/// Set RUST_LOG to control verbosity (e.g., "debug" or "actix_web=info,infraqueue=debug").
16pub fn init_logging() {
17    let _ = env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info"))
18        .try_init();
19}
20
21pub fn add(left: u64, right: u64) -> u64 {
22    left + right
23}