aliyun

package
v0.0.0-...-61a2cff Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AliyunRegionID        = "ALIYUN_REGION_ID"
	AliyunAccessKeyID     = "ALIYUN_ACCESS_KEY_ID"
	AliyunAccessKeySecret = "ALIYUN_ACCESS_KEY_SECRET"
	AliyunResourceGroupID = "ALIYUN_RESOURCE_GROUP_ID"
)
View Source 
const (
	ECSInstanceStatusNameRunning  = "Running"
	ECSInstanceStatusNamePending  = "Pending"
	ECSInstanceStatusNameStarting = "Starting"
	ECSInstanceStatusNameStopping = "Stopping"
	ECSInstanceStatusNameStopped  = "Stopped"
)

Variables

This section is empty.

Functions

func AttachVolume 

func AttachVolume(api ECSCreateVolumeAPI, request *ecs.AttachDiskRequest) (*ecs.AttachDiskResponse, error)

func AuthorizeSecurityGroup 

func AuthorizeSecurityGroup(api ECSCreateInstancesAPI, request *ecs.AuthorizeSecurityGroupRequest) (*ecs.AuthorizeSecurityGroupResponse, error)

func CreateKeyPair 

func CreateKeyPair(api ECSCreateKeyPairAPI, request *ecs.CreateKeyPairRequest) (*ecs.CreateKeyPairResponse, error)

func CreateVolume 

func CreateVolume(api ECSCreateVolumeAPI, request *ecs.CreateDiskRequest) (*ecs.CreateDiskResponse, error)

func DeleteInstances 

func DeleteInstances(api ECSDeleteInstancesAPI, request *ecs.DeleteInstancesRequest) (*ecs.DeleteInstancesResponse, error)

func DeleteKeyPairs 

func DeleteKeyPairs(api ECSDeleteKeyPairAPI, request *ecs.DeleteKeyPairsRequest) (*ecs.DeleteKeyPairsResponse, error)

func DeleteSecurityGroup 

func DeleteSecurityGroup(api ECSDeleteInstancesAPI, request *ecs.DeleteSecurityGroupRequest) (*ecs.DeleteSecurityGroupResponse, error)

func DeleteVPC 

func DeleteVPC(api ECSDeleteInstancesAPI, request *ecs.DeleteVpcRequest) (*ecs.DeleteVpcResponse, error)

func DeleteVSwitch 

func DeleteVSwitch(api ECSDeleteInstancesAPI, request *ecs.DeleteVSwitchRequest) (*ecs.DeleteVSwitchResponse, error)

func DeleteVolume 

func DeleteVolume(api ECSDeleteVolumeAPI, request *ecs.DeleteDiskRequest) (*ecs.DeleteDiskResponse, error)

func DetachKeyPair 

func DetachKeyPair(api ECSDeleteInstancesAPI, request *ecs.DetachKeyPairRequest) (*ecs.DetachKeyPairResponse, error)

func DetachVolume 

func DetachVolume(api ECSDeleteVolumeAPI, request *ecs.DetachDiskRequest) (*ecs.DetachDiskResponse, error)

func GetDisks 

func GetDisks(api ECSDescribeInstancesAPI, request *ecs.DescribeDisksRequest) (*ecs.DescribeDisksResponse, error)

func GetImages 

func GetImages(api ECSDescribeInstancesAPI, request *ecs.DescribeImagesRequest) (*ecs.DescribeImagesResponse, error)

func GetInstances 

func GetInstances(api ECSDescribeInstancesAPI, request *ecs.DescribeInstancesRequest) (*ecs.DescribeInstancesResponse, error)

func GetSecurityGroups 

func GetSecurityGroups(api ECSCreateInstancesAPI, request *ecs.DescribeSecurityGroupsRequest) (*ecs.DescribeSecurityGroupsResponse, error)

func GetVSwitches 

func GetVSwitches(api VPCCreateAPI, request *vpc.DescribeVSwitchesRequest) (*vpc.DescribeVSwitchesResponse, error)

func GetVpcs 

func GetVpcs(api VPCCreateAPI, request *vpc.DescribeVpcsRequest) (*vpc.DescribeVpcsResponse, error)

func MakeInstances 

func MakeInstances(api ECSCreateInstancesAPI, request *ecs.RunInstancesRequest) (*ecs.RunInstancesResponse, error)

