collector

Documentation

Index

• Variables
• func CollectSnapshotMetricsTimer(h *prometheus.HistogramVec, event SnapshotMethod) *prometheus.Timer
• func NewSnapshotMetricsTimer(method SnapshotMethod) *prometheus.Timer
• 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 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()