machine

Documentation

Index

• Constants
• type Actuator
  • func NewActuator(params ActuatorParams) (*Actuator, error)
  • func (a *Actuator) Create(context context.Context, cluster *v1alpha1.Cluster, machine *machinev1.Machine) error
  • func (a *Actuator) CreateMachine(cluster *v1alpha1.Cluster, machine *machinev1.Machine) (*corev1.Pod, error)
  • func (a *Actuator) Delete(context context.Context, cluster *v1alpha1.Cluster, machine *machinev1.Machine) error
  • func (a *Actuator) DeleteMachine(cluster *v1alpha1.Cluster, machine *machinev1.Machine) error
  • func (a *Actuator) Exists(context context.Context, cluster *v1alpha1.Cluster, machine *machinev1.Machine) (bool, error)
  • func (a *Actuator) Update(context context.Context, cluster *v1alpha1.Cluster, machine *machinev1.Machine) error
• type ActuatorParams

Constants

const (

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

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

	// StaticMachineAnnotation annotation to back up a node but without an instance reconciliation
	StaticMachineAnnotation = "machine.openshift.io/static-machine"

	// DeletionTimeoutAnnotation annotation to create a delay before machine is deleted by the actuator
	DeletionTimeoutAnnotation = "machine.openshift.io/deletion-timeout"
)

Types

type Actuator

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

Actuator is the AWS-specific actuator for the Cluster API machine controller

func NewActuator

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

NewActuator returns a new AWS Actuator

func (*Actuator) Create

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

Create runs a new kubemark instance

func (*Actuator) CreateMachine

func (a *Actuator) CreateMachine(cluster *v1alpha1.Cluster, machine *machinev1.Machine) (*corev1.Pod, error)

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

func (*Actuator) Delete

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

Delete deletes a machine and updates its finalizer

func (*Actuator) DeleteMachine

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

DeleteMachine deletes an AWS instance

func (*Actuator) Exists

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

Exists determines if the given machine currently exists. For AWS we query for instances in running state, with a matching name tag, to determine a match.

func (*Actuator) Update

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

Update attempts to sync machine state with an existing instance. Today this just updates status for details that may have changed. (IPs and hostnames) We do not currently support making any changes to actual machines in AWS. Instead these will be replaced via MachineDeployments.

type ActuatorParams

type ActuatorParams struct {
	Client        client.Client
	Config        *rest.Config
	Codec         *providerconfigv1.KubemarkProviderConfigCodec
	EventRecorder record.EventRecorder
}

ActuatorParams holds parameter information for Actuator