Documentation
¶
Index ¶
- func AddClientsToCredentialProviders(credentialProviders []e2e.NodeadmCredentialsProvider, test *PeeredVPCTest) []e2e.NodeadmCredentialsProvider
- func CreateNodes(ctx context.Context, test *PeeredVPCTest, nodesToCreate []NodeCreate)
- func CredentialProviders() []e2e.NodeadmCredentialsProvider
- func NewLoggerForTests() e2e.PausableLogger
- type AddonEc2Test
- func (a *AddonEc2Test) NewKubeStateMetricsTest() *addon.KubeStateMetricsTest
- func (a *AddonEc2Test) NewMetricsServerTest() *addon.MetricsServerTest
- func (a *AddonEc2Test) NewNodeMonitoringAgentTest() *addon.NodeMonitoringAgentTest
- func (a *AddonEc2Test) NewVerifyPodIdentityAddon(nodeName string) *addon.VerifyPodIdentityAddon
- type FlakeRun
- type FlakyCode
- type NodeCreate
- type NodeadmConfigMatcher
- type NodeadmConfigMatchers
- type OSProvider
- type PeeredVPCTest
- func (t *PeeredVPCTest) InstanceName(testName string, os e2e.NodeadmOS, provider e2e.NodeadmCredentialsProvider) string
- func (t *PeeredVPCTest) NewCleanNode(provider e2e.NodeadmCredentialsProvider, ...) *nodeadm.CleanNode
- func (t *PeeredVPCTest) NewPeeredNetwork(logger logr.Logger) *peered.Network
- func (t *PeeredVPCTest) NewPeeredNode(logger logr.Logger) *peered.Node
- func (t *PeeredVPCTest) NewTestNode(ctx context.Context, instanceName, nodeName, k8sVersion string, ...) *testNode
- func (t *PeeredVPCTest) NewUpgradeNode(nodeName, nodeIP string) *nodeadm.UpgradeNode
- func (t *PeeredVPCTest) NewVerifyPodIdentityAddon(nodeName string) *addon.VerifyPodIdentityAddon
- type SuiteConfiguration
- type TestNodeOption
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) 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) NewVerifyPodIdentityAddon ¶ added in v1.0.6
func (a *AddonEc2Test) NewVerifyPodIdentityAddon(nodeName string) *addon.VerifyPodIdentityAddon
NewVerifyPodIdentityAddon creates a new VerifyPodIdentityAddon
type FlakyCode ¶ added in v1.0.4
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.
type NodeCreate ¶ added in v1.0.5
type NodeCreate struct {
InstanceName string
InstanceSize e2e.InstanceSize
NodeName string
OS e2e.NodeadmOS
Provider e2e.NodeadmCredentialsProvider
}
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 OSProviderList ¶ added in v1.0.5
func OSProviderList(credentialProviders []e2e.NodeadmCredentialsProvider) []OSProvider
type PeeredVPCTest ¶ added in v1.0.5
type PeeredVPCTest struct {
SSMClient *ssmv2.Client
K8sClientConfig *rest.Config
Logger logr.Logger
ArtifactsPath string
Cluster *peered.HybridCluster
StackOut *credentials.StackOutput
RolesAnywhereCA *credentials.Certificate
OverrideNodeK8sVersion string
SkipCleanup bool
JumpboxInstanceId 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) InstanceName ¶ added in v1.0.5
func (t *PeeredVPCTest) InstanceName(testName string, os e2e.NodeadmOS, provider e2e.NodeadmCredentialsProvider) 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, 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 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