realtime

Documentation

Index

• type MetricsCollector
• type MetricsSnapshot
• type PipelineMonitor

Types

type MetricsCollector

type MetricsCollector interface {
	Collect(ctx context.Context) (*MetricsSnapshot, error)
	GetMetricTypes() []string
}

type MetricsSnapshot

type MetricsSnapshot struct {
	Timestamp     time.Time
	TaskMetrics   map[string]float64
	NodeMetrics   map[string]float64
	SystemMetrics SystemMetrics
}

type PipelineMonitor

type PipelineMonitor struct {
	// contains filtered or unexported fields
}