task

package
v0.0.6 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	CheckToolsPathDir = "/tmp/tiup"
)

place the check utilities are stored

Variables

View Source 
var (
	CheckTypeSystemInfo   = "insight"
	CheckTypeSystemLimits = "limits"
	CheckTypeSystemConfig = "system"
	CheckTypePort         = "port"
	CheckTypeService      = "service"
	CheckTypePackage      = "package"
	CheckTypePartitions   = "partitions"
	CheckTypeFIO          = "fio"
	CheckTypePermission   = "permission"
)

the check types

View Source 
var (
	// ErrUnsupportedRollback means the task do not support rollback.
	ErrUnsupportedRollback = stderrors.New("unsupported rollback")
	// ErrNoExecutor means not being able to get the executor.
	ErrNoExecutor = stderrors.New("no executor")
	// ErrNoOutput means not being able to get the output of host.
	ErrNoOutput = stderrors.New("no outputs available")
)
View Source 
var DBNAME string
View Source 
var DMSInfo struct {
	SourceEndpointArn      string
	TargetEndpointArn      string
	ReplicationInstanceArn string
}
View Source 
var (

	// ErrEnvInitFailed is ErrEnvInitFailed
	ErrEnvInitFailed = errNSEnvInit.NewType("failed")
)
View Source 
var SqlServerHost string

Functions

func CleanClusterSA 

func CleanClusterSA(executor *ctxt.Executor, clusterName string) error

func ConvertEpochToString 

func ConvertEpochToString(strTimestamp string) string

func ExecuteDBInstance 

func ExecuteDBInstance(texecutor ctxt.Executor, ctx context.Context, clusterName, clusterType, subClusterType string, doWhenNotFound *func() error, doWhenFound *func() error) error

func ExistsDMSResource 

func ExistsDMSResource(clusterType, subClusterType, clusterName, resourceName string, executor ctxt.Executor, ctx context.Context) bool

func ExistsELBResource 

func ExistsELBResource(executor ctxt.Executor, ctx context.Context, clusterType, subClusterType, clusterName, resourceName string) bool

func ExistsResource 

func ExistsResource(clusterType, subClusterType, clusterName, resourceName string, executor ctxt.Executor, ctx context.Context) bool

func FetchClusterSA 

func FetchClusterSA(executor *ctxt.Executor, clusterName string) (*[]IAMSAInfo, error)

func FetchInstances 

func FetchInstances(ctx context.Context, tags *map[string]string, _func *func(types.Instance) error) error

func GetAWSCrential 

func GetAWSCrential() (*aws.Credentials, error)

func GetAWSCrential(ctx context.Context) (*aws.Credentials, error) {

func GetCallerUser 

func GetCallerUser(ctx context.Context) (string, string, error)

Get the user from increntials for resource tag addition

func GetProject 

func GetProject(ctx context.Context) string

Get the project name. If it is not specified, user the cluster name as the project name

func GetS3BucketLocation 

func GetS3BucketLocation(ctx context.Context, bucketName string) error

func GetWSExecutor 

func GetWSExecutor(texecutor ctxt.Executor, ctx context.Context, clusterName, clusterType, user, keyFile string) (*ctxt.Executor, error)

func GetWSExecutor02 

func GetWSExecutor02(texecutor ctxt.Executor, ctx context.Context, clusterName, clusterType, user, keyFile string, awsCliFlag bool, args *interface{}) (*ctxt.Executor, error)

func GetWSExecutor03 

func GetWSExecutor03(texecutor ctxt.Executor, ctx context.Context, clusterName, clusterType, user, keyFile string, awsCliFlag bool, args *interface{}) (ctxt.Executor, error)

func HelmResourceExist 

func HelmResourceExist(executor *ctxt.Executor, resourceName string) (bool, error)

func InitClientInstance 

func InitClientInstance() error

func ListContainElement 

func ListContainElement(a []string, x string) bool

func LookupAptLock 

func LookupAptLock(appName string, inStr []byte) (bool, error)

func ParseRangeData 

func ParseRangeData(inputData string) (*[]int, error)

func ReadDBConntionInfo 

func ReadDBConntionInfo(workstation *ctxt.Executor, fileName string, connInfo interface{}) error

func SearchAddresses 

func SearchAddresses(client *ec2.Client, filters []types.Filter) (*string, error)

func SearchInternetGateway 

func SearchInternetGateway(client *ec2.Client, filters []types.Filter) (*string, *types.AttachmentStatus, *string, error)

func SearchNatGateway 

func SearchNatGateway(client *ec2.Client, filters []types.Filter, state []string) (*string, error)

func SearchRouteTable 

func SearchRouteTable(client *ec2.Client, filters []types.Filter) (*string, error)

func SearchSubnet 

func SearchSubnet(client *ec2.Client, filters []types.Filter) (*string, error)

func SearchTiDBNode 

func SearchTiDBNode(clusterComponents []TiDBClusterComponent, host string) string

func SearchVPCName 

func SearchVPCName(executor *ctxt.Executor, ctx context.Context, clusterKeyWord string) (*[]map[string]string, error)

func TransferToWorkstation 

func TransferToWorkstation(workstation *ctxt.Executor, sourceFile, destFile, mode string, params interface{}) error

func WaitDBInstanceUntilActive 

func WaitDBInstanceUntilActive(texecutor ctxt.Executor, ctx context.Context, clusterName string) error

Types

type ARNComponent 

type ARNComponent struct {
	ComponentType string
	ComponentName string
	ComponentID   string
	ImageID       string
	InstanceName  string
	KeyName       string
	State         string
	CIDR          string
	Region        string
	Zone          string
}

type AcceptVPCPeering 

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

func (*AcceptVPCPeering) Execute 

func (c *AcceptVPCPeering) Execute(ctx context.Context) error

Execute implements the Task interface

func (*AcceptVPCPeering) Rollback 

func (c *AcceptVPCPeering) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*AcceptVPCPeering) String 

func (c *AcceptVPCPeering) String() string

String implements the fmt.Stringer interface

type AccepterVpcInfo 

type AccepterVpcInfo struct {
	VpcId string `json:"VpcId"`
}

type AptLock 

type AptLock struct {
	Locks []struct {
		//"command":"cron", "pid":686, "type":"FLOCK", "size":null, "mode":"WRITE", "m":false, "start":0, "end":0, "path":"/run..."
		Command string `json:"command"`
		Pid     int32  `json:"pid"`
		Type    string `json:"type"`
		Size    string `json:"size"`
		Mode    string `json:"mode"`
		M       bool   `json:"m"`
		Start   int32  `json:"start"`
		End     int32  `json:"end"`
		Path    string `json:"path"`
	} `json:"locks"`
}

type Attachment 

type Attachment struct {
	State string `json:"State"`
	VpcId string `json:"VpcId"`
}

type AuroraSnapshotExportS3 

type AuroraSnapshotExportS3 struct {
	BaseWSTask
	// contains filtered or unexported fields
}

func (AuroraSnapshotExportS3) Execute 

func (c AuroraSnapshotExportS3) Execute(ctx context.Context) error

03. Data export to s3 03.01. Preare export role 03.02. Export snapshot to S3

type AuroraSnapshotTaken 

type AuroraSnapshotTaken struct {
	BaseWSTask
}

func (AuroraSnapshotTaken) Execute 

func (c AuroraSnapshotTaken) Execute(ctx context.Context) error

01. Aurora snapshot taken 01.01. Get Aurora connection info 01.02. Get binlog position 01.03. Make snapshot if it does not exist

type AutoScalings 

type AutoScalings struct {
	BaseResourceInfo
}

func (*AutoScalings) GetResourceArn 

func (d *AutoScalings) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*AutoScalings) ToPrintTable 

func (d *AutoScalings) ToPrintTable() *[][]string

type AvailabilityZones 

type AvailabilityZones struct {
	Zones []RegionZone `json:"AvailabilityZones"`
}

type BackupComponent 

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

BackupComponent is used to copy all files related the specific version a component to the target directory of path

func (*BackupComponent) Execute 

func (c *BackupComponent) Execute(ctx context.Context) error

Execute implements the Task interface

func (*BackupComponent) Rollback 

func (c *BackupComponent) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*BackupComponent) String 

func (c *BackupComponent) String() string

String implements the fmt.Stringer interface

type BaseAutoScaling 

type BaseAutoScaling struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseChangefeed 

type BaseChangefeed struct {
	BaseTask
	// contains filtered or unexported fields
}

type BaseCloudFormation 

type BaseCloudFormation struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseElasticAddress 

type BaseElasticAddress struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseGlueSchemaRegistryCluster 

type BaseGlueSchemaRegistryCluster struct {
	GlueSchemaRegistryInfos *GlueSchemaRegistryInfos
	// contains filtered or unexported fields
}

func (*BaseGlueSchemaRegistryCluster) ClusterExist 

func (b *BaseGlueSchemaRegistryCluster) ClusterExist(checkAvailableState bool) (bool, error)

* Return: * (true, nil): Cluster exist * (false, nil): Cluster does not exist * (false, error): Failed to check

func (*BaseGlueSchemaRegistryCluster) ReadGlueSchemaRegistryInfo 

func (b *BaseGlueSchemaRegistryCluster) ReadGlueSchemaRegistryInfo(ctx context.Context) error

type BaseInternetGateway 

type BaseInternetGateway struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseKMS 

type BaseKMS struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

func (*BaseKMS) GetKeyId 

func (b *BaseKMS) GetKeyId() (*string, error)

type BaseLaunchTemplate 

type BaseLaunchTemplate struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseMSKCluster 

type BaseMSKCluster struct {
	BaseTask
	// contains filtered or unexported fields
}

func (*BaseMSKCluster) ClusterExist 

func (b *BaseMSKCluster) ClusterExist(checkAvailableState bool) (bool, error)

* Return: * (true, nil): Cluster exist * (false, nil): Cluster does not exist * (false, error): Failed to check

func (*BaseMSKCluster) ConfigurationExist 

func (b *BaseMSKCluster) ConfigurationExist() (bool, error)

type BaseMSKConnectPlugin 

type BaseMSKConnectPlugin struct {
	MSKConnectPluginInfos *MSKConnectPluginInfos
	// contains filtered or unexported fields
}

func (*BaseMSKConnectPlugin) ClusterExist 

func (b *BaseMSKConnectPlugin) ClusterExist(pluginName string) (bool, error)

* Return: * (true, nil): Cluster exist * (false, nil): Cluster does not exist * (false, error): Failed to check

func (*BaseMSKConnectPlugin) ReadMSKConnectPluginInfo 

func (b *BaseMSKConnectPlugin) ReadMSKConnectPluginInfo(ctx context.Context) error

type BaseMskConnect 

type BaseMskConnect struct {
	BaseTask

	MskConnectInfos *MskConnectInfos
	// contains filtered or unexported fields
}

func (*BaseMskConnect) ClusterExist 

func (b *BaseMskConnect) ClusterExist(checkAvailableState bool) (bool, error)

* Return: * (true, nil): Cluster exist * (false, nil): Cluster does not exist * (false, error): Failed to check

type BaseNATGateway 

type BaseNATGateway struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseNLB 

type BaseNLB struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseNLBListener 

type BaseNLBListener struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseRDSExportS3 

type BaseRDSExportS3 struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseRedshiftCluster 

type BaseRedshiftCluster struct {
	BaseTask
	// contains filtered or unexported fields
}

func (*BaseRedshiftCluster) ClusterExist 

func (b *BaseRedshiftCluster) ClusterExist() (bool, error)

* Return: * (true, nil): Cluster exist * (false, nil): Cluster does not exist * (false, error): Failed to check

func (*BaseRedshiftCluster) ClusterParameterGroupsExist 

func (b *BaseRedshiftCluster) ClusterParameterGroupsExist() (bool, error)

func (*BaseRedshiftCluster) ClusterSubnetGroupNameExist 

func (b *BaseRedshiftCluster) ClusterSubnetGroupNameExist() (bool, error)

func (*BaseRedshiftCluster) GetRedshiftDBInfo 

func (d *BaseRedshiftCluster) GetRedshiftDBInfo() (*map[string]string, error)

type BaseResourceInfo 

type BaseResourceInfo struct {
	Data []interface{}
}

func (*BaseResourceInfo) Append 

func (d *BaseResourceInfo) Append(data interface{})

func (*BaseResourceInfo) GetData 

func (d *BaseResourceInfo) GetData() []interface{}

func (*BaseResourceInfo) GetResourceArn 

func (b *BaseResourceInfo) GetResourceArn(throwErr ThrowErrorFlag, returnValue func(interface{}) (*string, error)) (*string, error)

func (*BaseResourceInfo) Reset 

func (d *BaseResourceInfo) Reset() error

func (*BaseResourceInfo) ResourceExist 

func (b *BaseResourceInfo) ResourceExist() (bool, error)

* Return: * (true, nil): Cluster exist * (false, nil): Cluster does not exist * (false, error): Failed to check

func (*BaseResourceInfo) WriteIntoConfigFile 

func (b *BaseResourceInfo) WriteIntoConfigFile(_fileName string) error

type BaseRouteTable 

type BaseRouteTable struct {
	BaseTask

	ResourceData ResourceData
	// contains filtered or unexported fields
}

****************************************************************************

type BaseSecurityGroup 

type BaseSecurityGroup struct {
	BaseTask

	ResourceData ResourceData
	// contains filtered or unexported fields
}

****************************************************************************

type BaseServiceIamPolicy 

type BaseServiceIamPolicy struct {
	BaseTask

	ResourceData ResourceData
	// contains filtered or unexported fields
}

****************************************************************************

type BaseServiceIamRole 

type BaseServiceIamRole struct {
	BaseTask

	ResourceData ResourceData
	// contains filtered or unexported fields
}

****************************************************************************

func (*BaseServiceIamRole) GetKeyId 

func (b *BaseServiceIamRole) GetKeyId() (*string, error)

type BaseSubnets 

type BaseSubnets struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

func (*BaseSubnets) GetSubnets 

func (b *BaseSubnets) GetSubnets(numSubnets int) (*[]string, error)

type BaseTargetGroup 

type BaseTargetGroup struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseTask 

type BaseTask struct {
	BaseTaskInterface

	ResourceData ResourceData
	// contains filtered or unexported fields
}

func (*BaseTask) GetElasticAddress 

func (b *BaseTask) GetElasticAddress(throwErr ThrowErrorFlag) (*string, error)

func (*BaseTask) GetInternetGatewayId 

func (b *BaseTask) GetInternetGatewayId(throwErr ThrowErrorFlag) (*string, bool, error)

func (*BaseTask) GetNLBArn 

func (b *BaseTask) GetNLBArn(throwErr ThrowErrorFlag) (*string, error)

func (*BaseTask) GetRouteTable 

func (b *BaseTask) GetRouteTable() (*ec2types.RouteTable, error)

If the subnet is in the assoicate, return nothing If there is no route table, return error If there is route table, the subnet is not in the association. return the table id.

func (*BaseTask) GetSecurityGroup 

func (b *BaseTask) GetSecurityGroup(throwErr ThrowErrorFlag) (*string, error)

func (*BaseTask) GetSubnetsInfo 

func (b *BaseTask) GetSubnetsInfo(numSubnets int) (*[]string, error)

func (*BaseTask) GetTargetGroupArn 

func (b *BaseTask) GetTargetGroupArn(throwErr ThrowErrorFlag) (*string, error)

func (*BaseTask) GetTransitGatewayID 

func (b *BaseTask) GetTransitGatewayID() (*string, error)

func (*BaseTask) GetVpcItem 

func (b *BaseTask) GetVpcItem(itemType string) (*string, error)

func (*BaseTask) MakeASFilters 

func (b *BaseTask) MakeASFilters() *[]astypes.Filter

func (*BaseTask) MakeASTags 

func (b *BaseTask) MakeASTags() *[]astypes.Tag

func (*BaseTask) MakeEC2Filters 

func (b *BaseTask) MakeEC2Filters() *[]ec2types.Filter

func (*BaseTask) MakeEC2Tags 

func (b *BaseTask) MakeEC2Tags() *[]ec2types.Tag

func (*BaseTask) MakeNLBTags 

func (b *BaseTask) MakeNLBTags() *[]nlbtypes.Tag

type BaseTaskInterface 

type BaseTaskInterface interface {
	// contains filtered or unexported methods
}

type BaseTemplate 

type BaseTemplate struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseTiCDCGlue 

type BaseTiCDCGlue struct {
	BaseTask
}

type BaseTiDBCloud 

type BaseTiDBCloud struct {
}

***************************************************************************

func (*BaseTiDBCloud) ResourceExist 

func (c *BaseTiDBCloud) ResourceExist(projectID, clusterName string) (bool, error)

type BaseTiDBCloudImport 

type BaseTiDBCloudImport struct {
	BaseWSTask
	// contains filtered or unexported fields
}

***************************************************************************

func (*BaseTiDBCloudImport) GetClusterID 

func (c *BaseTiDBCloudImport) GetClusterID() (*string, error)

func (*BaseTiDBCloudImport) ResourceExist 

func (c *BaseTiDBCloudImport) ResourceExist() (bool, error)

type BaseTransitGateway 

type BaseTransitGateway struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

func (*BaseTransitGateway) GetStackname 

func (b *BaseTransitGateway) GetStackname() (*string, error)

func (*BaseTransitGateway) GetTransitGatewayID 

func (b *BaseTransitGateway) GetTransitGatewayID() (*string, error)

type BaseTransitGatewayVpcAttachment 

type BaseTransitGatewayVpcAttachment struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

type BaseVPC 

type BaseVPC struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

func (*BaseVPC) GetVPCItem 

func (b *BaseVPC) GetVPCItem(itemType string) (*string, error)

type BaseVpcEndpoint 

type BaseVpcEndpoint struct {
	BaseTask
	// contains filtered or unexported fields
}

****************************************************************************

func (*BaseVpcEndpoint) GetVpcEndpointID 

func (b *BaseVpcEndpoint) GetVpcEndpointID() (*string, error)

type BaseWSTask 

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

func (*BaseWSTask) Rollback 

func (c *BaseWSTask) Rollback(ctx context.Context) error

func (*BaseWSTask) String 

func (c *BaseWSTask) String() string

type BaseWorkerConfiguration 

type BaseWorkerConfiguration struct {
	WorkerConfigurationInfos *WorkerConfigurationInfos
	// contains filtered or unexported fields
}

func (*BaseWorkerConfiguration) ClusterExist 

func (b *BaseWorkerConfiguration) ClusterExist(checkAvailableState bool) (bool, error)

* Return: * (true, nil): Cluster exist * (false, nil): Cluster does not exist * (false, error): Failed to check

func (*BaseWorkerConfiguration) ReadWorkerConfigurationInfo 

func (b *BaseWorkerConfiguration) ReadWorkerConfigurationInfo() error

type Builder 

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

Builder is used to build TiUP task

func NewBuilder 

func NewBuilder() *Builder

NewBuilder returns a *Builder instance

func (*Builder) AcceptVPCPeering 

func (b *Builder) AcceptVPCPeering(pexecutor *ctxt.Executor, listComponent []string) *Builder

func (*Builder) AuroraSnapshotExportS3 

func (b *Builder) AuroraSnapshotExportS3(workstation *ws.Workstation, s3BackupFolder string, timer *awsutils.ExecutionTimer) *Builder

func (*Builder) AuroraSnapshotTaken 

func (b *Builder) AuroraSnapshotTaken(workstation *ws.Workstation, timer *awsutils.ExecutionTimer) *Builder

****************************************************************************

func (*Builder) BackupComponent 

func (b *Builder) BackupComponent(component, fromVer string, host, deployDir string) *Builder

BackupComponent appends a BackupComponent task to the current task collection

func (*Builder) Build 

func (b *Builder) Build() Task

