Documentation
¶
Overview ¶
Package collector includes all individual collectors to gather and export lsf metrics.
Index ¶
- Variables
- func ConvertServerType(server_type string) string
- func ConvertUT(data string, logger log.Logger) float64
- func ConvertresourceType(resource_type string) string
- func DisableDefaultCollectors()
- func FormatQueusStatus(status string, logger log.Logger) float64
- func FormatbhostsStatus(status string, logger log.Logger) float64
- func FormatlsLoadStatus(status string, logger log.Logger) float64
- func FormatlshostsUnit(size float64, unit string) float64
- type Collector
- func NewLSFInformationCollector(logger log.Logger) (Collector, error)
- func NewLSFJobCollector(logger log.Logger) (Collector, error)
- func NewLSFQueuesCollector(logger log.Logger) (Collector, error)
- func NewLSFbHostCollector(logger log.Logger) (Collector, error)
- func NewLSFlsLoadCollector(logger log.Logger) (Collector, error)
- func NewLSFlshostCollector(logger log.Logger) (Collector, error)
- type InformationCollector
- type Job
- type JobCollector
- type LsfCollector
- type QueuesCollector
- type TrimReader
Constants ¶
This section is empty.
Variables ¶
var ( // Regexp to parse lsid. ClusterNameRegex = regexp.MustCompile(`My\s+cluster\s+name\s+is\s+(?P<cluster_name>[^\s]+)`) MasterNameRegex = regexp.MustCompile(`My\s+master\s+name\s+is\s+(?P<master_name>[^\s]+)`) LSFVersionRegex = regexp.MustCompile(`(?P<lsf_version>\d+.\d+.\d+.\d+)`) ResourceRegex = regexp.MustCompile(`\((?P<resource_type>.+)\)`) )
Functions ¶
func ConvertresourceType ¶ added in v1.0.2
去除字符串中的()
func DisableDefaultCollectors ¶
func DisableDefaultCollectors()
DisableDefaultCollectors sets the collector state to false for all collectors which have not been explicitly enabled on the command line.
func FormatQueusStatus ¶ added in v1.0.1
func FormatbhostsStatus ¶ added in v1.0.1
func FormatlsLoadStatus ¶ added in v1.0.2
func FormatlshostsUnit ¶ added in v1.0.2
Types ¶
type Collector ¶
type Collector interface {
// Get new metrics and expose them via prometheus registry.
Update(ch chan<- prometheus.Metric) error
}
Collector is the interface a collector has to implement.
func NewLSFInformationCollector ¶ added in v1.0.2
NewLmstatCollector returns a new Collector exposing lmstat license stats.
func NewLSFJobCollector ¶
NewLmstatCollector returns a new Collector exposing lmstat license stats.
func NewLSFQueuesCollector ¶ added in v1.0.1
NewLmstatCollector returns a new Collector exposing lmstat license stats.
func NewLSFbHostCollector ¶ added in v1.0.1
NewLmstatCollector returns a new Collector exposing lmstat license stats.
func NewLSFlsLoadCollector ¶ added in v1.0.2
NewLmstatCollector returns a new Collector exposing lmstat license stats.
type InformationCollector ¶ added in v1.0.2
type InformationCollector struct {
LsfInformation *prometheus.Desc
// contains filtered or unexported fields
}
func (*InformationCollector) Update ¶ added in v1.0.2
func (c *InformationCollector) Update(ch chan<- prometheus.Metric) error
Update calls (*lmstatCollector).getLmStat to get the platform specific memory metrics.
type JobCollector ¶
type JobCollector struct {
JobInfo *prometheus.Desc
// contains filtered or unexported fields
}
func (*JobCollector) Update ¶
func (c *JobCollector) Update(ch chan<- prometheus.Metric) error
Update calls (*lmstatCollector).getLmStat to get the platform specific memory metrics.
type LsfCollector ¶
type LsfCollector struct {
Collectors map[string]Collector
// contains filtered or unexported fields
}
LsfCollector implements the prometheus.Collector interface.
func NewLsfCollector ¶
func NewLsfCollector(logger log.Logger, filters ...string) (*LsfCollector, error)
NewLsfCollector creates a new LsfCollector.
func (LsfCollector) Collect ¶
func (n LsfCollector) Collect(ch chan<- prometheus.Metric)
Collect implements the prometheus.Collector interface.
func (LsfCollector) Describe ¶
func (n LsfCollector) Describe(ch chan<- *prometheus.Desc)
Describe implements the prometheus.Collector interface.
type QueuesCollector ¶ added in v1.0.1
type QueuesCollector struct {
QueuesRuningJobCount *prometheus.Desc
QueuesPendingJobCount *prometheus.Desc
QueuesMaxJobCount *prometheus.Desc
QueuesStatus *prometheus.Desc
// contains filtered or unexported fields
}
func (*QueuesCollector) Update ¶ added in v1.0.1
func (c *QueuesCollector) Update(ch chan<- prometheus.Metric) error
Update calls (*lmstatCollector).getLmStat to get the platform specific memory metrics.
Source Files