metrics

type AppLookup func(slug string) (int64, error)

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

type MetricAggregator interface {
	AggregateMetrics(sourceTier, destTier string, olderThan time.Time) error
	PruneMetrics(tier string, before time.Time) (int64, error)
}

type MetricInserter interface {
	InsertMetrics(points []MetricPoint) error
}

type MetricPoint struct {
	AppID       *int64
	ContainerID string
	CPUPct      float64
	MemBytes    int64
	MemLimit    int64
	NetRx       float64
	NetTx       float64
	DiskRead    float64
	DiskWrite   float64
	Ts          int64
	Tier        string
}

type ReqMetricsAggregator interface {
	AggregateRequestMetrics(sourceTier, destTier string, olderThan time.Time) error
	PruneRequestMetrics(tier string, before time.Time) (int64, error)
}

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

type RequestMetricPoint struct {
	AppID      int64
	Ts         int64
	Tier       string
	Count      int64
	ErrorCount int64
	AvgLatency float64
	MaxLatency float64
}

type RequestMetricsInserter interface {
	InsertRequestMetrics(points []RequestMetricPoint) error
}

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

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

type StatusApp struct {
	Slug   string
	Status string
}

type StatusSyncer interface {
	ListApps() ([]StatusApp, error)
	UpdateAppStatus(slug, status string) error
}

type TierConfig struct {
	Name      string
	Retention time.Duration
}

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