govmomi

Documentation

Index

• Variables
• func Properties(vm *object.VirtualMachine) (*mo.VirtualMachine, error)
• type Provisioner
  • func New(clusterV1alpha1 clusterv1alpha1.ClusterV1alpha1Interface, ...) (*Provisioner, error)
  • func (pv *Provisioner) Create(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
  • func (pv *Provisioner) Delete(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
  • func (pv *Provisioner) Exists(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) (bool, error)
  • func (pv *Provisioner) GetKubeConfig(cluster *clusterv1.Cluster) (string, error)
  • func (pv *Provisioner) GetKubeadmToken(cluster *clusterv1.Cluster) (string, error)
  • func (pv *Provisioner) GetSSHPublicKey(cluster *clusterv1.Cluster) (string, error)
  • func (pv *Provisioner) HandleClusterError(cluster *clusterv1.Cluster, err *apierrors.ClusterError, eventAction string) error
  • func (pv *Provisioner) HandleMachineError(machine *clusterv1.Machine, err *apierrors.MachineError, eventAction string) error
  • func (pv *Provisioner) Update(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
• type SessionContext

Variables

var (
	DefaultSSHPublicKeyFile = "/root/.ssh/vsphere_tmp.pub"
)

Functions

func Properties

func Properties(vm *object.VirtualMachine) (*mo.VirtualMachine, error)

Properties is a convenience method that wraps fetching the VirtualMachine MO from its higher-level object.

Types

type Provisioner

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

func New

func New(clusterV1alpha1 clusterv1alpha1.ClusterV1alpha1Interface, k8sClient kubernetes.Interface, lister v1alpha1.Interface, eventRecorder record.EventRecorder) (*Provisioner, error)

func (*Provisioner) Create

func (pv *Provisioner) Create(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error

func (*Provisioner) Delete

func (pv *Provisioner) Delete(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error

Delete the machine

func (*Provisioner) Exists

func (pv *Provisioner) Exists(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) (bool, error)

func (*Provisioner) GetKubeConfig

func (pv *Provisioner) GetKubeConfig(cluster *clusterv1.Cluster) (string, error)

func (*Provisioner) GetKubeadmToken

func (pv *Provisioner) GetKubeadmToken(cluster *clusterv1.Cluster) (string, error)

func (*Provisioner) GetSSHPublicKey

func (pv *Provisioner) GetSSHPublicKey(cluster *clusterv1.Cluster) (string, error)

func (*Provisioner) HandleClusterError

func (pv *Provisioner) HandleClusterError(cluster *clusterv1.Cluster, err *apierrors.ClusterError, eventAction string) error

If the Provisioner has a client for updating Cluster objects, this will set the appropriate reason/message on the Cluster.Status. If not, such as during cluster installation, it will operate as a no-op. It also returns the original error for convenience, so callers can do "return handleClusterError(...)".

func (*Provisioner) HandleMachineError

func (pv *Provisioner) HandleMachineError(machine *clusterv1.Machine, err *apierrors.MachineError, eventAction string) error

If the Provisioner has a client for updating Machine objects, this will set the appropriate reason/message on the Machine.Status. If not, such as during cluster installation, it will operate as a no-op. It also returns the original error for convenience, so callers can do "return handleMachineError(...)".

func (*Provisioner) Update

func (pv *Provisioner) Update(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error

type SessionContext

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