alicloud

package
v46.0.0+incompatible Latest Latest
Warning

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

 Go to latest Published: May 22, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

* Copyright (C) 2017-2019 Alibaba Group Holding Limited

Index

Constants

View Source 
const (
	TagResourceImage    = TagResourceType("image")
	TagResourceInstance = TagResourceType("instance")
	TagResourceSnapshot = TagResourceType("snapshot")
	TagResourceDisk     = TagResourceType("disk")
)
View Source 
const (
	Creating = InstanceStatus("Creating") // For backward compatibility
	Pending  = InstanceStatus("Pending")
	Running  = InstanceStatus("Running")
	Starting = InstanceStatus("Starting")

	Stopped  = InstanceStatus("Stopped")
	Stopping = InstanceStatus("Stopping")
	Deleted  = InstanceStatus("Deleted")
)

Constants of InstanceStatus

View Source 
const (
	EipStatusAssociating   = EipStatus("Associating")
	EipStatusUnassociating = EipStatus("Unassociating")
	EipStatusInUse         = EipStatus("InUse")
	EipStatusAvailable     = EipStatus("Available")
)
View Source 
const (
	DiskStatusInUse     = DiskStatus("In_use")
	DiskStatusAvailable = DiskStatus("Available")
	DiskStatusAttaching = DiskStatus("Attaching")
	DiskStatusDetaching = DiskStatus("Detaching")
	DiskStatusCreating  = DiskStatus("Creating")
	DiskStatusReIniting = DiskStatus("ReIniting")
	DiskStatusAll       = DiskStatus("All") //Default
)
View Source 
const (
	DiskCategoryAll             = DiskCategory("all") //Default
	DiskCategoryCloud           = DiskCategory("cloud")
	DiskCategoryEphemeral       = DiskCategory("ephemeral")
	DiskCategoryEphemeralSSD    = DiskCategory("ephemeral_ssd")
	DiskCategoryCloudEfficiency = DiskCategory("cloud_efficiency")
	DiskCategoryCloudSSD        = DiskCategory("cloud_ssd")
)
View Source 
const (
	NoSpot             = SpotStrategyType("NoSpot")
	SpotWithPriceLimit = SpotStrategyType("SpotWithPriceLimit")
	SpotAsPriceGo      = SpotStrategyType("SpotAsPriceGo")
)

Constants of SpotStrategyType

View Source 
const (
	RAW = ImageFormatType("RAW")
	VHD = ImageFormatType("VHD")
)
View Source 
const (
	UseForceStop = true

	WaitTimeout  = time.Duration(600) * time.Second
	WaitInterval = time.Duration(5) * time.Second

	DefaultEipWaitSeconds       = 120
	DefaultSlbWeight            = 100
	BoshCPI                     = "Bosh-Alicloud-Cpi"
	BoshCPIVersion              = "1.0"
	DefaultSlbServerGroupPort   = 33333
	DefaultSlbServerGroupWeight = 100
)
View Source 
const (
	ChangeDiskStatusTimeout       = time.Duration(300) * time.Second
	ChangeDiskStatusSleepInterval = time.Duration(5) * time.Second
)
View Source 
const (
	// common
	NotFound       = "NotFound"
	WaitForTimeout = "WaitForTimeout"
	// ecs
	InstanceNotFound        = "Instance.Notfound"
	RamInstanceNotFound     = "Forbidden.InstanceNotFound"
	MessageInstanceNotFound = "instance is not found"
	//stemcell
	ImageIsImporting = "ImageIsImporting"
)
View Source 
const (
	ChangeInstanceStatusTimeout       = time.Duration(600) * time.Second
	ChangeInstanceStatusSleepInterval = time.Duration(5) * time.Second
)
View Source 
const (
	AlicloudImageServiceTag          = "AlicloudImageService"
	AlicloudDefaultImageName         = "bosh-stemcell"
	AlicloudDefaultImageArchitecture = "x86_64"
	AlicloudDefaultImageOSType       = "linux"
	WaitForImageReadyTimeout         = 3600
	DefaultWaitForImageReadyTimeout  = 1800
	DefaultWaitForInterval           = 10
)
View Source 
const (
	AlicloudOssServiceTag = "AlicloudOssService"
)

