driver

package
v0.48.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 5, 2023 License: Apache-2.0, BSD-3-Clause Imports: 58 Imported by: 0

Documentation

Overview

Package driver contains the cloud provider specific implementations to manage machines

Package driver contains the cloud provider specific implementations to manage machines

Package driver contains the cloud provider specific implementations to manage machines

Package driver contains the cloud provider specific implementations to manage machines

Package driver contains the cloud provider specific implementations to manage machines

Package driver contains the cloud provider specific implementations to manage machines

Package driver contains the cloud provider specific implementations to manage machines

Package driver contains the cloud provider specific implementations to manage machines

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExtractCredentialsFromData added in v0.36.0 

func ExtractCredentialsFromData(data map[string][]byte, keys ...string) string

ExtractCredentialsFromData extracts and trims a value from the given data map. The first key that exists is being returned, otherwise, the next key is tried, etc. If no key exists then an empty string is returned.

Types

type AWSDriver 

type AWSDriver struct {
	AWSMachineClass *v1alpha1.AWSMachineClass
	CredentialsData map[string][]byte
	UserData        string
	MachineID       string
	MachineName     string
}

AWSDriver is the driver struct for holding AWS machine information

func (*AWSDriver) Create 

func (d *AWSDriver) Create() (string, string, error)

Create method is used to create a AWS machine

func (*AWSDriver) Delete 

func (d *AWSDriver) Delete(machineID string) error

Delete method is used to delete a AWS machine

func (*AWSDriver) GetExisting 

func (d *AWSDriver) GetExisting() (string, error)

GetExisting method is used to get machineID for existing AWS machine

func (*AWSDriver) GetUserData added in v0.30.0 

func (d *AWSDriver) GetUserData() string

GetUserData return the used data whit which the VM will be booted

func (*AWSDriver) GetVMs 

func (d *AWSDriver) GetVMs(machineID string) (VMs, error)

GetVMs returns a VM matching the machineID If machineID is an empty string then it returns all matching instances

func (*AWSDriver) GetVolNames 

func (d *AWSDriver) GetVolNames(specs []corev1.PersistentVolumeSpec) ([]string, error)

GetVolNames parses volume names from pv specs

func (*AWSDriver) SetUserData added in v0.30.0 

func (d *AWSDriver) SetUserData(userData string)

SetUserData set the used data whit which the VM will be booted

type AlicloudDriver 

type AlicloudDriver struct {
	AlicloudMachineClass *v1alpha1.AlicloudMachineClass
	CredentialsData      map[string][]byte
	UserData             string
	MachineID            string
	MachineName          string
}

AlicloudDriver is the driver struct for holding Alicloud machine information

func (*AlicloudDriver) Create 

func (c *AlicloudDriver) Create() (string, string, error)

Create is used to create a VM

func (*AlicloudDriver) Delete 

func (c *AlicloudDriver) Delete(machineID string) error

Delete method is used to delete an alicloud machine

func (*AlicloudDriver) GetExisting 

func (c *AlicloudDriver) GetExisting() (string, error)

GetExisting method is used to get machineID for existing Alicloud machine

func (*AlicloudDriver) GetUserData added in v0.30.0 

func (c *AlicloudDriver) GetUserData() string

GetUserData return the used data whit which the VM will be booted

func (*AlicloudDriver) GetVMs 

func (c *AlicloudDriver) GetVMs(machineID string) (VMs, error)

GetVMs returns a VM matching the machineID If machineID is an empty string then it returns all matching instances

func (*AlicloudDriver) GetVolNames 

func (c *AlicloudDriver) GetVolNames(specs []corev1.PersistentVolumeSpec) ([]string, error)

GetVolNames parses volume names from pv specs

func (*AlicloudDriver) SetUserData added in v0.30.0 

func (c *AlicloudDriver) SetUserData(userData string)

SetUserData set the used data whit which the VM will be booted

type AzureDriver 

type AzureDriver struct {
	AzureMachineClass *v1alpha1.AzureMachineClass
	CredentialsData   map[string][]byte
	UserData          string
	MachineID         string
	MachineName       string
}

AzureDriver is the driver struct for holding azure machine information

func (*AzureDriver) Create 

