internal

package
v0.1.26 Latest Latest
Warning

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

 Go to latest Published: May 7, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Simple         = "simple"
	ExternalLustre = "external_lustre"
	GFS2Fence      = "gfs2_fence"
)

To apply a set of labels for a particular test, use the withLables() method. Labels

View Source 
const (
	TriageNamespaceName = "nnf-system-needs-triage"
)

Variables

View Source 
var (
	// TestUserID and TestGroupID are the UID/GID used for workflow permissions in
	// container and data movement tests. These must correspond to a real user on the
	// system's compute/Rabbit nodes so that MPI SSH authentication is properly exercised.
	// Defaults to the flux user (1051/1052) since that is the WLM user that submits
	// MPI jobs in production. Using the mpiuser account (1050) would bypass the SSH key
	// setup code path where issue #310 occurs.
	// Override via NNF_USER_ID and NNF_GROUP_ID environment variables.
	TestUserID  uint32 = 1051
	TestGroupID uint32 = 1052
)

Functions

func CleanupHelperPods added in v0.0.4 

func CleanupHelperPods(ctx context.Context, k8sClient client.Client, t *T)

func CurrentContext added in v0.0.4 

func CurrentContext() (string, error)

func GetSystemConfiguraton added in v0.0.4 

func GetSystemConfiguraton(ctx context.Context, k8sClient client.Client) *dwsv1alpha7.SystemConfiguration

func GetVersion added in v0.0.4 

func GetVersion() (string, error)

func IsSystemInNeedOfTriage 

func IsSystemInNeedOfTriage(ctx context.Context, k8sClient client.Client) bool

func IsSystemReserved 

func IsSystemReserved(ctx context.Context, k8sClient client.Client) (bool, string, error)

IsSystemReserved checks if the system under test is reserved by a known developer.

func ObjectKeyFromObjectReference 

func ObjectKeyFromObjectReference(r corev1.ObjectReference) types.NamespacedName

func ReportContainerPodLogs added in v0.1.24 

func ReportContainerPodLogs(ctx context.Context, k8sClient client.Client, workflow *dwsv1alpha7.Workflow) string

ReportContainerPodLogs collects container pod logs for a workflow and returns them as a formatted string for inclusion in test failure reports.

func SetSystemInNeedOfTriage 

func SetSystemInNeedOfTriage(ctx context.Context, k8sClient client.Client) error

func SetupCopyIn added in v0.0.4 

func SetupCopyIn(ctx context.Context, k8sClient client.Client, t *T, o TOptions)

Start up a pod that accesses the global lustre filesystem and creates a file in the location specified by the copy_in directive.

func TestIterator 

func TestIterator(tests []*T) *iterator

func VerifyContainerPodLogs added in v0.1.24 

func VerifyContainerPodLogs(ctx context.Context, k8sClient client.Client, workflow *dwsv1alpha7.Workflow)

VerifyContainerPodLogs finds container pods for the given workflow and verifies their logs don't contain SSH authentication errors that indicate MPI communication failures. This catches issues like NearNodeFlash/NearNodeFlash.github.io#310 where mpirun fails with "Permission denied" when SSHing to worker nodes.

func VerifyCopyOut added in v0.0.4 

func VerifyCopyOut(ctx context.Context, k8sClient client.Client, t *T, o TOptions)

Start up a pod that accesses the global lustre filesystem and verifies that the files specified by the copy_in and copy_out directives match.

func VerifyUserOnRabbit added in v0.1.24 

func VerifyUserOnRabbit(ctx context.Context, k8sClient client.Client, uid uint32)

VerifyUserOnRabbit creates a pod on a Rabbit node to verify that the given UID corresponds to a real user. This is important for MPI container tests: if the user doesn't exist on the system, SSH key setup follows a different code path and won't exercise the authentication flow that caused issue #310. Checks all Rabbit nodes in the system configuration.

func WaitForDeletion added in v0.0.4 

func WaitForDeletion(ctx context.Context, k8sClient client.Client, obj client.Object)

Types

type ContainerProfileOptions added in v0.0.2 

type ContainerProfileOptions struct {
	PrerunTimeoutSeconds  *int
	PostrunTimeoutSeconds *int
	RetryLimit            *int
	NoStorage             bool // make any storages in the profile optional
}

type StateHandler 

type StateHandler func(context.Context, client.Client, *dwsv1alpha7.Workflow)

StateHandler defines a method that handles a particular state in the workflow

type T 

type T struct {
	// contains filtered or unexported fields
}

func DuplicateTest 

func DuplicateTest(t *T, count int) *T

func MakeTest 

func MakeTest(name string, directives ...string) *T

func (*T) AdvanceStateAndWaitForReady 

func (t *T) AdvanceStateAndWaitForReady(ctx context.Context, k8sClient client.Client, workflow *dwsv1alpha7.Workflow, state dwsv1alpha7.WorkflowState)

func (*T) AndCleanupPersistentInstance 

func (t *T) AndCleanupPersistentInstance() *T

AndCleanupPersistentInstance will automatically destroy the persistent instance. It is useful if you have a create_persistent directive that you wish to destroy after the test has finished.

func (*T) Args 

func (t *T) Args() []interface{}

func (*T) Cleanup 

func (t *T) Cleanup(ctx context.Context, k8sClient client.Client) error

