analyzer

Documentation

Index

• type AnormalyAnalyzer
  • func NewAnormalyAnalyzer(kubeClient *kubernetes.Clientset, nodeName string, ...) *AnormalyAnalyzer
  • func (s *AnormalyAnalyzer) Analyze(state map[string][]common.TimeSeries)
  • func (s *AnormalyAnalyzer) Name() string
  • func (s *AnormalyAnalyzer) Run(stop <-chan struct{})

Types

type AnormalyAnalyzer

type AnormalyAnalyzer struct {
	// contains filtered or unexported fields
}

func NewAnormalyAnalyzer

func NewAnormalyAnalyzer(kubeClient *kubernetes.Clientset,
	nodeName string,
	podInformer coreinformers.PodInformer,
	nodeInformer coreinformers.NodeInformer,
	nepInformer v1alpha1.NodeQOSEnsurancePolicyInformer,
	actionInformer v1alpha1.AvoidanceActionInformer,
	stateChann chan map[string][]common.TimeSeries,
	noticeCh chan<- executor.AvoidanceExecutor,
) *AnormalyAnalyzer

NewAnormalyAnalyzer create an analyzer manager

func (*AnormalyAnalyzer) Analyze

func (s *AnormalyAnalyzer) Analyze(state map[string][]common.TimeSeries)

func (*AnormalyAnalyzer) Name

func (s *AnormalyAnalyzer) Name() string

func (*AnormalyAnalyzer) Run

func (s *AnormalyAnalyzer) Run(stop <-chan struct{})