Variables

View Source 
var CreateInstanceCatcher_IdempotentProcessing = Catcher{"IdempotentProcessing", 15, 5}
View Source 
var CreateInstanceCatcher_IpUsed = Catcher{"InvalidPrivateIpAddress.Duplicated", 30, 10}
View Source 
var CreateInstanceCatcher_IpUsed2 = Catcher{"InvalidIPAddress.AlreadyUsed", 30, 10}
View Source 
var CreateInstanceCatcher_TokenProcessing = Catcher{"LastTokenProcessing", 15, 5}
View Source 
var DeleteDiskCatcher = Catcher{"IncorrectDiskStatus.Initializing", 10, 15}
View Source 
var DeleteInstanceCatcher = Catcher{"IncorrectInstanceStatus.Initializing", 20, 15}
View Source 
var EcsInstanceNotFound = []string{"Instance.Notfound", "InvalidInstanceId.NotFound"}
View Source 
var IncorrectInstanceStatusCatcher = Catcher{"IncorrectInstanceStatus", 30, 10}
View Source 
var InstanceInvalidOperationConflictCatcher = Catcher{"InvalidOperation.Conflict", 20, 10}
View Source 
var InternalErrorCatcher = Catcher{"InternalError", 60, 5}
View Source 
var NetworkInterfaceInvalidOperationInvalidEniStateCacher = Catcher{"InvalidOperation.InvalidEniState", 60, 5}
View Source 
var OperationConflictCatcher = Catcher{"OperationConflict", 60, 5}
View Source 
var ResourceNotFound = []string{"InvalidResourceId.NotFound"}
View Source 
var ServiceBusyCatcher = Catcher{"ServiceUnavailable", 60, 5}

Functions

func AmendDiskPath 

func AmendDiskPath(path string, category DiskCategory) string

func DescribeDisks 

func DescribeDisks(client *ecs.Client, diskId string) (disk *ecs.Disk, err error)

func GetNotFoundErrorFromString 

func GetNotFoundErrorFromString(str string) error

func GetNotFoundMessage 

func GetNotFoundMessage(product, id string) string

func GetTimeErrorFromString 

func GetTimeErrorFromString(str string) error

func GetTimeoutMessage 

func GetTimeoutMessage(product, status string) string

func IsExceptedErrors 

func IsExceptedErrors(err error, expectCodes []string) bool

func NotFoundError 

func NotFoundError(err error) bool

func StringPointer 

func StringPointer(s string) *string

Types

type AgentConfig 

type AgentConfig struct {
	Ntp       []string        `json:"ntp"`
	Mbus      string          `json:"mbus"`
	Blobstore BlobstoreConfig `json:"blobstore"`
}

type BackendServerType 

type BackendServerType struct {
	ServerId string
	Weight   int
}

type BlobstoreConfig 

type BlobstoreConfig struct {
	Provider string                 `json:"provider"`
	Options  map[string]interface{} `json:"options"`
}

func (BlobstoreConfig) AsRegistrySettings 

func (a BlobstoreConfig) AsRegistrySettings() registry.BlobstoreSettings

type Catcher 

type Catcher struct {
	Reason           string
	RetryCount       int
	RetryWaitSeconds int
}

type CloudConfig 

type CloudConfig struct {
	Plugin     string `json:"plugin"`
	Properties Config `json:"properties"`
}

type CloudConfigJson 

type CloudConfigJson struct {
	Root CloudConfig `json:"cloud"`
}

type Config 

type Config struct {
	OpenApi  OpenApi        `json:"alicloud"`
	Registry RegistryConfig `json:"registry"`
	Agent    AgentConfig    `json:"agent"`
}

func NewConfigFromBytes 

