aws

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Jul 7, 2020 License: Apache-2.0 Imports: 22 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client struct {
	ResourceManagers []ClusterResourceManager
	Logger           *logrus.Entry
}

func NewDefaultClient

func NewDefaultClient(awsSession *session.Session, logger *logrus.Entry) *Client

func (*Client) DeleteResourcesForCluster

func (c *Client) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) (*clusterservice.Report, error)

DeleteResourcesForCluster Delete AWS resources based on tags using provided action engines

type ClusterResourceManager

type ClusterResourceManager interface {
	GetName() string
	DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)
}

ClusterResourceManager Perform actions for a specific resource

type ElasticacheManager added in v0.2.0

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

func NewDefaultElasticacheManager added in v0.2.0

func NewDefaultElasticacheManager(session *session.Session, logger *logrus.Entry) *ElasticacheManager

func (*ElasticacheManager) DeleteResourcesForCluster added in v0.2.0

func (r *ElasticacheManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

Delete all elasticache resources for a specified cluster

func (*ElasticacheManager) GetName added in v0.2.0

func (r *ElasticacheManager) GetName() string

type ElasticacheSnapshotManager added in v0.2.0

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

func NewDefaultElasticacheSnapshotManager added in v0.2.0

func NewDefaultElasticacheSnapshotManager(session *session.Session, logger *logrus.Entry) *ElasticacheSnapshotManager

func (*ElasticacheSnapshotManager) DeleteResourcesForCluster added in v0.2.0

func (r *ElasticacheSnapshotManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

func (*ElasticacheSnapshotManager) GetName added in v0.2.0

func (r *ElasticacheSnapshotManager) GetName() string

type RDSInstanceManager

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

func NewDefaultRDSInstanceManager

func NewDefaultRDSInstanceManager(session *session.Session, logger *logrus.Entry) *RDSInstanceManager

func (*RDSInstanceManager) DeleteResourcesForCluster

func (r *RDSInstanceManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

Delete all RDS resources for a specified cluster

func (*RDSInstanceManager) GetName

func (r *RDSInstanceManager) GetName() string

type RDSSnapshotManager

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

func NewDefaultRDSSnapshotManager

func NewDefaultRDSSnapshotManager(session *session.Session, logger *logrus.Entry) *RDSSnapshotManager

func (*RDSSnapshotManager) DeleteResourcesForCluster

func (r *RDSSnapshotManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

func (*RDSSnapshotManager) GetName

func (r *RDSSnapshotManager) GetName() string

type RDSSubnetGroup added in v0.3.0

type RDSSubnetGroup struct {
	Name string
	ARN  string
}

type RDSSubnetGroupManager added in v0.3.0

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

func NewDefaultRDSSubnetGroupManager added in v0.3.0

func NewDefaultRDSSubnetGroupManager(session *session.Session, logger *logrus.Entry) *RDSSubnetGroupManager

func (*RDSSubnetGroupManager) DeleteResourcesForCluster added in v0.3.0

func (r *RDSSubnetGroupManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

Delete all RDS Subnet Groups for a specified cluster

func (*RDSSubnetGroupManager) GetName added in v0.3.0

func (r *RDSSubnetGroupManager) GetName() string

type ResourceManagerType

type ResourceManagerType string

type RouteTableManager added in v0.3.0

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

func NewDefaultRouteTableManager added in v0.3.0

func NewDefaultRouteTableManager(session *session.Session, logger *logrus.Entry) *RouteTableManager

func (*RouteTableManager) DeleteResourcesForCluster added in v0.3.0

func (r *RouteTableManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

func (*RouteTableManager) GetName added in v0.3.0

func (r *RouteTableManager) GetName() string

type S3Manager

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

func NewDefaultS3Engine

func NewDefaultS3Engine(session *session.Session, logger *logrus.Entry) *S3Manager

func (*S3Manager) DeleteResourcesForCluster

func (s *S3Manager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

func (*S3Manager) GetName

func (r *S3Manager) GetName() string

type SecurityGroupManager added in v0.3.0

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

SecurityGroupManager type

func NewDefaultSecurityGroupManager added in v0.3.0

func NewDefaultSecurityGroupManager(session *session.Session, logger *logrus.Entry) *SecurityGroupManager

NewDefaultSecurityGroupManager create session for manager

func (*SecurityGroupManager) DeleteResourcesForCluster added in v0.3.0

func (r *SecurityGroupManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

DeleteResourcesForCluster deletes resource for cluster

func (*SecurityGroupManager) GetName added in v0.3.0

func (r *SecurityGroupManager) GetName() string

GetName getter function

type SubnetManager added in v0.2.0

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

func NewDefaultSubnetManager added in v0.2.0

func NewDefaultSubnetManager(session *session.Session, logger *logrus.Entry) *SubnetManager

func (*SubnetManager) DeleteResourcesForCluster added in v0.2.0

func (s *SubnetManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

func (*SubnetManager) GetName added in v0.2.0

func (r *SubnetManager) GetName() string

type VpcManager added in v0.3.0

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

VpcManager type

func NewDefaultVpcManager added in v0.3.0

func NewDefaultVpcManager(session *session.Session, logger *logrus.Entry) *VpcManager

NewDefaultVpcManager create session for manager

func (*VpcManager) DeleteResourcesForCluster added in v0.3.0

func (r *VpcManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

DeleteResourcesForCluster deletes resource for cluster

func (*VpcManager) GetName added in v0.3.0

func (r *VpcManager) GetName() string

GetName getter function

type VpcPeeringManager added in v0.3.0

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

VpcPeeringManager type

func NewDefaultVpcPeeringManager added in v0.3.0

func NewDefaultVpcPeeringManager(session *session.Session, logger *logrus.Entry) *VpcPeeringManager

NewDefaultVpcPeeringManager create session for manager

func (*VpcPeeringManager) DeleteResourcesForCluster added in v0.3.0

func (r *VpcPeeringManager) DeleteResourcesForCluster(clusterId string, tags map[string]string, dryRun bool) ([]*clusterservice.ReportItem, error)

DeleteResourcesForCluster deletes resource for cluster

func (*VpcPeeringManager) GetName added in v0.3.0

func (r *VpcPeeringManager) GetName() string

GetName getter function

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL