state

Documentation

Index

• Constants
• func DeleteNodeMaintenanceCR(ctx context.Context, k8sClient client.Client, nodeName string, ...) error
• func HandleNodeEffect(ctx context.Context, k8sClient client.Client, ...) error
• func HostUptime(ns, name, container string) (int, error)
• func RemoveNodeEffect(ctx context.Context, k8sClient client.Client, ...) error
• type State
  • func GetDPUState(dpu *provisioningv1.DPU, alloc allocator.Allocator) State

Constants

const (
	TemplateFile            = "bf.cfg.template"
	CloudInitDefaultTimeout = 90
	// The maximum size of the bf.cfg file is expanded to 128k since DOCA 2.8
	MaxBFSize     = 1024 * 128
	MaxRetryCount = 10
	// HostNameDPULabelKey is the label added to the DPU Kubernetes Node that indicates the hostname of the host that
	// this DPU belongs to.
	HostNameDPULabelKey = "provisioning.dpu.nvidia.com/host"
)

const (
	InitContainerMaxRestartCount = 10
)

Functions

func DeleteNodeMaintenanceCR

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

func HandleNodeEffect

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

func HostUptime

func HostUptime(ns, name, container string) (int, error)

func RemoveNodeEffect

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

Types

type State

type State interface {
	Handle(ctx context.Context, client client.Client, option util.DPUOptions) (provisioningv1.DPUStatus, error)
}

func GetDPUState

func GetDPUState(dpu *provisioningv1.DPU, alloc allocator.Allocator) State