Build returns a task that contains all tasks appended by previous operation

func (*Builder) BuildAsStep 

func (b *Builder) BuildAsStep(prefix string) *StepDisplay

BuildAsStep returns a task that is wrapped by a StepDisplay. The task will print single line progress.

func (*Builder) CheckSys 

func (b *Builder) CheckSys(host, dir, checkType string, topo *spec.Specification, opt *operator.CheckOptions) *Builder

CheckSys checks system information of deploy server

func (*Builder) ClusterOperate 

func (b *Builder) ClusterOperate(
	spec *spec.Specification,
	op operator.Operation,
	options operator.Options,
	tlsCfg *tls.Config,
) *Builder

ClusterOperate appends a cluster operation task. All the UserSSH needed must be init first.

func (*Builder) ClusterSSH 

func (b *Builder) ClusterSSH(
	topo spec.Topology,
	deployUser string, sshTimeout, exeTimeout uint64,
	proxyHost string, proxyPort int, proxyUser, proxyPassword, proxyKeyFile, proxyPassphrase string, proxySSHTimeout uint64,
	sshType, defaultSSHType executor.SSHType,
) *Builder

ClusterSSH init all UserSSH need for the cluster.

func (*Builder) CopyComponent 

func (b *Builder) CopyComponent(component, os, arch string,
	version string,
	srcPath, dstHost, dstDir string,
) *Builder

CopyComponent appends a CopyComponent task to the current task collection

func (*Builder) CopyFile 

func (b *Builder) CopyFile(src, dst, server string, download bool, limit int) *Builder

CopyFile appends a CopyFile task to the current task collection

func (*Builder) CreateAlertManagerNodes 

func (b *Builder) CreateAlertManagerNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateAurora 

func (b *Builder) CreateAurora(awsAuroraConfigs *spec.AwsAuroraConfigs) *Builder

func (*Builder) CreateAutoScaling 

func (b *Builder) CreateAutoScaling(pexecutor *ctxt.Executor, subClusterType, component string, network NetworkType, ec2Node *spec.AwsNodeModal, awsGeneralConfig *spec.AwsTopoConfigsGeneral) *Builder

****************************************************************************

func (*Builder) CreateBasicResource 

func (b *Builder) CreateBasicResource(pexecutor *ctxt.Executor, subClusterType string, network NetworkType, clusterInfo *ClusterInfo, openPorts []int) *Builder

NAT: specification RouteTable

  1. private: One
  2. public: One
  3. nat: Two(one: private/nat)

func (*Builder) CreateChangefeed 

func (b *Builder) CreateChangefeed(wsExe *ctxt.Executor, mskEndpoints *string) *Builder

****************************************************************************

func (*Builder) CreateCloudFormation 

func (b *Builder) CreateCloudFormation(templateFile string, parameters *[]types.Parameter, tags *[]types.Tag) *Builder

func (*Builder) CreateCloudFormationByS3URL added in v0.0.4 

func (b *Builder) CreateCloudFormationByS3URL(templateURL string, parameters *[]types.Parameter, tags *[]types.Tag) *Builder

func (*Builder) CreateDBCluster 

