Documentation
¶
Index ¶
- func CheckMetricNameExist(name string) bool
- type Collector
- type StateCollector
- func (s *StateCollector) Collect()
- func (s *StateCollector) GetCadvisorManager() cadvisor.Manager
- func (s *StateCollector) GetCollectors() *sync.Map
- func (s *StateCollector) GetStateFunc() func() map[string][]common.TimeSeries
- func (s *StateCollector) Name() string
- func (s *StateCollector) Run(stop <-chan struct{})
- func (s *StateCollector) StopCollectors()
- func (s *StateCollector) UpdateCollectors()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckMetricNameExist ¶ added in v0.3.0
Types ¶
type Collector ¶
type Collector interface {
GetType() types.CollectType
Collect() (map[string][]common.TimeSeries, error)
Stop() error
}
type StateCollector ¶
type StateCollector struct {
AnalyzerChann chan map[string][]common.TimeSeries
NodeResourceChann chan map[string][]common.TimeSeries
PodResourceChann chan map[string][]common.TimeSeries
State map[string][]common.TimeSeries
// contains filtered or unexported fields
}
func NewStateCollector ¶
func NewStateCollector(nodeName, sysPath string, kubeClient kubernetes.Interface, craneClient craneclientset.Interface, nodeQOSLister ensuranceListers.NodeQOSLister, nrtLister topologylisters.NodeResourceTopologyLister, podLister corelisters.PodLister, nodeLister corelisters.NodeLister, ifaces []string, healthCheck *metrics.HealthCheck, collectInterval time.Duration, exclusiveCPUSet func() cpuset.CPUSet, manager cadvisor.Manager, ) *StateCollector
func (*StateCollector) Collect ¶
func (s *StateCollector) Collect()
func (*StateCollector) GetCadvisorManager ¶ added in v0.4.0
func (s *StateCollector) GetCadvisorManager() cadvisor.Manager
func (*StateCollector) GetCollectors ¶ added in v0.3.0
func (s *StateCollector) GetCollectors() *sync.Map
func (*StateCollector) GetStateFunc ¶ added in v0.6.0
func (s *StateCollector) GetStateFunc() func() map[string][]common.TimeSeries
func (*StateCollector) Name ¶
func (s *StateCollector) Name() string
func (*StateCollector) Run ¶
func (s *StateCollector) Run(stop <-chan struct{})
func (*StateCollector) StopCollectors ¶
func (s *StateCollector) StopCollectors()
func (*StateCollector) UpdateCollectors ¶
func (s *StateCollector) UpdateCollectors()
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.