vm

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2018 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source
const DockerContextDir = "/workspace"

Variables

View Source
var Privileged = true

Functions

func CreateConsoleProbe added in v0.2.0

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 added in v0.2.0

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

type BackupListResponse added in v0.2.0

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

type BackupVolume added in v0.2.0

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 added in v0.2.0

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

type CreateBackupRequest added in v0.2.0

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

type CreateSnapshotRequest added in v0.2.0

type CreateSnapshotRequest struct{}

type CreateSnapshotResponse added in v0.2.0

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

type LonghornClient added in v0.2.0

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

func NewLonghornClient added in v0.2.0

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

func (*LonghornClient) AttachVolume added in v0.2.0

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

func (*LonghornClient) CreateBackup added in v0.2.0

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

func (*LonghornClient) CreateSnapshot added in v0.2.0

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

func (*LonghornClient) CreateVolume added in v0.2.0

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

func (*LonghornClient) DeleteVolume added in v0.2.0

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

func (*LonghornClient) GetBackup added in v0.2.0

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

func (*LonghornClient) GetBackupList added in v0.2.0

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

func (*LonghornClient) GetVolume added in v0.2.0

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

type LonghornVolume added in v0.2.0

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL