package node

import "k8s.io/kubernetes/pkg/util/node"

Index ¶

• Constants
• func GetHostname(hostnameOverride string) (string, error)
• func GetNodeHostIP(node *v1.Node) (net.IP, error)
• func GetNodeIP(client clientset.Interface, hostname string) net.IP
• func GetPreferredNodeAddress(node *v1.Node, preferredAddressTypes []v1.NodeAddressType) (string, error)
• func GetZoneKey(node *v1.Node) string
• func PatchNodeCIDR(c clientset.Interface, node types.NodeName, cidr string) error
• func PatchNodeCIDRs(c clientset.Interface, node types.NodeName, cidrs []string) error
• func PatchNodeStatus(c v1core.CoreV1Interface, nodeName types.NodeName, oldNode *v1.Node, newNode *v1.Node) (*v1.Node, []byte, error)
• func SetNodeCondition(c clientset.Interface, node types.NodeName, condition v1.NodeCondition) error
• type NoMatchError
• func (e *NoMatchError) Error() string

Package Files ¶

node.go

Constants ¶

const (
    // NodeUnreachablePodReason is the reason on a pod when its state cannot be confirmed as kubelet is unresponsive
    // on the node it is (was) running.
    NodeUnreachablePodReason = "NodeLost"
    // NodeUnreachablePodMessage is the message on a pod when its state cannot be confirmed as kubelet is unresponsive
    // on the node it is (was) running.
    NodeUnreachablePodMessage = "Node %v which was running pod %v is unresponsive"
)

func GetHostname ¶ Uses

func GetHostname(hostnameOverride string) (string, error)

GetHostname returns OS's hostname if 'hostnameOverride' is empty; otherwise, return 'hostnameOverride'.

func GetNodeHostIP ¶ Uses

func GetNodeHostIP(node *v1.Node) (net.IP, error)

GetNodeHostIP returns the provided node's IP, based on the priority: 1. NodeInternalIP 2. NodeExternalIP

func GetNodeIP ¶ Uses

func GetNodeIP(client clientset.Interface, hostname string) net.IP

GetNodeIP returns the ip of node with the provided hostname If required, wait for the node to be defined.

func GetPreferredNodeAddress ¶ Uses

func GetPreferredNodeAddress(node *v1.Node, preferredAddressTypes []v1.NodeAddressType) (string, error)

GetPreferredNodeAddress returns the address of the provided node, using the provided preference order. If none of the preferred address types are found, an error is returned.

func GetZoneKey ¶ Uses

func GetZoneKey(node *v1.Node) string

GetZoneKey is a helper function that builds a string identifier that is unique per failure-zone; it returns empty-string for no zone. Since there are currently two separate zone keys:

* "failure-domain.beta.kubernetes.io/zone"
* "topology.kubernetes.io/zone"

GetZoneKey will first check failure-domain.beta.kubernetes.io/zone and if not exists, will then check topology.kubernetes.io/zone

func PatchNodeCIDR ¶ Uses

func PatchNodeCIDR(c clientset.Interface, node types.NodeName, cidr string) error

PatchNodeCIDR patches the specified node's CIDR to the given value.

func PatchNodeCIDRs ¶ Uses

func PatchNodeCIDRs(c clientset.Interface, node types.NodeName, cidrs []string) error

PatchNodeCIDRs patches the specified node.CIDR=cidrs[0] and node.CIDRs to the given value.

func PatchNodeStatus ¶ Uses

func PatchNodeStatus(c v1core.CoreV1Interface, nodeName types.NodeName, oldNode *v1.Node, newNode *v1.Node) (*v1.Node, []byte, error)

PatchNodeStatus patches node status.

func SetNodeCondition ¶ Uses

func SetNodeCondition(c clientset.Interface, node types.NodeName, condition v1.NodeCondition) error

SetNodeCondition updates specific node condition with patch operation.

type NoMatchError ¶ Uses

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

NoMatchError is a typed implementation of the error interface. It indicates a failure to get a matching Node.

func (*NoMatchError) Error ¶ Uses

func (e *NoMatchError) Error() string

Error is the implementation of the conventional interface for representing an error condition, with the nil value representing no error.