func NewConfigFromBytes(bytes []byte) (Config, error)

func NewConfigFromFile 

func NewConfigFromFile(configFile string, fs boshsys.FileSystem) (Config, error)

func (Config) EcsTeaClient 

func (c Config) EcsTeaClient(region string) (*rpc.Client, error)

func (Config) GetCrossRegions 

func (c Config) GetCrossRegions() (regions []string, err error)

func (Config) GetHttpRegistryClient 

func (c Config) GetHttpRegistryClient(logger boshlog.Logger) registry.Client

func (Config) GetInstanceRegion 

func (c Config) GetInstanceRegion(instanceId string) (region string, err error)

func (Config) GetRegistryClient 

func (c Config) GetRegistryClient(logger boshlog.Logger) RegistryManager

func (Config) NewEcsClient 

func (c Config) NewEcsClient(region string) (*ecs.Client, error)

func (Config) NewOssClient 

func (c Config) NewOssClient(region string) (*oss.Client, error)

func (Config) NewSlbClient 

func (c Config) NewSlbClient(region string) (*slb.Client, error)

func (Config) Validate 

func (c Config) Validate() error

type DiskCategory 

type DiskCategory string

type DiskManager 

type DiskManager interface {
	GetDisks(instCid string) ([]ecs.Disk, error)
	GetDisk(diskCid string) (*ecs.Disk, error)

	CreateDisk(region string, args *ecs.CreateDiskRequest) (string, error)
	DeleteDisk(diskCid string) error

	AttachDisk(instCid, diskCid string) error
	DetachDisk(instCid, diskCid string) error

	ResizeDisk(diskCid string, sizeGB int) error
	ModifyDiskAttribute(diskCid, name, description string) error

	CreateSnapshot(diskCid string, snapshotName string) (string, error)
	DeleteSnapshot(snapshotCid string) error

	WaitForDiskStatus(diskCid string, toStatus DiskStatus) (string, error)
	ChangeDiskStatus(cid string, toStatus DiskStatus, checkFunc func(*ecs.Disk) (bool, error)) error

	GetDiskPath(path, diskId, instanceType string, category DiskCategory) string
}

func NewDiskManager 

func NewDiskManager(config Config, logger boshlog.Logger) DiskManager

type DiskManagerImpl 

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

func (DiskManagerImpl) AttachDisk 

func (a DiskManagerImpl) AttachDisk(instCid string, diskCid string) error

func (DiskManagerImpl) ChangeDiskStatus 

func (a DiskManagerImpl) ChangeDiskStatus(cid string, toStatus DiskStatus, checkFunc func(*ecs.Disk) (bool, error)) error

func (DiskManagerImpl) CreateDisk 

func (a DiskManagerImpl) CreateDisk(region string, args *ecs.CreateDiskRequest) (cid string, err error)

func (DiskManagerImpl) CreateSnapshot 

func (a DiskManagerImpl) CreateSnapshot(diskCid, snapshotName string) (snapshotId string, err error)

func (DiskManagerImpl) DeleteDisk 

func (a DiskManagerImpl) DeleteDisk(diskCid string) error

func (DiskManagerImpl) DeleteSnapshot 

func (a DiskManagerImpl) DeleteSnapshot(snapshotCid string) error

func (DiskManagerImpl) DetachDisk 

func (a DiskManagerImpl) DetachDisk(instCid, diskCid string) error

func (DiskManagerImpl) GetDisk 

func (a DiskManagerImpl) GetDisk(diskCid string) (disk *ecs.Disk, err error)

func (DiskManagerImpl) GetDiskPath 

func (a DiskManagerImpl) GetDiskPath(path, diskId, instanceType string, category DiskCategory) string

func (DiskManagerImpl) GetDisks 

func (a DiskManagerImpl) GetDisks(instCid string) (disks []ecs.Disk, err error)

func (DiskManagerImpl) ModifyDiskAttribute 

func (a DiskManagerImpl) ModifyDiskAttribute(diskCid, name, description string) error

func (DiskManagerImpl) ResizeDisk 

func (a DiskManagerImpl) ResizeDisk(diskCid string, size int) error

func (DiskManagerImpl) WaitForDiskStatus 

func (a DiskManagerImpl) WaitForDiskStatus(diskCid string, toStatus DiskStatus) (string, error)

type DiskStatus 

type DiskStatus string

type EipStatus 

type EipStatus string

type ImageFormatType 

type ImageFormatType string

type InnerType 

type InnerType string

type InstanceManager 

type InstanceManager interface {
	GetInstance(cid string) (*ecs.Instance, error)

	CreateInstance(region string, request map[string]interface{}) (string, error)
	ModifyInstanceAttribute(cid string, name string, description string) error
	AddTags(cid string, tags map[string]string) error

	DeleteInstance(cid string) error

	StartInstance(cid string) error
	StopInstance(cid string) error
	RebootInstance(cid string) error

	GetInstanceStatus(cid string) (InstanceStatus, error)

	// WaitForInstanceStatus(cid string, toStatus ecs.InstanceStatus) (ecs.InstanceStatus, error)
	ChangeInstanceStatus(cid string, toStatus InstanceStatus, checkFunc func(status InstanceStatus) (bool, error)) error

	// Cleanup the left network interfaces
	GetAttachedNetworkInterfaceIds(cid string) []string
	CleanupInstanceNetworkInterfaces(cid string, eniIds []string) error
}

func NewInstanceManager 

func NewInstanceManager(config Config, logger boshlog.Logger) InstanceManager

type InstanceManagerImpl 

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

func (InstanceManagerImpl) AddTags 

func (a InstanceManagerImpl) AddTags(cid string, tags map[string]string) error

func (InstanceManagerImpl) ChangeInstanceStatus 

func (a InstanceManagerImpl) ChangeInstanceStatus(cid string, toStatus InstanceStatus, checkFunc func(status InstanceStatus) (bool, error)) error

func (InstanceManagerImpl) CleanupInstanceNetworkInterfaces 

func (a InstanceManagerImpl) CleanupInstanceNetworkInterfaces(cid string, eniIds []string) error

func (InstanceManagerImpl) CreateInstance 

func (a InstanceManagerImpl) CreateInstance(region string, request map[string]interface{}) (string, error)

func (InstanceManagerImpl) DeleteInstance 

func (a InstanceManagerImpl) DeleteInstance(cid string) error

func (InstanceManagerImpl) GetAttachedNetworkInterfaceIds 

func (a InstanceManagerImpl) GetAttachedNetworkInterfaceIds(cid string) []string

func (InstanceManagerImpl) GetInstance 

func (a InstanceManagerImpl) GetInstance(cid string) (inst *ecs.Instance, err error)

func (InstanceManagerImpl) GetInstanceStatus 

func (a InstanceManagerImpl) GetInstanceStatus(cid string) (InstanceStatus, error)

func (InstanceManagerImpl) GetInstanceUserData 

func (a InstanceManagerImpl) GetInstanceUserData()

func (InstanceManagerImpl) ModifyInstanceAttribute 

func (a InstanceManagerImpl) ModifyInstanceAttribute(cid, name, description string) error

func (InstanceManagerImpl) RebootInstance 

func (a InstanceManagerImpl) RebootInstance(cid string) error

func (InstanceManagerImpl) StartInstance 

func (a InstanceManagerImpl) StartInstance(cid string) error

func (InstanceManagerImpl) StopInstance 

func (a InstanceManagerImpl) StopInstance(cid string) error

type InstanceStatus 

type InstanceStatus string

type Invoker 

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

func NewInvoker 

func NewInvoker() Invoker

func (*Invoker) AddCatcher 

func (a *Invoker) AddCatcher(catcher Catcher)

func (*Invoker) Run 

func (a *Invoker) Run(f func() error) error

func (*Invoker) RunUntil 

