aws

package
v0.30.0 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2023 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TestCategoryDimension           = "category"
	TestNameDimension               = "name"
	GitRefDimension                 = "gitRef"
	ProvisionedNodeCountDimension   = "provisionedNodeCount"
	DeprovisionedNodeCountDimension = "deprovisionedNodeCount"
	PodDensityDimension             = "podDensity"
)
View Source 
const WindowsDefaultImage = "mcr.microsoft.com/oss/kubernetes/pause:3.9"

Variables

View Source 
var (
	CleanableObjects = []client.Object{
		&v1alpha1.AWSNodeTemplate{},
	}
)

Functions

func GetTimeStreamAPI added in v0.29.1 

func GetTimeStreamAPI(session *session.Session) timestreamwriteiface.TimestreamWriteAPI

Types

type Environment 

type Environment struct {
	*common.Environment
	Region string

	STSAPI        *sts.STS
	EC2API        *ec2.EC2
	SSMAPI        *ssm.SSM
	IAMAPI        *iam.IAM
	FISAPI        *fis.FIS
	EKSAPI        *eks.EKS
	TimeStreamAPI timestreamwriteiface.TimestreamWriteAPI

	SQSProvider *interruption.SQSProvider
}

func NewEnvironment 

func NewEnvironment(t *testing.T) *Environment

func (*Environment) AfterEach 

func (env *Environment) AfterEach()

func (*Environment) BeforeEach 

func (env *Environment) BeforeEach()

func (*Environment) Cleanup 

func (env *Environment) Cleanup()

func (*Environment) ExpectAccountID 

func (env *Environment) ExpectAccountID() string

func (*Environment) ExpectExperimentTemplateDeleted 

func (env *Environment) ExpectExperimentTemplateDeleted(id string)

func (*Environment) ExpectIPv6ClusterDNS 

func (env *Environment) ExpectIPv6ClusterDNS() string

func (*Environment) ExpectInstance 

func (env *Environment) ExpectInstance(nodeName string) Assertion

func (*Environment) ExpectInstanceStopped 

func (env *Environment) ExpectInstanceStopped(nodeName string)

func (*Environment) ExpectInstanceTerminated 

func (env *Environment) ExpectInstanceTerminated(nodeName string)

func (*Environment) ExpectMessagesCreated 

func (env *Environment) ExpectMessagesCreated(msgs ...interface{})

func (*Environment) ExpectMetric 

func (env *Environment) ExpectMetric(name string, value float64, labels map[string]string)

func (*Environment) ExpectParsedProviderID 

func (env *Environment) ExpectParsedProviderID(providerID string) string

func (*Environment) ExpectQueueExists 

func (env *Environment) ExpectQueueExists()

func (*Environment) ExpectRunInstances 

func (env *Environment) ExpectRunInstances(instanceInput *ec2.RunInstancesInput) *ec2.Reservation

func (*Environment) ExpectSpotInterruptionExperiment 

func (env *Environment) ExpectSpotInterruptionExperiment(instanceIDs ...string) *fis.Experiment

func (*Environment) ExpectSpotInterruptionRole 

func (env *Environment) ExpectSpotInterruptionRole() *iam.Role

func (*Environment) ExpectWindowsIPAMDisabled 

func (env *Environment) ExpectWindowsIPAMDisabled()

func (*Environment) ExpectWindowsIPAMEnabled 

func (env *Environment) ExpectWindowsIPAMEnabled()

func (*Environment) GetCustomAMI 

func (env *Environment) GetCustomAMI(amiPath string, versionOffset int) string

func (*Environment) GetInstance 

func (env *Environment) GetInstance(nodeName string) ec2.Instance

func (*Environment) GetInstanceByID 

func (env *Environment) GetInstanceByID(instanceID string) ec2.Instance

func (*Environment) GetInstanceByIDWithOffset 

func (env *Environment) GetInstanceByIDWithOffset(offset int, instanceID string) ec2.Instance

func (*Environment) GetSecurityGroups 

func (env *Environment) GetSecurityGroups(tags map[string]string) []SecurityGroup

GetSecurityGroups returns all getSecurityGroups matching the label selector

func (*Environment) GetSubnetNameAndIds 

func (env *Environment) GetSubnetNameAndIds(tags map[string]string) []SubnetInfo

GetSubnetNameAndIds returns all subnets matching the label selector

func (*Environment) GetSubnets 

func (env *Environment) GetSubnets(tags map[string]string) map[string][]string

GetSubnets returns all subnets matching the label selector mapped from AZ -> {subnet-ids...}

func (*Environment) GetVolume 

func (env *Environment) GetVolume(volumeID *string) ec2.Volume

func (*Environment) MeasureDeprovisioningDurationFor added in v0.29.1 

func (env *Environment) MeasureDeprovisioningDurationFor(f func(), dimensions map[string]string)

func (*Environment) MeasureDurationFor 

func (env *Environment) MeasureDurationFor(f func(), eventType EventType, dimensions map[string]string)

MeasureDurationFor observes the duration between the beginning of the function f() and the end of the function f()

func (*Environment) MeasureProvisioningDurationFor added in v0.29.1 

func (env *Environment) MeasureProvisioningDurationFor(f func(), dimensions map[string]string)

type EventType 

type EventType string
const (
	ProvisioningEventType   EventType = "provisioning"
	DeprovisioningEventType EventType = "deprovisioning"
)

type NoOpTimeStreamAPI added in v0.29.1 

type NoOpTimeStreamAPI struct {
	timestreamwriteiface.TimestreamWriteAPI
}

func (NoOpTimeStreamAPI) WriteRecordsWithContext added in v0.29.1 

func (o NoOpTimeStreamAPI) WriteRecordsWithContext(_ context.Context, _ *timestreamwrite.WriteRecordsInput, _ ...request.Option) (*timestreamwrite.WriteRecordsOutput, error)

type SecurityGroup 

type SecurityGroup struct {
	ec2.GroupIdentifier
	Tags []*ec2.Tag
}

type SubnetInfo 

type SubnetInfo struct {
	Name string
	ID   string
}

SubnetInfo is a simple struct for testing

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.