state

Documentation

Index

• Constants
• func ClusterConfig(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)
• func DeleteNodeMaintenanceCR(ctx context.Context, k8sClient client.Client, nodeName string, ...) error
• func Deleting(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)
• func Error(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)
• func GetCustomActionJobName(nodeEffect *provisioningv1.NodeEffect, dpu *provisioningv1.DPU) string
• func HandleNodeEffect(ctx context.Context, k8sClient client.Client, ...) error
• func Initializing(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)
• func NodeEffect(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)
• func Pending(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)
• func ProcessJobConditions(job *batchv1.Job) (bool, error)
• func Ready(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)
• func Rebooting(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)
• func RemoveNodeEffect(ctx context.Context, k8sClient client.Client, dpu *provisioningv1.DPU) error

Constants

const (
	PodTemplateConfigMapKey string = "pod-template"
)

Functions

func ClusterConfig

func ClusterConfig(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)

func DeleteNodeMaintenanceCR

func DeleteNodeMaintenanceCR(ctx context.Context, k8sClient client.Client, nodeName string, namespace string) error

func Deleting

func Deleting(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)

func Error

func Error(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)

func GetCustomActionJobName

func GetCustomActionJobName(nodeEffect *provisioningv1.NodeEffect, dpu *provisioningv1.DPU) string

func HandleNodeEffect

func HandleNodeEffect(ctx context.Context, k8sClient client.Client, nodeEffect provisioningv1.NodeEffect, nodeName string, namespace string) error

func Initializing

func Initializing(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)

func NodeEffect

func NodeEffect(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)

func Pending

func Pending(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)

func ProcessJobConditions

func ProcessJobConditions(job *batchv1.Job) (bool, error)

func Ready

func Ready(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)

func Rebooting

func Rebooting(ctx context.Context, dpu *provisioningv1.DPU, ctrlCtx *dutil.ControllerContext) (provisioningv1.DPUStatus, error)

func RemoveNodeEffect

func RemoveNodeEffect(ctx context.Context, k8sClient client.Client, dpu *provisioningv1.DPU) error