func (b *Builder) CreateDBCluster(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDBClusterParameterGroup 

func (b *Builder) CreateDBClusterParameterGroup(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDBInstance 

func (b *Builder) CreateDBInstance(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDBParameterGroup 

func (b *Builder) CreateDBParameterGroup(pexecutor *ctxt.Executor, subClusterType, groupFamily string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDBSubnetGroup 

func (b *Builder) CreateDBSubnetGroup(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMCluster 

func (b *Builder) CreateDMCluster(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMMasterNodes 

func (b *Builder) CreateDMMasterNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMSInstance 

func (b *Builder) CreateDMSInstance(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMSService 

func (b *Builder) CreateDMSService(pexecutor *ctxt.Executor, subClusterType string, awsDMSConfigs *spec.AwsDMSConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMSSourceEndpoint 

func (b *Builder) CreateDMSSourceEndpoint(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMSSubnetGroup 

func (b *Builder) CreateDMSSubnetGroup(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMSTargetEndpoint 

func (b *Builder) CreateDMSTargetEndpoint(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMSTask 

func (b *Builder) CreateDMSTask(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDMWorkerNodes 

func (b *Builder) CreateDMWorkerNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateDrainerNodes 

func (b *Builder) CreateDrainerNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateEKSCluster 

func (b *Builder) CreateEKSCluster(pexecutor *ctxt.Executor, awsWSConfigs *spec.AwsWSConfigs, awsESConfigs *spec.AwsESTopoConfigs, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateElasticAddress 

func (b *Builder) CreateElasticAddress(pexecutor *ctxt.Executor, subClusterType string) *Builder

****************************************************************************

func (*Builder) CreateGlueSchemaRegistryCluster 

func (b *Builder) CreateGlueSchemaRegistryCluster(pexecutor *ctxt.Executor) *Builder

func (*Builder) CreateGrafanaNodes 

func (b *Builder) CreateGrafanaNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateInternetGateway 

func (b *Builder) CreateInternetGateway(pexecutor *ctxt.Executor, subClusterType string) *Builder

****************************************************************************

func (*Builder) CreateK8SESCluster 

func (b *Builder) CreateK8SESCluster(pexecutor *ctxt.Executor, awsWSConfigs *spec.AwsWSConfigs, awsESConfigs *spec.AwsESTopoConfigs, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateKMS 

func (b *Builder) CreateKMS(subClusterType string) *Builder

func (*Builder) CreateKafkaCluster 

func (b *Builder) CreateKafkaCluster(pexecutor *ctxt.Executor, subClusterType string, topo *spec.AwsKafkaTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateLaunchTemplate 

func (b *Builder) CreateLaunchTemplate(pexecutor *ctxt.Executor, subClusterType, component string, network NetworkType, ec2Node *spec.AwsNodeModal, awsGeneralConfig *spec.AwsTopoConfigsGeneral) *Builder

****************************************************************************

func (*Builder) CreateMS 

func (b *Builder) CreateMS(pexecutor *ctxt.Executor, subClusterType string, awsMSConfigs *spec.AwsMSConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateMSKCluster 

func (b *Builder) CreateMSKCluster(pexecutor *ctxt.Executor, subClusterType string, awsMSKTopoConfigs *spec.AwsMSKTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateMSKConnectPlugin 

func (b *Builder) CreateMSKConnectPlugin(pexecutor *ctxt.Executor, wsExe *ctxt.Executor, awsMSKConnectPluginTopoConfigs *spec.AwsMSKConnectPluginTopoConfigs) *Builder

****************************************************************************

func (*Builder) CreateMongoCluster 

func (b *Builder) CreateMongoCluster(pexecutor *ctxt.Executor, subClusterType string, topo *spec.AwsMongoTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateMonitorNodes 

func (b *Builder) CreateMonitorNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateMskConnect 

func (b *Builder) CreateMskConnect(wsExe *ctxt.Executor, createMskConnectInput *CreateMskConnectInput) *Builder

****************************************************************************

func (*Builder) CreateMySQLCluster 

func (b *Builder) CreateMySQLCluster(pexecutor *ctxt.Executor, subClusterType string, awsMySQLConfigs *spec.AwsMySQLTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateMySQLNodes 

func (b *Builder) CreateMySQLNodes(pexecutor *ctxt.Executor, subClusterType string, awsMySQLConfigs *spec.AwsMySQLTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateNAT 

func (b *Builder) CreateNAT(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateNATGateway 

func (b *Builder) CreateNATGateway(pexecutor *ctxt.Executor, subClusterType string) *Builder

****************************************************************************

func (*Builder) CreateNLB 

func (b *Builder) CreateNLB(pexecutor *ctxt.Executor, subClusterType string) *Builder

****************************************************************************

func (*Builder) CreateNLBListener 

func (b *Builder) CreateNLBListener(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) CreateNetwork 

func (b *Builder) CreateNetwork(pexecutor *ctxt.Executor, subClusterType string, isPrivate bool, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateOracle 

func (b *Builder) CreateOracle(pexecutor *ctxt.Executor, awsOracleConfigs *spec.AwsOracleConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreatePDNodes 

func (b *Builder) CreatePDNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreatePerfTables 

func (b *Builder) CreatePerfTables(wsExe *ctxt.Executor, mappingFile string, colTypesList []string) *Builder

****************************************************************************

func (*Builder) CreatePostgres 

func (b *Builder) CreatePostgres(pexecutor *ctxt.Executor, awsWSConfigs *spec.AwsWSConfigs, awsPostgresConfigs *spec.AwsPostgresConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreatePumpNodes 

func (b *Builder) CreatePumpNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateRDSExportS3 

func (b *Builder) CreateRDSExportS3(subClusterType, s3BackupFolder string, timer *awsutils.ExecutionTimer) *Builder

func (*Builder) CreateRedshiftCluster 

func (b *Builder) CreateRedshiftCluster(pexecutor *ctxt.Executor, subClusterType string, awsRedshiftTopoConfigs *spec.AwsRedshiftTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateRouteTable 

func (b *Builder) CreateRouteTable(pexecutor *ctxt.Executor, subClusterType string, network NetworkType) *Builder

****************************************************************************

func (*Builder) CreateRouteTgw 

func (b *Builder) CreateRouteTgw(pexecutor *ctxt.Executor, subClusterType string, subClusterTypes []string) *Builder

func (*Builder) CreateSecurityGroup 

func (b *Builder) CreateSecurityGroup(pexecutor *ctxt.Executor, subClusterType string, network NetworkType, openPorts []int) *Builder

****************************************************************************

func (*Builder) CreateServiceIamPolicy 

func (b *Builder) CreateServiceIamPolicy(subClusterType, policyDocument string) *Builder

****************************************************************************

func (*Builder) CreateServiceIamRole 

func (b *Builder) CreateServiceIamRole(subClusterType, policyDocument string) *Builder

****************************************************************************

func (*Builder) CreateSqlServer 

func (b *Builder) CreateSqlServer(pexecutor *ctxt.Executor, subClusterType string, awsMSConfigs *spec.AwsMSConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateSubnets 

func (b *Builder) CreateSubnets(pexecutor *ctxt.Executor, subClusterType string, network NetworkType, clusterInfo *ClusterInfo) *Builder

****************************************************************************

func (*Builder) CreateTargetGroup 

func (b *Builder) CreateTargetGroup(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) CreateTemplate 

func (b *Builder) CreateTemplate(pexecutor *ctxt.Executor, subClusterType string, network NetworkType) *Builder

****************************************************************************

func (*Builder) CreateTiCDCGlue 

func (b *Builder) CreateTiCDCGlue(wsExe *ctxt.Executor) *Builder

func (*Builder) CreateTiCDCNodes 

func (b *Builder) CreateTiCDCNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateTiDBCloud 

func (b *Builder) CreateTiDBCloud(tidbCloudConfigs *spec.TiDBCloudConfigs) *Builder

func (*Builder) CreateTiDBCloudImport 

func (b *Builder) CreateTiDBCloudImport(projectId, subClusterType string, timer *awsutils.ExecutionTimer) *Builder

func (*Builder) CreateTiDBCluster 

func (b *Builder) CreateTiDBCluster(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateTiDBNLB 

func (b *Builder) CreateTiDBNLB(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateTiDBNodes 

func (b *Builder) CreateTiDBNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateTiFlashNodes 

func (b *Builder) CreateTiFlashNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateTiKVNodes 

func (b *Builder) CreateTiKVNodes(pexecutor *ctxt.Executor, subClusterType string, awsTopoConfigs *spec.AwsTopoConfigs, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateTransitGateway 

func (b *Builder) CreateTransitGateway(pexecutor *ctxt.Executor) *Builder

func (*Builder) CreateTransitGatewayVpcAttachment 

func (b *Builder) CreateTransitGatewayVpcAttachment(pexecutor *ctxt.Executor, subClusterType string, network NetworkType) *Builder

func (*Builder) CreateVPC 

func (b *Builder) CreateVPC(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) CreateVpcEndpoint 

func (b *Builder) CreateVpcEndpoint(pexecutor *ctxt.Executor, vpceIdChan chan string, subClusterType, component string, network NetworkType, serviceName string) *Builder

****************************************************************************

func (*Builder) CreateWorkerConfiguration 

func (b *Builder) CreateWorkerConfiguration() *Builder

****************************************************************************

func (*Builder) CreateWorkstation 

func (b *Builder) CreateWorkstation(pexecutor *ctxt.Executor, subClusterType string, awsWSConfigs *spec.AwsWSConfigs, clusterInfo *ClusterInfo, wsExe *ctxt.Executor, gOpt *operator.Options, cbMakeWSContext func() error) *Builder

func (*Builder) CreateWorkstationCluster 

func (b *Builder) CreateWorkstationCluster(pexecutor *ctxt.Executor, subClusterType string, awsWSConfigs *spec.AwsWSConfigs, clusterInfo *ClusterInfo, wsExe *ctxt.Executor, gOpt *operator.Options, cbMakeWSContext func() error) *Builder

func (*Builder) DeleteAuroraSnapshots 

func (b *Builder) DeleteAuroraSnapshots(workstation *ws.Workstation) *Builder

func (*Builder) DeleteS3Folder 

func (b *Builder) DeleteS3Folder(workstation *ws.Workstation) *Builder

*****************************************************************************

func (*Builder) Deploy 

func (b *Builder) Deploy(user, host string) *Builder

GcloudCreateInstance appends a GcloudCreateInstance task to the current task collection

func (*Builder) DeployDM 

func (b *Builder) DeployDM(workstation *ws.Workstation, subClusterType, version string, timer *awsutils.ExecutionTimer) *Builder

****************************************************************************

func (*Builder) DeployDrainConfig 

func (b *Builder) DeployDrainConfig(pexecutor *ctxt.Executor, awsOracleConfigs *spec.AwsOracleConfigs, awsWSConfigs *spec.AwsWSConfigs, drainerReplicate *spec.DrainerReplicate) *Builder

func (*Builder) DeployKafka 

func (b *Builder) DeployKafka(pexecutor *ctxt.Executor, awsWSConfigs *spec.AwsWSConfigs, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) DeployMongo 

func (b *Builder) DeployMongo(pexecutor *ctxt.Executor, awsWSConfigs *spec.AwsWSConfigs, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) DeployMySQL 

func (b *Builder) DeployMySQL(workstation *ws.Workstation, subClusterType, version string, timer *awsutils.ExecutionTimer) *Builder

****************************************************************************

func (*Builder) DeployPDNS 

func (b *Builder) DeployPDNS(pexecutor *ctxt.Executor, subClusterType string, awsWSConfigs *spec.AwsWSConfigs) *Builder

func (*Builder) DeployRedshiftInstance 

func (b *Builder) DeployRedshiftInstance(pexecutor *ctxt.Executor, awsWSConfigs *spec.AwsWSConfigs, awsRedshiftTopoConfigs *spec.AwsRedshiftTopoConfigs, wsExe *ctxt.Executor) *Builder

func (*Builder) DeploySpark 

func (b *Builder) DeploySpark(inst spec.Instance, sparkVersion, srcPath, deployDir string) *Builder

DeploySpark deployes spark as dependency of TiSpark

func (*Builder) DeployThanos 

func (b *Builder) DeployThanos(opt *operator.ThanosS3Config, gOpt *operator.Options) *Builder

func (*Builder) DeployTiCDC 

func (b *Builder) DeployTiCDC(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) DeployTiDB 

func (b *Builder) DeployTiDB(subClusterType string, awsWSConfigs *spec.AwsWSConfigs, workstation *ws.Workstation) *Builder

func (*Builder) DeployTiDBInstance 

func (b *Builder) DeployTiDBInstance(awsWSConfigs *spec.AwsWSConfigs, subClusterType, tidbVersion string, workstation *ws.Workstation) *Builder

func (*Builder) DeployWS 

func (b *Builder) DeployWS(pexecutor *ctxt.Executor, subClusterType string, awsWSConfigs *spec.AwsWSConfigs) *Builder

func (*Builder) DestroyAurora 

func (b *Builder) DestroyAurora() *Builder

func (*Builder) DestroyAutoScaling 

func (b *Builder) DestroyAutoScaling(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyBasicResource 

func (b *Builder) DestroyBasicResource(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyCloudFormation 

func (b *Builder) DestroyCloudFormation(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyDBCluster 

func (b *Builder) DestroyDBCluster(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDBClusterParameterGroup 

func (b *Builder) DestroyDBClusterParameterGroup(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDBInstance 

func (b *Builder) DestroyDBInstance(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDBParameterGroup 

func (b *Builder) DestroyDBParameterGroup(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDBSubnetGroup 

func (b *Builder) DestroyDBSubnetGroup(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDMSEndpoints 

func (b *Builder) DestroyDMSEndpoints(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDMSInstance 

func (b *Builder) DestroyDMSInstance(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDMSService 

func (b *Builder) DestroyDMSService(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDMSSubnetGroup 

func (b *Builder) DestroyDMSSubnetGroup(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyDMSTask 

func (b *Builder) DestroyDMSTask(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyEC 

func (b *Builder) DestroyEC(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyEC2Nodes 

func (b *Builder) DestroyEC2Nodes(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyEKSCluster 

func (b *Builder) DestroyEKSCluster(pexecutor *ctxt.Executor, subClusterType string, gOpt operator.Options) *Builder

func (*Builder) DestroyElasticAddress 

func (b *Builder) DestroyElasticAddress(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyGlueSchemaRegistry 

func (b *Builder) DestroyGlueSchemaRegistry(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyInternetGateway 

func (b *Builder) DestroyInternetGateway(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyK8SESCluster 

func (b *Builder) DestroyK8SESCluster(pexecutor *ctxt.Executor, gOpt operator.Options) *Builder

func (*Builder) DestroyKMS 

func (b *Builder) DestroyKMS(subClusterType string) *Builder

func (*Builder) DestroyLaunchTemplate 

func (b *Builder) DestroyLaunchTemplate(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyMSKCluster 

func (b *Builder) DestroyMSKCluster(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyMSKConnectPlugin 

func (b *Builder) DestroyMSKConnectPlugin(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyMskConnect 

func (b *Builder) DestroyMskConnect(wsExe *ctxt.Executor) *Builder

func (*Builder) DestroyNAT 

func (b *Builder) DestroyNAT(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyNATGateway 

func (b *Builder) DestroyNATGateway(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyNLB 

func (b *Builder) DestroyNLB(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyNetwork 

func (b *Builder) DestroyNetwork(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyOracle 

func (b *Builder) DestroyOracle(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyPostgres 

func (b *Builder) DestroyPostgres(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyRDSExportS3 

func (b *Builder) DestroyRDSExportS3(subClusterType string) *Builder

func (*Builder) DestroyRedshiftCluster 

func (b *Builder) DestroyRedshiftCluster(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyRouteTable 

func (b *Builder) DestroyRouteTable(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroySecurityGroup 

func (b *Builder) DestroySecurityGroup(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyServiceIamPolicy 

func (b *Builder) DestroyServiceIamPolicy() *Builder

func (*Builder) DestroyServiceIamRole 

func (b *Builder) DestroyServiceIamRole() *Builder

func (*Builder) DestroySqlServer 

func (b *Builder) DestroySqlServer(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) DestroySubnets 

func (b *Builder) DestroySubnets(pexecutor *ctxt.Executor, subClusterType string, network NetworkType) *Builder

func (*Builder) DestroyTargetGroup 

func (b *Builder) DestroyTargetGroup(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyTemplate 

func (b *Builder) DestroyTemplate(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyTiDBCloud 

func (b *Builder) DestroyTiDBCloud(workstation *ws.Workstation) *Builder

func (*Builder) DestroyTiDBCloudImport 

func (b *Builder) DestroyTiDBCloudImport(workstation *ws.Workstation) *Builder

func (*Builder) DestroyTransitGateway 

func (b *Builder) DestroyTransitGateway(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyTransitGatewayVpcAttachment 

func (b *Builder) DestroyTransitGatewayVpcAttachment(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyTransitGateways 

func (b *Builder) DestroyTransitGateways(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyVPC 

func (b *Builder) DestroyVPC(pexecutor *ctxt.Executor, subClusterType string) *Builder

func (*Builder) DestroyVpcEndpoint 

func (b *Builder) DestroyVpcEndpoint(pexecutor *ctxt.Executor) *Builder

func (*Builder) DestroyVpcPeering 

func (b *Builder) DestroyVpcPeering(pexecutor *ctxt.Executor, listComponent []string) *Builder

func (*Builder) Download 

func (b *Builder) Download(component, os, arch string, version string) *Builder

Download appends a Downloader task to the current task collection

func (*Builder) EnvInit 

func (b *Builder) EnvInit(host, deployUser string, userGroup string, skipCreateUser bool) *Builder

EnvInit appends a EnvInit task to the current task collection

func (*Builder) Func 

func (b *Builder) Func(name string, fn func(ctx context.Context) error) *Builder

Func append a func task.

func (*Builder) InitConfig 

func (b *Builder) InitConfig(clusterName, clusterVersion string, specManager *spec.SpecManager, inst spec.Instance, deployUser string, ignoreCheck bool, paths meta.DirPaths) *Builder

InitConfig appends a CopyComponent task to the current task collection

func (*Builder) InstallOracleClient 

func (b *Builder) InstallOracleClient(pexecutor *ctxt.Executor, awsWSConfigs *spec.AwsWSConfigs) *Builder

func (*Builder) InstallPackage 

func (b *Builder) InstallPackage(srcPath, dstHost, dstDir string) *Builder

InstallPackage appends a InstallPackage task to the current task collection

func (*Builder) InstallTiDB 

func (b *Builder) InstallTiDB(pexecutor *ctxt.Executor, awsWSConfigs *spec.AwsWSConfigs) *Builder

func (*Builder) Limit 

func (b *Builder) Limit(host, domain, limit, item, value string) *Builder

Limit set a system limit

func (*Builder) ListAccount 

func (b *Builder) ListAccount(pexecutor *ctxt.Executor, account *string) *Builder

func (*Builder) ListAutoScaling 

func (b *Builder) ListAutoScaling(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListAwsEC2 

func (b *Builder) ListAwsEC2(pexecutor *ctxt.Executor, tableEC2 *[][]string) *Builder

func (*Builder) ListEC 

func (b *Builder) ListEC(pexecutor *ctxt.Executor, tableECs *[][]string) *Builder

func (*Builder) ListElasticAddress 

func (b *Builder) ListElasticAddress(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListInternetGateway 

func (b *Builder) ListInternetGateway(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListLaunchTemplate 

func (b *Builder) ListLaunchTemplate(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListMSKCluster 

func (b *Builder) ListMSKCluster(pexecutor *ctxt.Executor, mskInfos *MSKInfos) *Builder

func (*Builder) ListMSKConnectPlugin 

func (b *Builder) ListMSKConnectPlugin(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListNATGateway 

func (b *Builder) ListNATGateway(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListNLB 

func (b *Builder) ListNLB(pexecutor *ctxt.Executor, subClusterType string, nlb *types.LoadBalancer) *Builder

func (*Builder) ListNetwork 

func (b *Builder) ListNetwork(pexecutor *ctxt.Executor, tableSubnets *[][]string) *Builder

func (*Builder) ListOracle 

func (b *Builder) ListOracle(pexecutor *ctxt.Executor, tableOracle *[][]string) *Builder

func (*Builder) ListPostgres 

func (b *Builder) ListPostgres(pexecutor *ctxt.Executor, tablePostgres *[][]string) *Builder

func (*Builder) ListRedshiftCluster 

func (b *Builder) ListRedshiftCluster(pexecutor *ctxt.Executor, redshiftDBInfos *RedshiftDBInfos) *Builder

func (*Builder) ListRouteTable 

func (b *Builder) ListRouteTable(pexecutor *ctxt.Executor, tableRouteTables *[][]string) *Builder

func (*Builder) ListSecurityGroup 

func (b *Builder) ListSecurityGroup(pexecutor *ctxt.Executor, tableSecurityGroups *[][]string) *Builder

func (*Builder) ListServiceIamPolicy 

func (b *Builder) ListServiceIamPolicy() *Builder

func (*Builder) ListServiceIamRole 

func (b *Builder) ListServiceIamRole() *Builder

func (*Builder) ListSubnets 

func (b *Builder) ListSubnets(pexecutor *ctxt.Executor, subClusterType string, network NetworkType) *Builder

func (*Builder) ListTargetGroup 

func (b *Builder) ListTargetGroup(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListTemplate 

func (b *Builder) ListTemplate(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListTiDBCloud 

func (b *Builder) ListTiDBCloud(projectID uint64, status, clusterType string, tableClusters *[][]string, tableNodes *[][]string) *Builder

func (*Builder) ListTiDBCloudImport 

func (b *Builder) ListTiDBCloudImport(projectID uint64, status, clusterType string, tableClusters *[][]string, tableNodes *[][]string) *Builder

func (*Builder) ListTransitGateway 

func (b *Builder) ListTransitGateway(pexecutor *ctxt.Executor, transitGateway *TransitGateway) *Builder

func (*Builder) ListTransitGatewayVpcAttachment 

func (b *Builder) ListTransitGatewayVpcAttachment(pexecutor *ctxt.Executor, tableTransitGatewayVpcAttachments *[][]string) *Builder

func (*Builder) ListVPC 

func (b *Builder) ListVPC(pexecutor *ctxt.Executor, tableVPC *[][]string) *Builder

func (*Builder) ListVpcEndpoint 

func (b *Builder) ListVpcEndpoint(pexecutor *ctxt.Executor) *Builder

func (*Builder) ListVpcPeering 

func (b *Builder) ListVpcPeering(pexecutor *ctxt.Executor, subClusterTypes []string, tableVpcPeeringInfo *[][]string) *Builder

func (*Builder) MakeDBObjects 

func (b *Builder) MakeDBObjects(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) MakeRole4ExternalAccess 

func (b *Builder) MakeRole4ExternalAccess(workstation *ws.Workstation, projectId string, timer *awsutils.ExecutionTimer) *Builder

func (*Builder) Mkdir 

func (b *Builder) Mkdir(user, host string, dirs ...string) *Builder

Mkdir appends a Mkdir task to the current task collection

func (*Builder) MonitoredConfig 

func (b *Builder) MonitoredConfig(name, comp, host string, globResCtl meta.ResourceControl, options *spec.MonitoredOptions, deployUser string, tlsEnabled bool, paths meta.DirPaths) *Builder

MonitoredConfig appends a CopyComponent task to the current task collection

func (*Builder) Parallel 

func (b *Builder) Parallel(ignoreError bool, tasks ...Task) *Builder

Parallel appends a parallel task to the current task collection

func (*Builder) ParallelStep 

func (b *Builder) ParallelStep(prefix string, ignoreError bool, tasks ...*StepDisplay) *Builder

ParallelStep appends a new ParallelStepDisplay task, which will print multi line progress in parallel for inner tasks. Inner tasks must be a StepDisplay task.

func (*Builder) PrepareSysbenchTiCDC 

func (b *Builder) PrepareSysbenchTiCDC(pexecutor *ctxt.Executor, identityFile string, scriptParam ScriptParam) *Builder

func (*Builder) RegisterTarget 

func (b *Builder) RegisterTarget(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) Rmdir 

func (b *Builder) Rmdir(host string, dirs ...string) *Builder

Rmdir appends a Rmdir task to the current task collection

func (*Builder) RootSSH 

func (b *Builder) RootSSH(
	host string, port int, user, password, keyFile, passphrase string, sshTimeout, exeTimeout uint64,
	proxyHost string, proxyPort int, proxyUser, proxyPassword, proxyKeyFile, proxyPassphrase string, proxySSHTimeout uint64,
	sshType, defaultSSHType executor.SSHType,
) *Builder

RootSSH appends a RootSSH task to the current task collection

func (*Builder) RunCommonWS 

func (b *Builder) RunCommonWS(wsExe *ctxt.Executor, packages *[]string) *Builder

func (*Builder) RunOntimeBatchInsert 

func (b *Builder) RunOntimeBatchInsert(pexecutor *ctxt.Executor, opt *operator.LatencyWhenBatchOptions, gOpt *operator.Options, insertMode string) *Builder

func (*Builder) RunSysbench 

func (b *Builder) RunSysbench(pexecutor *ctxt.Executor, sysbenchConfigFile string, sysbenchResult *[][]string, opt *operator.LatencyWhenBatchOptions, cancelCtx *context.CancelFunc) *Builder

func (*Builder) SSHKeyGen 

func (b *Builder) SSHKeyGen(keypath string) *Builder

SSHKeyGen appends a SSHKeyGen task to the current task collection

func (*Builder) SSHKeySet 

func (b *Builder) SSHKeySet(privKeyPath, pubKeyPath string) *Builder

SSHKeySet appends a SSHKeySet task to the current task collection

func (*Builder) ScaleConfig 

func (b *Builder) ScaleConfig(clusterName, clusterVersion string, specManager *spec.SpecManager, topo spec.Topology, inst spec.Instance, deployUser string, paths meta.DirPaths) *Builder

ScaleConfig generate temporary config on scaling

func (*Builder) ScaleTiDB 

func (b *Builder) ScaleTiDB(pexecutor *ctxt.Executor, subClusterType string, awsWSConfigs *spec.AwsWSConfigs, awsTopoConfig *spec.AwsTopoConfigs) *Builder

func (*Builder) ScaleTiDBInstance 

func (b *Builder) ScaleTiDBInstance(pexecutor *ctxt.Executor, subClusterType string, clusterInfo *ClusterInfo) *Builder

func (*Builder) Serial 

func (b *Builder) Serial(tasks ...Task) *Builder

Serial appends the tasks to the tail of queue

func (*Builder) Shell 

func (b *Builder) Shell(host, command, cmdID string, sudo bool) *Builder

Shell command on cluster host

func (*Builder) Step 

func (b *Builder) Step(prefix string, inner Task) *Builder

Step appends a new StepDisplay task, which will print single line progress for inner tasks.

func (*Builder) SysbenchTiCDC 

func (b *Builder) SysbenchTiCDC(pexecutor *ctxt.Executor, identityFile string, clusterTable *[][]string) *Builder

func (*Builder) Sysctl 

func (b *Builder) Sysctl(host, key, val string) *Builder

Sysctl set a kernel parameter

func (*Builder) SystemCtl 

func (b *Builder) SystemCtl(host, unit, action string, daemonReload bool) *Builder

SystemCtl run systemctl on host

func (*Builder) TLSCert 

func (b *Builder) TLSCert(host, comp, role string, port int, ca *crypto.CertificateAuthority, paths meta.DirPaths) *Builder

TLSCert generates certificate for instance and transfers it to the server

func (*Builder) TakeTimer 

func (b *Builder) TakeTimer(timer *awsutils.ExecutionTimer, exePhase string) *Builder

func (*Builder) UpdateMeta 

func (b *Builder) UpdateMeta(cluster string, metadata *spec.ClusterMeta, deletedNodeIds []string) *Builder

UpdateMeta maintain the meta information

func (*Builder) UpdateTopology 

func (b *Builder) UpdateTopology(cluster, profile string, metadata *spec.ClusterMeta, deletedNodeIds []string) *Builder

UpdateTopology maintain the topology information

func (*Builder) UserSSH 

func (b *Builder) UserSSH(
	host string, port int, deployUser string, sshTimeout, exeTimeout uint64,
	proxyHost string, proxyPort int, proxyUser, proxyPassword, proxyKeyFile, proxyPassphrase string, proxySSHTimeout uint64,
	sshType, defaultSSHType executor.SSHType,
) *Builder

UserSSH append a UserSSH task to the current task collection

func (*Builder) WrapCreateEC2Nodes 

func (b *Builder) WrapCreateEC2Nodes(pexecutor *ctxt.Executor, subClusterType string, ec2Node *spec.AwsNodeModal, awsGeneralConfig *spec.AwsTopoConfigsGeneral, clusterInfo *ClusterInfo, componentName string) *Builder

type ByComponentType 

type ByComponentType []ARNComponent

func (ByComponentType) Len 

func (a ByComponentType) Len() int

func (ByComponentType) Less 

func (a ByComponentType) Less(i, j int) bool

func (ByComponentType) Swap 

func (a ByComponentType) Swap(i, j int)

type CDCTask 

type CDCTask struct {
	Id      string         `json:"id"`
	Summary CDCTaskSummary `json:"summary"`
}

type CDCTaskSummary 

type CDCTaskSummary struct {
	State      string  `json:"state"`
	Tso        big.Int `json:"tso"`
	Checkpoint string  `json:"checkpoint"`
	Error      string  `json:"error"`
}

type ChangefeedInfo 

type ChangefeedInfo struct {
	ID        string `json:"id,omitempty"`
	Namespace string `json:"namespace,omitempty"`
	Summary   struct {
		State      string  `json:"state,omitempty"`
		Tso        big.Int `json:"tso,omitempty"`
		Checkpoint string  `json:"checkpoint,omitempty"`
		Error      string  `json:"error,omitempty"`
	} `json:"summary"`
}

**************************************************************************** Struct definition

type CheckSys 

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

CheckSys performs checks of system information

func (*CheckSys) Execute 

func (c *CheckSys) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CheckSys) Rollback 

func (c *CheckSys) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CheckSys) String 

func (c *CheckSys) String() string

String implements the fmt.Stringer interface

type CloudFormationInfo 

type CloudFormationInfo struct {
	BaseResourceInfo
}

func (*CloudFormationInfo) GetResourceArn 

func (d *CloudFormationInfo) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*CloudFormationInfo) ToPrintTable 

func (d *CloudFormationInfo) ToPrintTable() *[][]string

type CloudFormationStatus_Process 

type CloudFormationStatus_Process types.StackStatus

****************************************************************************

type ClusterInfo 

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

func (ClusterInfo) String 

func (c ClusterInfo) String() string

type ClusterOperate 

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

ClusterOperate represents the cluster operation task.

func (*ClusterOperate) Execute 

func (c *ClusterOperate) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ClusterOperate) Rollback 

func (c *ClusterOperate) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ClusterOperate) String 

func (c *ClusterOperate) String() string

String implements the fmt.Stringer interface

type ColumnDef 

type ColumnDef struct {
	DataType string   `yaml:"DataType"`
	Def      string   `yaml:"Def"`
	Queries  []string `yaml:"Query,omitempty"`
}

type ColumnMapping 

type ColumnMapping struct {
	Meta struct {
		TableName string    `yaml:"TableName"`
		Source    MetaTable `yaml:"Source"`
		Target    MetaTable `yaml:"Target"`
	} `yaml:"Meta"`
	Mapping []struct {
		Source ColumnDef `yaml:"Source"`
		Target ColumnDef `yaml:"Target"`
		Value  string    `yaml:"Value"`
	} `yaml:"Mapping"`
}

type ConnectorState_Process 

type ConnectorState_Process types.ConnectorState

type CopyComponent 

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

CopyComponent is used to copy all files related the specific version a component to the target directory of path

func (*CopyComponent) Execute 

func (c *CopyComponent) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CopyComponent) Rollback 

func (c *CopyComponent) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CopyComponent) String 

func (c *CopyComponent) String() string

String implements the fmt.Stringer interface

type CopyFile 

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

CopyFile will copy a local file to the target host

func (*CopyFile) Execute 

func (c *CopyFile) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CopyFile) Rollback 

func (c *CopyFile) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CopyFile) String 

func (c *CopyFile) String() string

String implements the fmt.Stringer interface

type CreateAutoScaling 

type CreateAutoScaling struct {
	BaseAutoScaling
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateAutoScaling) Execute 

func (c *CreateAutoScaling) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateAutoScaling) Rollback 

func (c *CreateAutoScaling) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateAutoScaling) String 

func (c *CreateAutoScaling) String() string

String implements the fmt.Stringer interface

type CreateChangefeed 

type CreateChangefeed struct {
	BaseChangefeed
}

func (*CreateChangefeed) Execute 

func (c *CreateChangefeed) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateChangefeed) Rollback 

func (c *CreateChangefeed) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateChangefeed) String 

func (c *CreateChangefeed) String() string

String implements the fmt.Stringer interface

type CreateCloudFormationV2 

type CreateCloudFormationV2 struct {
	BaseCloudFormation
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateCloudFormationV2) Execute 

func (c *CreateCloudFormationV2) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateCloudFormationV2) Rollback 

func (c *CreateCloudFormationV2) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateCloudFormationV2) String 

func (c *CreateCloudFormationV2) String() string

String implements the fmt.Stringer interface

type CreateDBCluster 

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

func (*CreateDBCluster) Execute 

func (c *CreateDBCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDBCluster) Rollback 

func (c *CreateDBCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDBCluster) String 

func (c *CreateDBCluster) String() string

String implements the fmt.Stringer interface

type CreateDBClusterParameterGroup 

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

func (*CreateDBClusterParameterGroup) Execute 

func (c *CreateDBClusterParameterGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDBClusterParameterGroup) Rollback 

func (c *CreateDBClusterParameterGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDBClusterParameterGroup) String 

func (c *CreateDBClusterParameterGroup) String() string

String implements the fmt.Stringer interface

type CreateDBInstance 

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

func (*CreateDBInstance) Execute 

func (c *CreateDBInstance) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDBInstance) Rollback 

func (c *CreateDBInstance) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDBInstance) String 

func (c *CreateDBInstance) String() string

String implements the fmt.Stringer interface

type CreateDBParameterGroup 

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

func (*CreateDBParameterGroup) Execute 

func (c *CreateDBParameterGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDBParameterGroup) Rollback 

func (c *CreateDBParameterGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDBParameterGroup) String 

func (c *CreateDBParameterGroup) String() string

String implements the fmt.Stringer interface

type CreateDBSubnetGroup 

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

func (*CreateDBSubnetGroup) Execute 

func (c *CreateDBSubnetGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDBSubnetGroup) Rollback 

func (c *CreateDBSubnetGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDBSubnetGroup) String 

func (c *CreateDBSubnetGroup) String() string

String implements the fmt.Stringer interface

type CreateDMSInstance 

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

func (*CreateDMSInstance) Execute 

func (c *CreateDMSInstance) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDMSInstance) Rollback 

func (c *CreateDMSInstance) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDMSInstance) String 

func (c *CreateDMSInstance) String() string

String implements the fmt.Stringer interface

type CreateDMSSourceEndpoint 

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

func (*CreateDMSSourceEndpoint) Execute 

func (c *CreateDMSSourceEndpoint) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDMSSourceEndpoint) Rollback 

func (c *CreateDMSSourceEndpoint) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDMSSourceEndpoint) String 

func (c *CreateDMSSourceEndpoint) String() string

String implements the fmt.Stringer interface

type CreateDMSSubnetGroup 

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

func (*CreateDMSSubnetGroup) Execute 

func (c *CreateDMSSubnetGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDMSSubnetGroup) Rollback 

func (c *CreateDMSSubnetGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDMSSubnetGroup) String 

func (c *CreateDMSSubnetGroup) String() string

String implements the fmt.Stringer interface

type CreateDMSTargetEndpoint 

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

func (*CreateDMSTargetEndpoint) Execute 

func (c *CreateDMSTargetEndpoint) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDMSTargetEndpoint) Rollback 

func (c *CreateDMSTargetEndpoint) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDMSTargetEndpoint) String 

func (c *CreateDMSTargetEndpoint) String() string

String implements the fmt.Stringer interface

type CreateDMSTask 

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

func (*CreateDMSTask) Execute 

func (c *CreateDMSTask) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateDMSTask) Rollback 

func (c *CreateDMSTask) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateDMSTask) String 

func (c *CreateDMSTask) String() string

String implements the fmt.Stringer interface

type CreateEC2Nodes 

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

*****************************************************************************

func (*CreateEC2Nodes) CreateLaunchTemplate 

func (c *CreateEC2Nodes) CreateLaunchTemplate(ctx context.Context, client *ec2.Client, templateName *string, clusterName, clusterType, tagOwner, tagProject string) error

func (*CreateEC2Nodes) Execute 

func (c *CreateEC2Nodes) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateEC2Nodes) Rollback 

func (c *CreateEC2Nodes) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateEC2Nodes) String 

func (c *CreateEC2Nodes) String() string

String implements the fmt.Stringer interface

type CreateElasticAddress 

type CreateElasticAddress struct {
	BaseElasticAddress
}

****************************************************************************

func (*CreateElasticAddress) Execute 

func (c *CreateElasticAddress) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateElasticAddress) Rollback 

func (c *CreateElasticAddress) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateElasticAddress) String 

func (c *CreateElasticAddress) String() string

String implements the fmt.Stringer interface

type CreateGlueSchemaRegistryCluster 

type CreateGlueSchemaRegistryCluster struct {
	BaseGlueSchemaRegistryCluster
	// contains filtered or unexported fields
}

func (*CreateGlueSchemaRegistryCluster) Execute 

func (c *CreateGlueSchemaRegistryCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateGlueSchemaRegistryCluster) Rollback 

func (c *CreateGlueSchemaRegistryCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateGlueSchemaRegistryCluster) String 

func (c *CreateGlueSchemaRegistryCluster) String() string

String implements the fmt.Stringer interface

type CreateInternetGateway 

type CreateInternetGateway struct {
	BaseInternetGateway
}

****************************************************************************

func (*CreateInternetGateway) Execute 

func (c *CreateInternetGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateInternetGateway) Rollback 

func (c *CreateInternetGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateInternetGateway) String 

func (c *CreateInternetGateway) String() string

String implements the fmt.Stringer interface

type CreateKMS 

type CreateKMS struct {
	BaseKMS
}

****************************************************************************

func (*CreateKMS) Execute 

func (c *CreateKMS) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateKMS) Rollback 

func (c *CreateKMS) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateKMS) String 

func (c *CreateKMS) String() string

String implements the fmt.Stringer interface

type CreateLaunchTemplate 

type CreateLaunchTemplate struct {
	BaseLaunchTemplate
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateLaunchTemplate) Execute 

func (c *CreateLaunchTemplate) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateLaunchTemplate) Rollback 

func (c *CreateLaunchTemplate) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateLaunchTemplate) String 

func (c *CreateLaunchTemplate) String() string

String implements the fmt.Stringer interface

type CreateMS 

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

func (*CreateMS) Execute 

func (c *CreateMS) Execute(ctx context.Context) error

func (*CreateMS) Rollback 

func (c *CreateMS) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateMS) String 

func (c *CreateMS) String() string

String implements the fmt.Stringer interface

type CreateMSKCluster 

type CreateMSKCluster struct {
	BaseMSKCluster
	// contains filtered or unexported fields
}

func (*CreateMSKCluster) Execute 

func (c *CreateMSKCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateMSKCluster) Rollback 

func (c *CreateMSKCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateMSKCluster) String 

func (c *CreateMSKCluster) String() string

String implements the fmt.Stringer interface

type CreateMSKConnectPlugin 

type CreateMSKConnectPlugin struct {
	BaseMSKConnectPlugin
	// contains filtered or unexported fields
}

func (*CreateMSKConnectPlugin) Execute 

func (c *CreateMSKConnectPlugin) Execute(ctx context.Context) error

Todo:

plugin name: redshift-sink sink url: redshift url S3: directory

Execute implements the Task interface

func (*CreateMSKConnectPlugin) Rollback 

func (c *CreateMSKConnectPlugin) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateMSKConnectPlugin) String 

func (c *CreateMSKConnectPlugin) String() string

String implements the fmt.Stringer interface

type CreateMskConnect 

type CreateMskConnect struct {
	BaseMskConnect
	// contains filtered or unexported fields
}

func (*CreateMskConnect) Execute 

func (c *CreateMskConnect) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateMskConnect) Rollback 

func (c *CreateMskConnect) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateMskConnect) String 

func (c *CreateMskConnect) String() string

String implements the fmt.Stringer interface

type CreateMskConnectInput 

type CreateMskConnectInput struct {
	RedshiftDBInfo     *ws.RedshiftDBInfo // Redshift DB info
	MskEndpoints       *string            // AWS MSK Endpoints
	GlueSchemaRegistry string             // Glue schema registry
	Region             string             // Glue schema registry's region
	TopicName          string             // topic name to be consumed
	TableName          string             // table name to sync

}

type CreateNAT 

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

func (*CreateNAT) Execute 

func (c *CreateNAT) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateNAT) Rollback 

func (c *CreateNAT) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateNAT) String 

func (c *CreateNAT) String() string

String implements the fmt.Stringer interface

type CreateNATGateway 

type CreateNATGateway struct {
	BaseNATGateway
}

****************************************************************************

func (*CreateNATGateway) CreateInternetGatewayRoute 

func (c *CreateNATGateway) CreateInternetGatewayRoute() error

func (*CreateNATGateway) Execute 

func (c *CreateNATGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateNATGateway) Rollback 

func (c *CreateNATGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateNATGateway) String 

func (c *CreateNATGateway) String() string

String implements the fmt.Stringer interface

type CreateNLB 

type CreateNLB struct {
	BaseNLB
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateNLB) Execute 

func (c *CreateNLB) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateNLB) Rollback 

func (c *CreateNLB) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateNLB) String 

func (c *CreateNLB) String() string

String implements the fmt.Stringer interface

type CreateNLBListener 

type CreateNLBListener struct {
	BaseNLBListener
}

****************************************************************************

func (*CreateNLBListener) Execute 

func (c *CreateNLBListener) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateNLBListener) Rollback 

func (c *CreateNLBListener) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateNLBListener) String 

func (c *CreateNLBListener) String() string

String implements the fmt.Stringer interface

type CreateNetwork 

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

Mkdir is used to create directory on the target host

func (*CreateNetwork) Execute 

func (c *CreateNetwork) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateNetwork) Rollback 

func (c *CreateNetwork) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateNetwork) String 

func (c *CreateNetwork) String() string

String implements the fmt.Stringer interface

type CreateOracle 

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

func (*CreateOracle) Execute 

func (c *CreateOracle) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateOracle) Rollback 

func (c *CreateOracle) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateOracle) String 

func (c *CreateOracle) String() string

String implements the fmt.Stringer interface

type CreatePostgres 

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

func (*CreatePostgres) Execute 

func (c *CreatePostgres) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreatePostgres) Install 

func (c *CreatePostgres) Install(ctx context.Context) error

func (*CreatePostgres) Rollback 

func (c *CreatePostgres) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreatePostgres) String 

func (c *CreatePostgres) String() string

String implements the fmt.Stringer interface

type CreateRDSExportS3 

type CreateRDSExportS3 struct {
	BaseRDSExportS3
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateRDSExportS3) Execute 

func (c *CreateRDSExportS3) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateRDSExportS3) Rollback 

func (c *CreateRDSExportS3) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateRDSExportS3) String 

func (c *CreateRDSExportS3) String() string

String implements the fmt.Stringer interface

type CreateRedshiftCluster 

type CreateRedshiftCluster struct {
	BaseRedshiftCluster
	// contains filtered or unexported fields
}

func (*CreateRedshiftCluster) Execute 

func (c *CreateRedshiftCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateRedshiftCluster) Rollback 

func (c *CreateRedshiftCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateRedshiftCluster) String 

func (c *CreateRedshiftCluster) String() string

String implements the fmt.Stringer interface

type CreateRouteTable 

type CreateRouteTable struct {
	BaseRouteTable
}

****************************************************************************

func (*CreateRouteTable) AttachGW2VPC 

func (c *CreateRouteTable) AttachGW2VPC() error

func (*CreateRouteTable) CreateInternetGateway 

func (c *CreateRouteTable) CreateInternetGateway() error

func (*CreateRouteTable) CreateInternetGatewayRoute 

func (c *CreateRouteTable) CreateInternetGatewayRoute() error

func (*CreateRouteTable) Execute 

func (c *CreateRouteTable) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateRouteTable) Rollback 

func (c *CreateRouteTable) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateRouteTable) String 

func (c *CreateRouteTable) String() string

String implements the fmt.Stringer interface

type CreateRouteTgw 

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

func (*CreateRouteTgw) Execute 

func (c *CreateRouteTgw) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateRouteTgw) Rollback 

func (c *CreateRouteTgw) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateRouteTgw) String 

func (c *CreateRouteTgw) String() string

String implements the fmt.Stringer interface

type CreateSecurityGroup 

type CreateSecurityGroup struct {
	BaseSecurityGroup
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateSecurityGroup) Execute 

func (c *CreateSecurityGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateSecurityGroup) Rollback 

func (c *CreateSecurityGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateSecurityGroup) String 

func (c *CreateSecurityGroup) String() string

String implements the fmt.Stringer interface

type CreateServiceIamPolicy 

type CreateServiceIamPolicy struct {
	BaseServiceIamPolicy
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateServiceIamPolicy) Execute 

func (c *CreateServiceIamPolicy) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateServiceIamPolicy) Rollback 

func (c *CreateServiceIamPolicy) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateServiceIamPolicy) String 

func (c *CreateServiceIamPolicy) String() string

String implements the fmt.Stringer interface

type CreateServiceIamRole 

type CreateServiceIamRole struct {
	BaseServiceIamRole
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateServiceIamRole) Execute 

func (c *CreateServiceIamRole) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateServiceIamRole) Rollback 

func (c *CreateServiceIamRole) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateServiceIamRole) String 

func (c *CreateServiceIamRole) String() string

String implements the fmt.Stringer interface

type CreateSubnets 

type CreateSubnets struct {
	BaseSubnets
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateSubnets) Execute 

func (c *CreateSubnets) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateSubnets) Rollback 

func (c *CreateSubnets) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateSubnets) String 

func (c *CreateSubnets) String() string

String implements the fmt.Stringer interface

type CreateTargetGroup 

type CreateTargetGroup struct {
	BaseTargetGroup
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateTargetGroup) Execute 

func (c *CreateTargetGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateTargetGroup) Rollback 

func (c *CreateTargetGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateTargetGroup) String 

func (c *CreateTargetGroup) String() string

String implements the fmt.Stringer interface

type CreateTemplate 

type CreateTemplate struct {
	BaseTemplate
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateTemplate) Execute 

func (c *CreateTemplate) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateTemplate) Rollback 

func (c *CreateTemplate) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateTemplate) String 

func (c *CreateTemplate) String() string

String implements the fmt.Stringer interface

type CreateTiCDCGlue 

type CreateTiCDCGlue struct {
	BaseTiCDCGlue
}

func (*CreateTiCDCGlue) Execute 

func (c *CreateTiCDCGlue) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateTiCDCGlue) Rollback 

func (c *CreateTiCDCGlue) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateTiCDCGlue) String 

func (c *CreateTiCDCGlue) String() string

String implements the fmt.Stringer interface

type CreateTiDBCloud 

type CreateTiDBCloud struct {
	BaseTiDBCloud
	// contains filtered or unexported fields
}

func (*CreateTiDBCloud) Execute 

func (c *CreateTiDBCloud) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateTiDBCloud) Rollback 

func (c *CreateTiDBCloud) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateTiDBCloud) String 

func (c *CreateTiDBCloud) String() string

String implements the fmt.Stringer interface

func (*CreateTiDBCloud) WaitResourceUnitlAvailable 

func (c *CreateTiDBCloud) WaitResourceUnitlAvailable(projectID, clusterName string) error

type CreateTiDBCloudImport 

type CreateTiDBCloudImport struct {
	BaseTiDBCloudImport
}

func (*CreateTiDBCloudImport) Execute 

func (c *CreateTiDBCloudImport) Execute(ctx context.Context) error

Executef implements the Task interface

  1. Get bucket arn
  2. Get Path
  3. Role

func (*CreateTiDBCloudImport) Rollback 

func (c *CreateTiDBCloudImport) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateTiDBCloudImport) String 

func (c *CreateTiDBCloudImport) String() string

String implements the fmt.Stringer interface

func (*CreateTiDBCloudImport) WaitResourceUnitlAvailable 

func (c *CreateTiDBCloudImport) WaitResourceUnitlAvailable() error

type CreateTiKVNodes 

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

---------------------------------TiKV *****************************************************************************

func (*CreateTiKVNodes) Execute 

func (c *CreateTiKVNodes) Execute(ctx context.Context) error

batch 

-> zone

online 

-> zone

Loop the topo structure, and find out all the instance. 

Name: test-name,  Cluster: ohmytiup-tidb, component: tikv, label/category: online, label/category: host01
Name: test-name,  Cluster: ohmytiup-tidb, component: tikv, label/category: online, label/category: host02
Name: test-name,  Cluster: ohmytiup-tidb, component: tikv, label/category: online, label/category: host03
Name: test-name,  Cluster: ohmytiup-tidb, component: tikv, label/category: batch, label/category: host04
Name: test-name,  Cluster: ohmytiup-tidb, component: tikv, label/category: batch, label/category: host05
Name: test-name,  Cluster: ohmytiup-tidb, component: tikv, label/category: batch, label/category: host06

Execute implements the Task interface

func (*CreateTiKVNodes) Rollback 

func (c *CreateTiKVNodes) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateTiKVNodes) String 

func (c *CreateTiKVNodes) String() string

String implements the fmt.Stringer interface

type CreateTransitGateway 

type CreateTransitGateway struct {
	BaseTransitGateway
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateTransitGateway) Execute 

func (c *CreateTransitGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateTransitGateway) Rollback 

func (c *CreateTransitGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateTransitGateway) String 

func (c *CreateTransitGateway) String() string

String implements the fmt.Stringer interface

type CreateTransitGatewayVpcAttachment 

type CreateTransitGatewayVpcAttachment struct {
	BaseTransitGatewayVpcAttachment
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateTransitGatewayVpcAttachment) Execute 

func (c *CreateTransitGatewayVpcAttachment) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateTransitGatewayVpcAttachment) Rollback 

func (c *CreateTransitGatewayVpcAttachment) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateTransitGatewayVpcAttachment) String 

func (c *CreateTransitGatewayVpcAttachment) String() string

String implements the fmt.Stringer interface

type CreateVPC 

type CreateVPC struct {
	BaseVPC
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateVPC) Execute 

func (c *CreateVPC) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateVPC) Rollback 