func (a *Invoker) RunUntil(timeout time.Duration, interval time.Duration, f func() (bool, error)) (bool, error)

type NetworkManager 

type NetworkManager interface {
	DescribeEip(region, eip string) (ecs.EipAddressInDescribeEipAddresses, error)
	BindEip(region, instanceId, eip string) error
	WaitForEipStatus(region, eip string, toStatus EipStatus) error

	BindSLB(region, instanceId, slbId string, weight int) error
	BindSlbServerGroup(region, instanceId, slbId string, weight int, port int) error
	DescribeSecurityGroupAttribute(region, groupId string) (ecs.DescribeSecurityGroupAttributeResponse, error)
	JoinSecurityGroup(region, instanceId, groupId string) error
}

func NewNetworkManager 

func NewNetworkManager(config Config, logger boshlog.Logger) NetworkManager

type NetworkManagerImpl 

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

func (NetworkManagerImpl) BindEip 

func (a NetworkManagerImpl) BindEip(region, instanceId, eip string) error

func (NetworkManagerImpl) BindSLB 

func (a NetworkManagerImpl) BindSLB(region, instanceId string, slbId string, weight int) error

TODO: add retry

func (NetworkManagerImpl) BindSlbServerGroup 

func (a NetworkManagerImpl) BindSlbServerGroup(region, instanceId string, slbServerGroupId string, weight int, port int) error

func (NetworkManagerImpl) DescribeEip 

func (a NetworkManagerImpl) DescribeEip(region, eip string) (eipAddress ecs.EipAddressInDescribeEipAddresses, err error)

func (NetworkManagerImpl) DescribeSecurityGroupAttribute 

func (a NetworkManagerImpl) DescribeSecurityGroupAttribute(region, groupId string) (group ecs.DescribeSecurityGroupAttributeResponse, err error)

func (NetworkManagerImpl) JoinSecurityGroup 

func (a NetworkManagerImpl) JoinSecurityGroup(region, instanceId, groupId string) error

func (NetworkManagerImpl) WaitForEipStatus 

func (a NetworkManagerImpl) WaitForEipStatus(region, eip string, toStatus EipStatus) error

type OpenApi 

type OpenApi struct {
	Region           string `json:"region"`
	AvailabilityZone string `json:"availability_zone"`
	AccessEndpoint   string `json:"access_endpoint"`
	AccessKeyId      string `json:"access_key_id"`
	AccessKeySecret  string `json:"access_key_secret"`
	SecurityToken    string `json:"security_token"`
	Encrypted        *bool  `json:"encrypted,omitempty"`
	KmsKeyId         string `json:"kms_key_id"`
	EcsEndpoint      string `json:"ecs_endpoint"`
	SlbEndpoint      string `json:"slb_endpoint"`
	OssEndpoint      string `json:"oss_endpoint"`
	LocationEndpoint string `json:"location_endpoint"`
}

func (OpenApi) GetAvailabilityZone 

func (a OpenApi) GetAvailabilityZone() string

func (OpenApi) GetRegion 

func (a OpenApi) GetRegion(region string) string

type OssManager 

type OssManager interface {
	CreateBucket(name string, options ...oss.Option) error
	DeleteBucket(name string) error
	GetBucket(name string) (bucket *oss.Bucket, err error)
	UploadFile(bucket oss.Bucket, objectKey, filePath string, partSize int64, options ...oss.Option) error
	MultipartUploadFile(bucket oss.Bucket, objectKey, filePath string, partSize int64, options ...oss.Option) error
	DeleteObject(bucket oss.Bucket, name string) error
}

func NewOssManager 

func NewOssManager(config Config, logger boshlog.Logger) OssManager

type OssManagerImpl 

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

func (OssManagerImpl) CreateBucket 

func (a OssManagerImpl) CreateBucket(name string, options ...oss.Option) error

func (OssManagerImpl) DeleteBucket 

func (a OssManagerImpl) DeleteBucket(name string) error

func (OssManagerImpl) DeleteObject 

