machine

package

v0.0.0-...-d2bd037 Latest Latest Go to latest Published: Jul 21, 2020 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/xuanyunhui/cluster-api-provider-alibabacloud

Documentation ¶

Index ¶

Constants
type Actuator
- func NewActuator(params ActuatorParams) (*Actuator, error)
type ActuatorParams
type AliCloudClientWrapper
- func NewAliCloudClientWrapper(client aliCloud.Client, regionId string) *AliCloudClientWrapper

Constants ¶

View Source

const (

	// MachineCreationSucceeded indicates success for machine creation
	MachineCreationSucceeded = "MachineCreationSucceeded"

	// MachineCreationFailed indicates that machine creation failed
	MachineCreationFailed = "MachineCreationFailed"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Actuator ¶

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

Actuator is responsible for performing machine reconciliation.

func NewActuator ¶

func NewActuator(params ActuatorParams) (*Actuator, error)

NewActuator returns a new AliCloud Actuator

func (*Actuator) Create ¶

func (a *Actuator) Create(context context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error

Create runs an ECS instance

func (*Actuator) CreateMachine ¶

func (a *Actuator) CreateMachine(cluster *clusterv1.Cluster, machine *machinev1.Machine) (*ecs.Instance, error)

CreateMachine starts a new ECS instance as described by the cluster and machine resources

func (*Actuator) Delete ¶

func (a *Actuator) Delete(context context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error

Delete deletes a machine and updates its finalizer

func (*Actuator) DeleteMachine ¶

func (a *Actuator) DeleteMachine(cluster *clusterv1.Cluster, machine *machinev1.Machine) error

DeleteMachine deletes an ECS instance

func (*Actuator) Describe ¶

func (a *Actuator) Describe(cluster *clusterv1.Cluster, machine *machinev1.Machine) (*ecs.Instance, error)

func (*Actuator) Exists ¶

func (a *Actuator) Exists(context context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) (bool, error)

func (*Actuator) Update ¶

func (a *Actuator) Update(context context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error

update

type ActuatorParams ¶

type ActuatorParams struct {
	Client                client.Client
	Config                *rest.Config
	AliCloudClientBuilder aliClient.AliCloudClientBuilderFuncType
	Codec                 *providerconfigv1.AlicloudProviderConfigCodec
	EventRecorder         record.EventRecorder
}

ActuatorParams holds parameter information for Actuator

type AliCloudClientWrapper ¶

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

AliCloudClientWrapper implements CloudProviderClient for alicloud e2e framework

func NewAliCloudClientWrapper ¶

func NewAliCloudClientWrapper(client aliCloud.Client, regionId string) *AliCloudClientWrapper

func (*AliCloudClientWrapper) GetAvailabilityZoneId ¶

func (client *AliCloudClientWrapper) GetAvailabilityZoneId(machine *machinev1beta1.Machine) (string, error)

GetAvailabilityZoneId gets availability zone

func (*AliCloudClientWrapper) GetDataDisks ¶

func (client *AliCloudClientWrapper) GetDataDisks(machine *machinev1beta1.Machine) (map[string]map[string]interface{}, error)

GetDataDisks gets volumes attached to instance

func (*AliCloudClientWrapper) GetPrivateIP ¶

func (client *AliCloudClientWrapper) GetPrivateIP(machine *machinev1beta1.Machine) (string, error)

func (*AliCloudClientWrapper) GetPublicDNSName ¶

func (client *AliCloudClientWrapper) GetPublicDNSName(machine *machinev1beta1.Machine) (string, error)

func (*AliCloudClientWrapper) GetRamRole ¶

func (client *AliCloudClientWrapper) GetRamRole(machine *machinev1beta1.Machine) (string, error)

GetRamRole gets RAM role

func (*AliCloudClientWrapper) GetRunningInstances ¶

func (client *AliCloudClientWrapper) GetRunningInstances(machine *machinev1beta1.Machine) ([]interface{}, error)

func (*AliCloudClientWrapper) GetSecurityGroups ¶

func (client *AliCloudClientWrapper) GetSecurityGroups(machine *machinev1beta1.Machine) ([]string, error)

GetSecurityGroups gets security groups

func (*AliCloudClientWrapper) GetTags ¶

func (client *AliCloudClientWrapper) GetTags(machine *machinev1beta1.Machine) (map[string]string, error)

GetTags gets tags

Source Files ¶

View all Source files

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