waitup 1.0.1

Wait for TCP ports and HTTP endpoints to be available. Essential for Docker, K8s, and CI/CD pipelines to ensure services are ready before proceeding.
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

#![allow(
    clippy::print_stdout,
    clippy::uninlined_format_args,
    reason = "example code that demonstrates library usage"
)]

//! Multiple services orchestration example.
//!
//! This example demonstrates complex service orchestration with different
//! wait strategies for different groups of services.
//! Run with: cargo run --example `multiple_services`

use std::time::Duration;
use waitup::{wait_for_connection, Target, WaitConfig};

async fn wait_for_core_services() -> Result<(), waitup::WaitForError> {
    println!("🏗️  Phase 1: Waiting for core infrastructure services...");

    let core_services = vec![
        Target::tcp("postgres", 5432)?,      // Primary database
        Target::tcp("redis", 6379)?,         // Cache
        Target::tcp("elasticsearch", 9200)?, // Search engine
    ];

    let config = WaitConfig::builder()
        .timeout(Duration::from_secs(180)) // 3 minutes for core services
        .interval(Duration::from_secs(2))
        .wait_for_any(false) // ALL core services must be ready
        .build();

    let result = wait_for_connection(&core_services, &config).await?;
    println!("✅ Core services ready in {:?}", result.elapsed);

    Ok(())
}

async fn wait_for_application_services() -> Result<(), waitup::WaitForError> {
    println!("🚀 Phase 2: Waiting for application services...");

    let app_services = vec![
        Target::parse("http://auth-service:8001/health", 200)?,
        Target::parse("http://user-service:8002/health", 200)?,
        Target::parse("http://notification-service:8003/health", 200)?,
        Target::parse("http://payment-service:8004/health", 200)?,
    ];

    let config = WaitConfig::builder()
        .timeout(Duration::from_secs(120)) // 2 minutes for app services
        .interval(Duration::from_secs(3))
        .wait_for_any(false)
        .build();

    let result = wait_for_connection(&app_services, &config).await?;
    println!("✅ Application services ready in {:?}", result.elapsed);

    Ok(())
}

async fn wait_for_external_dependencies() -> Result<(), waitup::WaitForError> {
    println!("🌐 Phase 3: Checking external dependencies (any one available)...");

    // Multiple external APIs - we only need one to be available
    let external_apis = vec![
        Target::parse("https://api.stripe.com/v1", 401)?, // Expected auth error
        Target::parse("https://api.sendgrid.com/v3", 401)?, // Expected auth error
        Target::parse("https://hooks.slack.com/services", 404)?, // Expected not found
    ];

    let config = WaitConfig::builder()
        .timeout(Duration::from_secs(60)) // 1 minute for external APIs
        .interval(Duration::from_secs(5))
        .wait_for_any(true) // ANY external API working is fine
        .build();

    let result = wait_for_connection(&external_apis, &config).await?;
    println!("✅ External dependencies available in {:?}", result.elapsed);

    Ok(())
}

async fn start_load_balancer() -> Result<(), waitup::WaitForError> {
    println!("⚖️  Phase 4: Starting load balancer...");

    // Check that our load balancer is ready
    let lb_target = vec![Target::parse("http://load-balancer:80/health", 200)?];

    let config = WaitConfig::builder()
        .timeout(Duration::from_secs(30))
        .interval(Duration::from_secs(2))
        .build();

    let result = wait_for_connection(&lb_target, &config).await?;
    println!("✅ Load balancer ready in {:?}", result.elapsed);

    Ok(())
}

#[tokio::main]
async fn main() -> Result<(), waitup::WaitForError> {
    println!("🎭 Complex Multi-Service Orchestration Example");
    println!("============================================");

    let start_time = std::time::Instant::now();

    // Phase 1: Core infrastructure must be ready first
    wait_for_core_services().await?;

    // Phase 2: Application services depend on core infrastructure
    wait_for_application_services().await?;

    // Phase 3: External dependencies (at least one must work)
    wait_for_external_dependencies().await?;

    // Phase 4: Load balancer brings everything together
    start_load_balancer().await?;

    let total_time = start_time.elapsed();

    println!();
    println!("🎉 All services are orchestrated and ready!");
    println!("⏱️  Total orchestration time: {:?}", total_time);
    println!("🌟 Your distributed system is now fully operational!");

    // At this point, you could start accepting traffic or run your main application

    Ok(())
}