Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

collector

package

Go to main page

Versions in this module

v1

v1.0.3

May 26, 2023

v1.0.2

May 24, 2023

Changes in this version

+ var LSF_BINDIR = kingpin.Flag("lsf_path.lsf_bindir", "LSF BIN DIR PATH.").Envar("LSF_BINDIR").Required().String()

+ var LSF_ENVDIR = kingpin.Flag("lsf_path.envdir", "LSF ENV DIR PATH.").Envar("LSF_ENVDIR").Required().String()

+ var LSF_LIBDIR = kingpin.Flag("lsf_path.libdir", "LSF LIB DIR PATH.").Envar("LSF_LIBDIR").Required().String()

+ var LSF_SERVERDIR = kingpin.Flag("lsf_path.serverdir", "LSF SERVER DIR PATH.").Envar("LSF_SERVERDIR").Required().String()

+ var ResourceRegex = regexp.MustCompile(`\((?P<resource_type>.+)\)`)

+ func ConvertServerType(server_type string) string

+ func ConvertUT(data string, logger log.Logger) float64

+ func ConvertresourceType(resource_type string) string

+ 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 NewLSFlsLoadCollector(logger log.Logger) (Collector, error)

+ func NewLSFlshostCollector(logger log.Logger) (Collector, error)

+ type InformationCollector struct

+ LsfInformation *prometheus.Desc

+ func (c *InformationCollector) Update(ch chan<- prometheus.Metric) error

type QueuesCollector

+ QueuesPendingJobCount *prometheus.Desc

+ QueuesRuningJobCount *prometheus.Desc

+ type TrimReader struct

+ func (tr TrimReader) Read(bs []byte) (int, error)

v1.0.1

May 18, 2023

Changes in this version

+ var ClusterNameRegex = regexp.MustCompile(`My\s+cluster\s+name\s+is\s+(?P<cluster_name>[^\s]+)`)

+ var LSFVersionRegex = regexp.MustCompile(`(?P<lsf_version>\d+.\d+.\d+.\d+)`)

+ var MasterNameRegex = regexp.MustCompile(`My\s+master\s+name\s+is\s+(?P<master_name>[^\s]+)`)

+ func FormatQueusStatus(status string, logger log.Logger) float64

+ func FormatbhostsStatus(status string, logger log.Logger) float64

+ func QueuesSplite(lsfOutput []byte, logger log.Logger) (map[int]*queuesInfo, error)

type Collector

+ func NewLSFQueuesCollector(logger log.Logger) (Collector, error)

+ func NewLSFbHostCollector(logger log.Logger) (Collector, error)

+ type QueuesCollector struct

+ QueuesMaxJobCount *prometheus.Desc

+ QueuesPendingCount *prometheus.Desc

+ QueuesRuningCount *prometheus.Desc

+ QueuesStatus *prometheus.Desc

+ func (c *QueuesCollector) Update(ch chan<- prometheus.Metric) error

v1.0.0

May 17, 2023

Changes in this version

+ func DisableDefaultCollectors()

+ type Collector interface

+ Update func(ch chan<- prometheus.Metric) error

+ func NewLSFJobCollector(logger log.Logger) (Collector, error)

+ type Job struct

+ ExecutionHost string

+ FromHost string

+ ID string

+ JobName string

+ Queue string

+ Status string

+ SubmitTime int64

+ User string

+ type JobCollector struct

+ JobInfo *prometheus.Desc

+ func (c *JobCollector) Update(ch chan<- prometheus.Metric) error

+ type LsfCollector struct

+ Collectors map[string]Collector

+ func NewLsfCollector(logger log.Logger, filters ...string) (*LsfCollector, error)

+ func (n LsfCollector) Collect(ch chan<- prometheus.Metric)

+ func (n LsfCollector) Describe(ch chan<- *prometheus.Desc)