solti-discover 0.0.2

Solti SDK agent-registration and heartbeat client for the Podium control-plane.
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

//! # solti-discover - agent heartbeat.
//!
//! Periodic sync task that registers an agent with the control plane and reports liveness and platform telemetry.
//!
//! | feature | transport         | protocol                      |
//! |---------|-------------------|-------------------------------|
//! | `grpc`  | tonic gRPC client | `proto/v1/sync.proto`         |
//! | `http`  | reqwest HTTP/JSON | `POST /api/v1/discovery/sync` |
//!
//! ## Quick start
//!
//! ```text
//! let cfg = DiscoverConfig::builder(/* ... */).build()?;
//! let (task, spec) = solti_discover::sync(cfg)?;
//! supervisor.submit_with_task(task, &spec).await?;
//! ```
//!
//! ## Also
//!
//! - [`DiscoverConfig`] / [`DiscoverConfigBuilder`] identity, endpoint, transport, timeouts, capabilities.
//! - [`DiscoverError`] config, transport, parse, and rejection failures.
//! - [`sync`] factory returning `Result<(TaskRef, TaskSpec), DiscoverError>`.

mod errors;
pub use errors::DiscoverError;

mod metrics;
pub use metrics::{
    DiscoverMetricsBackend, DiscoverMetricsHandle, FAIL_AUTH, FAIL_CONNECT, FAIL_OTHER, FAIL_PARSE,
    FAIL_REJECTED_CLIENT, FAIL_REJECTED_SERVER, FAIL_TIMEOUT, NoOpDiscoverMetrics, OUTCOME_FAILURE,
    OUTCOME_SUCCESS, noop_discover_metrics,
};

#[cfg(any(feature = "grpc", feature = "http"))]
mod config;
#[cfg(any(feature = "grpc", feature = "http"))]
pub use config::{
    DEFAULT_CONNECT_TIMEOUT_MS, DEFAULT_REQUEST_TIMEOUT_MS, DiscoverConfig, DiscoverConfigBuilder,
    DiscoveryTransport,
};

#[cfg(any(feature = "grpc", feature = "http"))]
mod tasks;
#[cfg(any(feature = "grpc", feature = "http"))]
pub use tasks::sync;

#[cfg(any(feature = "grpc", feature = "http"))]
pub(crate) mod proto {
    include!(concat!(env!("OUT_DIR"), "/solti.discover.v1.rs"));

    #[cfg(feature = "http")]
    include!(concat!(env!("OUT_DIR"), "/solti.discover.v1.serde.rs"));
}

#[cfg(any(feature = "grpc", feature = "http"))]
pub use proto::{SyncRequest, SyncResponse};