Documentation
¶
Index ¶
- func DeleteDPFOperatorConfig(ctx context.Context, testClient client.Client)
- func DeployDPFSystemComponents(ctx context.Context, input DeployDPFSystemComponentsInput)
- func ProvisionDPUCluster(ctx context.Context, input ProvisionDPUClustersInput)
- func ProvisionDPUSet(ctx context.Context, input ProvisionDPUClustersInput)
- func ValidateDPFOperatorFlannelPodCIDRChange(ctx context.Context, input *systemTestInput)
- func ValidateDPFOperatorImageConfiguration(ctx context.Context, input *systemTestInput)
- func ValidateDPFOperatorKubernetesAPIServerVIPAndPort(ctx context.Context, input *systemTestInput)
- func ValidateDPFOperatorMTUConfigurationChange(ctx context.Context, input *systemTestInput)
- func ValidateDPFOperatorMTUCurrentConfiguration(ctx context.Context, input *systemTestInput)
- func ValidateDPFOperatorMaxDPUParallelInstallations(ctx context.Context, input *systemTestInput)
- func ValidateDPFOperatorPathConfiguration(ctx context.Context, input *systemTestInput)
- func ValidateDPUDeploymentCreation(ctx context.Context, input *systemTestInput)
- func ValidateDPUDeploymentDeletionWhileDisruptiveUpgradeInProgress(ctx context.Context, input *systemTestInput)
- func ValidateDPUDeploymentMetrics(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceChainCreation(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceChainDeletion(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceChainMetrics(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceConfigPorts(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceCreationAndMirroring(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceCredentialRequestCreation(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceCredentialRequestDeletion(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceCredentialRequestMetrics(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceDeletion(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceIPAMCreationCidrSplit(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceIPAMCreationInvalid(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceIPAMCreationSubnetSplit(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceIPAMDeletionCidrSplit(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceIPAMMetrics(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceIPAMMetricsDeletion(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceInterfaceCreation(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceMetrics(ctx context.Context, input *systemTestInput)
- func ValidateDPUServiceTemplateCreationNoAnnotations(ctx context.Context, input *systemTestInput)
- func ValidateGeneralDPFMetrics(ctx context.Context, input *systemTestInput)
- func ValidateImagePullSecretsSync(ctx context.Context, input *systemTestInput)
- func ValidateOperatorFullCreation(ctx context.Context, input *systemTestInput)
- func VerifyDPUClusterPods(ctx context.Context, podSubstrToVerify []string)
- func VerifyDPUClusterWithNodes(ctx context.Context, input ProvisionDPUClustersInput)
- func VerifyDPUServiceTemplateCreationWithAnnotations(ctx context.Context, input *systemTestInput)
- func VerifyDPUServiceTemplateMetrics(ctx context.Context, input *systemTestInput)
- func VerifyDeploymentUnderlyingObjectsCreated(ctx context.Context, g Gomega, testClient client.Client, ...) bool
- func VerifyHBNOnlyServiceFunctionChain(ctx context.Context, input *systemTestInput)
- func VerifyKSMMetricsCollection(ctx context.Context)
- func VerifyPlainServiceFunctionChain(ctx context.Context, input *systemTestInput)
- type ByTracker
- type DeployDPFSystemComponentsInput
- type IperfResult
- type ProvisionDPUClustersInput
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteDPFOperatorConfig ¶
func DeployDPFSystemComponents ¶
func DeployDPFSystemComponents(ctx context.Context, input DeployDPFSystemComponentsInput)
DeployDPFSystemComponents creates the operatorConfig and some dependencies and checks that the system components are deployed from the operator. 1) Ensures the DPF Operator is running and ready 2) Creates a PersistentVolumeClaim for the Provisioning controller 3) Creates ImagePullSecrets which are tested as part of the e2e flow (note these are fake and could possibly be replaced by real ones) 4) Creates the operatorConfig for the test 5) Ensures the DPF System components - including DPUServices - have been deployed.
func ProvisionDPUCluster ¶
func ProvisionDPUCluster(ctx context.Context, input ProvisionDPUClustersInput)
ProvisionDPUCluster provisions a DPUCluster and creates a BFB.
func ProvisionDPUSet ¶
func ProvisionDPUSet(ctx context.Context, input ProvisionDPUClustersInput)
ProvisionDPUSet DPUSet that will provision DPUs in the background if the environment has such DPUs. It doesn't check whether the DPUs become ready intentionally to allow for subsequent tests to be executed in the meantime.
func ValidateDPFOperatorImageConfiguration ¶
ValidateDPFOperatorImageConfiguration verifies that DPFOperatorConfiguration Image options work. It changes the images for all system components to arbitrary values, checks that the changes have propagated and then changes them back to their default versions. This function tests DPUService image setting as it is complex and requires e2e testing.
func ValidateDPFOperatorKubernetesAPIServerVIPAndPort ¶
ValidateDPFOperatorKubernetesAPIServerVIPAndPort validates that the Kubernetes API Server related variables are propagated correctly to the DMS pods.
func ValidateDPUServiceCreationAndMirroring ¶
ValidateDPUServiceCreationAndMirroring creates the DPUService in DPU cluster and host cluster. It verifies all triggered objects are created and ready. Can be used as s test precondition(ex: DPUServiceDeletion test) and as a separate test.
func VerifyDPUClusterPods ¶
func VerifyDPUClusterWithNodes ¶
func VerifyDPUClusterWithNodes(ctx context.Context, input ProvisionDPUClustersInput)
VerifyDPUClusterWithNodes waits and verifies if the DPUCluster has nodes meaning that there were DPUs provisioned. In addition verifies that the DPUs become ready.
func VerifyDeploymentUnderlyingObjectsCreated ¶
func VerifyDeploymentUnderlyingObjectsCreated(ctx context.Context, g Gomega, testClient client.Client, dpuDeployment *dpuservicev1.DPUDeployment) bool
Types ¶
type ByTracker ¶
type ByTracker struct {
// contains filtered or unexported fields
}
ByTracker tracks Ginkgo By() statements to ensure they are only printed once
type DeployDPFSystemComponentsInput ¶
type DeployDPFSystemComponentsInput struct {
ProvisioningControllerPVC *corev1.PersistentVolumeClaim
ImagePullSecrets []string
// contains filtered or unexported fields
}
type IperfResult ¶
type IperfResult struct {
Start struct {
Connected []struct {
LocalHost string `json:"local_host"`
RemoteHost string `json:"remote_host"`
} `json:"connected"`
} `json:"start"`
Intervals []struct {
Sum struct {
BitsPerSecond float64 `json:"bits_per_second"`
} `json:"sum"`
} `json:"intervals"`
End struct {
SumSent struct {
BitsPerSecond float64 `json:"bits_per_second"`
} `json:"sum_sent"`
} `json:"end"`
}
IperfResult is used to parse the result of an iperf3 command
type ProvisionDPUClustersInput ¶
type ProvisionDPUClustersInput struct {
// contains filtered or unexported fields
}
Source Files