func (c *CreateVPC) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateVPC) String 

func (c *CreateVPC) String() string

String implements the fmt.Stringer interface

type CreateVpcEndpoint 

type CreateVpcEndpoint struct {
	BaseVpcEndpoint
	// contains filtered or unexported fields
}

****************************************************************************

func (*CreateVpcEndpoint) Execute 

func (c *CreateVpcEndpoint) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateVpcEndpoint) Rollback 

func (c *CreateVpcEndpoint) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateVpcEndpoint) String 

func (c *CreateVpcEndpoint) String() string

String implements the fmt.Stringer interface

type CreateVpcPeering 

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

type CreateWorkerConfiguration 

type CreateWorkerConfiguration struct {
	BaseWorkerConfiguration
	// contains filtered or unexported fields
}

func (*CreateWorkerConfiguration) Execute 

func (c *CreateWorkerConfiguration) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateWorkerConfiguration) Rollback 

func (c *CreateWorkerConfiguration) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateWorkerConfiguration) String 

func (c *CreateWorkerConfiguration) String() string

String implements the fmt.Stringer interface

type CreateWorkstation 

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

func (*CreateWorkstation) Execute 

func (c *CreateWorkstation) Execute(ctx context.Context) error

Execute implements the Task interface

func (*CreateWorkstation) Rollback 

func (c *CreateWorkstation) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*CreateWorkstation) String 

func (c *CreateWorkstation) String() string

String implements the fmt.Stringer interface

type DBCluster 

type DBCluster struct {
	AllocatedStorage    int    `json:"AllocatedStorage"`
	DBClusterIdentifier string `json:"DBClusterIdentifier"`
	Status              string `json:"Status"`
	DBClusterArn        string `json:"DBClusterArn"`
}

type DBClusterParameterGroup 

type DBClusterParameterGroup struct {
	DBClusterParameterGroupName string `json:"DBClusterParameterGroupName"`
	DBParameterGroupFamily      string `json:"DBParameterGroupFamily"`
	Description                 string `json:"Description"`
	DBClusterParameterGroupArn  string `json:"DBClusterParameterGroupArn"`
}

type DBClusterParameterGroups 

type DBClusterParameterGroups struct {
	DBClusterParameterGroups []DBClusterParameterGroup `json:"DBClusterParameterGroups"`
}

type DBClusters 

type DBClusters struct {
	DBClusters []DBCluster `json:"DBClusters"`
}

type DBConnectInfo 

type DBConnectInfo struct {
	DBHost     string `yaml:"Host"`
	DBPort     int    `yaml:"Port"`
	DBUser     string `yaml:"User"`
	DBPassword string `yaml:"Password"`
}

type DBInfo 

type DBInfo struct {
	DBHost     string
	DBPort     int64
	DBUser     string
	DBPassword string
}

type DBInstance 

type DBInstance struct {
	DBInstanceIdentifier string             `json:"DBInstanceIdentifier"`
	DBInstanceStatus     string             `json:"DBInstanceStatus"`
	DBInstanceArn        string             `json:"DBInstanceArn"`
	MasterUsername       string             `json:"MasterUsername"`
	Endpoint             DBInstanceEndpoint `json:"Endpoint"`
}

type DBInstanceEndpoint 

type DBInstanceEndpoint struct {
	Address string `json:"Address"`
	Port    int    `json:"Port"`
}

type DBInstances 

type DBInstances struct {
	DBInstances []DBInstance `json:"DBInstances"`
}

type DBParameterGroup 

type DBParameterGroup struct {
	DBParameterGroupName   string `json:"DBParameterGroupName"`
	DBParameterGroupFamily string `json:"DBParameterGroupFamily"`
	Description            string `json:"Description"`
	DBParameterGroupArn    string `json:"DBParameterGroupArn"`
}

type DBParameterGroups 

type DBParameterGroups struct {
	DBParameterGroups []DBParameterGroup `json:"DBParameterGroups"`
}

type DBSubnetGroup 

type DBSubnetGroup struct {
	DBSubnetGroupName string `json:"DBSubnetGroupName"`
	VpcId             string `json:"VpcId"`
	SubnetGroupStatus string `json:"SubnetGroupStatus"`
	DBSubnetGroupArn  string `json:"DBSubnetGroupArn"`
}

type DBSubnetGroups 

type DBSubnetGroups struct {
	DBSubnetGroups []DBSubnetGroup `json:"DBSubnetGroups"`
}

type DMClusterInfo 

type DMClusterInfo struct {
	Name       string `json:"name"`
	User       string `json:"user"`
	DMVersion  string `json:"version"`
	Path       string `json:"path"`
	PrivateKey string `json:"private_key"`
}

type DMClustersInfo 

type DMClustersInfo struct {
	Clusters []DMClusterInfo `json:"clusters"`
}

type DMSSubnetGroup 

