dockerstats

Oct 20, 2026

Changes in this version

+ const MaxGapFactor

+ var ErrUnavailable = errors.New("stats unavailable")

+ var ErrUnknownItem = errors.New("unknown item")

+ func HealthOf(status string) (float64, bool)

+ func StateOf(c container.Summary) string

+ type Allocation struct

+ CPULimit float64

+ MemLimit uint64

+ func AllocationOf(h *container.HostConfig) Allocation

+ func (a Allocation) CPUCores(s *container.StatsResponse) float64

+ type Config struct

+ Clock stats.Clock

+ Dir string

+ Emit func(e stats.Event, who Identity, minutes int)

+ Interval time.Duration

+ Source Source

+ type DockerSource struct

+ func NewDockerSource() (*DockerSource, error)

+ func (d *DockerSource) Close() error

+ func (d *DockerSource) Inspect(ctx context.Context, id string) (container.InspectResponse, error)

+ func (d *DockerSource) List(ctx context.Context) ([]container.Summary, error)

+ func (d *DockerSource) Stats(ctx context.Context, ids []string) map[string]*container.StatsResponse

+ type Identity struct

+ App string

+ Group string

+ ID string

+ Kind string

+ Name string

+ func Identify(labels map[string]string, names []string) (Identity, bool)

+ func ParseID(id string) (Identity, bool)

+ type ItemInfo struct

+ Alerts int

+ CPUPercent *float64

+ Detail string

+ MemoryLimit *uint64

+ MemoryUsed *uint64

+ StartedAt *time.Time

+ State string

+ type Sampler struct

+ func New(cfg Config) (*Sampler, error)

+ func (s *Sampler) Alerts(id string) ([]stats.Rule, []stats.Event, error)

+ func (s *Sampler) Close() error

+ func (s *Sampler) Items() ([]ItemInfo, error)

+ func (s *Sampler) Notes() []string

+ func (s *Sampler) Run(ctx context.Context)

+ func (s *Sampler) Series(id string, r stats.Range) (SeriesView, error)

+ func (s *Sampler) SetRules(id string, rules []stats.Rule) error

+ func (s *Sampler) Tick(ctx context.Context)

+ type SeriesView struct

+ CPUAllocation *float64

+ MemoryLimit *uint64

+ Notes []string

+ Result stats.Result

+ type Snapshot struct

+ At time.Time

+ func Measure(prev *Snapshot, s *container.StatsResponse, now time.Time, a Allocation, ...) (stats.Sample, Snapshot)

+ type Source interface

+ Inspect func(ctx context.Context, id string) (container.InspectResponse, error)

+ List func(ctx context.Context) ([]container.Summary, error)

+ Stats func(ctx context.Context, ids []string) map[string]*container.StatsResponse