check

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 20, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 2 more Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
const (
	EdgeHealthPodLabelKey   = "name"
	EdgeHealthPodLabelValue = "edge-health"
	PodIPIndexKey           = "PodIP"
	NodeIPIndexKey          = "NodeIP"
	NodeNameIndexKey        = "NodeName"
)

Variables

This section is empty.

Functions

func NodeIPKeyFunc added in v0.8.2

func NodeIPKeyFunc(obj interface{}) ([]string, error)

TODO: node internal IP in superedge will same in two node in a cluster

func NodeNameKeyFunc added in v0.8.2

func NodeNameKeyFunc(obj interface{}) ([]string, error)

func PodIPKeyFunc added in v0.8.2

func PodIPKeyFunc(obj interface{}) ([]string, error)

Types

type Check

type Check interface {
	GetNodeList()
	Check()
	AddCheckPlugin(plugins []checkplugin.CheckPlugin)
	CheckPluginsLen() int
	GetHealthCheckPeriod() int
}

func NewCheckEdge

func NewCheckEdge(checkplugins []checkplugin.CheckPlugin, healthcheckperiod int, healthCheckScoreLine float64) Check

type CheckEdge

type CheckEdge struct {
	HealthCheckPeriod    int
	CheckPlugins         map[string]checkplugin.CheckPlugin
	HealthCheckScoreLine float64
}

func (CheckEdge) AddCheckPlugin

func (c CheckEdge) AddCheckPlugin(plugins []checkplugin.CheckPlugin)

func (CheckEdge) Check

func (c CheckEdge) Check()

func (CheckEdge) CheckPluginsLen

func (c CheckEdge) CheckPluginsLen() int

func (CheckEdge) GetCheckPlugins

func (c CheckEdge) GetCheckPlugins() map[string]checkplugin.CheckPlugin

func (CheckEdge) GetHealthCheckPeriod

func (c CheckEdge) GetHealthCheckPeriod() int

func (CheckEdge) GetNodeList

func (c CheckEdge) GetNodeList()

type ConfigMapController

type ConfigMapController struct {
	ConfigMapInformer     cache.SharedIndexInformer
	ConfigMapLister       corelisters.ConfigMapLister
	ConfigMapListerSynced cache.InformerSynced
	// contains filtered or unexported fields
}
var ConfigMapManager *ConfigMapController

func NewConfigMapController

func NewConfigMapController(clientset kubernetes.Interface) *ConfigMapController

func (*ConfigMapController) Run

func (n *ConfigMapController) Run(ctx context.Context)

type NodeMetaController added in v0.8.2

type NodeMetaController struct {
	MetaClientset          metadata.Interface
	NodeMetaInformer       cache.SharedIndexInformer
	NodeMetaILister        cache.GenericLister
	NodeMetaInformerSynced cache.InformerSynced
}
var NodeMetaManager *NodeMetaController

func NewNodeMetaController added in v0.8.2

func NewNodeMetaController(metaClientset metadata.Interface) *NodeMetaController

func (*NodeMetaController) Run added in v0.8.2

func (n *NodeMetaController) Run(ctx context.Context)

type PodController added in v0.8.2

type PodController struct {
	PodInformer     cache.SharedIndexInformer
	PodListerSynced cache.InformerSynced
	// contains filtered or unexported fields
}
var PodManager *PodController

func NewPodController added in v0.8.2

func NewPodController(clientset kubernetes.Interface) *PodController

func (*PodController) GetNodeIPByNodeName added in v0.8.2

func (n *PodController) GetNodeIPByNodeName(nodeName string) (string, error)

func (*PodController) GetNodeNameByNodeIP added in v0.8.2

func (n *PodController) GetNodeNameByNodeIP(nodeIP string) (string, error)

func (*PodController) GetPodIPByNodeIP added in v0.8.2

func (n *PodController) GetPodIPByNodeIP(nodeIP string) (string, error)

func (*PodController) Run added in v0.8.2

func (n *PodController) Run(ctx context.Context)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL