cleanup

package
v1.0.18 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2026 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CFNStackCleanup 

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

func NewCFNStackCleanup 

func NewCFNStackCleanup(cfnClient *cloudformation.Client, logger logr.Logger) *CFNStackCleanup

func (*CFNStackCleanup) DeleteStack 

func (c *CFNStackCleanup) DeleteStack(ctx context.Context, stackName string) error

func (*CFNStackCleanup) ListArchitectureStacks 

func (c *CFNStackCleanup) ListArchitectureStacks(ctx context.Context, input FilterInput) ([]string, error)

ListArchitectureStacks lists all the architecture stacks for a given cluster architecture stacks start with EKSHybridCI-Arch

func (*CFNStackCleanup) ListCredentialStacks 

func (c *CFNStackCleanup) ListCredentialStacks(ctx context.Context, input FilterInput) ([]string, error)

ListCredentialStacks lists all the credential stacks for a given cluster credentials stacks start with EKSHybridCI but not EKSHybridCI-Arch

type Cleanup added in v1.0.5 

type Cleanup struct {
	Cleanup        func(ctx context.Context, filterInput FilterInput) error
	FailureMessage string
}

type CloudWatchLogsCleaner added in v1.0.6 

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

func NewCloudWatchLogsCleaner added in v1.0.6 

func NewCloudWatchLogsCleaner(client *cloudwatchlogs.Client, taggingClient *ResourceTaggingClient, logger logr.Logger) *CloudWatchLogsCleaner

func (*CloudWatchLogsCleaner) DeleteLogGroup added in v1.0.6 

func (c *CloudWatchLogsCleaner) DeleteLogGroup(ctx context.Context, logGroupName string) error

func (*CloudWatchLogsCleaner) ListLogGroups added in v1.0.6 

func (c *CloudWatchLogsCleaner) ListLogGroups(ctx context.Context, filterInput FilterInput) ([]string, error)

ListLogGroups lists all log groups that match the filter input the instance age threshold is not used for log groups, instead we use 15 days as the threshold

type EC2Cleaner 

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

func NewEC2Cleaner 

func NewEC2Cleaner(ec2Client *ec2.Client, logger logr.Logger) *EC2Cleaner

func (*EC2Cleaner) DeleteInstances 

func (e *EC2Cleaner) DeleteInstances(ctx context.Context, instanceIDs []string) error

func (*EC2Cleaner) DeleteKeyPair 

func (e *EC2Cleaner) DeleteKeyPair(ctx context.Context, keyPairID string) error

func (*EC2Cleaner) ListKeyPairs 

func (e *EC2Cleaner) ListKeyPairs(ctx context.Context, input FilterInput) ([]string, error)

func (*EC2Cleaner) ListTaggedInstances 

func (e *EC2Cleaner) ListTaggedInstances(ctx context.Context, input FilterInput) ([]string, error)

type EKSClusterCleanup 

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

func NewEKSClusterCleanup 

func NewEKSClusterCleanup(eksClient *eks.Client, logger logr.Logger) *EKSClusterCleanup

func (*EKSClusterCleanup) DeleteCluster 

func (c *EKSClusterCleanup) DeleteCluster(ctx context.Context, clusterName string) error

func (*EKSClusterCleanup) ListEKSClusters 

func (c *EKSClusterCleanup) ListEKSClusters(ctx context.Context, input FilterInput) ([]string, error)

type FSxCleaner added in v1.0.18 

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

func NewFSxCleaner added in v1.0.18 

func NewFSxCleaner(fsxClient *fsx.Client, ec2Client *ec2.Client, logger logr.Logger) *FSxCleaner

func (*FSxCleaner) DeleteFileSystems added in v1.0.18 

func (f *FSxCleaner) DeleteFileSystems(ctx context.Context, fileSystemIDs []string) error

func (*FSxCleaner) ListTaggedFileSystems added in v1.0.18 

func (f *FSxCleaner) ListTaggedFileSystems(ctx context.Context, input FilterInput) ([]string, error)

type FilterInput 

type FilterInput struct {
	ClusterName          string
	ClusterNamePrefix    string
	AllClusters          bool
	InstanceAgeThreshold time.Duration
	DryRun               bool
}

type IAMCleaner 

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

func NewIAMCleaner 

func NewIAMCleaner(iamClient *iam.Client, logger logr.Logger) *IAMCleaner

func (*IAMCleaner) DeleteInstanceProfile 

func (c *IAMCleaner) DeleteInstanceProfile(ctx context.Context, profileName string) error

func (*IAMCleaner) DeleteRole 

func (c *IAMCleaner) DeleteRole(ctx context.Context, roleName string) error

func (*IAMCleaner) ListInstanceProfiles 

func (c *IAMCleaner) ListInstanceProfiles(ctx context.Context, filterInput FilterInput) ([]string, error)

func (*IAMCleaner) ListRoles 

func (c *IAMCleaner) ListRoles(ctx context.Context, filterInput FilterInput) ([]string, error)

func (*IAMCleaner) ListRolesForInstanceProfile 

func (c *IAMCleaner) ListRolesForInstanceProfile(ctx context.Context, profileName string) ([]string, error)

func (*IAMCleaner) RemoveRolesFromInstanceProfile 

func (c *IAMCleaner) RemoveRolesFromInstanceProfile(ctx context.Context, roles []string, profileName string) error

type ManagedNodeGroupCleanup added in v1.0.10 

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

func NewManagedNodeGroupCleanup added in v1.0.10 

func NewManagedNodeGroupCleanup(eksClient *eks.Client, logger logr.Logger) *ManagedNodeGroupCleanup

func (*ManagedNodeGroupCleanup) DeleteManagedNodeGroup added in v1.0.10 

func (c *ManagedNodeGroupCleanup) DeleteManagedNodeGroup(ctx context.Context, clusterName, nodeGroupName string) error

func (*ManagedNodeGroupCleanup) ListManagedNodeGroups added in v1.0.10 

func (c *ManagedNodeGroupCleanup) ListManagedNodeGroups(ctx context.Context, input FilterInput) ([]NodeGroupInfo, error)

type NodeGroupInfo added in v1.0.10 

type NodeGroupInfo struct {
	ClusterName   string
	NodeGroupName string
}

type ResourceTaggingClient added in v1.0.6 

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

func NewResourceTaggingClient added in v1.0.6 

func NewResourceTaggingClient(client *resourcegroupstaggingapi.Client) *ResourceTaggingClient

func (*ResourceTaggingClient) GetResourcesWithClusterTag added in v1.0.6 

func (c *ResourceTaggingClient) GetResourcesWithClusterTag(ctx context.Context, resourceType string, filterInput FilterInput) (map[string][]Tag, error)

GetResourcesWithClusterTag returns a array of resourceARNs for the resourceType with the given cluster tag this is useful for getting resources which do not allow filtering by tag in their native api and (usually) an additional api call per resource to get the tags which we need to determine if we want to delete the resource

type ResourceWithTags 

type ResourceWithTags struct {
	ID           string
	CreationTime time.Time
	Tags         []Tag
}

type RolesAnywhereCleaner 

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

func NewRolesAnywhereCleaner 

func NewRolesAnywhereCleaner(rolesAnywhere *rolesanywhere.Client, logger logr.Logger) *RolesAnywhereCleaner

func (*RolesAnywhereCleaner) DeleteProfile 

func (c *RolesAnywhereCleaner) DeleteProfile(ctx context.Context, profileID string) error

func (*RolesAnywhereCleaner) DeleteTrustAnchor 

func (c *RolesAnywhereCleaner) DeleteTrustAnchor(ctx context.Context, anchorID string) error

func (*RolesAnywhereCleaner) ListProfiles 

func (c *RolesAnywhereCleaner) ListProfiles(ctx context.Context, filterInput FilterInput) ([]string, error)

func (*RolesAnywhereCleaner) ListTrustAnchors 

func (c *RolesAnywhereCleaner) ListTrustAnchors(ctx context.Context, filterInput FilterInput) ([]string, error)

type S3Cleaner 

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

func NewS3Cleaner 

func NewS3Cleaner(s3Client *s3.Client, logger logr.Logger) *S3Cleaner

func (*S3Cleaner) DeleteBucket 

func (s *S3Cleaner) DeleteBucket(ctx context.Context, bucketName string) error

func (*S3Cleaner) EmptyS3Bucket 

func (s *S3Cleaner) EmptyS3Bucket(ctx context.Context, bucketName string) error

func (*S3Cleaner) ListBuckets 

func (s *S3Cleaner) ListBuckets(ctx context.Context, filterInput FilterInput) ([]string, error)

type SSMCleaner 

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

func NewSSMCleaner 

func NewSSMCleaner(ssm *ssm.Client, logger logr.Logger) *SSMCleaner

func (*SSMCleaner) DeleteActivation 

func (s *SSMCleaner) DeleteActivation(ctx context.Context, activationID string) error

func (*SSMCleaner) DeleteManagedInstance 

func (s *SSMCleaner) DeleteManagedInstance(ctx context.Context, instanceID string) error

func (*SSMCleaner) DeleteParameter 

func (s *SSMCleaner) DeleteParameter(ctx context.Context, parameterName string) error

func (*SSMCleaner) ListActivations 

func (s *SSMCleaner) ListActivations(ctx context.Context, filterInput FilterInput) ([]string, error)

func (*SSMCleaner) ListActivationsForNode 

func (s *SSMCleaner) ListActivationsForNode(ctx context.Context, nodeName, clusterName string) ([]string, error)

func (*SSMCleaner) ListManagedInstances 

func (s *SSMCleaner) ListManagedInstances(ctx context.Context, filterInput FilterInput) ([]string, error)

func (*SSMCleaner) ListManagedInstancesByActivationID 

func (s *SSMCleaner) ListManagedInstancesByActivationID(ctx context.Context, activationIDs ...string) ([]string, error)

func (*SSMCleaner) ListParameters 

func (s *SSMCleaner) ListParameters(ctx context.Context, filterInput FilterInput) ([]string, error)

type Sweeper 

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

func NewSweeper 

func NewSweeper(aws aws.Config, logger logr.Logger, endpoint string) Sweeper

func (*Sweeper) Run 

func (c *Sweeper) Run(ctx context.Context, input SweeperInput) error

type SweeperInput 

type SweeperInput struct {
	AllClusters          bool          `yaml:"allClusters"`
	DryRun               bool          `yaml:"dryRun"`
	ClusterName          string        `yaml:"clusterName"`
	ClusterNamePrefix    string        `yaml:"clusterNamePrefix"`
	InstanceAgeThreshold time.Duration `yaml:"instanceAgeThreshold"`
}

type Tag 

type Tag struct {
	Key   string
	Value string
}

type VPCCleaner 

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

VPCCleaner is responsible for cleaning up AWS VPC resources

func NewVPCCleaner 

func NewVPCCleaner(ec2Client *ec2.Client, logger logr.Logger) *VPCCleaner

NewVPCCleaner creates a new VPC cleaner

func (*VPCCleaner) DeleteInternetGateway 

func (v *VPCCleaner) DeleteInternetGateway(ctx context.Context, igwID string) error

func (*VPCCleaner) DeleteNetworkInterface 

func (v *VPCCleaner) DeleteNetworkInterface(ctx context.Context, networkInterfaceID string) error

func (*VPCCleaner) DeletePeeringConnection 

func (v *VPCCleaner) DeletePeeringConnection(ctx context.Context, peeringConnectionID string) error

func (*VPCCleaner) DeleteRouteTable 

func (v *VPCCleaner) DeleteRouteTable(ctx context.Context, routeTableID string) error

func (*VPCCleaner) DeleteSecurityGroup 

func (v *VPCCleaner) DeleteSecurityGroup(ctx context.Context, securityGroupID string) error

func (*VPCCleaner) DeleteSubnet 

func (v *VPCCleaner) DeleteSubnet(ctx context.Context, subnetID string) error

func (*VPCCleaner) DeleteTransitGateway added in v1.0.5 

func (v *VPCCleaner) DeleteTransitGateway(ctx context.Context, tgwID string) error

func (*VPCCleaner) DeleteVPC 

func (v *VPCCleaner) DeleteVPC(ctx context.Context, vpcID string) error

func (*VPCCleaner) ListInternetGateways 

func (v *VPCCleaner) ListInternetGateways(ctx context.Context, input FilterInput) ([]string, error)

func (*VPCCleaner) ListNetworkInterfaces 

func (v *VPCCleaner) ListNetworkInterfaces(ctx context.Context, vpcID string) ([]string, error)

func (*VPCCleaner) ListPeeringConnections 

func (v *VPCCleaner) ListPeeringConnections(ctx context.Context, input FilterInput) ([]string, error)

func (*VPCCleaner) ListRouteTables 

func (v *VPCCleaner) ListRouteTables(ctx context.Context, input FilterInput) ([]string, error)

func (*VPCCleaner) ListSecurityGroups 

func (v *VPCCleaner) ListSecurityGroups(ctx context.Context, input FilterInput) ([]string, error)

func (*VPCCleaner) ListSubnets 

func (v *VPCCleaner) ListSubnets(ctx context.Context, input FilterInput) ([]string, error)

func (*VPCCleaner) ListTransitGateways added in v1.0.5 

func (v *VPCCleaner) ListTransitGateways(ctx context.Context, input FilterInput) ([]string, error)

ListTransitGateways lists all transit gateways

func (*VPCCleaner) ListVPCs 

func (v *VPCCleaner) ListVPCs(ctx context.Context, input FilterInput) ([]string, error)

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.