vm

Documentation

Index

• Constants
• Variables
• func CreateConsoleProbe() *corev1.Probe
• func GetAlivePods(pods []*corev1.Pod) []*corev1.Pod
• func HostnameOrDie() string
• func IsPodUnschedulable(pod *corev1.Pod) bool
• type AttachVolumeRequest
• type BackupListResponse
• type BackupVolume
• type Controller
• type CreateBackupRequest
• type CreateSnapshotRequest
• type CreateSnapshotResponse
• type LonghornClient
  • func NewLonghornClient(endpoint, accessKey, secretKey string, insecureSkipVerify bool) *LonghornClient
  • func (c *LonghornClient) AttachVolume(name, nodeID string) error
  • func (c *LonghornClient) CreateBackup(volumeName, snapshotName string) error
  • func (c *LonghornClient) CreateSnapshot(name string) (*CreateSnapshotResponse, error)
  • func (c *LonghornClient) CreateVolume(machine *api.VirtualMachine, image *api.MachineImage) error
  • func (c *LonghornClient) DeleteVolume(name string) error
  • func (c *LonghornClient) GetBackup(volumeName, snapshotName string) (*BackupVolume, error)
  • func (c *LonghornClient) GetBackupList(volumeName string) (*BackupListResponse, error)
  • func (c *LonghornClient) GetVolume(name string) (*LonghornVolume, error)
• type LonghornVolume
• type VirtualMachineController
  • func NewVirtualMachineController(vmClient vmclientset.Interface, kubeClient kubernetes.Interface, ...) *VirtualMachineController
  • func (ctrl *VirtualMachineController) Run()

Constants

const DockerContextDir = "/workspace"

Variables

var Privileged = true

Functions

func CreateConsoleProbe

func CreateConsoleProbe() *corev1.Probe

func GetAlivePods

func GetAlivePods(pods []*corev1.Pod) []*corev1.Pod

func HostnameOrDie

func HostnameOrDie() string

func IsPodUnschedulable

func IsPodUnschedulable(pod *corev1.Pod) bool

Types

type AttachVolumeRequest

type AttachVolumeRequest struct {
	NodeID string `json:"hostId"`
}

type BackupListResponse

type BackupListResponse struct {
	Items []*BackupVolume `json:"data"`
}

type BackupVolume

type BackupVolume struct {
	Name         string            `json:"name"`
	SnapshotName string            `json:"snapshotName"`
	VolumeName   string            `json:"volumeName"`
	URL          string            `json:"url"`
	Labels       map[string]string `json:"labels"`
}

type Controller

type Controller struct {
	Name     string `json:"name"`
	Endpoint string `json:"endpoint"`
	NodeID   string `json:"hostId"`
}

type CreateBackupRequest

type CreateBackupRequest struct {
	SnapshotName string `json:"name"`
}

type CreateSnapshotRequest

type CreateSnapshotRequest struct{}

type CreateSnapshotResponse

type CreateSnapshotResponse struct {
	Name string `json:"name"`
	Size string `json:"size"`
}

type LonghornClient

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

func NewLonghornClient

func NewLonghornClient(endpoint, accessKey, secretKey string, insecureSkipVerify bool) *LonghornClient

func (*LonghornClient) AttachVolume

func (c *LonghornClient) AttachVolume(name, nodeID string) error

func (*LonghornClient) CreateBackup

func (c *LonghornClient) CreateBackup(volumeName, snapshotName string) error

func (*LonghornClient) CreateSnapshot

func (c *LonghornClient) CreateSnapshot(name string) (*CreateSnapshotResponse, error)

func (*LonghornClient) CreateVolume

func (c *LonghornClient) CreateVolume(machine *api.VirtualMachine, image *api.MachineImage) error

func (*LonghornClient) DeleteVolume

func (c *LonghornClient) DeleteVolume(name string) error

func (*LonghornClient) GetBackup

func (c *LonghornClient) GetBackup(volumeName, snapshotName string) (*BackupVolume, error)

func (*LonghornClient) GetBackupList

func (c *LonghornClient) GetBackupList(volumeName string) (*BackupListResponse, error)

func (*LonghornClient) GetVolume

func (c *LonghornClient) GetVolume(name string) (*LonghornVolume, error)

type LonghornVolume

type LonghornVolume struct {
	Name                string `json:"name"`
	Frontend            string `json:"frontend"`
	Size                string `json:"size"`
	BaseImage           string `json:"baseImage"`
	NumberOfReplicas    int    `json:"numberOfReplicas"`
	StaleReplicaTimeout int    `json:"staleReplicaTimeout"`

	Robustness  string       `json:"robustness"`
	State       string       `json:"state"`
	Controllers []Controller `json:"controllers"`
}

type VirtualMachineController

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

func NewVirtualMachineController

func NewVirtualMachineController(
	vmClient vmclientset.Interface,
	kubeClient kubernetes.Interface,
	podInformer coreinformers.PodInformer,
	jobInformer batchinformers.JobInformer,
	svcInformer coreinformers.ServiceInformer,
	pvInformer coreinformers.PersistentVolumeInformer,
	pvcInformer coreinformers.PersistentVolumeClaimInformer,
	nodeInformer coreinformers.NodeInformer,
	machineInformer vminformers.VirtualMachineInformer,
	credInformer vminformers.CredentialInformer,
	settingInformer vminformers.SettingInformer,
	machineImageInformer vminformers.MachineImageInformer,
	bridgeIface string,
	noResourceLimits bool,
) *VirtualMachineController

func (*VirtualMachineController) Run

func (ctrl *VirtualMachineController) Run()