func MakeSecurityGroup 

func MakeSecurityGroup(api ECSCreateInstancesAPI, request *ecs.CreateSecurityGroupRequest) (*ecs.CreateSecurityGroupResponse, error)

func MakeTags 

func MakeTags(api ECSCreateInstancesAPI, request *ecs.TagResourcesRequest) (*ecs.TagResourcesResponse, error)

func MakeVPC 

func MakeVPC(api VPCCreateAPI, request *vpc.CreateVpcRequest) (*vpc.CreateVpcResponse, error)

func MakeVSwitch 

func MakeVSwitch(api VPCCreateAPI, request *vpc.CreateVSwitchRequest) (*vpc.CreateVSwitchResponse, error)

func ModifyInstanceSpec 

func ModifyInstanceSpec(api ECSModifyInstancesAPI, request *ecs.ModifyInstanceSpecRequest) (*ecs.ModifyInstanceSpecResponse, error)

func ModifyVolumeSize 

func ModifyVolumeSize(api ECSModifyVolumeAPI, request *ecs.ResizeDiskRequest) (*ecs.ResizeDiskResponse, error)

func ModifyVolumeSpec 

func ModifyVolumeSpec(api ECSModifyVolumeAPI, request *ecs.ModifyDiskSpecRequest) (*ecs.ModifyDiskSpecResponse, error)

func StartInstances 

func StartInstances(api ECSModifyInstancesAPI, request *ecs.StartInstancesRequest) (*ecs.StartInstancesResponse, error)

func StopInstances 

func StopInstances(api ECSStopInstancesAPI, request *ecs.StopInstancesRequest) (*ecs.StopInstancesResponse, error)

func TagResources 

func TagResources(api ECSDescribeInstancesAPI, request *ecs.TagResourcesRequest) (*ecs.TagResourcesResponse, error)

Types

type Driver 

type Driver struct {
	ECSClient       *ecs.Client
	VPCClient       *vpc.Client
	ResourceGroupID string
}

func (Driver) CreateInstances 

func (d Driver) CreateInstances(hosts *v1.Hosts, infra *v1.Infra) error

func (Driver) CreateKeyPair 

func (d Driver) CreateKeyPair(infra *v1.Infra) error

func (Driver) CreateVolumes 

func (d Driver) CreateVolumes(infra *v1.Infra, host *v1.Hosts, disks []v1.Disk) error

func (Driver) DeleteInfra 

func (d Driver) DeleteInfra(infra *v1.Infra) error

func (Driver) DeleteInstanceByID 

func (d Driver) DeleteInstanceByID(_ string, _ *v1.Infra) error

func (Driver) DeleteInstances 

func (d Driver) DeleteInstances(hosts *v1.Hosts) error

func (Driver) DeleteKeyPair 

func (d Driver) DeleteKeyPair(infra *v1.Infra) error

func (Driver) DeleteVolume 

func (d Driver) DeleteVolume(disksID []string) error

func (Driver) GetInstances 

func (d Driver) GetInstances(infra *v1.Infra, status string) ([]v1.Hosts, error)

func (Driver) GetInstancesByLabel 

func (d Driver) GetInstancesByLabel(key string, value string, infra *v1.Infra) (*v1.Hosts, error)

func (Driver) ModifyInstances 

func (d Driver) ModifyInstances(curHosts *v1.Hosts, desHosts *v1.Hosts) error

func (Driver) ModifyVolume 

func (d Driver) ModifyVolume(curDisk *v1.Disk, desDisk *v1.Disk) error

func (Driver) StopInstances 

func (d Driver) StopInstances(hosts *v1.Hosts) error

type ECSCreateInstancesAPI 

type ECSCreateInstancesAPI interface {
	RunInstances(request *ecs.RunInstancesRequest) (response *ecs.RunInstancesResponse, err error)
	TagResources(requests *ecs.TagResourcesRequest) (response *ecs.TagResourcesResponse, err error)
	CreateSecurityGroup(request *ecs.CreateSecurityGroupRequest) (response *ecs.CreateSecurityGroupResponse, err error)
	DescribeSecurityGroups(request *ecs.DescribeSecurityGroupsRequest) (response *ecs.DescribeSecurityGroupsResponse, err error)
	AuthorizeSecurityGroup(request *ecs.AuthorizeSecurityGroupRequest) (response *ecs.AuthorizeSecurityGroupResponse, err error)
}

