package collector
import "k8s.io/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/collector"
Index ¶
- func GetCollectorConfigs(labels map[string]string) map[string]string
- type Collector
- type CollectorManager
- type Config
- type FakeCollectorManager
- func (fkm *FakeCollectorManager) Collect(metric map[string][]v1.MetricVal) (time.Time, map[string][]v1.MetricVal, error)
- func (fkm *FakeCollectorManager) GetSpec() ([]v1.MetricSpec, error)
- func (fkm *FakeCollectorManager) RegisterCollector(collector Collector) error
- type GenericCollector
- func NewCollector(collectorName string, configFile []byte) (*GenericCollector, error)
- func (collector *GenericCollector) Collect(metrics map[string][]v1.MetricVal) (time.Time, map[string][]v1.MetricVal, error)
- func (collector *GenericCollector) GetSpec() []v1.MetricSpec
- func (collector *GenericCollector) Name() string
- type GenericCollectorManager
- func (cm *GenericCollectorManager) Collect() (time.Time, map[string][]v1.MetricVal, error)
- func (cm *GenericCollectorManager) GetSpec() ([]v1.MetricSpec, error)
- func (cm *GenericCollectorManager) RegisterCollector(collector Collector) error
- type MetricConfig
- type Prometheus
- type PrometheusCollector
- func NewPrometheusCollector(collectorName string, configFile []byte) (*PrometheusCollector, error)
- func (collector *PrometheusCollector) Collect(metrics map[string][]v1.MetricVal) (time.Time, map[string][]v1.MetricVal, error)
- func (collector *PrometheusCollector) GetSpec() []v1.MetricSpec
- func (collector *PrometheusCollector) Name() string
Functions ¶
func GetCollectorConfigs ¶
Types ¶
type Collector ¶
type Collector interface { // Collect metrics from this collector. // Returns the next time this collector should be collected from. // Next collection time is always returned, even when an error occurs. // A collection time of zero means no more collection. Collect(map[string][]v1.MetricVal) (time.Time, map[string][]v1.MetricVal, error) // Return spec for all metrics associated with this collector GetSpec() []v1.MetricSpec // Name of this collector. Name() string }
Metric collector.
type CollectorManager ¶
type CollectorManager interface { // Register a collector. RegisterCollector(collector Collector) error // Collect from collectors that are ready and return the next time // at which a collector will be ready to collect from. // Next collection time is always returned, even when an error occurs. // A collection time of zero means no more collection. Collect() (time.Time, map[string][]v1.MetricVal, error) // Get metric spec from all registered collectors. GetSpec() ([]v1.MetricSpec, error) }
Manages and runs collectors.
func NewCollectorManager ¶
func NewCollectorManager() (CollectorManager, error)
Returns a new CollectorManager that is thread-compatible.
type Config ¶
type Config struct { //the endpoint to hit to scrape metrics Endpoint string `json:"endpoint"` //holds information about different metrics that can be collected MetricsConfig []MetricConfig `json:"metrics_config"` }
type FakeCollectorManager ¶
type FakeCollectorManager struct { }
func (*FakeCollectorManager) Collect ¶
func (fkm *FakeCollectorManager) Collect(metric map[string][]v1.MetricVal) (time.Time, map[string][]v1.MetricVal, error)
func (*FakeCollectorManager) GetSpec ¶
func (fkm *FakeCollectorManager) GetSpec() ([]v1.MetricSpec, error)
func (*FakeCollectorManager) RegisterCollector ¶
func (fkm *FakeCollectorManager) RegisterCollector(collector Collector) error
type GenericCollector ¶
type GenericCollector struct {
// contains filtered or unexported fields
}
func NewCollector ¶
func NewCollector(collectorName string, configFile []byte) (*GenericCollector, error)
Returns a new collector using the information extracted from the configfile
func (*GenericCollector) Collect ¶
func (collector *GenericCollector) Collect(metrics map[string][]v1.MetricVal) (time.Time, map[string][]v1.MetricVal, error)
Returns collected metrics and the next collection time of the collector
func (*GenericCollector) GetSpec ¶
func (collector *GenericCollector) GetSpec() []v1.MetricSpec
func (*GenericCollector) Name ¶
func (collector *GenericCollector) Name() string
Returns name of the collector
type GenericCollectorManager ¶
func (*GenericCollectorManager) Collect ¶
func (*GenericCollectorManager) GetSpec ¶
func (cm *GenericCollectorManager) GetSpec() ([]v1.MetricSpec, error)
func (*GenericCollectorManager) RegisterCollector ¶
func (cm *GenericCollectorManager) RegisterCollector(collector Collector) error
type MetricConfig ¶
type MetricConfig struct { //the name of the metric Name string `json:"name"` //enum type for the metric type MetricType v1.MetricType `json:"metric_type"` // metric units to display on UI and in storage (eg: MB, cores) // this is only used for display. Units string `json:"units"` //data type of the metric (eg: int, float) DataType v1.DataType `json:"data_type"` //the frequency at which the metric should be collected PollingFrequency time.Duration `json:"polling_frequency"` //the regular expression that can be used to extract the metric Regex string `json:"regex"` }
metricConfig holds information extracted from the config file about a metric
type Prometheus ¶
type Prometheus struct { //the endpoint to hit to scrape metrics Endpoint string `json:"endpoint"` //the frequency at which metrics should be collected PollingFrequency time.Duration `json:"polling_frequency"` //holds names of different metrics that can be collected MetricsConfig []string `json:"metrics_config"` }
type PrometheusCollector ¶
type PrometheusCollector struct {
// contains filtered or unexported fields
}
func NewPrometheusCollector ¶
func NewPrometheusCollector(collectorName string, configFile []byte) (*PrometheusCollector, error)
Returns a new collector using the information extracted from the configfile
func (*PrometheusCollector) Collect ¶
func (collector *PrometheusCollector) Collect(metrics map[string][]v1.MetricVal) (time.Time, map[string][]v1.MetricVal, error)
Returns collected metrics and the next collection time of the collector
func (*PrometheusCollector) GetSpec ¶
func (collector *PrometheusCollector) GetSpec() []v1.MetricSpec
func (*PrometheusCollector) Name ¶
func (collector *PrometheusCollector) Name() string
Returns name of the collector
Source Files ¶
collector_manager.go config.go fakes.go generic_collector.go prometheus_collector.go types.go
- Version
- v1.1.9-beta.0
- Published
- Feb 23, 2016
- Platform
- linux/amd64
- Imports
- 10 packages
- Last checked
- 50 seconds ago –
Tools for package owners.