collectors

Documentation

Index

• Variables
• func FileExists(filename string) bool
• func SliceContains(slice []string, str string) bool
• type CESMetric
• type Collector
  • func NewMmcesCollector(logger log.Logger) Collector
  • func NewMmdfCollector(logger log.Logger) Collector
  • func NewMmdiagCollector(logger log.Logger) Collector
  • func NewMmgetstateCollector(logger log.Logger) Collector
  • func NewMmhealthCollector(logger log.Logger) Collector
  • func NewMmpmonCollector(logger log.Logger) Collector
  • func NewMountCollector(logger log.Logger) Collector
  • func NewVerbsCollector(logger log.Logger) Collector
• type DFMetric
• type DiagMetric
• type DiagWaiter
• type GPFSCollector
  • func NewGPFSCollector(logger log.Logger) *GPFSCollector
• type GPFSFilesystem
• type HealthMetric
• type MmcesCollector
  • func (c *MmcesCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *MmcesCollector) Describe(ch chan<- *prometheus.Desc)
• type MmdfCollector
  • func (c *MmdfCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *MmdfCollector) Describe(ch chan<- *prometheus.Desc)
• type MmdiagCollector
  • func (c *MmdiagCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *MmdiagCollector) Describe(ch chan<- *prometheus.Desc)
• type MmgetstateCollector
  • func (c *MmgetstateCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *MmgetstateCollector) Describe(ch chan<- *prometheus.Desc)
• type MmgetstateMetrics
• type MmhealthCollector
  • func (c *MmhealthCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *MmhealthCollector) Describe(ch chan<- *prometheus.Desc)
• type MmpmonCollector
  • func (c *MmpmonCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *MmpmonCollector) Describe(ch chan<- *prometheus.Desc)
• type MountCollector
  • func (c *MountCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *MountCollector) Describe(ch chan<- *prometheus.Desc)
• type PerfMetrics
• type VerbsCollector
  • func (c *VerbsCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *VerbsCollector) Describe(ch chan<- *prometheus.Desc)
• type VerbsMetrics

Variables

var (
	KbToBytes = []string{"fsSize", "freeBlocks", "totalMetadata"}

	MmdfExec = mmdf
)

var (
	MmgetstateExec = mmgetstate
)

var (
	MmlsfsExec = mmlsfs
)

var (
	MmpmonExec = mmpmon
)

Functions

func FileExists

func FileExists(filename string) bool

func SliceContains

func SliceContains(slice []string, str string) bool

Types

type CESMetric

type CESMetric struct {
	Service string
	State   string
}

type Collector

type Collector interface {
	// Get new metrics and expose them via prometheus registry.
	Describe(ch chan<- *prometheus.Desc)
	Collect(ch chan<- prometheus.Metric)
}

func NewMmcesCollector

func NewMmcesCollector(logger log.Logger) Collector

func NewMmdfCollector

func NewMmdfCollector(logger log.Logger) Collector

func NewMmdiagCollector

func NewMmdiagCollector(logger log.Logger) Collector

func NewMmgetstateCollector

func NewMmgetstateCollector(logger log.Logger) Collector

func NewMmhealthCollector

func NewMmhealthCollector(logger log.Logger) Collector

func NewMmpmonCollector

func NewMmpmonCollector(logger log.Logger) Collector

func NewMountCollector

func NewMountCollector(logger log.Logger) Collector

func NewVerbsCollector

func NewVerbsCollector(logger log.Logger) Collector

type DFMetric

type DFMetric struct {
	FS              string
	InodesUsed      float64
	InodesFree      float64
	InodesAllocated float64
	InodesTotal     float64
	FSTotal         float64
	FSFree          float64
	MetadataTotal   float64
	MetadataFree    float64
}

type DiagMetric

type DiagMetric struct {
	Waiters []DiagWaiter
}

type DiagWaiter

type DiagWaiter struct {
	Seconds float64
	Thread  string
}

type GPFSCollector

type GPFSCollector struct {
	sync.Mutex
	Collectors map[string]Collector
}

func NewGPFSCollector

func NewGPFSCollector(logger log.Logger) *GPFSCollector

type GPFSFilesystem

type GPFSFilesystem struct {
	Name       string
	Mountpoint string
}

type HealthMetric

type HealthMetric struct {
	Component  string
	EntityName string
	EntityType string
	Status     string
}

type MmcesCollector

type MmcesCollector struct {
	State *prometheus.Desc
	// contains filtered or unexported fields
}

func (*MmcesCollector) Collect

func (c *MmcesCollector) Collect(ch chan<- prometheus.Metric)

func (*MmcesCollector) Describe

func (c *MmcesCollector) Describe(ch chan<- *prometheus.Desc)

type MmdfCollector

type MmdfCollector struct {
	InodesUsed      *prometheus.Desc
	InodesFree      *prometheus.Desc
	InodesAllocated *prometheus.Desc
	InodesTotal     *prometheus.Desc
	FSTotal         *prometheus.Desc
	FSFree          *prometheus.Desc
	MetadataTotal   *prometheus.Desc
	MetadataFree    *prometheus.Desc
	// contains filtered or unexported fields
}

func (*MmdfCollector) Collect

func (c *MmdfCollector) Collect(ch chan<- prometheus.Metric)

func (*MmdfCollector) Describe

func (c *MmdfCollector) Describe(ch chan<- *prometheus.Desc)

type MmdiagCollector

type MmdiagCollector struct {
	Waiter *prometheus.Desc
	// contains filtered or unexported fields
}

func (*MmdiagCollector) Collect

func (c *MmdiagCollector) Collect(ch chan<- prometheus.Metric)

func (*MmdiagCollector) Describe

func (c *MmdiagCollector) Describe(ch chan<- *prometheus.Desc)

type MmgetstateCollector

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

func (*MmgetstateCollector) Collect

func (c *MmgetstateCollector) Collect(ch chan<- prometheus.Metric)

func (*MmgetstateCollector) Describe

func (c *MmgetstateCollector) Describe(ch chan<- *prometheus.Desc)

type MmgetstateMetrics

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

type MmhealthCollector

type MmhealthCollector struct {
	State *prometheus.Desc
	// contains filtered or unexported fields
}

func (*MmhealthCollector) Collect

func (c *MmhealthCollector) Collect(ch chan<- prometheus.Metric)

func (*MmhealthCollector) Describe

func (c *MmhealthCollector) Describe(ch chan<- *prometheus.Desc)

type MmpmonCollector

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

func (*MmpmonCollector) Collect

func (c *MmpmonCollector) Collect(ch chan<- prometheus.Metric)

func (*MmpmonCollector) Describe

func (c *MmpmonCollector) Describe(ch chan<- *prometheus.Desc)

type MountCollector

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

func (*MountCollector) Collect

func (c *MountCollector) Collect(ch chan<- prometheus.Metric)

func (*MountCollector) Describe

func (c *MountCollector) Describe(ch chan<- *prometheus.Desc)

type PerfMetrics

type PerfMetrics struct {
	FS           string
	NodeName     string
	ReadBytes    int64
	WriteBytes   int64
	Reads        int64
	Writes       int64
	Opens        int64
	Closes       int64
	ReadDir      int64
	InodeUpdates int64
}

type VerbsCollector

type VerbsCollector struct {
	Status *prometheus.Desc
	// contains filtered or unexported fields
}

func (*VerbsCollector) Collect

func (c *VerbsCollector) Collect(ch chan<- prometheus.Metric)

func (*VerbsCollector) Describe

func (c *VerbsCollector) Describe(ch chan<- *prometheus.Desc)

type VerbsMetrics

type VerbsMetrics struct {
	Status string
}