suite

package
v1.0.11 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2025 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddClientsToCredentialProviders added in v1.0.5 

func AddClientsToCredentialProviders(credentialProviders []e2e.NodeadmCredentialsProvider, test *PeeredVPCTest) []e2e.NodeadmCredentialsProvider

func CreateNodes added in v1.0.5 

func CreateNodes(ctx context.Context, test *PeeredVPCTest, nodesToCreate []NodeCreate)

func CredentialProviders added in v1.0.5 

func CredentialProviders() []e2e.NodeadmCredentialsProvider

func NewLoggerForTests added in v1.0.5 

func NewLoggerForTests() e2e.PausableLogger

Types

type AddonEc2Test added in v1.0.6 

type AddonEc2Test struct {
	*PeeredVPCTest
}

AddonEc2Test is a wrapper around the fields needed for addon tests that decouples the PeeredVPCTest from specific addon test implementations.

func (*AddonEc2Test) NewCertManagerTest added in v1.0.8 

func (a *AddonEc2Test) NewCertManagerTest(ctx context.Context) (*addon.CertManagerTest, error)

NewCertManagerTest creates a new CertManagerTest

func (*AddonEc2Test) NewKubeStateMetricsTest added in v1.0.7 

func (a *AddonEc2Test) NewKubeStateMetricsTest() *addon.KubeStateMetricsTest

NewKubeStateMetricsTest creates a new KubeStateMetricsTest

func (*AddonEc2Test) NewMetricsServerTest added in v1.0.7 

func (a *AddonEc2Test) NewMetricsServerTest() *addon.MetricsServerTest

NewMetricsServerTest creates a new MetricsServerTest

func (*AddonEc2Test) NewNodeMonitoringAgentTest added in v1.0.6 

func (a *AddonEc2Test) NewNodeMonitoringAgentTest() *addon.NodeMonitoringAgentTest

NewNodeMonitoringAgentTest creates a new NodeMonitoringAgentTest

func (*AddonEc2Test) NewNvidiaDevicePluginTest added in v1.0.8 

func (a *AddonEc2Test) NewNvidiaDevicePluginTest(nodeName string) *addon.NvidiaDevicePluginTest

NewNvidiaDevicePluginTest creates a new NvidiaDevicePluginTest

func (*AddonEc2Test) NewPrometheusNodeExporterTest added in v1.0.8 

func (a *AddonEc2Test) NewPrometheusNodeExporterTest() *addon.PrometheusNodeExporterTest

NewPrometheusNodeExporterTest creates a new PrometheusNodeExporterTest

func (*AddonEc2Test) NewVerifyPodIdentityAddon added in v1.0.6 

func (a *AddonEc2Test) NewVerifyPodIdentityAddon(nodeName string) *addon.VerifyPodIdentityAddon

NewVerifyPodIdentityAddon creates a new VerifyPodIdentityAddon

type BottlerocketNodeWaiter added in v1.0.9 

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

func (*BottlerocketNodeWaiter) Run added in v1.0.9 

func (w *BottlerocketNodeWaiter) Run(ctx context.Context, flakeRun FlakeRun)

type FlakeRun added in v1.0.4 

type FlakeRun struct {
	DeferCleanup    func(func(context.Context), ...interface{})
	RetryableExpect func(actual interface{}, extra ...interface{}) Assertion
}

type FlakyCode added in v1.0.4 

type FlakyCode struct {
	Logger      logr.Logger
	FailHandler func(message string, callerSkip ...int)
}

FlakyCode can be used to run a test block multiple times until it succeeds. It will retry the test block the number of times specified by flakeAttempts. If the test block fails, the deferred cleanups will be run. If the test block succeeds, the deferred cleanups will not be run until the end of the entire test.

func (*FlakyCode) It added in v1.0.4 

func (f *FlakyCode) It(ctx context.Context, description string, flakeAttempts int, body func(ctx context.Context, flakeRun FlakeRun))

type NodeCreate added in v1.0.5 

type NodeCreate struct {
	InstanceName string
	InstanceSize e2e.InstanceSize
	NodeName     string
	OS           e2e.NodeadmOS
	Provider     e2e.NodeadmCredentialsProvider
	ComputeType  e2e.ComputeType
}

type NodeWaiter added in v1.0.9 

type NodeWaiter interface {
	Run(ctx context.Context, flakeRun FlakeRun)
}

type NodeadmConfigMatcher added in v1.0.5 

type NodeadmConfigMatcher struct {
	MatchOS            func(name string) bool
	MatchCredsProvider func(name creds.CredentialProvider) bool
}

type NodeadmConfigMatchers added in v1.0.5 

type NodeadmConfigMatchers []NodeadmConfigMatcher

func (NodeadmConfigMatchers) Matches added in v1.0.5 

func (m NodeadmConfigMatchers) Matches(osName string, creds creds.CredentialProvider) bool

type OSProvider added in v1.0.5 

type OSProvider struct {
	OS       e2e.NodeadmOS
	Provider e2e.NodeadmCredentialsProvider
}

func BottlerocketOSProviderList added in v1.0.9 