type DMSSubnetGroup struct {
	ReplicationSubnetGroupIdentifier string `json:"ReplicationSubnetGroupIdentifier"`
	VpcId                            string `json:"VpcId"`
	SubnetGroupStatus                string `json:"SubnetGroupStatus"`
}

type DMSSubnetGroups 

type DMSSubnetGroups struct {
	DMSSubnetGroups []DMSSubnetGroup `json:"ReplicationSubnetGroups"`
}

type DMTaskDetail 

type DMTaskDetail struct {
	Result  bool   `json:"result"`
	Msg     string `json:"msg"`
	Sources []struct {
		Result       bool   `json:"result"`
		Msg          string `json:"msg"`
		SourceStatus struct {
			Source      string `json:"source"`
			Worker      string `json:"worker"`
			Result      string `json:"result"`
			RelayStatus string `json:"relayStatus"`
		} `json:"sourceStatus"`
		SubTaskStatus []struct {
			Name                string `json:"name"`
			Stage               string `json:"stage"`
			Unit                string `json:"unit"`
			Result              string `json:"result"`
			UnresolvedDDLLockID string `json:"unresolvedDDLLockID"`
			Sync                struct {
				TotalEvents         string   `json:"totalEvents"`
				TotalTps            string   `json:"totalTps"`
				RecentTps           string   `json:"recentTps"`
				MasterBinlog        string   `json:"masterBinlog"`
				MasterBinlogGtid    string   `json:"masterBinlogGtid"`
				SyncerBinlog        string   `json:"syncerBinlog"`
				SyncerBinlogGtid    string   `json:"syncerBinlogGtid"`
				BlockingDDLs        []string `json:"blockingDDLs"`
				UnresolvedGroups    []string `json:"unresolvedGroups"`
				Synced              bool     `json:"synced"`
				BinlogType          string   `json:"binlogType"`
				SecondsBehindMaster string   `json:"secondsBehindMaster"`
				BlockDDLOwner       string   `json:"blockDDLOwner"`
				ConflictMsg         string   `json:"conflictMsg"`
			} `json:"sync"`
		} `json:"subTaskStatus"`
	} `json:"sources"`
}

type DeleteAuroraSnapshots 

type DeleteAuroraSnapshots struct {
	BaseWSTask
}

func (DeleteAuroraSnapshots) Execute 

func (c DeleteAuroraSnapshots) Execute(ctx context.Context) error

01. Aurora snapshot taken 01.01. Get Aurora connection info 01.02. Get binlog position 01.03. Make snapshot if it does not exist

type DeleteS3Folder 

type DeleteS3Folder struct {
	BaseWSTask
}

func (DeleteS3Folder) Execute 

func (c DeleteS3Folder) Execute(ctx context.Context) error

03. Data export to s3 03.01. Preare export role 03.02. Export snapshot to S3

type Deploy 

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

Mkdir is used to create directory on the target host

func (*Deploy) Execute 

func (r *Deploy) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Deploy) Rollback 

func (r *Deploy) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Deploy) String 

func (r *Deploy) String() string

String implements the fmt.Stringer interface

type DeployDM 

type DeployDM struct {
	BaseWSTask
	// contains filtered or unexported fields
}

func (*DeployDM) Execute 

func (c *DeployDM) Execute(ctx context.Context) error

14. Diff check

func (*DeployDM) Rollback 

func (c *DeployDM) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployDM) String 

func (c *DeployDM) String() string

String implements the fmt.Stringer interface

type DeployDrainConfig 

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

func (*DeployDrainConfig) Execute 

func (c *DeployDrainConfig) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployDrainConfig) Rollback 

func (c *DeployDrainConfig) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployDrainConfig) String 

func (c *DeployDrainConfig) String() string

String implements the fmt.Stringer interface

type DeployEKS 

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

func (*DeployEKS) Execute 

func (c *DeployEKS) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployEKS) Rollback 

func (c *DeployEKS) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployEKS) String 

func (c *DeployEKS) String() string

String implements the fmt.Stringer interface

type DeployEKSNodeGroup 

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

********** ********** ********** Generate node group for k8s ********* ********** **********

func (*DeployEKSNodeGroup) Execute 

func (c *DeployEKSNodeGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployEKSNodeGroup) Rollback 

func (c *DeployEKSNodeGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployEKSNodeGroup) String 

func (c *DeployEKSNodeGroup) String() string

String implements the fmt.Stringer interface

type DeployK8SES 

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

func (*DeployK8SES) Execute 

func (c *DeployK8SES) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployK8SES) Rollback 

func (c *DeployK8SES) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployK8SES) String 

func (c *DeployK8SES) String() string

String implements the fmt.Stringer interface

type DeployKafka 

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

func (*DeployKafka) Execute 

func (c *DeployKafka) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployKafka) Rollback 

func (c *DeployKafka) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployKafka) String 

func (c *DeployKafka) String() string

String implements the fmt.Stringer interface

type DeployMongo 

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

func (*DeployMongo) Execute 

func (c *DeployMongo) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployMongo) Rollback 

func (c *DeployMongo) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployMongo) String 

func (c *DeployMongo) String() string

String implements the fmt.Stringer interface

type DeployMySQL 

type DeployMySQL struct {
	BaseWSTask
	// contains filtered or unexported fields
}

func (*DeployMySQL) Execute 

func (c *DeployMySQL) Execute(ctx context.Context) error

14. Diff check

func (*DeployMySQL) Rollback 

func (c *DeployMySQL) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployMySQL) String 

func (c *DeployMySQL) String() string

String implements the fmt.Stringer interface

type DeployPDNS 

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

func (*DeployPDNS) Execute 

func (c *DeployPDNS) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployPDNS) Rollback 

func (c *DeployPDNS) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployPDNS) String 

func (c *DeployPDNS) String() string

String implements the fmt.Stringer interface

type DeployRedshiftInstance 

type DeployRedshiftInstance struct {
	BaseRedshiftCluster
	// contains filtered or unexported fields
}

Deploy Redshift Instance

func (*DeployRedshiftInstance) Execute 

func (c *DeployRedshiftInstance) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployRedshiftInstance) Rollback 

func (c *DeployRedshiftInstance) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployRedshiftInstance) String 

func (c *DeployRedshiftInstance) String() string

String implements the fmt.Stringer interface

type DeployThanos 

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

func (*DeployThanos) Execute 

func (c *DeployThanos) Execute(ctx context.Context) error

func (*DeployThanos) Rollback 

func (c *DeployThanos) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployThanos) String 

func (c *DeployThanos) String() string

String implements the fmt.Stringer interface

type DeployTiCDC 

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

func (*DeployTiCDC) Execute 

func (c *DeployTiCDC) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployTiCDC) Rollback 

func (c *DeployTiCDC) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployTiCDC) String 

func (c *DeployTiCDC) String() string

String implements the fmt.Stringer interface

type DeployTiDB 

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

func (*DeployTiDB) Execute 

func (c *DeployTiDB) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployTiDB) Rollback 

func (c *DeployTiDB) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployTiDB) String 

func (c *DeployTiDB) String() string

String implements the fmt.Stringer interface

type DeployTiDBInstance 

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

func (*DeployTiDBInstance) Execute 

func (c *DeployTiDBInstance) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployTiDBInstance) Rollback 

func (c *DeployTiDBInstance) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployTiDBInstance) String 

func (c *DeployTiDBInstance) String() string

String implements the fmt.Stringer interface

type DeployWS 

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

******************************************* Workspace

func (*DeployWS) Execute 

func (c *DeployWS) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DeployWS) Rollback 

func (c *DeployWS) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DeployWS) String 

func (c *DeployWS) String() string

String implements the fmt.Stringer interface

type DestroyAutoScaling 

type DestroyAutoScaling struct {
	BaseAutoScaling
	// contains filtered or unexported fields
}

func (*DestroyAutoScaling) Execute 

func (c *DestroyAutoScaling) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyAutoScaling) Rollback 

func (c *DestroyAutoScaling) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyAutoScaling) String 

func (c *DestroyAutoScaling) String() string

String implements the fmt.Stringer interface

type DestroyAutoScalingGroup 

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

func (*DestroyAutoScalingGroup) Execute 

func (c *DestroyAutoScalingGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyAutoScalingGroup) Rollback 

func (c *DestroyAutoScalingGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyAutoScalingGroup) String 

func (c *DestroyAutoScalingGroup) String() string

String implements the fmt.Stringer interface

type DestroyCloudFormationV2 

type DestroyCloudFormationV2 struct {
	BaseCloudFormation
}

func (*DestroyCloudFormationV2) Execute 

func (c *DestroyCloudFormationV2) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyCloudFormationV2) Rollback 

func (c *DestroyCloudFormationV2) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyCloudFormationV2) String 

func (c *DestroyCloudFormationV2) String() string

String implements the fmt.Stringer interface

type DestroyDBCluster 

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

func (*DestroyDBCluster) Execute 

func (c *DestroyDBCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDBCluster) Rollback 

func (c *DestroyDBCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDBCluster) String 

func (c *DestroyDBCluster) String() string

String implements the fmt.Stringer interface

type DestroyDBClusterParameterGroup 

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

func (*DestroyDBClusterParameterGroup) Execute 

func (c *DestroyDBClusterParameterGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDBClusterParameterGroup) Rollback 

func (c *DestroyDBClusterParameterGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDBClusterParameterGroup) String 

func (c *DestroyDBClusterParameterGroup) String() string

String implements the fmt.Stringer interface

type DestroyDBInstance 

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

func (*DestroyDBInstance) Execute 

func (c *DestroyDBInstance) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDBInstance) Rollback 

func (c *DestroyDBInstance) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDBInstance) String 

func (c *DestroyDBInstance) String() string

String implements the fmt.Stringer interface

type DestroyDBParameterGroup 

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

func (*DestroyDBParameterGroup) Execute 

func (c *DestroyDBParameterGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDBParameterGroup) Rollback 

func (c *DestroyDBParameterGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDBParameterGroup) String 

func (c *DestroyDBParameterGroup) String() string

String implements the fmt.Stringer interface

type DestroyDBSubnetGroup 

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

func (*DestroyDBSubnetGroup) Execute 

func (c *DestroyDBSubnetGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDBSubnetGroup) Rollback 

func (c *DestroyDBSubnetGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDBSubnetGroup) String 

func (c *DestroyDBSubnetGroup) String() string

String implements the fmt.Stringer interface

type DestroyDMSEndpoints 

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

func (*DestroyDMSEndpoints) Execute 

func (c *DestroyDMSEndpoints) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDMSEndpoints) Rollback 

func (c *DestroyDMSEndpoints) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDMSEndpoints) String 

func (c *DestroyDMSEndpoints) String() string

String implements the fmt.Stringer interface

type DestroyDMSInstance 

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

func (*DestroyDMSInstance) Execute 

func (c *DestroyDMSInstance) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDMSInstance) Rollback 

func (c *DestroyDMSInstance) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDMSInstance) String 

func (c *DestroyDMSInstance) String() string

String implements the fmt.Stringer interface

type DestroyDMSSubnetGroup 

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

func (*DestroyDMSSubnetGroup) Execute 

func (c *DestroyDMSSubnetGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDMSSubnetGroup) Rollback 

func (c *DestroyDMSSubnetGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDMSSubnetGroup) String 

func (c *DestroyDMSSubnetGroup) String() string

String implements the fmt.Stringer interface

type DestroyDMSTask 

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

func (*DestroyDMSTask) Execute 

func (c *DestroyDMSTask) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyDMSTask) Rollback 

func (c *DestroyDMSTask) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyDMSTask) String 

func (c *DestroyDMSTask) String() string

String implements the fmt.Stringer interface

type DestroyEC 

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

func (*DestroyEC) Execute 

func (c *DestroyEC) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyEC) Rollback 

func (c *DestroyEC) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyEC) String 

func (c *DestroyEC) String() string

String implements the fmt.Stringer interface

type DestroyEKS 

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

func (*DestroyEKS) Execute 

func (c *DestroyEKS) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyEKS) Rollback 

func (c *DestroyEKS) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyEKS) String 

func (c *DestroyEKS) String() string

String implements the fmt.Stringer interface

type DestroyEKSNodeGroup 

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

func (*DestroyEKSNodeGroup) Execute 

func (c *DestroyEKSNodeGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyEKSNodeGroup) Rollback 

func (c *DestroyEKSNodeGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyEKSNodeGroup) String 

func (c *DestroyEKSNodeGroup) String() string

String implements the fmt.Stringer interface

type DestroyElasticAddress 

type DestroyElasticAddress struct {
	BaseElasticAddress
}

func (*DestroyElasticAddress) Execute 

func (c *DestroyElasticAddress) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyElasticAddress) Rollback 

func (c *DestroyElasticAddress) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyElasticAddress) String 

func (c *DestroyElasticAddress) String() string

String implements the fmt.Stringer interface

type DestroyGlueSchemaRegistryCluster 

type DestroyGlueSchemaRegistryCluster struct {
	BaseGlueSchemaRegistryCluster
	// contains filtered or unexported fields
}

func (*DestroyGlueSchemaRegistryCluster) Execute 

func (c *DestroyGlueSchemaRegistryCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyGlueSchemaRegistryCluster) Rollback 

func (c *DestroyGlueSchemaRegistryCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyGlueSchemaRegistryCluster) String 

func (c *DestroyGlueSchemaRegistryCluster) String() string

String implements the fmt.Stringer interface

type DestroyInternetGateway 

type DestroyInternetGateway struct {
	BaseInternetGateway
	// contains filtered or unexported fields
}

func (*DestroyInternetGateway) Execute 

func (c *DestroyInternetGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyInternetGateway) Rollback 

func (c *DestroyInternetGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyInternetGateway) String 

func (c *DestroyInternetGateway) String() string

String implements the fmt.Stringer interface

type DestroyK8SES 

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

func (*DestroyK8SES) Execute 

func (c *DestroyK8SES) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyK8SES) Rollback 

func (c *DestroyK8SES) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyK8SES) String 

func (c *DestroyK8SES) String() string

String implements the fmt.Stringer interface

type DestroyKMS 

type DestroyKMS struct {
	BaseKMS
}

func (*DestroyKMS) Execute 

func (c *DestroyKMS) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyKMS) Rollback 

func (c *DestroyKMS) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyKMS) String 

func (c *DestroyKMS) String() string

String implements the fmt.Stringer interface

type DestroyLaunchTemplate 

type DestroyLaunchTemplate struct {
	BaseLaunchTemplate
	// contains filtered or unexported fields
}

func (*DestroyLaunchTemplate) Execute 

func (c *DestroyLaunchTemplate) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyLaunchTemplate) Rollback 

func (c *DestroyLaunchTemplate) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyLaunchTemplate) String 

func (c *DestroyLaunchTemplate) String() string

String implements the fmt.Stringer interface

type DestroyMSKCluster 

type DestroyMSKCluster struct {
	BaseMSKCluster
	// contains filtered or unexported fields
}

func (*DestroyMSKCluster) Execute 

func (c *DestroyMSKCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyMSKCluster) Rollback 

func (c *DestroyMSKCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyMSKCluster) String 

func (c *DestroyMSKCluster) String() string

String implements the fmt.Stringer interface

type DestroyMSKConnectPlugin 

type DestroyMSKConnectPlugin struct {
	BaseMSKConnectPlugin
	// contains filtered or unexported fields
}

func (*DestroyMSKConnectPlugin) Execute 

func (c *DestroyMSKConnectPlugin) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyMSKConnectPlugin) Rollback 

func (c *DestroyMSKConnectPlugin) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyMSKConnectPlugin) String 

func (c *DestroyMSKConnectPlugin) String() string

String implements the fmt.Stringer interface

type DestroyMskConnect 

type DestroyMskConnect struct {
	BaseMskConnect
	// contains filtered or unexported fields
}

func (*DestroyMskConnect) Execute 

func (c *DestroyMskConnect) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyMskConnect) Rollback 

func (c *DestroyMskConnect) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyMskConnect) String 

func (c *DestroyMskConnect) String() string

String implements the fmt.Stringer interface

type DestroyNAT 

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

func (*DestroyNAT) Execute 

func (c *DestroyNAT) Execute(ctx context.Context) error

func (*DestroyNAT) Rollback 

func (c *DestroyNAT) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyNAT) String 

func (c *DestroyNAT) String() string

String implements the fmt.Stringer interface

type DestroyNATGateway 

type DestroyNATGateway struct {
	BaseNATGateway
}

func (*DestroyNATGateway) Execute 

func (c *DestroyNATGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyNATGateway) Rollback 

func (c *DestroyNATGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyNATGateway) String 

func (c *DestroyNATGateway) String() string

String implements the fmt.Stringer interface

type DestroyNLB 

type DestroyNLB struct {
	BaseNLB
	// contains filtered or unexported fields
}

func (*DestroyNLB) Execute 

func (c *DestroyNLB) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyNLB) Rollback 

func (c *DestroyNLB) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyNLB) String 

func (c *DestroyNLB) String() string

String implements the fmt.Stringer interface

type DestroyNetwork 

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

func (*DestroyNetwork) Execute 

func (c *DestroyNetwork) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyNetwork) Rollback 

func (c *DestroyNetwork) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyNetwork) String 

func (c *DestroyNetwork) String() string

String implements the fmt.Stringer interface

type DestroyOracle 

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

func (*DestroyOracle) Execute 

func (c *DestroyOracle) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyOracle) Rollback 

func (c *DestroyOracle) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyOracle) String 

func (c *DestroyOracle) String() string

String implements the fmt.Stringer interface

type DestroyPostgres 

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

func (*DestroyPostgres) Execute 

func (c *DestroyPostgres) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyPostgres) Rollback 

func (c *DestroyPostgres) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyPostgres) String 

func (c *DestroyPostgres) String() string

String implements the fmt.Stringer interface

type DestroyRDSExportS3 

type DestroyRDSExportS3 struct {
	BaseRDSExportS3
}

func (*DestroyRDSExportS3) Execute 

func (c *DestroyRDSExportS3) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyRDSExportS3) Rollback 

func (c *DestroyRDSExportS3) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyRDSExportS3) String 

func (c *DestroyRDSExportS3) String() string

String implements the fmt.Stringer interface

type DestroyRedshiftCluster 

type DestroyRedshiftCluster struct {
	BaseRedshiftCluster
	// contains filtered or unexported fields
}

func (*DestroyRedshiftCluster) Execute 

func (c *DestroyRedshiftCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyRedshiftCluster) Rollback 

func (c *DestroyRedshiftCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyRedshiftCluster) String 

func (c *DestroyRedshiftCluster) String() string

String implements the fmt.Stringer interface

type DestroyRouteTable 

type DestroyRouteTable struct {
	BaseRouteTable
}

func (*DestroyRouteTable) Execute 

func (c *DestroyRouteTable) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyRouteTable) Rollback 

func (c *DestroyRouteTable) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyRouteTable) String 

func (c *DestroyRouteTable) String() string

String implements the fmt.Stringer interface

type DestroySecurityGroup 

type DestroySecurityGroup struct {
	BaseSecurityGroup
	// contains filtered or unexported fields
}

func (*DestroySecurityGroup) Execute 

func (c *DestroySecurityGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroySecurityGroup) Rollback 

func (c *DestroySecurityGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroySecurityGroup) String 

func (c *DestroySecurityGroup) String() string

String implements the fmt.Stringer interface

type DestroyServiceIamPolicy 

type DestroyServiceIamPolicy struct {
	BaseServiceIamPolicy
	// contains filtered or unexported fields
}

func (*DestroyServiceIamPolicy) Execute 

func (c *DestroyServiceIamPolicy) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyServiceIamPolicy) Rollback 

func (c *DestroyServiceIamPolicy) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyServiceIamPolicy) String 

func (c *DestroyServiceIamPolicy) String() string

