NodeStorage¶

class controller.storage.kubernetes.node.NodeStorage(api_client, logger)¶

Bases: object

Storage layer for Kubernetes node objects.

Parameters:

api_client (ApiClient) – Kubernetes API client.
logger (BoundLogger) – Logger to use.

Methods Summary

`get_cached_images`(nodes)	Build map of what images are cached on each node.
`is_tolerated`(node, tolerations)	Determine whether a pod can be placed on a node.
`list`(node_selector, timeout)	Get data about Kubernetes nodes.

Methods Documentation

get_cached_images(nodes)¶

Build map of what images are cached on each node.

Parameters:: nodes (list[V1Node]) – List of Kubernetes nodes with their metadata.
Returns:: Mapping of node names to lists of cached images on that node.
Return type:: dict of list

is_tolerated(node, tolerations)¶

Determine whether a pod can be placed on a node.

Evaluates the node taints against the provided tolerations and determines whether an image with those tolerations can be placed on that node. Nodes with a PreferNoSchedule taint are still tolerated.

Parameters:

node (V1Node) – Kubernetes node.
tolerations (list[Toleration]) – List of tolerations that the pod will have.

Returns:

Information about whether that image can be placed on that node.

Return type:

NodeToleration

async list(node_selector, timeout)¶

Get data about Kubernetes nodes.

Parameters:

node_selector (dict[str, str]) – Node selector rules to restrict the list of nodes of interest.
timeout (Timeout) – Timeout for call.

Returns:

List of node metadata.

Return type:

list of kubernetes_asyncio.client.models.V1Node