type ECSCreateKeyPairAPI 

type ECSCreateKeyPairAPI interface {
	CreateKeyPair(request *ecs.CreateKeyPairRequest) (response *ecs.CreateKeyPairResponse, err error)
}

type ECSCreateVolumeAPI 

type ECSCreateVolumeAPI interface {
	CreateDisk(request *ecs.CreateDiskRequest) (response *ecs.CreateDiskResponse, err error)
	AttachDisk(request *ecs.AttachDiskRequest) (response *ecs.AttachDiskResponse, err error)
}

type ECSDeleteInstancesAPI 

type ECSDeleteInstancesAPI interface {
	DeleteInstances(request *ecs.DeleteInstancesRequest) (response *ecs.DeleteInstancesResponse, err error)
	DeleteSecurityGroup(request *ecs.DeleteSecurityGroupRequest) (response *ecs.DeleteSecurityGroupResponse, err error)
	DeleteVSwitch(request *ecs.DeleteVSwitchRequest) (response *ecs.DeleteVSwitchResponse, err error)
	DeleteVpc(request *ecs.DeleteVpcRequest) (response *ecs.DeleteVpcResponse, err error)
	DetachKeyPair(request *ecs.DetachKeyPairRequest) (response *ecs.DetachKeyPairResponse, err error)
}

type ECSDeleteKeyPairAPI 

type ECSDeleteKeyPairAPI interface {
	DeleteKeyPairs(request *ecs.DeleteKeyPairsRequest) (response *ecs.DeleteKeyPairsResponse, err error)
}

type ECSDeleteVolumeAPI 

type ECSDeleteVolumeAPI interface {
	DeleteDisk(request *ecs.DeleteDiskRequest) (response *ecs.DeleteDiskResponse, err error)
	DetachDisk(request *ecs.DetachDiskRequest) (response *ecs.DetachDiskResponse, err error)
}

type ECSDescribeInstancesAPI 

type ECSDescribeInstancesAPI interface {
	DescribeInstances(request *ecs.DescribeInstancesRequest) (response *ecs.DescribeInstancesResponse, err error)
	DescribeDisks(request *ecs.DescribeDisksRequest) (response *ecs.DescribeDisksResponse, err error)
	DescribeImages(request *ecs.DescribeImagesRequest) (response *ecs.DescribeImagesResponse, err error)
	DescribeInstanceStatus(request *ecs.DescribeInstanceStatusRequest) (response *ecs.DescribeInstanceStatusResponse, err error)
	TagResources(request *ecs.TagResourcesRequest) (response *ecs.TagResourcesResponse, err error)
}

type ECSModifyInstancesAPI 

type ECSModifyInstancesAPI interface {
	ModifyInstanceSpec(request *ecs.ModifyInstanceSpecRequest) (response *ecs.ModifyInstanceSpecResponse, err error)
	StartInstances(request *ecs.StartInstancesRequest) (response *ecs.StartInstancesResponse, err error)
}

type ECSModifyVolumeAPI 

type ECSModifyVolumeAPI interface {
	ModifyDiskSpec(request *ecs.ModifyDiskSpecRequest) (response *ecs.ModifyDiskSpecResponse, err error)
	ResizeDisk(request *ecs.ResizeDiskRequest) (response *ecs.ResizeDiskResponse, err error)
}

type ECSStopInstancesAPI 

type ECSStopInstancesAPI interface {
	StopInstances(request *ecs.StopInstancesRequest) (response *ecs.StopInstancesResponse, err error)
}

type VPCCreateAPI 

type VPCCreateAPI interface {
	CreateVpc(request *vpc.CreateVpcRequest) (response *vpc.CreateVpcResponse, err error)
	CreateVSwitch(request *vpc.CreateVSwitchRequest) (response *vpc.CreateVSwitchResponse, err error)
	DescribeVpcs(request *vpc.DescribeVpcsRequest) (response *vpc.DescribeVpcsResponse, err error)
	DescribeVSwitches(request *vpc.DescribeVSwitchesRequest) (response *vpc.DescribeVSwitchesResponse, err error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.