String implements the fmt.Stringer interface

type DestroyServiceIamRole 

type DestroyServiceIamRole struct {
	BaseServiceIamRole
}

func (*DestroyServiceIamRole) Execute 

func (c *DestroyServiceIamRole) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyServiceIamRole) Rollback 

func (c *DestroyServiceIamRole) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyServiceIamRole) String 

func (c *DestroyServiceIamRole) String() string

String implements the fmt.Stringer interface

type DestroySubnets 

type DestroySubnets struct {
	BaseSubnets
}

func (*DestroySubnets) Execute 

func (c *DestroySubnets) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroySubnets) Rollback 

func (c *DestroySubnets) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroySubnets) String 

func (c *DestroySubnets) String() string

String implements the fmt.Stringer interface

type DestroyTargetGroup 

type DestroyTargetGroup struct {
	BaseTargetGroup
	// contains filtered or unexported fields
}

func (*DestroyTargetGroup) Execute 

func (c *DestroyTargetGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyTargetGroup) Rollback 

func (c *DestroyTargetGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyTargetGroup) String 

func (c *DestroyTargetGroup) String() string

String implements the fmt.Stringer interface

type DestroyTemplate 

type DestroyTemplate struct {
	BaseTemplate
	// contains filtered or unexported fields
}

func (*DestroyTemplate) Execute 

func (c *DestroyTemplate) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyTemplate) Rollback 

func (c *DestroyTemplate) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyTemplate) String 

func (c *DestroyTemplate) String() string

String implements the fmt.Stringer interface

type DestroyTiDBCloud 

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

func (*DestroyTiDBCloud) Execute 

func (c *DestroyTiDBCloud) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyTiDBCloud) Rollback 

func (c *DestroyTiDBCloud) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyTiDBCloud) String 

func (c *DestroyTiDBCloud) String() string

String implements the fmt.Stringer interface

type DestroyTiDBCloudImport 

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

func (*DestroyTiDBCloudImport) Execute 

func (c *DestroyTiDBCloudImport) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyTiDBCloudImport) Rollback 

func (c *DestroyTiDBCloudImport) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyTiDBCloudImport) String 

func (c *DestroyTiDBCloudImport) String() string

String implements the fmt.Stringer interface

type DestroyTransitGateway 

type DestroyTransitGateway struct {
	BaseTransitGateway
	// contains filtered or unexported fields
}

func (*DestroyTransitGateway) Execute 

func (c *DestroyTransitGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyTransitGateway) Rollback 

func (c *DestroyTransitGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyTransitGateway) String 

func (c *DestroyTransitGateway) String() string

String implements the fmt.Stringer interface

type DestroyTransitGatewayVpcAttachment 

type DestroyTransitGatewayVpcAttachment struct {
	BaseTransitGatewayVpcAttachment
	// contains filtered or unexported fields
}

func (*DestroyTransitGatewayVpcAttachment) Execute 

func (c *DestroyTransitGatewayVpcAttachment) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyTransitGatewayVpcAttachment) Rollback 

func (c *DestroyTransitGatewayVpcAttachment) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyTransitGatewayVpcAttachment) String 

func (c *DestroyTransitGatewayVpcAttachment) String() string

String implements the fmt.Stringer interface

type DestroyVPC 

type DestroyVPC struct {
	BaseVPC
	// contains filtered or unexported fields
}

func (*DestroyVPC) Execute 

func (c *DestroyVPC) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyVPC) Rollback 

func (c *DestroyVPC) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyVPC) String 

func (c *DestroyVPC) String() string

String implements the fmt.Stringer interface

type DestroyVpcEndpoint 

type DestroyVpcEndpoint struct {
	BaseVpcEndpoint
}

func (*DestroyVpcEndpoint) Execute 

func (c *DestroyVpcEndpoint) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyVpcEndpoint) Rollback 

func (c *DestroyVpcEndpoint) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyVpcEndpoint) String 

func (c *DestroyVpcEndpoint) String() string

String implements the fmt.Stringer interface

type DestroyVpcPeering 

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

func (*DestroyVpcPeering) Execute 

func (c *DestroyVpcPeering) Execute(ctx context.Context) error

func (*DestroyVpcPeering) Rollback 

func (c *DestroyVpcPeering) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyVpcPeering) String 

func (c *DestroyVpcPeering) String() string

String implements the fmt.Stringer interface

type DestroyWorkerConfiguration 

type DestroyWorkerConfiguration struct {
	BaseWorkerConfiguration
	// contains filtered or unexported fields
}

func (*DestroyWorkerConfiguration) Execute 

func (c *DestroyWorkerConfiguration) Execute(ctx context.Context) error

Execute implements the Task interface

func (*DestroyWorkerConfiguration) Rollback 

func (c *DestroyWorkerConfiguration) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*DestroyWorkerConfiguration) String 

func (c *DestroyWorkerConfiguration) String() string

String implements the fmt.Stringer interface

type DisplayDMCluster 

type DisplayDMCluster struct {
	ClusterMeta struct {
		ClusterType    string `json:"cluster_type"`
		ClusterName    string `json:"cluster_name"`
		ClusterVersion string `json:"cluster_version"`
		DeployUser     string `json:"deploy_user"`
		SshType        string `json:"ssh_type"`
		TlsEnabled     bool   `json:"tls_enabled"`
	} `json:"cluster_meta"`
	Instances []struct {
		ID            string `json:"id"`
		Role          string `json:"role"`
		Host          string `json:"host"`
		Ports         string `json:"ports"`
		OsArch        string `json:"os_arch"`
		Status        string `json:"status"`
		Since         string `json:"since"`
		DataDir       string `json:"data_dir"`
		DeployDir     string `json:"deploy_dir"`
		ComponentName string `json:"ComponentName"`
		Port          int    `json:"Port"`
	} `json:"instances"`
}

type Downloader 

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

Downloader is used to download the specific version of a component from the repository, there is nothing to do if the specified version exists.

func NewDownloader 

func NewDownloader(component string, os string, arch string, version string) *Downloader

NewDownloader create a Downloader instance.

func (*Downloader) Execute 

func (d *Downloader) Execute(_ context.Context) error

Execute implements the Task interface

func (*Downloader) Rollback 

func (d *Downloader) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Downloader) String 

func (d *Downloader) String() string

String implements the fmt.Stringer interface

type EC2 

type EC2 struct {
	InstanceId       string              `json:"InstanceId"`
	State            ECState             `json:"State"`
	SubnetId         string              `json:"SubnetId"`
	VpcId            string              `json:"VpcId"`
	InstanceType     string              `json:"InstanceType"`
	ImageId          string              `json:"ImageId"`
	PrivateIpAddress string              `json:"PrivateIpAddress"`
	PrivateDnsName   string              `json:"PrivateDnsName"`
	PublicIpAddress  string              `json:"PublicIpAddress"`
	Tags             []map[string]string `json:"Tags"`
}

func GetWorkstation 

func GetWorkstation(executor ctxt.Executor, ctx context.Context) (*EC2, error)

func (EC2) String 

func (e EC2) String() string

type EC2NodeConfig 

type EC2NodeConfig struct {
	InstanceType string
	Count        int
	VolumeSize   int
	VolumeType   string
	Iops         int

	Labels []map[string]string
}

InstanceType:"c5.2xlarge", Count:3, VolumeSize:300, VolumeType:"gp3", Iops:3000

type EC2s 

type EC2s struct {
	Instances []EC2 `json:"Instances"`
}

func (EC2s) String 

func (e EC2s) String() string

type ECState 

type ECState struct {
	Code int    `json:"Code"`
	Name string `json:"Name"`
}

func (ECState) String 

func (e ECState) String() string

type ElasticAddresss 

type ElasticAddresss struct {
	BaseResourceInfo
}

func (*ElasticAddresss) GetResourceArn 

func (d *ElasticAddresss) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*ElasticAddresss) ToPrintTable 

func (d *ElasticAddresss) ToPrintTable() *[][]string

type Endpoint 

type Endpoint struct {
	EndpointIdentifier string `json:"EndpointIdentifier"`
	EndpointType       string `json:"EndpointType"`
	EngineName         string `json:"EngineName"`
	Status             string `json:"Status"`
	EndpointArn        string `json:"EndpointArn"`
}

type EndpointRecord 

type EndpointRecord struct {
	Endpoint Endpoint `json:"Endpoint"`
}

type Endpoints 

type Endpoints struct {
	Endpoints []Endpoint `json:"Endpoints"`
}

type EnvInit 

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

EnvInit is used to initialize the remote environment, e.g: 1. Generate SSH key 2. ssh-copy-id

func (*EnvInit) Execute 

func (e *EnvInit) Execute(ctx context.Context) error

Execute implements the Task interface

func (*EnvInit) Rollback 

func (e *EnvInit) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*EnvInit) String 

func (e *EnvInit) String() string

String implements the fmt.Stringer interface

type Func 

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

Func wrap a closure.

func NewFunc 

func NewFunc(name string, fn func(ctx context.Context) error) *Func

NewFunc create a Func task

func (*Func) Execute 

func (m *Func) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Func) Rollback 

func (m *Func) Rollback(_ context.Context) error

Rollback implements the Task interface

func (*Func) String 

func (m *Func) String() string

String implements the fmt.Stringer interface

type GlueSchemaRegistryInfo 

type GlueSchemaRegistryInfo struct {
	ClusterName string
}

type GlueSchemaRegistryInfos 

type GlueSchemaRegistryInfos struct {
	BaseResourceInfo
}

func (*GlueSchemaRegistryInfos) Append 

func (d *GlueSchemaRegistryInfos) Append()

func (*GlueSchemaRegistryInfos) ToPrintTable 

func (d *GlueSchemaRegistryInfos) ToPrintTable() *[][]string

type HelmListInfo 

type HelmListInfo struct {
	Name       string `json:"name"`
	NameSpace  string `json:"namespace"`
	Revision   string `json:"revision"`
	Updated    string `json:"updated"`
	Status     string `json:status`
	Chart      string `json:chart`
	AppVersion string `json:"app_version"`
}

[{"name":"nginx-ingress-controller","namespace":"default","revision":"1","updated":"2023-01-05 14:48:14.781865271 +0000 UTC","status":"deployed","chart":"ingress-nginx-4.4.2","app_version":"1.5.1"}]

type IAMSAInfo 

type IAMSAInfo struct {
	MetaData struct {
		Name      string `json:"name"`
		Namespace string `json:"namespace"`
	} `json:"metadata"`
	WellKnownPolicies struct {
		ImageBuilder              bool `json:"imageBuilder"`
		AutoScaler                bool `json:"autoScaler"`
		AwsLoadBalancerController bool `json:"awsLoadBalancerController"`
		ExternalDNS               bool `json:"externalDNS"`
		CertManager               bool `json:"certManager"`
		EbsCSIController          bool `json:"ebsCSIController"`
		EfsCSIController          bool `json:"efsCSIController"`
	} `json:"wellKnownPolicies"`
	Status struct {
		RoleARN string `json:"roleARN"`
	} `json:"status"`
}

type InitConfig 

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

InitConfig is used to copy all configurations to the target directory of path

func (*InitConfig) Execute 

func (c *InitConfig) Execute(ctx context.Context) error

Execute implements the Task interface

func (*InitConfig) Rollback 

func (c *InitConfig) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*InitConfig) String 

func (c *InitConfig) String() string

String implements the fmt.Stringer interface

type InstallOracleClient 

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

func (*InstallOracleClient) Execute 

func (c *InstallOracleClient) Execute(ctx context.Context) error

Execute implements the Task interface

func (*InstallOracleClient) Rollback 

func (c *InstallOracleClient) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*InstallOracleClient) String 

func (c *InstallOracleClient) String() string

String implements the fmt.Stringer interface

type InstallPackage 

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

InstallPackage is used to copy all files related the specific version a component to the target directory of path

func (*InstallPackage) Execute 

func (c *InstallPackage) Execute(ctx context.Context) error

Execute implements the Task interface

func (*InstallPackage) Rollback 

func (c *InstallPackage) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*InstallPackage) String 

func (c *InstallPackage) String() string

String implements the fmt.Stringer interface

type InstallThanos 

type InstallThanos struct {
	TargetServer *string
	ProxyServer  *string
	User         string
	KeyFile      string

	StoreServers *[]string
	// contains filtered or unexported fields
}

func (*InstallThanos) Execute 

func (c *InstallThanos) Execute(ctx context.Context) error

##################################################################### # template render and update config #####################################################################

func (*InstallThanos) Rollback 

func (c *InstallThanos) Rollback(ctx context.Context) error

func (*InstallThanos) String 

func (c *InstallThanos) String() string

type InstallTiDB 

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

func (*InstallTiDB) Execute 

func (c *InstallTiDB) Execute(ctx context.Context) error

Execute implements the Task interface

func (*InstallTiDB) Rollback 

func (c *InstallTiDB) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*InstallTiDB) String 

func (c *InstallTiDB) String() string

String implements the fmt.Stringer interface

type InternetGateway 

type InternetGateway struct {
	InternetGatewayId string       `json:"InternetGatewayId"`
	Attachments       []Attachment `json:"Attachments"`
}

func (InternetGateway) String 

func (i InternetGateway) String() string

type InternetGateways 

type InternetGateways struct {
	InternetGateways []InternetGateway `json:"InternetGateways"`
}

func (InternetGateways) String 

func (i InternetGateways) String() string

type InternetGatewaysInfo 

type InternetGatewaysInfo struct {
	BaseResourceInfo
}

func (*InternetGatewaysInfo) GetResourceArn 

func (d *InternetGatewaysInfo) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*InternetGatewaysInfo) ToPrintTable 

func (d *InternetGatewaysInfo) ToPrintTable() *[][]string

type IpPermissions 

type IpPermissions struct {
	FromPort   int        `json:"FromPort"`
	IpProtocol string     `json:"IpProtocol"`
	IpRanges   []IpRanges `json:"IpRanges"`
	ToPort     int        `json:"ToPort"`
}

type IpRanges 

type IpRanges struct {
	CidrIp string `json:"CidrIp"`
}

type KMSInfo 

type KMSInfo struct {
	BaseResourceInfo
}

func (*KMSInfo) GetResourceArn 

func (d *KMSInfo) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*KMSInfo) ToPrintTable 

func (d *KMSInfo) ToPrintTable() *[][]string

type KafkaInstallPkgTask 

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

*********** The package installation for parallel

func (*KafkaInstallPkgTask) Execute 

func (c *KafkaInstallPkgTask) Execute(ctx context.Context) error

func (*KafkaInstallPkgTask) Rollback 

func (c *KafkaInstallPkgTask) Rollback(ctx context.Context) error

func (*KafkaInstallPkgTask) String 

func (c *KafkaInstallPkgTask) String() string

type KafkaNodes 

type KafkaNodes struct {
	All            []string
	Zookeeper      []string
	Broker         []string
	SchemaRegistry []string
	RestService    []string
	Connector      []string
}

type LaunchTemplates 

type LaunchTemplates struct {
	BaseResourceInfo
}

func (*LaunchTemplates) GetResourceArn 

func (d *LaunchTemplates) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*LaunchTemplates) ToPrintTable 

func (d *LaunchTemplates) ToPrintTable() *[][]string

type Limit 

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

Limit set a system limit on host

func (*Limit) Execute 

func (l *Limit) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Limit) Rollback 

func (l *Limit) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Limit) String 

func (l *Limit) String() string

String implements the fmt.Stringer interface

type List 

type List struct {
	User          string
	Host          string
	ArnComponents []ARNComponent
}

func (*List) Execute 

func (c *List) Execute(ctx context.Context, clusterName, clusterType string) error

Execute implements the Task interface

func (*List) Rollback 

func (c *List) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*List) String 

func (c *List) String() string

String implements the fmt.Stringer interface

type ListAccount 

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

func (*ListAccount) Execute 

func (c *ListAccount) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListAccount) Rollback 

func (c *ListAccount) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListAccount) String 

func (c *ListAccount) String() string

String implements the fmt.Stringer interface

type ListAllAwsEC2 

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

func (*ListAllAwsEC2) Execute 

func (c *ListAllAwsEC2) Execute(ctx context.Context) error

func (*ListAllAwsEC2) Rollback 

func (c *ListAllAwsEC2) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListAllAwsEC2) String 

func (c *ListAllAwsEC2) String() string

String implements the fmt.Stringer interface

type ListAutoScaling 

type ListAutoScaling struct {
	BaseAutoScaling
}

func (*ListAutoScaling) Execute 

func (c *ListAutoScaling) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListAutoScaling) Rollback 

func (c *ListAutoScaling) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListAutoScaling) String 

func (c *ListAutoScaling) String() string

String implements the fmt.Stringer interface

type ListEC 

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

func (*ListEC) Execute 

func (c *ListEC) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListEC) Rollback 

func (c *ListEC) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListEC) String 

func (c *ListEC) String() string

String implements the fmt.Stringer interface

type ListElasticAddress 

type ListElasticAddress struct {
	BaseElasticAddress
}

func (*ListElasticAddress) Execute 

func (c *ListElasticAddress) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListElasticAddress) Rollback 

func (c *ListElasticAddress) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListElasticAddress) String 

func (c *ListElasticAddress) String() string

String implements the fmt.Stringer interface

type ListGlueSchemaRegistryCluster 

type ListGlueSchemaRegistryCluster struct {
	BaseGlueSchemaRegistryCluster
}

func (*ListGlueSchemaRegistryCluster) Execute 

func (c *ListGlueSchemaRegistryCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListGlueSchemaRegistryCluster) Rollback 

func (c *ListGlueSchemaRegistryCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListGlueSchemaRegistryCluster) String 

func (c *ListGlueSchemaRegistryCluster) String() string

String implements the fmt.Stringer interface

type ListInternetGateway 

type ListInternetGateway struct {
	BaseInternetGateway
}

func (*ListInternetGateway) Execute 

func (c *ListInternetGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListInternetGateway) Rollback 

func (c *ListInternetGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListInternetGateway) String 

func (c *ListInternetGateway) String() string

String implements the fmt.Stringer interface

type ListLaunchTemplate 

type ListLaunchTemplate struct {
	BaseLaunchTemplate
}

func (*ListLaunchTemplate) Execute 

func (c *ListLaunchTemplate) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListLaunchTemplate) Rollback 

func (c *ListLaunchTemplate) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListLaunchTemplate) String 

func (c *ListLaunchTemplate) String() string

String implements the fmt.Stringer interface

type ListMSKCluster 

type ListMSKCluster struct {
	BaseMSKCluster
}

func (*ListMSKCluster) Execute 

func (c *ListMSKCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListMSKCluster) Rollback 

func (c *ListMSKCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListMSKCluster) String 

func (c *ListMSKCluster) String() string

String implements the fmt.Stringer interface

type ListMSKConnectPlugin 

type ListMSKConnectPlugin struct {
	BaseMSKConnectPlugin
}

func (*ListMSKConnectPlugin) Execute 

func (c *ListMSKConnectPlugin) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListMSKConnectPlugin) Rollback 

func (c *ListMSKConnectPlugin) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListMSKConnectPlugin) String 

func (c *ListMSKConnectPlugin) String() string

String implements the fmt.Stringer interface

type ListMskConnect 

type ListMskConnect struct {
	BaseMskConnect
}

func (*ListMskConnect) Execute 

func (c *ListMskConnect) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListMskConnect) Rollback 

func (c *ListMskConnect) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListMskConnect) String 

func (c *ListMskConnect) String() string

String implements the fmt.Stringer interface

type ListNATGateway 

type ListNATGateway struct {
	BaseNATGateway
}

func (*ListNATGateway) Execute 

func (c *ListNATGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListNATGateway) Rollback 

func (c *ListNATGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListNATGateway) String 

