node

Documentation

Index

• func GetNodePods(client k8sClient.Interface, heapsterClient client.HeapsterClient, ...) (*pod.PodList, error)
• type Node
• type NodeAllocatedResources
• type NodeCell
  • func (self NodeCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue
  • func (self NodeCell) GetResourceSelector() *metric.ResourceSelector
• type NodeDetail
  • func GetNodeDetail(client k8sClient.Interface, heapsterClient client.HeapsterClient, name string) (*NodeDetail, error)
• type NodeList
  • func GetNodeList(client client.Interface, dsQuery *dataselect.DataSelectQuery, ...) (*NodeList, error)
  • func GetNodeListFromChannels(channels *common.ResourceChannels, dsQuery *dataselect.DataSelectQuery, ...) (*NodeList, error)

Functions

func GetNodePods

func GetNodePods(client k8sClient.Interface, heapsterClient client.HeapsterClient, dsQuery *dataselect.DataSelectQuery, name string) (*pod.PodList, error)

GetNodePods return pods list in given named node

Types

type Node

type Node struct {
	ObjectMeta common.ObjectMeta `json:"objectMeta"`
	TypeMeta   common.TypeMeta   `json:"typeMeta"`

	// Ready Status of the node
	Ready api.ConditionStatus `json:"ready"`
}

Node is a presentation layer view of Kubernetes nodes. This means it is node plus additional augmented data we can get from other sources.

type NodeAllocatedResources

type NodeAllocatedResources struct {
	// CPURequests is number of allocated milicores.
	CPURequests int64 `json:"cpuRequests"`

	// CPURequestsFraction is a fraction of CPU, that is allocated.
	CPURequestsFraction float64 `json:"cpuRequestsFraction"`

	// CPULimits is defined CPU limit.
	CPULimits int64 `json:"cpuLimits"`

	// CPULimitsFraction is a fraction of defined CPU limit, can be over 100%, i.e.
	// overcommitted.
	CPULimitsFraction float64 `json:"cpuLimitsFraction"`

	// CPUCapacity is specified node CPU capacity in milicores.
	CPUCapacity int64 `json:"cpuCapacity"`

	// MemoryRequests is a fraction of memory, that is allocated.
	MemoryRequests int64 `json:"memoryRequests"`

	// MemoryRequestsFraction is a fraction of memory, that is allocated.
	MemoryRequestsFraction float64 `json:"memoryRequestsFraction"`

	// MemoryLimits is defined memory limit.
	MemoryLimits int64 `json:"memoryLimits"`

	// MemoryLimitsFraction is a fraction of defined memory limit, can be over 100%, i.e.
	// overcommitted.
	MemoryLimitsFraction float64 `json:"memoryLimitsFraction"`

	// MemoryCapacity is specified node memory capacity in bytes.
	MemoryCapacity int64 `json:"memoryCapacity"`

	// AllocatedPods in number of currently allocated pods on the node.
	AllocatedPods int `json:"allocatedPods"`

	// PodCapacity is maximum number of pods, that can be allocated on the node.
	PodCapacity int64 `json:"podCapacity"`
}

NodeAllocatedResources describes node allocated resources.

type NodeCell

type NodeCell api.Node

func (NodeCell) GetProperty

func (self NodeCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue

func (NodeCell) GetResourceSelector

func (self NodeCell) GetResourceSelector() *metric.ResourceSelector

type NodeDetail

type NodeDetail struct {
	ObjectMeta common.ObjectMeta `json:"objectMeta"`
	TypeMeta   common.TypeMeta   `json:"typeMeta"`

	// NodePhase is the current lifecycle phase of the node.
	Phase api.NodePhase `json:"phase"`

	// Resources allocated by node.
	AllocatedResources NodeAllocatedResources `json:"allocatedResources"`

	// External ID of the node assigned by some machine database (e.g. a cloud provider).
	ExternalID string `json:"externalID"`

	// PodCIDR represents the pod IP range assigned to the node.
	PodCIDR string `json:"podCIDR"`

	// ID of the node assigned by the cloud provider.
	ProviderID string `json:"providerID"`

	// Unschedulable controls node schedulability of new pods. By default node is schedulable.
	Unschedulable bool `json:"unschedulable"`

	// Set of ids/uuids to uniquely identify the node.
	NodeInfo api.NodeSystemInfo `json:"nodeInfo"`

	// Conditions is an array of current node conditions.
	Conditions []common.Condition `json:"conditions"`

	// Container images of the node.
	ContainerImages []string `json:"containerImages"`

	// PodList contains information about pods belonging to this node.
	PodList pod.PodList `json:"podList"`

	// Events is list of events associated to the node.
	EventList common.EventList `json:"eventList"`

	// Metrics collected for this resource
	Metrics []metric.Metric `json:"metrics"`
}

NodeDetail is a presentation layer view of Kubernetes Node resource. This means it is Node plus additional augmented data we can get from other sources.

func GetNodeDetail

func GetNodeDetail(client k8sClient.Interface, heapsterClient client.HeapsterClient, name string) (*NodeDetail, error)

GetNodeDetail gets node details.

type NodeList

type NodeList struct {
	ListMeta common.ListMeta `json:"listMeta"`

	// Unordered list of Nodes.
	Nodes             []Node          `json:"nodes"`
	CumulativeMetrics []metric.Metric `json:"cumulativeMetrics"`
}

NodeList contains a list of nodes in the cluster.

func GetNodeList

func GetNodeList(client client.Interface, dsQuery *dataselect.DataSelectQuery, heapsterClient *heapster.HeapsterClient) (*NodeList, error)

GetNodeList returns a list of all Nodes in the cluster.

func GetNodeListFromChannels

func GetNodeListFromChannels(channels *common.ResourceChannels, dsQuery *dataselect.DataSelectQuery,
	heapsterClient *heapster.HeapsterClient) (*NodeList, error)

GetNodeListFromChannels returns a list of all Nodes in the cluster.