pub struct MonitoringManager { /* private fields */ }
Expand description
監視マネージャー
Implementations§
Source§impl MonitoringManager
impl MonitoringManager
pub fn new(config: MonitoringConfig) -> Self
Sourcepub fn add_exporter(&mut self, exporter: Box<dyn MonitoringExporterImpl>)
pub fn add_exporter(&mut self, exporter: Box<dyn MonitoringExporterImpl>)
エクスポーターを追加
Sourcepub async fn record_metric(&self, metric: Metric) -> Result<(), MonitoringError>
pub async fn record_metric(&self, metric: Metric) -> Result<(), MonitoringError>
メトリクスを記録
Sourcepub async fn increment_counter(
&self,
name: &str,
labels: HashMap<String, String>,
value: u64,
) -> Result<(), MonitoringError>
pub async fn increment_counter( &self, name: &str, labels: HashMap<String, String>, value: u64, ) -> Result<(), MonitoringError>
カウンターメトリクスをインクリメント
Sourcepub async fn update_gauge(
&self,
name: &str,
labels: HashMap<String, String>,
value: f64,
) -> Result<(), MonitoringError>
pub async fn update_gauge( &self, name: &str, labels: HashMap<String, String>, value: f64, ) -> Result<(), MonitoringError>
ゲージメトリクスを更新
Sourcepub async fn record_trace_span(
&self,
span: TraceSpan,
) -> Result<(), MonitoringError>
pub async fn record_trace_span( &self, span: TraceSpan, ) -> Result<(), MonitoringError>
トレーススパンを記録
Sourcepub async fn record_log(&self, entry: LogEntry) -> Result<(), MonitoringError>
pub async fn record_log(&self, entry: LogEntry) -> Result<(), MonitoringError>
ログエントリを記録
Sourcepub async fn update_workflow_stats(
&self,
workflow_id: &str,
execution_time: Duration,
status: &ExecutionStatus,
) -> Result<(), MonitoringError>
pub async fn update_workflow_stats( &self, workflow_id: &str, execution_time: Duration, status: &ExecutionStatus, ) -> Result<(), MonitoringError>
ワークフロー実行統計を更新
Sourcepub async fn update_activity_stats(
&self,
activity_name: &str,
execution_time: Duration,
success: bool,
) -> Result<(), MonitoringError>
pub async fn update_activity_stats( &self, activity_name: &str, execution_time: Duration, success: bool, ) -> Result<(), MonitoringError>
Activity実行統計を更新
Sourcepub async fn track_workflow_event(
&self,
execution_id: &WorkflowExecutionId,
event_type: ExecutionEventType,
metadata: HashMap<String, Value>,
) -> Result<(), MonitoringError>
pub async fn track_workflow_event( &self, execution_id: &WorkflowExecutionId, event_type: ExecutionEventType, metadata: HashMap<String, Value>, ) -> Result<(), MonitoringError>
ワークフロー実行イベントを監視
Sourcepub async fn track_activity_event(
&self,
execution_id: &WorkflowExecutionId,
activity_id: &ActivityExecutionId,
activity_name: &str,
success: bool,
execution_time: Duration,
) -> Result<(), MonitoringError>
pub async fn track_activity_event( &self, execution_id: &WorkflowExecutionId, activity_id: &ActivityExecutionId, activity_name: &str, success: bool, execution_time: Duration, ) -> Result<(), MonitoringError>
Activity実行イベントを監視
Sourcepub async fn perform_health_check(&self) -> SystemHealth
pub async fn perform_health_check(&self) -> SystemHealth
システムヘルスチェックを実行
Sourcepub async fn get_workflow_stats(
&self,
workflow_id: &str,
) -> Option<WorkflowStats>
pub async fn get_workflow_stats( &self, workflow_id: &str, ) -> Option<WorkflowStats>
ワークフロー統計を取得
Sourcepub async fn get_activity_stats(
&self,
activity_name: &str,
) -> Option<ActivityStats>
pub async fn get_activity_stats( &self, activity_name: &str, ) -> Option<ActivityStats>
Activity統計を取得
Sourcepub async fn get_all_metrics(&self) -> Vec<Metric>
pub async fn get_all_metrics(&self) -> Vec<Metric>
全てのメトリクスを取得
Sourcepub async fn get_recent_logs(&self, limit: usize) -> Vec<LogEntry>
pub async fn get_recent_logs(&self, limit: usize) -> Vec<LogEntry>
最近のログを取得
Auto Trait Implementations§
impl !Freeze for MonitoringManager
impl !RefUnwindSafe for MonitoringManager
impl Send for MonitoringManager
impl Sync for MonitoringManager
impl Unpin for MonitoringManager
impl !UnwindSafe for MonitoringManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more