func (c *ListNATGateway) String() string

String implements the fmt.Stringer interface

type ListNLB 

type ListNLB struct {
	BaseNLB
	// contains filtered or unexported fields
}

func (*ListNLB) Execute 

func (c *ListNLB) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListNLB) Rollback 

func (c *ListNLB) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListNLB) String 

func (c *ListNLB) String() string

String implements the fmt.Stringer interface

type ListNetwork 

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

func (*ListNetwork) Execute 

func (c *ListNetwork) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListNetwork) Rollback 

func (c *ListNetwork) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListNetwork) String 

func (c *ListNetwork) String() string

String implements the fmt.Stringer interface

type ListOracle 

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

----- Oracle

func (*ListOracle) Execute 

func (c *ListOracle) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListOracle) Rollback 

func (c *ListOracle) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListOracle) String 

func (c *ListOracle) String() string

String implements the fmt.Stringer interface

type ListPostgres 

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

----- Postgres

func (*ListPostgres) Execute 

func (c *ListPostgres) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListPostgres) Rollback 

func (c *ListPostgres) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListPostgres) String 

func (c *ListPostgres) String() string

String implements the fmt.Stringer interface

type ListRedshiftCluster 

type ListRedshiftCluster struct {
	BaseRedshiftCluster
}

func (*ListRedshiftCluster) Execute 

func (c *ListRedshiftCluster) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListRedshiftCluster) Rollback 

func (c *ListRedshiftCluster) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListRedshiftCluster) String 

func (c *ListRedshiftCluster) String() string

String implements the fmt.Stringer interface

type ListRouteTable 

type ListRouteTable struct {
	BaseRouteTable
	// contains filtered or unexported fields
}

func (*ListRouteTable) Execute 

func (c *ListRouteTable) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListRouteTable) Rollback 

func (c *ListRouteTable) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListRouteTable) String 

func (c *ListRouteTable) String() string

String implements the fmt.Stringer interface

type ListSecurityGroup 

type ListSecurityGroup struct {
	BaseSecurityGroup
	// contains filtered or unexported fields
}

func (*ListSecurityGroup) Execute 

func (c *ListSecurityGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListSecurityGroup) Rollback 

func (c *ListSecurityGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListSecurityGroup) String 

func (c *ListSecurityGroup) String() string

String implements the fmt.Stringer interface

type ListServiceIamPolicy 

type ListServiceIamPolicy struct {
	BaseServiceIamPolicy
}

func (*ListServiceIamPolicy) Execute 

func (c *ListServiceIamPolicy) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListServiceIamPolicy) Rollback 

func (c *ListServiceIamPolicy) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListServiceIamPolicy) String 

func (c *ListServiceIamPolicy) String() string

String implements the fmt.Stringer interface

type ListServiceIamRole 

type ListServiceIamRole struct {
	BaseServiceIamRole
}

func (*ListServiceIamRole) Execute 

func (c *ListServiceIamRole) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListServiceIamRole) Rollback 

func (c *ListServiceIamRole) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListServiceIamRole) String 

func (c *ListServiceIamRole) String() string

String implements the fmt.Stringer interface

type ListSubnets 

type ListSubnets struct {
	BaseSubnets
}

func (*ListSubnets) Execute 

func (c *ListSubnets) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListSubnets) Rollback 

func (c *ListSubnets) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListSubnets) String 

func (c *ListSubnets) String() string

String implements the fmt.Stringer interface

type ListTargetGroup 

type ListTargetGroup struct {
	BaseTargetGroup
}

func (*ListTargetGroup) Execute 

func (c *ListTargetGroup) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListTargetGroup) Rollback 

func (c *ListTargetGroup) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListTargetGroup) String 

func (c *ListTargetGroup) String() string

String implements the fmt.Stringer interface

type ListTemplate 

type ListTemplate struct {
	BaseTemplate
}

func (*ListTemplate) Execute 

func (c *ListTemplate) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListTemplate) Rollback 

func (c *ListTemplate) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListTemplate) String 

func (c *ListTemplate) String() string

String implements the fmt.Stringer interface

type ListTiDB2Aurora 

type ListTiDB2Aurora struct {
	User          string
	Host          string
	ArnComponents []ARNComponent
}

func (*ListTiDB2Aurora) Execute 

func (c *ListTiDB2Aurora) Execute(ctx context.Context, clusterName, clusterType, subClusterType string) error

Execute implements the Task interface

func (*ListTiDB2Aurora) Rollback 

func (c *ListTiDB2Aurora) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListTiDB2Aurora) String 

func (c *ListTiDB2Aurora) String() string

String implements the fmt.Stringer interface

type ListTiDBCloud 

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

func (*ListTiDBCloud) Execute 

func (c *ListTiDBCloud) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListTiDBCloud) Rollback 

func (c *ListTiDBCloud) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListTiDBCloud) String 

func (c *ListTiDBCloud) String() string

String implements the fmt.Stringer interface

type ListTiDBCloudImport 

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

func (*ListTiDBCloudImport) Execute 

func (c *ListTiDBCloudImport) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListTiDBCloudImport) Rollback 

func (c *ListTiDBCloudImport) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListTiDBCloudImport) String 

func (c *ListTiDBCloudImport) String() string

String implements the fmt.Stringer interface

type ListTransitGateway 

type ListTransitGateway struct {
	BaseTransitGateway
	// contains filtered or unexported fields
}

func (*ListTransitGateway) Execute 

func (c *ListTransitGateway) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListTransitGateway) Rollback 

func (c *ListTransitGateway) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListTransitGateway) String 

func (c *ListTransitGateway) String() string

String implements the fmt.Stringer interface

type ListTransitGatewayVpcAttachment 

type ListTransitGatewayVpcAttachment struct {
	BaseTransitGatewayVpcAttachment
	// contains filtered or unexported fields
}

func (*ListTransitGatewayVpcAttachment) Execute 

func (c *ListTransitGatewayVpcAttachment) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListTransitGatewayVpcAttachment) Rollback 

func (c *ListTransitGatewayVpcAttachment) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListTransitGatewayVpcAttachment) String 

func (c *ListTransitGatewayVpcAttachment) String() string

String implements the fmt.Stringer interface

type ListVPC 

type ListVPC struct {
	BaseVPC
	// contains filtered or unexported fields
}

func (*ListVPC) Execute 

func (c *ListVPC) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListVPC) Rollback 

func (c *ListVPC) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListVPC) String 

func (c *ListVPC) String() string

String implements the fmt.Stringer interface

type ListVpcEndpoint 

type ListVpcEndpoint struct {
	BaseVpcEndpoint
	// contains filtered or unexported fields
}

func (*ListVpcEndpoint) Execute 

func (c *ListVpcEndpoint) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListVpcEndpoint) Rollback 

func (c *ListVpcEndpoint) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListVpcEndpoint) String 

func (c *ListVpcEndpoint) String() string

String implements the fmt.Stringer interface

type ListVpcPeering 

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

------

func (*ListVpcPeering) Execute 

func (c *ListVpcPeering) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListVpcPeering) Rollback 

func (c *ListVpcPeering) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListVpcPeering) String 

func (c *ListVpcPeering) String() string

String implements the fmt.Stringer interface

type ListWorkerConfiguration 

type ListWorkerConfiguration struct {
	BaseWorkerConfiguration
}

func (*ListWorkerConfiguration) Execute 

func (c *ListWorkerConfiguration) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ListWorkerConfiguration) Rollback 

func (c *ListWorkerConfiguration) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ListWorkerConfiguration) String 

func (c *ListWorkerConfiguration) String() string

String implements the fmt.Stringer interface

type MSKConnectPluginInfo 

type MSKConnectPluginInfo struct {
	ClusterName *string
	Arn         *string
}

type MSKConnectPluginInfos 

type MSKConnectPluginInfos struct {
	BaseResourceInfo
}

func (*MSKConnectPluginInfos) Append 

func (d *MSKConnectPluginInfos) Append(customPluginSummary *types.CustomPluginSummary)

func (*MSKConnectPluginInfos) GetPluginArn 

func (d *MSKConnectPluginInfos) GetPluginArn() (*string, error)

func (*MSKConnectPluginInfos) ToPrintTable 

func (d *MSKConnectPluginInfos) ToPrintTable() *[][]string

type MSKInfo 

type MSKInfo struct {
	ClusterName         string
	KafkaVersion        string
	State               string
	Endpoints           []string
	ClientVpcIpAddress  []string
	NumberOfBrokerNodes int32
	ClusterType         string
}

type MSKInfos 

type MSKInfos struct {
	BaseResourceInfo
}

func (*MSKInfos) GetFirstEndpoint 

func (d *MSKInfos) GetFirstEndpoint() (*string, error)

func (*MSKInfos) GetResourceArn 

func (d *MSKInfos) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*MSKInfos) ToPrintTable 

func (d *MSKInfos) ToPrintTable() *[][]string

type MakeDBObjects 

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

func (*MakeDBObjects) Execute 

func (c *MakeDBObjects) Execute(ctx context.Context) error

Execute implements the Task interface

func (*MakeDBObjects) Rollback 

func (c *MakeDBObjects) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*MakeDBObjects) String 

func (c *MakeDBObjects) String() string

String implements the fmt.Stringer interface

type MakeRole4ExternalAccess 

type MakeRole4ExternalAccess struct {
	BaseWSTask
	// contains filtered or unexported fields
}

func (MakeRole4ExternalAccess) Execute 

func (c MakeRole4ExternalAccess) Execute(ctx context.Context) error

09. Create import role 15. TiDB Data import

type Member 

type Member struct {
	ID   int    `json:"_id"`
	Host string `json:"host"`
}

type MetaTable 

type MetaTable struct {
	DBType      string   `yaml:"DBType"`
	DBName      string   `yaml:"DBName"`
	PK          string   `yaml:"PK"`
	Executor    string   `yaml:"Executor"`
	TailColumns []string `yaml:"TailColumns"`
}

type MetricsOfLatencyWhenBatch 

type MetricsOfLatencyWhenBatch struct {
	TransRow             int64
	TotalExecutionTime   int64
	AverageExecutionTime int64

	BatchExecutionTime int64
	BatchSize          int
	Loop               int
	BatchTotalRows     int64
}

type Mkdir 

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

Mkdir is used to create directory on the target host

func (*Mkdir) Execute 

func (m *Mkdir) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Mkdir) Rollback 

func (m *Mkdir) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Mkdir) String 

func (m *Mkdir) String() string

String implements the fmt.Stringer interface

type MongoInstallPkgTask 

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

*********** The package installation for parallel

func (*MongoInstallPkgTask) Execute 

func (c *MongoInstallPkgTask) Execute(ctx context.Context) error

func (*MongoInstallPkgTask) Rollback 

func (c *MongoInstallPkgTask) Rollback(ctx context.Context) error

func (*MongoInstallPkgTask) String 

func (c *MongoInstallPkgTask) String() string

type MonitoredConfig 

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

MonitoredConfig is used to generate the monitor node configuration

func (*MonitoredConfig) Execute 

func (m *MonitoredConfig) Execute(ctx context.Context) error

Execute implements the Task interface

func (*MonitoredConfig) Rollback 

func (m *MonitoredConfig) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*MonitoredConfig) String 

func (m *MonitoredConfig) String() string

String implements the fmt.Stringer interface

type MskConnectInfo 

type MskConnectInfo struct {
	ClusterName string
}

type MskConnectInfos 

type MskConnectInfos struct {
	BaseResourceInfo
}

func (*MskConnectInfos) GetResourceArn 

func (d *MskConnectInfos) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*MskConnectInfos) ToPrintTable 

func (d *MskConnectInfos) ToPrintTable() *[][]string

type NATGateways 

type NATGateways struct {
	BaseResourceInfo
}

func (*NATGateways) GetResourceArn 

func (d *NATGateways) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*NATGateways) ToPrintTable 

func (d *NATGateways) ToPrintTable() *[][]string

type NLBListeners 

type NLBListeners struct {
	BaseResourceInfo
}

func (*NLBListeners) GetResourceArn 

func (d *NLBListeners) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*NLBListeners) ToPrintTable 

func (d *NLBListeners) ToPrintTable() *[][]string

type NLBs 

type NLBs struct {
	BaseResourceInfo
}

func (*NLBs) GetResourceArn 

func (d *NLBs) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*NLBs) ToPrintTable 

func (d *NLBs) ToPrintTable() *[][]string

type NatGatewayState_Process 

type NatGatewayState_Process types.NatGatewayState

type NetworkType 

type NetworkType string
const (
	NetworkTypeNAT     NetworkType = "nat"
	NetworkTypePublic  NetworkType = "public"
	NetworkTypePrivate NetworkType = "private"
)

type NewDBCluster 

type NewDBCluster struct {
	DBCluster DBCluster `json:"DBCluster"`
}

type NewDBClusterParameterGroup 

type NewDBClusterParameterGroup struct {
	DBClusterParameterGroup DBClusterParameterGroup `json:"DBClusterParameterGroup"`
}

type NewDBInstance 

type NewDBInstance struct {
	DBInstance DBInstance `json:"DBInstance"`
}

type NewDBParameterGroup 

type NewDBParameterGroup struct {
	DBParameterGroup DBParameterGroup `json:"DBParameterGroup"`
}

type NewEC2 

type NewEC2 struct {
	Instances EC2 `json:"Instances"`
}

func (NewEC2) String 

func (e NewEC2) String() string

type NewInternetGateway 

type NewInternetGateway struct {
	InternetGateway InternetGateway `json:"InternetGateway"`
}

func (NewInternetGateway) String 

func (i NewInternetGateway) String() string

type Parallel 

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

Parallel will execute a bundle of task in parallelism way

func (*Parallel) Execute 

func (pt *Parallel) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Parallel) Rollback 

func (pt *Parallel) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Parallel) String 

func (pt *Parallel) String() string

String implements the fmt.Stringer interface

type ParallelStepDisplay 

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

ParallelStepDisplay is a task that will display multiple progress bars in parallel for inner tasks. Inner tasks will be executed in parallel.

func (*ParallelStepDisplay) Execute 

func (ps *ParallelStepDisplay) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ParallelStepDisplay) Rollback 

func (ps *ParallelStepDisplay) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ParallelStepDisplay) String 

func (ps *ParallelStepDisplay) String() string

String implements the fmt.Stringer interface

type PerfTables 

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

func (*PerfTables) Execute 

func (c *PerfTables) Execute(ctx context.Context) error

Execute implements the Task interface

func (*PerfTables) Rollback 

func (c *PerfTables) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*PerfTables) String 

func (c *PerfTables) String() string

String implements the fmt.Stringer interface

type PrepareSysbenchTiCDC 

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

func (*PrepareSysbenchTiCDC) Execute 

func (c *PrepareSysbenchTiCDC) Execute(ctx context.Context) error

Execute implements the Task interface

func (*PrepareSysbenchTiCDC) Rollback 

func (c *PrepareSysbenchTiCDC) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*PrepareSysbenchTiCDC) String 

func (c *PrepareSysbenchTiCDC) String() string

String implements the fmt.Stringer interface

type RDSExportS3Info 

type RDSExportS3Info struct {
	BaseResourceInfo
}

func (*RDSExportS3Info) GetResourceArn 

func (d *RDSExportS3Info) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*RDSExportS3Info) ToPrintTable 

func (d *RDSExportS3Info) ToPrintTable() *[][]string

type RSConfig 

type RSConfig struct {
	ID      string   `json:"_id"`
	Members []Member `json:"members"`
}

type RSStatus 

type RSStatus struct {
	ReplicaSet string `json:"set"`
	MyState    int    `json:"myState"`
	Members    []struct {
		ID       int    `json:"_id"`
		Name     string `json:"name"`
		StateStr string `json:"stateStr"`
	} `json:"members"`
}

type ReadResourceMode 

type ReadResourceMode int
const (
	ReadResourceModeCommon        ReadResourceMode = 0
	ReadResourceModeBeforeCreate  ReadResourceMode = 1
	ReadResourceModeAfterCreate   ReadResourceMode = 2
	ReadResourceModeBeforeDestroy ReadResourceMode = 3
	ReadResourceModeAfterDestroy  ReadResourceMode = 4
)

type RedshiftDBInfos 

type RedshiftDBInfos struct {
	BaseResourceInfo
}

func (*RedshiftDBInfos) GetResourceArn 

func (d *RedshiftDBInfos) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*RedshiftDBInfos) ToPrintTable 

func (d *RedshiftDBInfos) ToPrintTable() *[][]string

type RegionZone 

type RegionZone struct {
	RegionName string `json:"RegionName"`
	ZoneName   string `json:"ZoneName"`
}

type RegisterTarget 

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

func (*RegisterTarget) Execute 

func (c *RegisterTarget) Execute(ctx context.Context) error

Execute implements the Task interface

func (*RegisterTarget) Rollback 

func (c *RegisterTarget) Rollback(ctx context.Context) error

func (*RegisterTarget) String 

func (c *RegisterTarget) String() string

String implements the fmt.Stringer interface

type ReplicationInstance 

type ReplicationInstance struct {
	ReplicationInstanceIdentifier       string `json:"ReplicationInstanceIdentifier"`
	ReplicationInstanceClass            string `json:"ReplicationInstanceClass"`
	ReplicationInstanceStatus           string `json:"ReplicationInstanceStatus"`
	ReplicationInstanceArn              string `json:"ReplicationInstanceArn"`
	ReplicationInstancePrivateIpAddress string `json:"ReplicationInstancePrivateIpAddress"`
}

type ReplicationInstanceRecord 

type ReplicationInstanceRecord struct {
	ReplicationInstance ReplicationInstance `json:"ReplicationInstance"`
}

type ReplicationInstances 

type ReplicationInstances struct {
	ReplicationInstances []ReplicationInstance `json:"ReplicationInstances"`
}

type ReplicationTask 

type ReplicationTask struct {
	ReplicationTaskIdentifier string `json:"ReplicationTaskIdentifier"`
	SourceEndpointArn         string `json:"SourceEndpointArn"`
	TargetEndpointArn         string `json:"TargetEndpointArn"`
	ReplicationInstanceArn    string `json:"ReplicationInstanceArn"`
	MigrationType             string `json:"MigrationType"`
	Status                    string `json:"Status"`
	ReplicationTaskArn        string `json:"ReplicationTaskArn"`
}

type ReplicationTaskRecord 

type ReplicationTaskRecord struct {
	ReplicationTask ReplicationTask `json:"ReplicationTask"`
}

type ReplicationTasks 

type ReplicationTasks struct {
	ReplicationTasks []ReplicationTask `json:"ReplicationTasks"`
}

type RequesterVpcInfo 

type RequesterVpcInfo struct {
	CidrBlock string `json:"CidrBlock"`
	VpcId     string `json:"VpcId"`
}

type Reservations 

type Reservations struct {
	Reservations []EC2s `json:"Reservations"`
}

func ListClusterEc2s 

func ListClusterEc2s(ctx context.Context, pexecutor ctxt.Executor, clusterName string) (*Reservations, error)

func (Reservations) String 

func (e Reservations) String() string

type ResourceData 

type ResourceData interface {
	Reset() error
	Append(interface{})
	ResourceExist() (bool, error)
	ToPrintTable() *[][]string
	GetResourceArn(ThrowErrorFlag) (*string, error)
	GetData() []interface{}

	WriteIntoConfigFile(_fileName string) error
}

type ResourceTag 

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

type ResultRouteTable 

type ResultRouteTable struct {
	TheRouteTable RouteTable `json:"RouteTable"`
}

func (ResultRouteTable) String 

func (r ResultRouteTable) String() string

type Rmdir 

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

Rmdir is used to delete directory on the target host

func (*Rmdir) Execute 

