dynamo-llm 1.2.0

Dynamo LLM Library
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

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

use super::handle::AuditRecord;
use crate::telemetry::bus::TelemetryBus;
use tokio::sync::broadcast;

static BUS: TelemetryBus<AuditRecord> = TelemetryBus::new();

pub fn init(capacity: usize) {
    BUS.init(capacity);
}

pub fn subscribe() -> broadcast::Receiver<AuditRecord> {
    BUS.subscribe()
}

pub fn publish(rec: AuditRecord) {
    BUS.publish(rec);
}