collector

Documentation

Index

• func CheckMetricNameExist(name string) bool
• type Collector
• type StateCollector
  • func NewStateCollector(nodeName string, nepLister ensuranceListers.NodeQOSEnsurancePolicyLister, ...) *StateCollector
  • func (s *StateCollector) Collect()
  • func (s *StateCollector) GetCadvisorManager() cadvisor.Manager
  • func (s *StateCollector) GetCollectors() *sync.Map
  • func (s *StateCollector) Name() string
  • func (s *StateCollector) Run(stop <-chan struct{})
  • func (s *StateCollector) StopCollectors()
  • func (s *StateCollector) UpdateCollectors()

Functions

func CheckMetricNameExist

func CheckMetricNameExist(name string) bool

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
	// contains filtered or unexported fields
}

func NewStateCollector

func NewStateCollector(nodeName string, nepLister ensuranceListers.NodeQOSEnsurancePolicyLister, podLister corelisters.PodLister,
	nodeLister corelisters.NodeLister, ifaces []string, healthCheck *metrics.HealthCheck, collectInterval time.Duration) *StateCollector

func (*StateCollector) Collect

func (s *StateCollector) Collect()

func (*StateCollector) GetCadvisorManager

func (s *StateCollector) GetCadvisorManager() cadvisor.Manager

func (*StateCollector) GetCollectors

func (s *StateCollector) GetCollectors() *sync.Map

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()