node

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Jul 5, 2022 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// LabelNodeRolePrefix is a label prefix for node roles
	// It's copied over to here until it's merged in core: https://github.com/kubernetes/kubernetes/pull/39112
	LabelNodeRolePrefix = "node-role.kubernetes.io/"

	// LabelNodeRole specifies the role of a node
	LabelNodeRole = "kubernetes.io/role"

	NodeRoleMaster       = "master"
	NodeRoleControlPlane = "control-plane"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Handler

type Handler struct {
	Options *typed.HandlerOptions

	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, kubeconfig string) (handler *Handler, err error)

New returns a node handler from kubeconfig or in-cluster config

func (*Handler) DeepCopy

func (in *Handler) DeepCopy() *Handler

func (*Handler) Get

func (h *Handler) Get(name string) (*corev1.Node, error)

Get get node by name, alias to "GetByName".

func (*Handler) GetAllInfo

func (h *Handler) GetAllInfo() ([]NodeInfo, error)

get all k8s node info

func (*Handler) GetByName

func (h *Handler) GetByName(name string) (*corev1.Node, error)

GetByName get node by name.

func (*Handler) GetCIDR

func (h *Handler) GetCIDR(name string) (string, error)

get the node podCIDR

func (*Handler) GetCIDRs

func (h *Handler) GetCIDRs(name string) ([]string, error)

get the node podCIDRs

func (*Handler) GetHostname

func (h *Handler) GetHostname(name string) (hostname string, err error)

get the node hostname

func (*Handler) GetIP

func (h *Handler) GetIP(name string) (ip string, err error)

get the node ip

func (*Handler) GetMasterInfo

func (h *Handler) GetMasterInfo() ([]NodeInfo, error)

get all master node info

func (*Handler) GetNonTerminatedPods

func (h *Handler) GetNonTerminatedPods(name string) (*corev1.PodList, error)

get not terminated pod in the node.

func (*Handler) GetPods

func (h *Handler) GetPods(name string) (*corev1.PodList, error)

get all pods in the node

func (*Handler) GetRoles

func (h *Handler) GetRoles(name string) []string

GetRoles returns the roles of a given node. The roles are determined by looking for:

node-role.kubernetes.io/<role>=""
kubernetes.io/role="<role>"

func (*Handler) GetStatus

func (h *Handler) GetStatus(name string) *NodeStatus

get the node status

func (*Handler) GetWorkerInfo

func (h *Handler) GetWorkerInfo() ([]NodeInfo, error)

get all worker node info

func (*Handler) IsControlPlane

func (h *Handler) IsControlPlane(name string) bool

check if the node is control-plane

func (*Handler) IsMaster

func (h *Handler) IsMaster(name string) bool

check if the node is master

func (*Handler) IsReady

func (h *Handler) IsReady(name string) bool

check if the node status is ready

func (*Handler) List

func (h *Handler) List(labels string) (*corev1.NodeList, error)

List list nodes by labels, alias to "ListByLabel".

func (*Handler) ListAll

func (h *Handler) ListAll() (*corev1.NodeList, error)

ListAll list all nodes.

func (*Handler) ListByLabel

func (h *Handler) ListByLabel(labels string) (*corev1.NodeList, error)

ListByLabel list nodes by labels.

func (*Handler) RunInformer

func (h *Handler) RunInformer(
	addFunc func(obj interface{}),
	updateFunc func(oldObj, newObj interface{}),
	deleteFunc func(obj interface{}),
	stopCh chan struct{})

RunInformer

func (*Handler) SetLimit

func (h *Handler) SetLimit(limit int64)

func (*Handler) SetTimeout

func (h *Handler) SetTimeout(timeout int64)

func (*Handler) WithDryRun

func (h *Handler) WithDryRun() *Handler

type NodeInfo

type NodeInfo struct {
	Hostname           string
	IPAddress          string
	AllocatableCpu     string
	AllocatableMemory  string
	AllocatableStorage string
	TotalCpu           string
	TotalMemory        string
	TotalStorage       string

	Architecture            string
	BootID                  string
	ContainerRuntimeVersion string
	KernelVersion           string
	KubeProxyVersion        string
	KubeletVersion          string
	MachineID               string
	OperatingSystem         string
	OSImage                 string
	SystemUUID              string
}

type NodeStatus

type NodeStatus struct {
	Status  string
	Message string
	Reason  string
}

Jump to

Keyboard shortcuts

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