machine

Documentation

Index

• Constants
• func GetMachineIfExists(c client.Client, namespace, name string) (*machinev1.Machine, error)
• type OpenstackClient
  • func NewActuator(params openstack.ActuatorParams) (*OpenstackClient, error)
  • func (oc *OpenstackClient) Create(ctx context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error
  • func (oc *OpenstackClient) Delete(ctx context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error
  • func (oc *OpenstackClient) Exists(ctx context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) (bool, error)
  • func (oc *OpenstackClient) Update(ctx context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error

Constants

const (
	CloudConfigPath = "/etc/cloud/cloud_config.yaml"

	UserDataKey          = "userData"
	DisableTemplatingKey = "disableTemplating"
	PostprocessorKey     = "postprocessor"

	TimeoutInstanceCreate       = 5
	TimeoutInstanceDelete       = 5
	RetryIntervalInstanceStatus = 10 * time.Second
)

const InstanceStatusAnnotationKey = "instance-status"

Functions

func GetMachineIfExists

func GetMachineIfExists(c client.Client, namespace, name string) (*machinev1.Machine, error)

Get a `machinev1.Machine` matching the specified name and namespace.

Same as cluster-api's `util.GetMachineIfExists`, but works with `machinev1` instead of `clusterv1`. The latter does not work with OpenShift deployments.

Types

type OpenstackClient

type OpenstackClient struct {
	*openstack.DeploymentClient
	// contains filtered or unexported fields
}

func NewActuator

func NewActuator(params openstack.ActuatorParams) (*OpenstackClient, error)

func (*OpenstackClient) Create

func (oc *OpenstackClient) Create(ctx context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error

func (*OpenstackClient) Delete

func (oc *OpenstackClient) Delete(ctx context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error

func (*OpenstackClient) Exists

func (oc *OpenstackClient) Exists(ctx context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) (bool, error)

func (*OpenstackClient) Update

func (oc *OpenstackClient) Update(ctx context.Context, cluster *clusterv1.Cluster, machine *machinev1.Machine) error