telemetry

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

type ComponentSnapshot struct {
	Name           string                    `json:"name"`
	Status         string                    `json:"status"`
	Pressure       string                    `json:"pressure"`
	Active         int64                     `json:"active"`
	RowsPerSecond  float64                   `json:"rows_per_second"`
	BytesPerSecond float64                   `json:"bytes_per_second"`
	ErrorRate      float64                   `json:"error_rate"`
	Latency        LatencySnapshot           `json:"latency"`
	Queue          QueueSnapshot             `json:"queue"`
	Windows        map[string]WindowSnapshot `json:"windows"`
}

type Config struct {
	BufferSize  int
	FeedSize    int
	HistorySize int
}

type EdgeSnapshot struct {
	From          string  `json:"from"`
	To            string  `json:"to"`
	ThroughputMBs float64 `json:"throughput_mbps"`
	Imbalance     float64 `json:"imbalance"`
	Status        string  `json:"status"`
	Pressure      string  `json:"pressure"`
}

type Event struct {
	Time      time.Time      `json:"time"`
	Component string         `json:"component"`
	Type      string         `json:"type"`
	Rows      int64          `json:"rows"`
	Bytes     int64          `json:"bytes"`
	Latency   time.Duration  `json:"latency"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type FeedEvent struct {
	Time       time.Time `json:"time"`
	Path       string    `json:"path"`
	Component  string    `json:"component"`
	Type       string    `json:"type"`
	Message    string    `json:"message"`
	Rows       int64     `json:"rows"`
	Bytes      int64     `json:"bytes"`
	LatencyMS  float64   `json:"latency_ms"`
	QueueDepth int64     `json:"queue_depth"`
}

type HealthSnapshot struct {
	Status  string   `json:"status"`
	Reasons []string `json:"reasons"`
}

type LatencySnapshot struct {
	P50MS float64 `json:"p50_ms"`
	P95MS float64 `json:"p95_ms"`
	P99MS float64 `json:"p99_ms"`
}

type PathSnapshot struct {
	Name          string          `json:"name"`
	Status        string          `json:"status"`
	RowsPerSecond float64         `json:"rows_per_second"`
	MBPerSecond   float64         `json:"mb_per_second"`
	ErrorRate     float64         `json:"error_rate"`
	Latency       LatencySnapshot `json:"latency"`
	Window        string          `json:"window"`
}

type Publisher interface {
	Publish(Event) bool
}

type QueueSnapshot struct {
	Current     int64   `json:"current"`
	Capacity    int64   `json:"capacity"`
	Utilization float64 `json:"utilization"`
	Max1s       int64   `json:"max_1s"`
	Max1m       int64   `json:"max_1m"`
	Unit        string  `json:"unit,omitempty"`
}

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

type Snapshot struct {
	Time          time.Time           `json:"time"`
	Components    []ComponentSnapshot `json:"components"`
	Edges         []EdgeSnapshot      `json:"edges"`
	Paths         []PathSnapshot      `json:"paths"`
	Feed          []FeedEvent         `json:"feed,omitempty"`
	Health        HealthSnapshot      `json:"health"`
	DroppedEvents uint64              `json:"dropped_events"`
}

type WindowSnapshot struct {
	RowsPerSecond  float64         `json:"rows_per_second"`
	BytesPerSecond float64         `json:"bytes_per_second"`
	ErrorRate      float64         `json:"error_rate"`
	Latency        LatencySnapshot `json:"latency"`
	QueueDepth     int64           `json:"queue_depth"`
	QueueCapacity  int64           `json:"queue_capacity"`
}