dynamo-llm 1.6.2

Dynamo LLM Library
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

// SPDX-FileCopyrightText: Copyright (c) 2024-2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
// SPDX-License-Identifier: Apache-2.0

mod broker_zmq;
mod direct_zmq;
mod recovery_lane;
mod source_health;
mod state_agent;
mod subscriber;
mod target;
mod worker_query;
mod worker_query_endpoint;
mod worker_query_state;
mod worker_query_transport;

pub(crate) use state_agent::start_state_agent_router;
pub(crate) use subscriber::{
    KvEventSubscriptionHandle, RecoverySupervisor, start_subscriber, start_target_subscriber,
};
pub(crate) use target::{IndexerRecoveryTarget, RecoveryResetReason, RecoveryTarget};
pub(crate) use worker_query::DEFAULT_RECOVERY_ATTEMPT_TIMEOUT;
pub(crate) use worker_query::TargetFaultDisposition;
#[cfg(test)]
pub(crate) use worker_query::WorkerQueryClient;
#[cfg(feature = "ckf-diagnostics")]
pub(crate) use worker_query::WorkerQueryHealthSnapshot;
pub(crate) use worker_query_endpoint::{
    start_worker_kv_query_endpoint, start_worker_kv_query_endpoint_with_status,
};
pub(crate) use worker_query_transport::RuntimeWorkerQueryTransport;
#[cfg(test)]
pub(crate) use worker_query_transport::WorkerQueryTransport;