node

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 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

View Source 
var ERR_TYPE = fmt.Errorf("type must be *corev1.Node, corev1.Node or string")

Functions

This section is empty.

Types

type Handler 

type Handler struct {
	Options *typed.HandlerOptions
	// 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) Clientset added in v0.2.0 

func (h *Handler) Clientset() *kubernetes.Clientset

func (*Handler) DeepCopy 

func (in *Handler) DeepCopy() *Handler

func (*Handler) DiscoveryClient added in v0.2.0 

func (h *Handler) DiscoveryClient() *discovery.DiscoveryClient

func (*Handler) DynamicClient added in v0.2.0 

func (h *Handler) DynamicClient() dynamic.Interface

func (*Handler) Get 

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

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

func (*Handler) GetAge added in v0.2.0 

func (h *Handler) GetAge(object interface{}) (time.Duration, error)

GetAge

func (*Handler) GetByName 

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

GetByName get node by name.

func (*Handler) GetCIDR 

func (h *Handler) GetCIDR(object interface{}) (string, error)

GetCIDR get the node podCIDR

func (*Handler) GetCIDRs 

func (h *Handler) GetCIDRs(object interface{}) ([]string, error)

GetCIDRs get the node podCIDRs

func (*Handler) GetExternaDNS added in v0.2.0 

func (h *Handler) GetExternaDNS(object interface{}) ([]string, error)

GetExternaDNS returns the node ip

func (*Handler) GetExternalIP added in v0.2.0 

func (h *Handler) GetExternalIP(object interface{}) ([]string, error)

GetExternalIP returns the node ip

func (*Handler) GetHostname 

func (h *Handler) GetHostname(object interface{}) ([]string, error)

GetHostname returns the node ip

func (*Handler) GetInternalDNS added in v0.2.0 

func (h *Handler) GetInternalDNS(object interface{}) ([]string, error)

GetInternalDNS returns the node ip

func (*Handler) GetInternalIP added in v0.2.0 

func (h *Handler) GetInternalIP(object interface{}) ([]string, error)

GetInternalIP returns the node ip

func (*Handler) GetMasterInfo 

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

GetMasterInfo

func (*Handler) GetNodeInfo added in v0.2.0 

func (h *Handler) GetNodeInfo(object interface{}) (*NodeInfo, error)

GetNodeInfo get given node info.

func (*Handler) GetPhase added in v0.2.0 

func (h *Handler) GetPhase(object interface{}) (string, error)

These are the valid phases of node. Running, Pending, Terminated

func (*Handler) GetPods 

func (h *Handler) GetPods(object interface{}) ([]corev1.Pod, error)

GetPods get all pods running in the node

func (*Handler) GetRoles 

func (h *Handler) GetRoles(object interface{}) ([]string, error)

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) GetWorkerInfo 

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

GetWorkerInfo

func (*Handler) IsControlPlane 

func (h *Handler) IsControlPlane(object interface{}) bool

IsControlPlane check whether the node is control-plane.

func (*Handler) IsMaster 

func (h *Handler) IsMaster(object interface{}) bool

IsMaster check whether the node is master.

func (*Handler) IsReady 

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

IsReady check whether the node 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) RESTClient added in v0.2.0 

func (h *Handler) RESTClient() *rest.RESTClient

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.