Versions in this module Expand all Collapse all v0 v0.3.5 Nov 22, 2018 Changes in this version + const DefaultLoginPassword + var DevicePattern = regexp.MustCompile("/dev/xvd(.)") v0.3.4 Nov 13, 2018 Changes in this version + const DefaultVolumeClass + const DefaultZone + const G + var InstanceTypeMap = map[CpuAndMemory]string + var MyProvider = constants.ProviderAliyun + func ConvertToInstanceType(cpu, memory int) (string, error) + func ConvertToVolumeType(volumeClass int) (string, error) + type CpuAndMemory struct + Cpu int + Memory int + type Provider struct + func NewProvider() *Provider + func (p *Provider) CheckResource(ctx context.Context, clusterWrapper *models.ClusterWrapper) error + func (p *Provider) DescribeClusterDetails(ctx context.Context, cluster *models.ClusterWrapper) error + func (p *Provider) DescribeRuntimeProviderZones(ctx context.Context, url, credential string) ([]string, error) + func (p *Provider) DescribeSubnets(ctx context.Context, req *pb.DescribeSubnetsRequest) (*pb.DescribeSubnetsResponse, error) + func (p *Provider) DescribeVpc(ctx context.Context, runtimeId, vpcId string) (*models.Vpc, error) + func (p *Provider) HandleSubtask(ctx context.Context, task *models.Task) error + func (p *Provider) ParseClusterConf(ctx context.Context, versionId, runtimeId, conf string, ...) error + func (p *Provider) SplitJobIntoTasks(ctx context.Context, job *models.Job) (*models.TaskLayer, error) + func (p *Provider) UpdateClusterStatus(ctx context.Context, job *models.Job) error + func (p *Provider) ValidateCredential(ctx context.Context, runtimeId, url, credential, zone string) error + func (p *Provider) WaitSubtask(ctx context.Context, task *models.Task) error + type ProviderHandler struct + func GetProviderHandler(ctx context.Context) *ProviderHandler + func (p *ProviderHandler) AttachVolumes(task *models.Task) error + func (p *ProviderHandler) CheckResourceQuotas(ctx context.Context, clusterWrapper *models.ClusterWrapper) error + func (p *ProviderHandler) CreateVolumes(task *models.Task) error + func (p *ProviderHandler) DeleteInstances(task *models.Task) error + func (p *ProviderHandler) DeleteVolumes(task *models.Task) error + func (p *ProviderHandler) DescribeAvailabilityZoneBySubnetId(runtimeId, subnetId string) (string, error) + func (p *ProviderHandler) DescribeImage(runtimeId, imageName string) (string, error) + func (p *ProviderHandler) DescribeKeyPairs(url, credential, zone string) ([]string, error) + func (p *ProviderHandler) DescribeSubnets(ctx context.Context, req *pb.DescribeSubnetsRequest) (*pb.DescribeSubnetsResponse, error) + func (p *ProviderHandler) DescribeVpc(runtimeId, vpcId string) (*models.Vpc, error) + func (p *ProviderHandler) DescribeZones(url, credential string) ([]string, error) + func (p *ProviderHandler) DetachVolumes(task *models.Task) error + func (p *ProviderHandler) ResizeInstances(task *models.Task) error + func (p *ProviderHandler) ResizeVolumes(task *models.Task) error + func (p *ProviderHandler) RunInstances(task *models.Task) error + func (p *ProviderHandler) StartInstances(task *models.Task) error + func (p *ProviderHandler) StopInstances(task *models.Task) error + func (p *ProviderHandler) WaitAttachVolumes(task *models.Task) error + func (p *ProviderHandler) WaitCreateVolumes(task *models.Task) error + func (p *ProviderHandler) WaitDeleteInstances(task *models.Task) error + func (p *ProviderHandler) WaitDeleteVolumes(task *models.Task) error + func (p *ProviderHandler) WaitDetachVolumes(task *models.Task) error + func (p *ProviderHandler) WaitInstanceState(task *models.Task, state string) error + func (p *ProviderHandler) WaitResizeInstances(task *models.Task) error + func (p *ProviderHandler) WaitResizeVolumes(task *models.Task) error + func (p *ProviderHandler) WaitRunInstances(task *models.Task) error + func (p *ProviderHandler) WaitStartInstances(task *models.Task) error + func (p *ProviderHandler) WaitStopInstances(task *models.Task) error + func (p *ProviderHandler) WaitVolumeState(task *models.Task, state string) error
Go to main page