Struct MaterializedView 

pub struct MaterializedView { /* private fields */ }

Implementations

impl MaterializedView

pub fn ingest_event(&mut self, event: &Event) -> ViewResult<()>

impl MaterializedView

pub fn new() -> Self

pub fn bounded() -> Self

pub fn shared_bounded() -> SharedMaterializedView

pub fn add_sink(&mut self, sink: Box<dyn ViewSink>)

pub fn set_source(&mut self, source: impl Into<String>)

pub fn emit_llm_call(&mut self, row: LlmCallRow) -> ViewResult<()>

pub fn emit_token_usage(&mut self, row: TokenUsageRow) -> ViewResult<()>

pub fn emit_audit_event(&mut self, row: AuditEventRow) -> ViewResult<()>

pub fn emit_process_node(&mut self, row: ProcessNodeRow) -> ViewResult<()>

pub fn emit_tool_call(&mut self, row: ToolCallRow) -> ViewResult<()>

pub fn emit_network_target(&mut self, row: NetworkTargetRow) -> ViewResult<()>

pub fn emit_resource_sample(&mut self, row: ResourceSampleRow) -> ViewResult<()>

impl MaterializedView

pub fn apply_llm_call(&mut self, row: &LlmCallRow)

pub fn apply_token_usage(&mut self, row: &TokenUsageRow)

pub fn apply_audit_event(&mut self, row: &AuditEventRow)

pub fn apply_tool_call(&mut self, row: &ToolCallRow)

pub fn apply_resource_sample(&mut self, row: &ResourceSampleRow)

pub fn upsert_session(&mut self, row: &SessionRow)

pub fn upsert_network_target(&mut self, row: &NetworkTargetRow)

pub fn upsert_process_node(&mut self, row: &ProcessNodeRow)

pub fn export_snapshot(&self, options: SnapshotOptions) -> Snapshot

pub fn token_summary(&self, group_by: &str) -> Vec<TokenSummary>

pub fn audit_rows( &self, audit_type: Option<&str>, limit: usize, ) -> Vec<AuditEventRow>

pub fn llm_call_rows(&self, limit: usize) -> Vec<LlmCallRow>

Trait Implementations

impl Default for MaterializedView

fn default() -> MaterializedView

Returns the “default value” for a type.