func (r *Rmdir) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Rmdir) Rollback 

func (r *Rmdir) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Rmdir) String 

func (r *Rmdir) String() string

String implements the fmt.Stringer interface

type RootSSH 

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

RootSSH is used to establish a SSH connection to the target host with specific key

func (*RootSSH) Execute 

func (s *RootSSH) Execute(ctx context.Context) error

Execute implements the Task interface

func (*RootSSH) Rollback 

func (s *RootSSH) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (RootSSH) String 

func (s RootSSH) String() string

String implements the fmt.Stringer interface

type Route 

type Route struct {
	DestinationCidrBlock string `json:"DestinationCidrBlock"`
	TransitGatewayId     string `json:"TransitGatewayId"`
	GatewayId            string `json:"GatewayId"`
	Origin               string `json:"Origin"`
	State                string `json:"State"`
}

type RouteTable 

type RouteTable struct {
	RouteTableId string  `json:"RouteTableId"`
	Tags         []Tag   `json:"Tags"`
	Routes       []Route `json:"Routes"`
}

func (RouteTable) String 

func (r RouteTable) String() string

type RouteTables 

type RouteTables struct {
	RouteTables []RouteTable `json:"RouteTables"`
}

func (RouteTables) String 

func (r RouteTables) String() string

type RouteTablesInfo 

type RouteTablesInfo struct {
	BaseResourceInfo
}

func (*RouteTablesInfo) GetResourceArn 

func (d *RouteTablesInfo) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*RouteTablesInfo) GetRouteTableId 

func (d *RouteTablesInfo) GetRouteTableId() (*string, error)

func (*RouteTablesInfo) ToPrintTable 

func (d *RouteTablesInfo) ToPrintTable() *[][]string

type RunCommonWS 

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

Deploy Redshift Instance

func (*RunCommonWS) Execute 

func (c *RunCommonWS) Execute(ctx context.Context) error

Execute implements the Task interface

func (*RunCommonWS) Rollback 

func (c *RunCommonWS) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*RunCommonWS) String 

func (c *RunCommonWS) String() string

String implements the fmt.Stringer interface

type RunOntimeBatchInsert 

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

func (*RunOntimeBatchInsert) Execute 

func (c *RunOntimeBatchInsert) Execute(ctx context.Context) error

Execute implements the Task interface

func (*RunOntimeBatchInsert) Rollback 

func (c *RunOntimeBatchInsert) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*RunOntimeBatchInsert) String 

func (c *RunOntimeBatchInsert) String() string

String implements the fmt.Stringer interface

type RunSysbench 

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

------ ----- ----- RunSysbench

func (*RunSysbench) Execute 

func (c *RunSysbench) Execute(ctx context.Context) error

Execute implements the Task interface

func (*RunSysbench) Rollback 

func (c *RunSysbench) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*RunSysbench) String 

func (c *RunSysbench) String() string

String implements the fmt.Stringer interface

type SSHKeyGen 

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

SSHKeyGen is used to generate SSH key

func (*SSHKeyGen) Execute 

func (s *SSHKeyGen) Execute(ctx context.Context) error

Execute implements the Task interface

func (*SSHKeyGen) Rollback 

func (s *SSHKeyGen) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*SSHKeyGen) String 

func (s *SSHKeyGen) String() string

String implements the fmt.Stringer interface

type SSHKeySet 

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

SSHKeySet is used to set the Context private/public key path

func (*SSHKeySet) Execute 

func (s *SSHKeySet) Execute(ctx context.Context) error

Execute implements the Task interface

func (*SSHKeySet) Rollback 

func (s *SSHKeySet) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*SSHKeySet) String 

func (s *SSHKeySet) String() string

String implements the fmt.Stringer interface

type ScaleConfig 

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

ScaleConfig is used to copy all configurations to the target directory of path

func (*ScaleConfig) Execute 

func (c *ScaleConfig) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ScaleConfig) Rollback 

func (c *ScaleConfig) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ScaleConfig) String 

func (c *ScaleConfig) String() string

String implements the fmt.Stringer interface

type ScaleTiDB 

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

func (*ScaleTiDB) Execute 

func (c *ScaleTiDB) Execute(ctx context.Context) error

Execute implements the Task interface

func (*ScaleTiDB) Rollback 

func (c *ScaleTiDB) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*ScaleTiDB) String 

func (c *ScaleTiDB) String() string

String implements the fmt.Stringer interface

type ScriptParam 

type ScriptParam struct {
	TiDBHost string
	TiDBPort int
	TiDBUser string
	TiDBPass string
	TiDBDB   string

	MySQLHost string
	MySQLPort int
	MySQLUser string
	MySQLPass string
	MySQLDB   string

	MSHost string
	MSPort int
	MSDB   string
	MSUser string
	MSPass string

	NumTables int
	Threads   int
	TableSize int
}

type SecurityGroup 

type SecurityGroup struct {
	GroupId       string          `json:"GroupId"`
	GroupName     string          `json:"GroupName"`
	IpPermissions []IpPermissions `json:"IpPermissions"`
	Tags          []Tag           `json:"Tags"`
}

func (SecurityGroup) String 

func (s SecurityGroup) String() string

type SecurityGroups 

type SecurityGroups struct {
	SecurityGroups []SecurityGroup `json:"SecurityGroups"`
}

func (SecurityGroups) String 

func (i SecurityGroups) String() string

type SecurityGroupsInfo 

type SecurityGroupsInfo struct {
	BaseResourceInfo
}

func (*SecurityGroupsInfo) GetResourceArn 

func (d *SecurityGroupsInfo) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*SecurityGroupsInfo) ToPrintTable 

func (d *SecurityGroupsInfo) ToPrintTable() *[][]string

type Serial 

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

Serial will execute a bundle of task in serialized way

func (*Serial) Execute 

func (s *Serial) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Serial) Rollback 

func (s *Serial) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Serial) String 

func (s *Serial) String() string

String implements the fmt.Stringer interface

type ServiceIamPolicys 

type ServiceIamPolicys struct {
	BaseResourceInfo
}

func (*ServiceIamPolicys) GetResourceArn 

func (d *ServiceIamPolicys) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*ServiceIamPolicys) ToPrintTable 

func (d *ServiceIamPolicys) ToPrintTable() *[][]string

type ServiceIamRoles 

type ServiceIamRoles struct {
	BaseResourceInfo
}

func (*ServiceIamRoles) GetResourceArn 

func (d *ServiceIamRoles) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*ServiceIamRoles) ToPrintTable 

func (d *ServiceIamRoles) ToPrintTable() *[][]string

type Shell 

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

Shell is used to create directory on the target host

func (*Shell) Execute 

func (m *Shell) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Shell) Rollback 

func (m *Shell) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Shell) String 

func (m *Shell) String() string

String implements the fmt.Stringer interface

type StepDisplay 

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

StepDisplay is a task that will display a progress bar for inner task.

func (*StepDisplay) Execute 

func (s *StepDisplay) Execute(ctx context.Context) error

Execute implements the Task interface

func (*StepDisplay) Rollback 

func (s *StepDisplay) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*StepDisplay) SetHidden 

func (s *StepDisplay) SetHidden(h bool) *StepDisplay

SetHidden set step hidden or not.

func (*StepDisplay) String 

func (s *StepDisplay) String() string

String implements the fmt.Stringer interface

type Subnet 

type Subnet struct {
	AvailabilityZone string `json:"AvailabilityZone"`
	CidrBlock        string `json:"CidrBlock"`
	State            string `json:"State"`
	SubnetId         string `json:"SubnetId"`
	VpcId            string `json:"VpcId"`
	Tags             []Tag  `json:"Tags"`
}

func (Subnet) String 

func (s Subnet) String() string

type SubnetResult 

type SubnetResult struct {
	Subnet Subnet `json:"Subnet"`
}

func (SubnetResult) String 

func (r SubnetResult) String() string

type Subnets 

type Subnets struct {
	Subnets []Subnet `json:"Subnets"`
}

func (Subnets) String 

func (s Subnets) String() string

type SubnetsInfo 

type SubnetsInfo struct {
	BaseResourceInfo
}

func (*SubnetsInfo) GetResourceArn 

func (d *SubnetsInfo) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*SubnetsInfo) ToPrintTable 

func (d *SubnetsInfo) ToPrintTable() *[][]string

type SysbenchTiCDC 

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

func (*SysbenchTiCDC) Execute 

func (c *SysbenchTiCDC) Execute(ctx context.Context) error

Execute implements the Task interface

func (*SysbenchTiCDC) Rollback 

func (c *SysbenchTiCDC) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*SysbenchTiCDC) String 

func (c *SysbenchTiCDC) String() string

String implements the fmt.Stringer interface

type Sysctl 

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

Sysctl set a kernel param on host

func (*Sysctl) Execute 

func (s *Sysctl) Execute(ctx context.Context) error

Execute implements the Task interface

func (*Sysctl) Rollback 

func (s *Sysctl) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*Sysctl) String 

func (s *Sysctl) String() string

String implements the fmt.Stringer interface

type SystemCtl 

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

SystemCtl run systemctl command on host

func (*SystemCtl) Execute 

func (c *SystemCtl) Execute(ctx context.Context) error

Execute implements the Task interface

func (*SystemCtl) Rollback 

func (c *SystemCtl) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*SystemCtl) String 

func (c *SystemCtl) String() string

String implements the fmt.Stringer interface

type TLSCert 

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

TLSCert generates a certificate for instance

func (*TLSCert) Execute 

func (c *TLSCert) Execute(ctx context.Context) error

Execute implements the Task interface

func (*TLSCert) Rollback 

func (c *TLSCert) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*TLSCert) String 

func (c *TLSCert) String() string

String implements the fmt.Stringer interface

type Tag 

type Tag struct {
	Key   string `json:"Key"`
	Value string `json:"Value"`
}

type TagDescription 

type TagDescription struct {
	Tags []Tag `json:"Tags"`
}

type TagDescriptions 

type TagDescriptions struct {
	TagDescriptions []TagDescription `json:"TagDescriptions"`
}

type TagList 

type TagList struct {
	TagList []Tag `json:"TagList"`
}

type TargetGroups 

type TargetGroups struct {
	BaseResourceInfo
}

func (*TargetGroups) GetResourceArn 

func (d *TargetGroups) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*TargetGroups) ToPrintTable 

func (d *TargetGroups) ToPrintTable() *[][]string

type Task 

type Task interface {
	fmt.Stringer
	Execute(ctx context.Context) error
	Rollback(ctx context.Context) error
}

Task represents a operation while TiUP execution

type Templates 

type Templates struct {
	BaseResourceInfo
}

func (*Templates) GetResourceArn 

func (d *Templates) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*Templates) ToPrintTable 

func (d *Templates) ToPrintTable() *[][]string

type ThrowErrorFlag 

type ThrowErrorFlag bool
const (
	ThrowErrorIfNotExists ThrowErrorFlag = true
	ContinueIfNotExists   ThrowErrorFlag = false
)

type TiDBClusterComponent 

type TiDBClusterComponent struct {
	Id            string `json:"id"`
	Role          string `json:"role"`
	Host          string `json:"host"`
	Ports         string `json:"ports"`
	OsArch        string `json:"os_arch"`
	Status        string `json:"status"`
	Since         string `json:"since"`
	DataDir       string `json:"data_dir"`
	DeployDir     string `json:"deploy_dir"`
	ComponentName string `json:"ComponentName"`
	Port          int    `json:"Port"`
}

type TiDBClusterDetail 

type TiDBClusterDetail struct {
	TiDBClusterMeta TiDBClusterMeta        `json:"cluster_meta"`
	Instances       []TiDBClusterComponent `json:"instances"`
}

type TiDBClusterDisplay 

type TiDBClusterDisplay struct {
	ClusterMeta struct {
		ClusterType    string `json:"cluster_type"`
		ClusterName    string `json:"cluster_name"`
		ClusterVersion string `json:"cluster_version"`
		DeployUser     string `json:"deploy_user"`
		SshType        string `json:"ssh_type"`
		TlsEnabled     bool   `json:"tls_enabled"`
		DashboardUrl   string `json:"dashboard_url"`
	} `json:"cluster_meta"`
	Instances []TiDBInstanceInfo `json:"instances"`
}

type TiDBClusterInfo 

type TiDBClusterInfo struct {
	Name       string `json:"name"`
	User       string `json:"user"`
	Version    string `json:"version"`
	Path       string `json:"path"`
	PrivateKey string `json:"private_key"`
}

type TiDBClusterInfos 

type TiDBClusterInfos struct {
	TiDBClusterInfos []TiDBClusterInfo `json:"clusters"`
}

type TiDBClusterMeta 

type TiDBClusterMeta struct {
	ClusterType    string `json:"cluster_type"`
	ClusterName    string `json:"cluster_name"`
	ClusterVersion string `json:"cluster_version"`
	DeployUser     string `json:"deploy_user"`
	SshType        string `json:"ssh_type"`
	TlsEnabled     bool   `json:"tls_enabled"`
	DashboardUrl   string `json:"dashboard_url"`
}

type TiDBInstanceInfo 

type TiDBInstanceInfo struct {
	ID            string `json:"id"`
	Role          string `json:"role"`
	Host          string `json:"host"`
	Ports         string `json:"ports"`
	OsArch        string `json:"os_arch"`
	Status        string `json:"status"`
	Memory        string `json:"memory"`
	MemoryLimit   string `json:"memory_limit"`
	CPUQuota      string `json:"cpu_quota"`
	Since         string `json:"since"`
	DataDir       string `json:"data_dir"`
	DeployDir     string `json:"deploy_dir"`
	ComponentName string `json:"ComponentName"`
	Port          int    `json:"Port"`
}

type TplSQLServer 

type TplSQLServer struct {
	Name string
	Host string
	Port int
}

type TplTiKVData 

type TplTiKVData struct {
	IPAddress string
	Labels    []map[string]string
}

type TplTiupData 

type TplTiupData struct {
	PD           []string
	TiDB         []string
	TiFlash      []string
	TiKV         []TplTiKVData
	TiCDC        []string
	DM           []string
	Monitor      []string
	Grafana      []string
	AlertManager []string
	Pump         []string
	Drainer      []string

	Labels []string
}

func (TplTiupData) String 

func (t TplTiupData) String() string

type TransitGateway 

type TransitGateway struct {
	TransitGatewayId  string `json:"TransitGatewayId"`
	TransitGatewayArn string `json:"TransitGatewayArn`
	State             string `json:"State"`
}

****************************************************************************

type TransitGatewayAttachmentState_Process 

type TransitGatewayAttachmentState_Process types.TransitGatewayAttachmentState

type TransitGatewayState_Process 

type TransitGatewayState_Process types.TransitGatewayState

type TransitGatewayVpcAttachments 

type TransitGatewayVpcAttachments struct {
	BaseResourceInfo
}

func (*TransitGatewayVpcAttachments) GetResourceArn 

func (d *TransitGatewayVpcAttachments) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*TransitGatewayVpcAttachments) ToPrintTable 

func (d *TransitGatewayVpcAttachments) ToPrintTable() *[][]string

type TransitGateways 

type TransitGateways struct {
	TransitGateways []TransitGateway `json:"TransitGateways"`
}

type TransitGatewaysInfo 

type TransitGatewaysInfo struct {
	BaseResourceInfo
}

func (*TransitGatewaysInfo) GetResourceArn 

func (d *TransitGatewaysInfo) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*TransitGatewaysInfo) ToPrintTable 

func (d *TransitGatewaysInfo) ToPrintTable() *[][]string

type UpdateMeta 

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

UpdateMeta is used to maintain the cluster meta information

func (*UpdateMeta) Execute 

func (u *UpdateMeta) Execute(ctx context.Context) error

Execute implements the Task interface the metadata especially the topology is in wide use, the other callers point to this field by a pointer, so we should update the original topology directly, and don't make a copy

func (*UpdateMeta) Rollback 

func (u *UpdateMeta) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*UpdateMeta) String 

func (u *UpdateMeta) String() string

String implements the fmt.Stringer interface

type UpdateTopology 

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

UpdateTopology is used to maintain the cluster meta information

func (*UpdateTopology) Execute 

func (u *UpdateTopology) Execute(ctx context.Context) error

Execute implements the Task interface

func (*UpdateTopology) Rollback 

func (u *UpdateTopology) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (*UpdateTopology) String 

func (u *UpdateTopology) String() string

String implements the fmt.Stringer interface

type UserSSH 

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

UserSSH is used to establish a SSH connection to the target host with generated key

func (*UserSSH) Execute 

func (s *UserSSH) Execute(ctx context.Context) error

Execute implements the Task interface

func (*UserSSH) Rollback 

func (s *UserSSH) Rollback(ctx context.Context) error

Rollback implements the Task interface

func (UserSSH) String 

func (s UserSSH) String() string

String implements the fmt.Stringer interface

type VPCPeeringConnection 

type VPCPeeringConnection struct {
	VpcConnectionId  string
	Status           string
	RequesterVpcId   string
	RequesterVpcCIDR string
	AcceptorVpcId    string
	AcceptorVpcCIDR  string
	AcceptorVpcName  string
}

type VPCPeeringStatus 

type VPCPeeringStatus struct {
	Code    string `json:"Code"`
	Message string `json:""Message`
}

type VPCStatus 

type VPCStatus struct {
	Code    string `json:"Code"`
	Message string `json:"Message"`
}

type VPCs 

type VPCs struct {
	BaseResourceInfo
}

func (*VPCs) GetResourceArn 

func (d *VPCs) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*VPCs) ToPrintTable 

func (d *VPCs) ToPrintTable() *[][]string

type Vpc 

type Vpc struct {
	CidrBlock string `json:"CidrBlock"`
	State     string `json:"State"`
	VpcId     string `json:"VpcId"`
	OwnerId   string `json:"OwnerId"`
	Tags      []Tag  `json:"Tags"`
}

func (Vpc) String 

func (v Vpc) String() string

type VpcConnection 

type VpcConnection struct {
	VpcPeeringConnection VpcPeer `json:"VpcPeeringConnection"`
}

type VpcConnections 

type VpcConnections struct {
	VpcPeeringConnections []VpcPeer `json:"VpcPeeringConnections"`
}

type VpcEndpointState_Process 

type VpcEndpointState_Process string

type VpcEndpointsInfo 

type VpcEndpointsInfo struct {
	BaseResourceInfo
}

func (*VpcEndpointsInfo) GetResourceArn 

func (d *VpcEndpointsInfo) GetResourceArn(throwErr ThrowErrorFlag) (*string, error)

func (*VpcEndpointsInfo) ToPrintTable 

func (d *VpcEndpointsInfo) ToPrintTable() *[][]string

type VpcPeer 

type VpcPeer struct {
	VpcPeeringConnectionId string    `json:"VpcPeeringConnectionId"`
	VpcStatus              VPCStatus `json:"Status"`
}

type Vpcs 

type Vpcs struct {
	Vpcs []Vpc `json:"Vpcs"`
}

type WorkerConfigurationInfo 

type WorkerConfigurationInfo struct {
	Name                   *string
	WorkerConfigurationArn *string
	LatestRevision         int64
}

type WorkerConfigurationInfos 

type WorkerConfigurationInfos struct {
	BaseResourceInfo
}

func (*WorkerConfigurationInfos) Append 

func (d *WorkerConfigurationInfos) Append(workerConfiguration *types.WorkerConfigurationSummary)

func (*WorkerConfigurationInfos) GetWorkerConfigurationARN 

func (d *WorkerConfigurationInfos) GetWorkerConfigurationARN() (*string, error)

func (*WorkerConfigurationInfos) IsEmpty 

func (d *WorkerConfigurationInfos) IsEmpty() bool

func (*WorkerConfigurationInfos) ToPrintTable 

func (d *WorkerConfigurationInfos) ToPrintTable() *[][]string

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.