package collector

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

Index ¶

• Variables
• func CollectSnapshotMetricsTimer(h *prometheus.HistogramVec, event SnapshotMethod) *prometheus.Timer
• func NewSnapshotMetricsTimer(method SnapshotMethod) *prometheus.Timer
• type CacheMetricsCollector
• func NewCacheMetricsCollector(m *types.CacheMetrics, imageRef, daemonID string) *CacheMetricsCollector
• func (c *CacheMetricsCollector) Collect()
• type CacheMetricsVecCollector
• func NewCacheMetricsVecCollector() *CacheMetricsVecCollector
• func (c *CacheMetricsVecCollector) Collect()
• type Collector
• type DaemonEventCollector
• func NewDaemonEventCollector(ev types.DaemonState) *DaemonEventCollector
• func (d *DaemonEventCollector) Collect()
• type DaemonInfoCollector
• func NewDaemonInfoCollector(version *types.BuildTimeInfo, value float64) *DaemonInfoCollector
• func (d *DaemonInfoCollector) Collect()
• type DaemonResourceCollector
• func (d *DaemonResourceCollector) Collect()
• type FsMetricsCollector
• func NewFsMetricsCollector(m *types.FsMetrics, imageRef string) *FsMetricsCollector
• func (f *FsMetricsCollector) Collect()
• type FsMetricsVecCollector
• func NewFsMetricsVecCollector() *FsMetricsVecCollector
• func (f *FsMetricsVecCollector) Clear()
• func (f *FsMetricsVecCollector) Collect()
• type InflightMetricsVecCollector
• func NewInflightMetricsVecCollector(hungIOInterval time.Duration) *InflightMetricsVecCollector
• func (i *InflightMetricsVecCollector) Collect()
• type SnapshotMethod
• type SnapshotterMetricsCollector
• func NewSnapshotterMetricsCollector(ctx context.Context, cacheDir string, pid int) (*SnapshotterMetricsCollector, error)
• func (s *SnapshotterMetricsCollector) Collect()
• func (s *SnapshotterMetricsCollector) CollectCacheUsage()
• func (s *SnapshotterMetricsCollector) CollectResourceUsage()

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 CacheMetricsCollector ¶

type CacheMetricsCollector struct {
	Metrics  *types.CacheMetrics
	ImageRef string
	DaemonID string
}

func NewCacheMetricsCollector ¶

func NewCacheMetricsCollector(m *types.CacheMetrics, imageRef, daemonID string) *CacheMetricsCollector

func (*CacheMetricsCollector) Collect ¶

func (c *CacheMetricsCollector) Collect()

type CacheMetricsVecCollector ¶

type CacheMetricsVecCollector struct {
	MetricsVec []CacheMetricsCollector
}

func NewCacheMetricsVecCollector ¶

func NewCacheMetricsVecCollector() *CacheMetricsVecCollector

func (*CacheMetricsVecCollector) Collect ¶

func (c *CacheMetricsVecCollector) Collect()

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 ¶

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