NewNodeExecutionK8sReader
Initializes and returns a new NodeExecutionK8sReader instance. This function sets up the reader with necessary metadata such as namespace, execution ID, node ID, and a Kubernetes client cache, preparing it to read Kubernetes resources related to a specific node execution.
def NewNodeExecutionK8sReader(
meta: pluginsCore.TaskExecutionMetadata,
client: pluginsCore.KubeClient
) - > *NodeExecutionK8sReader
Creates and returns a new NodeExecutionK8sReader instance, initialized with metadata about a task execution and a Kubernetes client. This reader is used to access Kubernetes resources related to a specific node execution.
Parameters
| Name | Type | Description |
|---|---|---|
| meta | pluginsCore.TaskExecutionMetadata | Metadata containing information about the task execution, including the task execution ID, which is used to derive the execution ID, node ID, and namespace. |
| client | pluginsCore.KubeClient | A Kubernetes client used to interact with the Kubernetes API, specifically its cached version, for retrieving node execution-related resources. |
Returns
| Type | Description |
|---|---|
*NodeExecutionK8sReader | A new NodeExecutionK8sReader instance configured for the specified node execution. |