func (a OssManagerImpl) DeleteObject(bucket oss.Bucket, name string) error

func (OssManagerImpl) GetBucket 

func (a OssManagerImpl) GetBucket(name string) (bucket *oss.Bucket, err error)

func (OssManagerImpl) MultipartUploadFile 

func (a OssManagerImpl) MultipartUploadFile(
	bucket oss.Bucket, objectKey, filePath string, partSize int64, options ...oss.Option) error

func (OssManagerImpl) UploadFile 

func (a OssManagerImpl) UploadFile(
	bucket oss.Bucket, objectKey, filePath string, partSize int64, options ...oss.Option) error

type ProviderError 

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

An Error represents a custom error for Terraform failure response

func (*ProviderError) Error 

func (e *ProviderError) Error() string

func (*ProviderError) ErrorCode 

func (err *ProviderError) ErrorCode() string

func (*ProviderError) Message 

func (err *ProviderError) Message() string

type RegistryConfig 

type RegistryConfig struct {
	User     string      `json:"user"`
	Password string      `json:"password"`
	Protocol string      `json:"protocol"`
	Host     string      `json:"host"`
	Port     json.Number `json:"port"`
}

func (RegistryConfig) GetEndpoint 

func (a RegistryConfig) GetEndpoint() string

func (RegistryConfig) IsEmpty 

func (a RegistryConfig) IsEmpty() bool

func (RegistryConfig) ToInstanceUserData 

func (a RegistryConfig) ToInstanceUserData() string

type RegistryManager 

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

func NewRegistryManager 

func NewRegistryManager(c Config, logger boshlog.Logger) RegistryManager

func (RegistryManager) Delete 

func (a RegistryManager) Delete(instanceID string) error

func (RegistryManager) Fetch 

func (a RegistryManager) Fetch(instanceID string) (registry.AgentSettings, error)

func (RegistryManager) Update 

func (a RegistryManager) Update(instanceID string, settings registry.AgentSettings) error

type SlbServerGroupBackendServerType 

type SlbServerGroupBackendServerType struct {
	ServerId string
	Weight   int
	Port     int
}

type SpotStrategyType 

type SpotStrategyType string

type StemcellManager 

type StemcellManager interface {
	FindStemcellById(id string) (*ecs.Image, error)
	DeleteStemcell(id string) error
	ImportImage(args *ecs.ImportImageRequest) (string, error)
	CopyImage(args *ecs.CopyImageRequest) (string, error)
	OpenLocalFile(path string) (*os.File, error)
	WaitForImageReady(id string) error
}

func NewStemcellManager 

func NewStemcellManager(config Config, logger boshlog.Logger) StemcellManager

type StemcellManagerImpl 

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

func (StemcellManagerImpl) CopyImage 

func (a StemcellManagerImpl) CopyImage(args *ecs.CopyImageRequest) (string, error)

func (StemcellManagerImpl) DeleteStemcell 

func (a StemcellManagerImpl) DeleteStemcell(id string) error

func (StemcellManagerImpl) FindStemcellById 

func (a StemcellManagerImpl) FindStemcellById(id string) (*ecs.Image, error)

func (StemcellManagerImpl) FindStemcellByName 

func (a StemcellManagerImpl) FindStemcellByName(name string) (*ecs.Image, error)

func (StemcellManagerImpl) ImportImage 

func (a StemcellManagerImpl) ImportImage(args *ecs.ImportImageRequest) (string, error)

func (StemcellManagerImpl) OpenLocalFile 

func (a StemcellManagerImpl) OpenLocalFile(path string) (*os.File, error)

func (StemcellManagerImpl) WaitForImage 

func (a StemcellManagerImpl) WaitForImage(regionId, imageId string, timeout int) error

Wait Image ready

func (StemcellManagerImpl) WaitForImageReady 

func (a StemcellManagerImpl) WaitForImageReady(id string) error

import image from oss may take >=15min we set timeout value to 30min, if needed turn it up

type TagResourceType 

type TagResourceType 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.