func BottlerocketOSProviderList(credentialProviders []e2e.NodeadmCredentialsProvider) []OSProvider

func OSProviderList added in v1.0.5 

func OSProviderList(credentialProviders []e2e.NodeadmCredentialsProvider) []OSProvider

type PeeredVPCTest added in v1.0.5 

type PeeredVPCTest struct {
	EKSClient *eks.Client
	EC2Client *ec2v2.Client
	SSMClient *ssmv2.Client

	K8sClient       peeredtypes.K8s
	K8sClientConfig *rest.Config
	S3Client        *s3v2.Client
	IAMClient       *iam.Client

	Logger logr.Logger

	ArtifactsPath string

	Cluster  *peered.HybridCluster
	StackOut *credentials.StackOutput

	RolesAnywhereCA *credentials.Certificate

	OverrideNodeK8sVersion string

	SkipCleanup       bool
	JumpboxInstanceId string

	PodIdentityS3Bucket string
	// contains filtered or unexported fields
}

func BeforeVPCTest added in v1.0.5 

func BeforeVPCTest(ctx context.Context, suite *SuiteConfiguration) *PeeredVPCTest

BeforeVPCTest is a helper function that builds a PeeredVPCTest and sets up the credential providers. It is intended to be used in BeforeEach.

func BuildPeeredVPCTestForSuite added in v1.0.5 

func BuildPeeredVPCTestForSuite(ctx context.Context, suite *SuiteConfiguration) (*PeeredVPCTest, error)

func (*PeeredVPCTest) CreateManagedNodeGroups added in v1.0.10 

func (t *PeeredVPCTest) CreateManagedNodeGroups(ctx context.Context) error

CreateManagedNodeGroups creates EKS managed node groups for mixed mode testing

func (*PeeredVPCTest) InstanceName added in v1.0.5 

func (t *PeeredVPCTest) InstanceName(testName, osName, providerName string) string

func (*PeeredVPCTest) NewCleanNode added in v1.0.5 

func (t *PeeredVPCTest) NewCleanNode(provider e2e.NodeadmCredentialsProvider, infraCleaner nodeadm.NodeInfrastructureCleaner, nodeName, nodeIP string) *nodeadm.CleanNode

func (*PeeredVPCTest) NewPeeredNetwork added in v1.0.5 

func (t *PeeredVPCTest) NewPeeredNetwork(logger logr.Logger) *peered.Network

func (*PeeredVPCTest) NewPeeredNode added in v1.0.5 

func (t *PeeredVPCTest) NewPeeredNode(logger logr.Logger) *peered.Node

func (*PeeredVPCTest) NewTestNode added in v1.0.5 

func (t *PeeredVPCTest) NewTestNode(ctx context.Context, instanceName, nodeName, k8sVersion string, os e2e.NodeadmOS, provider e2e.NodeadmCredentialsProvider, instanceSize e2e.InstanceSize, computeType e2e.ComputeType, opts ...TestNodeOption) *testNode

func (*PeeredVPCTest) NewUpgradeNode added in v1.0.5 

func (t *PeeredVPCTest) NewUpgradeNode(nodeName, nodeIP string) *nodeadm.UpgradeNode

func (*PeeredVPCTest) NewVerifyPodIdentityAddon added in v1.0.5 

func (t *PeeredVPCTest) NewVerifyPodIdentityAddon(nodeName string) *addon.VerifyPodIdentityAddon

type StandardLinuxNodeWaiter added in v1.0.9 

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

func (*StandardLinuxNodeWaiter) Run added in v1.0.9 

func (w *StandardLinuxNodeWaiter) Run(ctx context.Context, flakeRun FlakeRun)

type SuiteConfiguration added in v1.0.5 

type SuiteConfiguration struct {
	TestConfig             *e2e.TestConfig          `json:"testConfig"`
	SkipCleanup            bool                     `json:"skipCleanup"`
	CredentialsStackOutput *credentials.StackOutput `json:"ec2StackOutput"`
	RolesAnywhereCACertPEM []byte                   `json:"rolesAnywhereCACertPEM"`
	RolesAnywhereCAKeyPEM  []byte                   `json:"rolesAnywhereCAPrivateKeyPEM"`
	PublicKey              string                   `json:"publicKey"`
	JumpboxInstanceId      string                   `json:"jumpboxInstanceId"`
}

func BeforeSuiteCredentialSetup added in v1.0.5 

func BeforeSuiteCredentialSetup(ctx context.Context, filePath string) SuiteConfiguration

BeforeSuiteCredentialSetup is a helper function that creates the credential stack and returns a byte[] json representation of the SuiteConfiguration struct. This is intended to be used in SynchronizedBeforeSuite and run for each process.

func BeforeSuiteCredentialUnmarshal added in v1.0.5 

func BeforeSuiteCredentialUnmarshal(ctx context.Context, data []byte) *SuiteConfiguration

type TestNodeOption added in v1.0.5 

type TestNodeOption func(*testNode)

func WithLogging added in v1.0.5 

func WithLogging(loggerControl e2e.PausableLogger, serialOutputWriter io.Writer) TestNodeOption

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.