Public declaration syntax from forge-rs/crates/forge-agent/src/cambium.rs
Original source SHA-256: d55ca139681664d21857ea2529daf61e330c3e5279d496213b4c9f7dc53e00f2
Function bodies and constant values are omitted. This is not the complete implementation.

Source line 15
pub use cambium_sdk_rs::{CambiumEvent, CambiumJson, CambiumScope};

Source line 24
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct ForgeCambiumObserverConfig {
/// Cambium tenant/product scope assigned by the embedding host.

pub scope: CambiumScope,
/// Host-assigned Forge run id.

pub run_id: String,
/// OAS agent id or stable agent identifier for lineage.

pub agent_id: String,
/// Principal that requested or authorized the Forge run.

pub principal_id: String,
/// Authentication authority for the principal, when known.

pub authenticated_by: Option<String>,
/// Stable event id prefix used with each Forge tool call id.

pub event_id_prefix: String,
/// Optional distributed trace id.

pub trace_id: Option<String>,
/// Optional span id paired with `trace_id`.

pub span_id: Option<String>,
/// Initial producer sequence. The first emitted event increments from this.

pub producer_sequence_start: u64
}

Source line 46
pub struct CambiumAgentLoopObserver {

}

Source line 59
pub fn try_new(config: ForgeCambiumObserverConfig) -> Result<Self, String>;

Source line 76
#[must_use]
pub fn events(&self) -> Vec<CambiumEvent>;

Source line 85
#[must_use]
pub fn drain_events(&self) -> Vec<CambiumEvent>;