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
TODO: node internal IP in superedge will same in two node in a cluster
func NodeNameKeyFunc ¶ added in v0.8.2
func PodIPKeyFunc ¶ added in v0.8.2
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) CheckPluginsLen ¶
func (CheckEdge) GetCheckPlugins ¶
func (c CheckEdge) GetCheckPlugins() map[string]checkplugin.CheckPlugin
func (CheckEdge) GetHealthCheckPeriod ¶
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)
Click to show internal directories.
Click to hide internal directories.