103 lines
3.2 KiB
Go
103 lines
3.2 KiB
Go
// Copyright 2015 The Prometheus Authors
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package prometheus
|
|
|
|
type processCollector struct {
|
|
pid int
|
|
collectFn func(chan<- Metric)
|
|
pidFn func() (int, error)
|
|
cpuTotal Counter
|
|
openFDs, maxFDs Gauge
|
|
vsize, rss Gauge
|
|
startTime Gauge
|
|
}
|
|
|
|
// NewProcessCollector returns a collector which exports the current state of
|
|
// process metrics including cpu, memory and file descriptor usage as well as
|
|
// the process start time for the given process id under the given namespace.
|
|
func NewProcessCollector(pid int, namespace string) *processCollector {
|
|
return NewProcessCollectorPIDFn(
|
|
func() (int, error) { return pid, nil },
|
|
namespace,
|
|
)
|
|
}
|
|
|
|
// NewProcessCollectorPIDFn returns a collector which exports the current state
|
|
// of process metrics including cpu, memory and file descriptor usage as well
|
|
// as the process start time under the given namespace. The given pidFn is
|
|
// called on each collect and is used to determine the process to export
|
|
// metrics for.
|
|
func NewProcessCollectorPIDFn(
|
|
pidFn func() (int, error),
|
|
namespace string,
|
|
) *processCollector {
|
|
c := processCollector{
|
|
pidFn: pidFn,
|
|
collectFn: func(chan<- Metric) {},
|
|
|
|
cpuTotal: NewCounter(CounterOpts{
|
|
Namespace: namespace,
|
|
Name: "process_cpu_seconds_total",
|
|
Help: "Total user and system CPU time spent in seconds.",
|
|
}),
|
|
openFDs: NewGauge(GaugeOpts{
|
|
Namespace: namespace,
|
|
Name: "process_open_fds",
|
|
Help: "Number of open file descriptors.",
|
|
}),
|
|
maxFDs: NewGauge(GaugeOpts{
|
|
Namespace: namespace,
|
|
Name: "process_max_fds",
|
|
Help: "Maximum number of open file descriptors.",
|
|
}),
|
|
vsize: NewGauge(GaugeOpts{
|
|
Namespace: namespace,
|
|
Name: "process_virtual_memory_bytes",
|
|
Help: "Virtual memory size in bytes.",
|
|
}),
|
|
rss: NewGauge(GaugeOpts{
|
|
Namespace: namespace,
|
|
Name: "process_resident_memory_bytes",
|
|
Help: "Resident memory size in bytes.",
|
|
}),
|
|
startTime: NewGauge(GaugeOpts{
|
|
Namespace: namespace,
|
|
Name: "process_start_time_seconds",
|
|
Help: "Start time of the process since unix epoch in seconds.",
|
|
}),
|
|
}
|
|
|
|
// Set up process metric collection if supported by the runtime.
|
|
if processCollectSupported() {
|
|
c.collectFn = c.processCollect
|
|
}
|
|
|
|
return &c
|
|
}
|
|
|
|
// Describe returns all descriptions of the collector.
|
|
func (c *processCollector) Describe(ch chan<- *Desc) {
|
|
ch <- c.cpuTotal.Desc()
|
|
ch <- c.openFDs.Desc()
|
|
ch <- c.maxFDs.Desc()
|
|
ch <- c.vsize.Desc()
|
|
ch <- c.rss.Desc()
|
|
ch <- c.startTime.Desc()
|
|
}
|
|
|
|
// Collect returns the current state of all metrics of the collector.
|
|
func (c *processCollector) Collect(ch chan<- Metric) {
|
|
c.collectFn(ch)
|
|
}
|