dpuservice

package
v0.1.0-latest-stable Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsDPUDeploymentReady

func IsDPUDeploymentReady(ctx context.Context, g Gomega, testClient client.Client, deploymentName string, namespace string) bool

func IsDPUServiceInterfaceReady

func IsDPUServiceInterfaceReady(ctx context.Context, g Gomega, testClient client.Client, interfaceName string, namespace string) bool

func SetDPUServiceHBNIPAM

func SetDPUServiceHBNIPAM(DPUServiceIPAM *dpuservicev1.DPUServiceIPAM, cfg TestIPAMConfig, dpu1Name, dpu2Name string)

func SetDPUServiceInterfacePatch

func SetDPUServiceInterfacePatch(dpuServiceInterface *dpuservicev1.DPUServiceInterface, config TestDPUServiceInterfaceConfig)

func SetDPUServiceInterfacePhysical

func SetDPUServiceInterfacePhysical(dpuServiceInterface *dpuservicev1.DPUServiceInterface, config TestDPUServiceInterfaceConfig)

func SetDPUServiceInterfaceSF

func SetDPUServiceInterfaceSF(dpuServiceInterface *dpuservicev1.DPUServiceInterface, config TestDPUServiceInterfaceConfig)

func SetDPUServiceInterfaceVF

func SetDPUServiceInterfaceVF(dpuServiceInterface *dpuservicev1.DPUServiceInterface, config TestDPUServiceInterfaceConfig)

func SetHBNChainSwitches

func SetHBNChainSwitches(dpuServiceChain *dpuservicev1.DPUServiceChain, interfaceType string, firstInterfaceName string, secondInterfaceName string)

func VerifyUnderlyingDPUObjectsReady

func VerifyUnderlyingDPUObjectsReady(ctx context.Context, dpuClusterClient client.Client, chainNamespace string, interfaceConfigs []TestDPUServiceInterfaceConfig, chainNames []string)

func WaitForDPUDeploymentReady

func WaitForDPUDeploymentReady(ctx context.Context, testClient client.Client, namespace string, deploymentNames []string, timeout time.Duration)

func WaitForDPUServiceChainsReady

func WaitForDPUServiceChainsReady(ctx context.Context, testClient client.Client, dpuClusterClient client.Client, chainNames []string, namespace string, timeout time.Duration)

func WaitForDPUServiceInterfacesReady

func WaitForDPUServiceInterfacesReady(ctx context.Context, testClient client.Client, dpuClusterClient client.Client, dpuServiceInterfaceNames []string, namespace string)

WaitForDPUServiceInterfacesReady waits for multiple dpu service interfaces to be ready

func WaitForDPUServices

func WaitForDPUServices(ctx context.Context, testClient client.Client, namespace string, serviceNames []string)

WaitForDPUServices waits until all expected DPUService objects exist and report Ready. On failure, it prints the expected, found, missing, extra, and not-ready services.

Types

type TestDPUServiceInterfaceConfig

type TestDPUServiceInterfaceConfig struct {
	Name            string
	Namespace       string
	Labels          map[string]string
	Annotations     map[string]string
	NodeName        *string
	Type            string
	InterfaceName   string
	PFIndex         int
	VFIndex         int
	ServiceID       string
	Network         string
	VirtualNetwork  *string
	PeerBridge      string
	PeerExternalIDs map[string]string
	// NodeSelector restricts the DPUServiceInterface to the DPU cluster nodes it matches.
	NodeSelector *metav1.LabelSelector
	// CleanupLabels are the labels the cleanup tracker selects the object by. Empty means the It scope,
	// set it to a named scope for objects that have to outlive the spec creating them.
	CleanupLabels map[string]string
}

TestDPUServiceInterfaceConfig holds service interface configuration

type TestIPAMConfig

type TestIPAMConfig struct {
	Name         string
	Network      string
	GatewayIndex int32
	PrefixSize   int32
	DPU1Subnet   string
	DPU2Subnet   string
	// Routes are static routes added through the gateway of the node subnet, for destinations a Pod
	// is not on-link with.
	Routes []string
	// Labels are set on the pool the DPUServiceIPAM creates, so that a DPUServiceChain port can
	// select it through the matchLabels of its IPAM.
	Labels map[string]string
	// CleanupLabels are the labels the cleanup tracker selects the object by. Empty means the It scope,
	// set it to a named scope for objects that have to outlive the spec creating them.
	CleanupLabels map[string]string
}

TestIPAMConfig represents the configuration for IPAM

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL