resource

Mar 8, 2026

Changes in this version

+ type Deps struct

+ ContainerSvc *container.Service

+ EventCallback EventCallback

+ Logger *slog.Logger

+ Runtime pbruntime.Runtime

+ Store ResourceStore

Mar 5, 2026

Changes in this version

type Collector

+ func (c *Collector) GetHostStat() *HostStatReader

+ type HostStatReader struct

+ func NewHostStatReader() *HostStatReader

+ func (r *HostStatReader) CPUPercent() float64

+ func (r *HostStatReader) MemTotal() int64

+ func (r *HostStatReader) MemUsed() int64

+ func (r *HostStatReader) Start(ctx context.Context)

type Service

+ func (s *Service) GetHostStat() *HostStatReader

Mar 5, 2026

Changes in this version

+ type AlertState string

+ const AlertStateBoth

+ const AlertStateCPU

+ const AlertStateMemory

+ const AlertStateNormal

+ type Collector struct

+ func NewCollector(rt pbruntime.Runtime, containerSvc *container.Service, logger *slog.Logger) *Collector

+ func (c *Collector) GetAllLatest() map[int64]*ResourceSnapshot

+ func (c *Collector) GetLatestSnapshot(containerID int64) *ResourceSnapshot

+ func (c *Collector) SetInterval(d time.Duration)

+ func (c *Collector) SetOnSnapshot(fn func(snap *ResourceSnapshot))

+ func (c *Collector) Start(ctx context.Context)

+ type EventCallback func(eventType string, data interface{})

+ type Granularity string

+ const Granularity1h

+ const Granularity1m

+ const Granularity5m

+ const GranularityRaw

+ type ResourceAlertConfig struct

+ AlertState AlertState

+ CPUConsecutiveBreaches int

+ CPUThreshold float64

+ ContainerID int64

+ CreatedAt time.Time

+ Enabled bool

+ ID int64

+ LastAlertedAt *time.Time

+ MemConsecutiveBreaches int

+ MemThreshold float64

+ UpdatedAt time.Time

+ type ResourceSnapshot struct

+ BlockReadBytes int64

+ BlockWriteBytes int64

+ CPUPercent float64

+ ContainerID int64

+ ID int64

+ MemLimit int64

+ MemUsed int64

+ NetRxBytes int64

+ NetTxBytes int64

+ Timestamp time.Time

+ type ResourceStore interface

+ AggregateDailyRollup func(ctx context.Context, bucketStart, bucketEnd time.Time) error

+ AggregateHourlyRollup func(ctx context.Context, bucketStart, bucketEnd time.Time) error

+ DeleteDailyBefore func(ctx context.Context, before time.Time, batchSize int) (int64, error)

+ DeleteHourlyBefore func(ctx context.Context, before time.Time, batchSize int) (int64, error)

+ DeleteSnapshotsBefore func(ctx context.Context, before time.Time, batchSize int) (int64, error)

+ GetAlertConfig func(ctx context.Context, containerID int64) (*ResourceAlertConfig, error)

+ GetLatestSnapshot func(ctx context.Context, containerID int64) (*ResourceSnapshot, error)

+ GetTopConsumersByPeriod func(ctx context.Context, metric string, period string, limit int) ([]TopConsumerRow, error)

+ InsertDailyRollup func(ctx context.Context, r *RollupRow) error

+ InsertHourlyRollup func(ctx context.Context, r *RollupRow) error

+ InsertSnapshot func(ctx context.Context, s *ResourceSnapshot) (int64, error)

+ ListSnapshots func(ctx context.Context, containerID int64, from, to time.Time) ([]*ResourceSnapshot, error)

+ ListSnapshotsAggregated func(ctx context.Context, containerID int64, from, to time.Time, ...) ([]*ResourceSnapshot, error)

+ UpsertAlertConfig func(ctx context.Context, cfg *ResourceAlertConfig) error

+ type RollupRow struct

+ AvgCPUPercent float64

+ AvgMemLimit int64

+ AvgMemUsed int64

+ AvgNetRx int64

+ AvgNetTx int64

+ Bucket time.Time

+ ContainerID int64

+ SampleCount int

+ type Service struct

+ func NewService(store ResourceStore, rt pbruntime.Runtime, containerSvc *container.Service, ...) *Service

+ func (s *Service) GetAlertConfig(ctx context.Context, containerID int64) (*ResourceAlertConfig, error)

+ func (s *Service) GetAllLatestSnapshots() map[int64]*ResourceSnapshot

+ func (s *Service) GetContainerName(containerID int64) string

+ func (s *Service) GetCurrentSnapshot(containerID int64) *ResourceSnapshot

+ func (s *Service) GetHistory(ctx context.Context, containerID int64, timeRange string) ([]*ResourceSnapshot, Granularity, error)

+ func (s *Service) GetTopConsumersByPeriod(ctx context.Context, metric, period string, limit int) ([]TopConsumerRow, error)

+ func (s *Service) SetEventCallback(fn EventCallback)

+ func (s *Service) Start(ctx context.Context)

+ func (s *Service) UpsertAlertConfig(ctx context.Context, cfg *ResourceAlertConfig) error

+ type TopConsumerRow struct

+ AvgPercent float64

+ AvgValue float64

+ ContainerID int64

+ ContainerName string