func (d *AzureDriver) Create() (string, string, error)

Create method is used to create an azure machine

func (*AzureDriver) Delete 

func (d *AzureDriver) Delete(machineID string) error

Delete method is used to delete an azure machine

func (*AzureDriver) GetExisting 

func (d *AzureDriver) GetExisting() (string, error)

GetExisting method is used to fetch the machineID for an azure machine

func (*AzureDriver) GetUserData added in v0.30.0 

func (d *AzureDriver) GetUserData() string

GetUserData return the user data with which the VM will be booted

func (*AzureDriver) GetVMs 

func (d *AzureDriver) GetVMs(machineID string) (result VMs, err error)

GetVMs returns a list of VM or VM resources Azure earlier treated all VM resources (instance, NIC, Disks) as a single resource and atomically created/deleted them in the driver interface. This caused issues when the controller crashes, during deletions. To fix this, now GetVMs interface checks for all resources instead of just VMs.

func (*AzureDriver) GetVolNames 

func (d *AzureDriver) GetVolNames(specs []corev1.PersistentVolumeSpec) ([]string, error)

GetVolNames parses volume names from pv specs

func (*AzureDriver) SetUserData added in v0.30.0 

func (d *AzureDriver) SetUserData(userData string)

SetUserData set the used data whit which the VM will be booted

type Driver 

type Driver interface {
	Create() (string, string, error)
	Delete(string) error
	GetExisting() (string, error)
	GetVMs(string) (VMs, error)
	GetVolNames([]corev1.PersistentVolumeSpec) ([]string, error)
	GetUserData() string
	SetUserData(string)
}

Driver is the common interface for creation/deletion of the VMs over different cloud-providers.

func NewAWSDriver 

func NewAWSDriver(create func() (string, error), delete func() error, existing func() (string, error)) Driver

NewAWSDriver returns an empty AWSDriver object

func NewDriver 

func NewDriver(machineID string, secretData map[string][]byte, classKind string, machineClass interface{}, machineName string) Driver

NewDriver creates a new driver object based on the classKind

func NewFakeDriver 

func NewFakeDriver(
	create func() (string, string, error),
	add func(string, string) error,
	delete func(string) error,
	existing func() (string, error),
	getVMs func() (VMs, error),
	getVolNames func([]corev1.PersistentVolumeSpec) ([]string, error),
	getUserData func() string,
	setUserData func(string),
) Driver

NewFakeDriver returns a new fakedriver object

func NewPacketDriver 

func NewPacketDriver(create func() (string, error), delete func() error, existing func() (string, error)) Driver

NewPacketDriver returns an empty PacketDriver object

type FakeDriver 

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

FakeDriver is a fake driver returned when none of the actual drivers match

func (*FakeDriver) Add added in v0.37.0 

func (d *FakeDriver) Add(machineID string, machineName string) error

Add add a newly created machine to the fakeVMs list

func (*FakeDriver) Create 

func (d *FakeDriver) Create() (string, string, error)

Create returns a newly created fake driver

func (*FakeDriver) Delete 

func (d *FakeDriver) Delete(machineID string) error

Delete deletes a fake driver

func (*FakeDriver) GetExisting 

func (d *FakeDriver) GetExisting() (string, error)

GetExisting returns the existing fake driver

func (*FakeDriver) GetUserData added in v0.30.0 

func (d *FakeDriver) GetUserData() string

GetUserData return the used data whit which the VM will be booted

func (*FakeDriver) GetVMs 

func (d *FakeDriver) GetVMs(name string) (VMs, error)

GetVMs returns a list of VMs

func (*FakeDriver) GetVolNames 

func (d *FakeDriver) GetVolNames(specs []corev1.PersistentVolumeSpec) ([]string, error)

GetVolNames parses volume names from pv specs

func (*FakeDriver) SetUserData added in v0.30.0 

func (d *FakeDriver) SetUserData(userData string)

SetUserData set the used data whit which the VM will be booted

type GCPDriver 

type GCPDriver struct {
	GCPMachineClass *v1alpha1.GCPMachineClass
	CredentialsData map[string][]byte
	UserData        string
	MachineID       string
	MachineName     string
}

GCPDriver is the driver struct for holding GCP machine information

