package collector

import "github.com/containerd/nydus-snapshotter/pkg/metrics/collector"

Index

Variables

var OPCodeMap = map[uint32]string{
	15: "OP_READ",
}

Functions

func CollectSnapshotMetricsTimer

func CollectSnapshotMetricsTimer(h *prometheus.HistogramVec, event SnapshotMethod) *prometheus.Timer

func NewSnapshotMetricsTimer

func NewSnapshotMetricsTimer(method SnapshotMethod) *prometheus.Timer

Types

type Collector

type Collector interface {
	// Collect metrics to prometheus data.
	Collect()
}

type DaemonEventCollector

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

func NewDaemonEventCollector

func NewDaemonEventCollector(ev types.DaemonState) *DaemonEventCollector

func (*DaemonEventCollector) Collect

func (d *DaemonEventCollector) Collect()

type DaemonInfoCollector

type DaemonInfoCollector struct {
	Version *types.BuildTimeInfo
	// contains filtered or unexported fields
}

func NewDaemonInfoCollector

func NewDaemonInfoCollector(version *types.BuildTimeInfo, value float64) *DaemonInfoCollector

func (*DaemonInfoCollector) Collect

func (d *DaemonInfoCollector) Collect()

type DaemonResourceCollector

type DaemonResourceCollector struct {
	DaemonID string
	Value    float64
}

func (*DaemonResourceCollector) Collect

func (d *DaemonResourceCollector) Collect()

type FsMetricsCollector

type FsMetricsCollector struct {
	Metrics  *types.FsMetrics
	ImageRef string
}

func NewFsMetricsCollector

func NewFsMetricsCollector(m *types.FsMetrics, imageRef string) *FsMetricsCollector

func (*FsMetricsCollector) Collect

func (f *FsMetricsCollector) Collect()

type FsMetricsVecCollector

type FsMetricsVecCollector struct {
	MetricsVec []FsMetricsCollector
}

func NewFsMetricsVecCollector

func NewFsMetricsVecCollector() *FsMetricsVecCollector

func (*FsMetricsVecCollector) Clear

func (f *FsMetricsVecCollector) Clear()

func (*FsMetricsVecCollector) Collect

func (f *FsMetricsVecCollector) Collect()

type InflightMetricsVecCollector

type InflightMetricsVecCollector struct {
	MetricsVec     []*types.InflightMetrics
	HungIOInterval time.Duration
}

func NewInflightMetricsVecCollector

func NewInflightMetricsVecCollector(hungIOInterval time.Duration) *InflightMetricsVecCollector

func (*InflightMetricsVecCollector) Collect

func (i *InflightMetricsVecCollector) Collect()

type SnapshotMethod

type SnapshotMethod string
const (
	SnapshotMethodUnknown SnapshotMethod = "UNKNOWN"
	SnapshotMethodPrepare SnapshotMethod = "PREPARE"
	SnapshotMethodMount   SnapshotMethod = "MOUNTS"
	SnapshotMethodCleanup SnapshotMethod = "CLEANUP"
	SnapshotMethodRemove  SnapshotMethod = "REMOVE"
)

type SnapshotterMetricsCollector

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

func NewSnapshotterMetricsCollector

func NewSnapshotterMetricsCollector(ctx context.Context, cacheDir string, pid int) (*SnapshotterMetricsCollector, error)

func (*SnapshotterMetricsCollector) Collect

func (s *SnapshotterMetricsCollector) Collect()

func (*SnapshotterMetricsCollector) CollectCacheUsage

func (s *SnapshotterMetricsCollector) CollectCacheUsage()

func (*SnapshotterMetricsCollector) CollectResourceUsage

func (s *SnapshotterMetricsCollector) CollectResourceUsage()

Source Files

collector.go daemon.go fs.go snapshotter.go

Version
v0.15.1 (latest)
Published
Jan 26, 2025
Platform
linux/amd64
Imports
10 packages
Last checked
1 week ago

Tools for package owners.