Cleanup a test with the programmed test options. Note that the order in which test options are cleanup is the opposite order of their creation to ensure dependencies between options are correct.

func (*T) DelayInState added in v0.1.21 

func (t *T) DelayInState(state dwsv1alpha7.WorkflowState, duration time.Duration) *T

DelayInState allows you to pause in a specific state for a given duration. Multiple delays can be added by calling this method multiple times.

func (*T) Execute 

func (t *T) Execute(ctx context.Context, k8sClient client.Client)

func (*T) ExpectError 

func (t *T) ExpectError(state dwsv1alpha7.WorkflowState) *T

Expect an error at the designed state; Proceed to teardown

func (*T) Focused 

func (t *T) Focused() *T

func (*T) HardwareRequired added in v0.0.4 

func (t *T) HardwareRequired() *T

func (*T) HasContainerDirective added in v0.1.24 

func (t *T) HasContainerDirective() bool

HasContainerDirective returns true if this test includes a #DW container directive.

func (*T) Name 

func (t *T) Name() string

func (*T) Pending 

func (t *T) Pending() *T

func (*T) Prepare 

func (t *T) Prepare(ctx context.Context, k8sClient client.Client) error

Prepare a test with the programmed test options.

func (*T) RequiresHardware added in v0.1.26 

func (t *T) RequiresHardware() *T

RequiresHardware marks a test as requiring real hardware (skipped in kind environments).

func (*T) Serialized 

func (t *T) Serialized() *T

func (*T) ShouldTeardown 

func (t *T) ShouldTeardown() bool

func (*T) StopAfter 

func (t *T) StopAfter(state dwsv1alpha7.WorkflowState) *T

Stop after lets you stop a test after a given state is reached

func (*T) WithContainerProfile added in v0.0.2 

func (t *T) WithContainerProfile(base string, options *ContainerProfileOptions) *T

func (*T) WithExternalComputes added in v0.0.7 

func (t *T) WithExternalComputes() *T

WithExternalComputes engages external computes for the the test.

func (*T) WithGlobalLustre 

func (t *T) WithGlobalLustre(mountRoot string, fsName string, mgsNids string)

func (*T) WithGlobalLustreFromPersistentLustre 

func (t *T) WithGlobalLustreFromPersistentLustre(name string, namespaces []string) *T

WithGlobalLustreFromPersistentLustre will create a global lustre file system from a persistent lustre file system namespaces can be added in addition to the default `nnf-dm-system`

func (*T) WithLabels 

func (t *T) WithLabels(labels ...string) *T

func (*T) WithMgsPool added in v0.0.2 

func (t *T) WithMgsPool(name string, count int) *T

func (*T) WithPermissions 

func (t *T) WithPermissions(userId, groupId uint32) *T

func (*T) WithPersistentLustre 

func (t *T) WithPersistentLustre(name string) *T

func (*T) WithStorageProfile 

func (t *T) WithStorageProfile() *T

WithStorageProfile will manage a storage profile of name 'name'

func (*T) WithStorageProfileExternalMGS added in v0.0.2 

func (t *T) WithStorageProfileExternalMGS(externalMGS string) *T

func (*T) WithStorageProfileExternalMGSFromPersistentLustre added in v0.1.23 

func (t *T) WithStorageProfileExternalMGSFromPersistentLustre() *T

WithStorageProfileExternalMGSFromPersistentLustre configures the storage profile to use the NID from the test's persistent lustre instance as the external MGS. The profile is created after the persistent lustre is provisioned so the NID is available.

func (*T) WithStorageProfileLvCreate added in v0.1.21 

func (t *T) WithStorageProfileLvCreate(lvCreateCmd string) *T

func (*T) WithStorageProfileStandaloneMGT added in v0.0.2 

func (t *T) WithStorageProfileStandaloneMGT(standaloneMGT string) *T

func (*T) Workflow 

func (t *T) Workflow() *dwsv1alpha7.Workflow

func (*T) WorkflowDirectives 

func (t *T) WorkflowDirectives() []string

Retrieve the #DW Directives from the test case

func (*T) WorkflowName 

func (t *T) WorkflowName() string

type TCleanupPersistentInstance 

type TCleanupPersistentInstance struct {
	// contains filtered or unexported fields
}

type TContainerProfile added in v0.0.2 

type TContainerProfile struct {
	// contains filtered or unexported fields
}

type TDelayInState added in v0.1.21 

type TDelayInState struct {
	// contains filtered or unexported fields
}

type TDuplicate 

type TDuplicate struct {
	// contains filtered or unexported fields
}

type TExpectError 

type TExpectError struct {
	// contains filtered or unexported fields
}

type TGlobalLustre 

type TGlobalLustre struct {
	// contains filtered or unexported fields
}

type TMgsPool added in v0.0.2 

type TMgsPool struct {
	// contains filtered or unexported fields
}

type TOptions 

type TOptions struct {
	// contains filtered or unexported fields
}

TOptions lets you configure things prior to a test running or during test execution. Nil values represent no configuration of that type.

type TPersistentLustre 

type TPersistentLustre struct {
	// contains filtered or unexported fields
}

type TStopAfter 

type TStopAfter struct {
	// contains filtered or unexported fields
}

type TStorageProfile 

type TStorageProfile struct {
	// contains filtered or unexported fields
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.