func (*GCPDriver) Create 

func (d *GCPDriver) Create() (string, string, error)

Create method is used to create a GCP machine

func (*GCPDriver) Delete 

func (d *GCPDriver) Delete(machineID string) error

Delete method is used to delete a GCP machine

func (*GCPDriver) GetExisting 

func (d *GCPDriver) GetExisting() (string, error)

GetExisting method is used to get machineID for existing GCP machine

func (*GCPDriver) GetUserData added in v0.30.0 

func (d *GCPDriver) GetUserData() string

GetUserData return the used data whit which the VM will be booted

func (*GCPDriver) GetVMs 

func (d *GCPDriver) GetVMs(machineID string) (VMs, error)

GetVMs returns a list of VMs

func (*GCPDriver) GetVolNames 

func (d *GCPDriver) GetVolNames(specs []corev1.PersistentVolumeSpec) ([]string, error)

GetVolNames parses volume names from pv specs

func (*GCPDriver) SetUserData added in v0.30.0 

func (d *GCPDriver) SetUserData(userData string)

SetUserData set the used data whit which the VM will be booted

type OpenStackDriver 

type OpenStackDriver struct {
	OpenStackMachineClass *v1alpha1.OpenStackMachineClass
	CredentialsData       map[string][]byte
	UserData              string
	MachineID             string
	MachineName           string
}

OpenStackDriver is the driver struct for holding OS machine information

func (*OpenStackDriver) Create 

func (d *OpenStackDriver) Create() (string, string, error)

Create method is used to create an OS machine

func (*OpenStackDriver) Delete 

func (d *OpenStackDriver) Delete(machineID string) error

Delete method is used to delete an OS machine

func (*OpenStackDriver) GetExisting 

func (d *OpenStackDriver) GetExisting() (string, error)

GetExisting method is used to get machineID for existing OS machine

func (*OpenStackDriver) GetUserData added in v0.30.0 

func (d *OpenStackDriver) GetUserData() string

GetUserData return the used data whit which the VM will be booted

func (*OpenStackDriver) GetVMs 

func (d *OpenStackDriver) GetVMs(machineID string) (VMs, error)

GetVMs returns a VM matching the machineID If machineID is an empty string then it returns all matching instances

func (*OpenStackDriver) GetVolNames 

func (d *OpenStackDriver) GetVolNames(specs []corev1.PersistentVolumeSpec) ([]string, error)

GetVolNames parses volume names from pv specs

func (*OpenStackDriver) SetUserData added in v0.30.0 

func (d *OpenStackDriver) SetUserData(userData string)

SetUserData set the used data whit which the VM will be booted

type PacketDriver 

type PacketDriver struct {
	PacketMachineClass *v1alpha1.PacketMachineClass
	CredentialsData    map[string][]byte
	UserData           string
	MachineID          string
	MachineName        string
}

PacketDriver is the driver struct for holding Packet machine information

func (*PacketDriver) Create 

func (d *PacketDriver) Create() (string, string, error)

Create method is used to create a Packet machine

func (*PacketDriver) Delete 

func (d *PacketDriver) Delete(machineID string) error

Delete method is used to delete a Packet machine

func (*PacketDriver) GetExisting 

func (d *PacketDriver) GetExisting() (string, error)

GetExisting method is used to get machineID for existing Packet machine

func (*PacketDriver) GetUserData added in v0.30.0 

func (d *PacketDriver) GetUserData() string

GetUserData return the used data whit which the VM will be booted

func (*PacketDriver) GetVMs 

func (d *PacketDriver) GetVMs(machineID string) (VMs, error)

GetVMs returns a machine matching the machineID If machineID is an empty string then it returns all matching instances

func (*PacketDriver) GetVolNames 

func (d *PacketDriver) GetVolNames(specs []corev1.PersistentVolumeSpec) ([]string, error)

GetVolNames parses volume names from pv specs

func (*PacketDriver) SetUserData added in v0.30.0 

func (d *PacketDriver) SetUserData(userData string)

SetUserData set the used data whit which the VM will be booted

type VMs 

type VMs map[string]string

VMs maintains a list of VM returned by the provider Key refers to the machine-id on the cloud provider value refers to the machine-name of the machine object

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.