Documentation ¶
Index ¶
- type NodeStatusController
- func (n *NodeStatusController) Dump() []byte
- func (n *NodeStatusController) GetNodeStatus() corev1.NodeStatus
- func (n *NodeStatusController) NotifyNodeStatus(ctx context.Context, cb func(*corev1.Node))
- func (n *NodeStatusController) Ping(ctx context.Context) error
- func (n *NodeStatusController) Start(quit <-chan struct{}, wg *sync.WaitGroup)
- func (n *NodeStatusController) UpdateNode(node *corev1.Node)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NodeStatusController ¶
type NodeStatusController struct {
// contains filtered or unexported fields
}
func NewNodeStatusController ¶
func NewNodeStatusController( cli cloud.CloudClient, internalIP string, daemonEndpointPort int32, capacity corev1.ResourceList, labels map[string]string, ) *NodeStatusController
func (*NodeStatusController) Dump ¶
func (n *NodeStatusController) Dump() []byte
func (*NodeStatusController) GetNodeStatus ¶
func (n *NodeStatusController) GetNodeStatus() corev1.NodeStatus
func (*NodeStatusController) NotifyNodeStatus ¶
func (n *NodeStatusController) NotifyNodeStatus(ctx context.Context, cb func(*corev1.Node))
func (*NodeStatusController) Start ¶
func (n *NodeStatusController) Start(quit <-chan struct{}, wg *sync.WaitGroup)
func (*NodeStatusController) UpdateNode ¶
func (n *NodeStatusController) UpdateNode(node *corev1.Node)
Click to show internal directories.
Click to hide internal directories.