machines

package
v1.4.2 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2024 License: MIT Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartStorageProcessor added in v1.3.1 

func StartStorageProcessor(ctx context.Context, t *MachineMigrationTask, disks kvmrun.DiskPool, ready, stateMigrated chan struct{}) error

Types

type DiskBackupTask 

type DiskBackupTask struct {
	*task.GenericTask
	*services.ServiceServer
	// contains filtered or unexported fields
}

func NewDiskBackupTask 

func NewDiskBackupTask(req *pb.StartDiskBackupRequest, ss *services.ServiceServer, vm *kvmrun.Machine) *DiskBackupTask

func (*DiskBackupTask) BeforeStart 

func (t *DiskBackupTask) BeforeStart(_ interface{}) error

func (*DiskBackupTask) GetKey 

func (t *DiskBackupTask) GetKey() string

func (*DiskBackupTask) GetNS 

func (t *DiskBackupTask) GetNS() string

func (*DiskBackupTask) Main 

func (t *DiskBackupTask) Main() error

func (*DiskBackupTask) OnFailure 

func (t *DiskBackupTask) OnFailure() error

type MachineMigrationTask 

type MachineMigrationTask struct {
	*task.GenericTask
	*services.ServiceServer
	// contains filtered or unexported fields
}

func NewMachineMigrationTask 

func NewMachineMigrationTask(req *m_pb.StartMigrationRequest, ss *services.ServiceServer, vm *kvmrun.Machine) *MachineMigrationTask

func (*MachineMigrationTask) BeforeStart 

func (t *MachineMigrationTask) BeforeStart(_ interface{}) error

func (*MachineMigrationTask) GetKey 

func (t *MachineMigrationTask) GetKey() string

func (*MachineMigrationTask) GetNS 

func (t *MachineMigrationTask) GetNS() string

func (*MachineMigrationTask) Main 

func (t *MachineMigrationTask) Main() error

func (*MachineMigrationTask) OnFailure 

func (t *MachineMigrationTask) OnFailure() error

func (*MachineMigrationTask) OnSuccess 

func (t *MachineMigrationTask) OnSuccess() error

func (*MachineMigrationTask) Stat 

func (t *MachineMigrationTask) Stat() *task.TaskStat

type MachineMigrationTask_StorageProcessor added in v1.3.1 

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

type ServiceServer 

type ServiceServer struct {
	*services.ServiceServer
}

func (*ServiceServer) ActivateVNC 

func (s *ServiceServer) ActivateVNC(ctx context.Context, req *pb.ActivateVNCRequest) (*pb.ActivateVNCResponse, error)

func (*ServiceServer) AttachCdrom 

func (s *ServiceServer) AttachCdrom(ctx context.Context, req *pb.AttachCdromRequest) (*empty.Empty, error)

func (*ServiceServer) AttachChannel 

func (s *ServiceServer) AttachChannel(ctx context.Context, req *pb.AttachChannelRequest) (*empty.Empty, error)

func (*ServiceServer) AttachCloudInitDrive 

func (s *ServiceServer) AttachCloudInitDrive(ctx context.Context, req *pb.AttachCloudInitRequest) (*empty.Empty, error)

func (*ServiceServer) AttachDisk 

func (s *ServiceServer) AttachDisk(ctx context.Context, req *pb.AttachDiskRequest) (*empty.Empty, error)

func (*ServiceServer) AttachHostPCIDevice added in v1.3.1 

func (s *ServiceServer) AttachHostPCIDevice(ctx context.Context, req *pb.AttachHostPCIDeviceRequest) (*empty.Empty, error)

func (*ServiceServer) AttachInputDevice 

func (s *ServiceServer) AttachInputDevice(ctx context.Context, req *pb.AttachInputDeviceRequest) (*empty.Empty, error)

func (*ServiceServer) AttachNetIface 

func (s *ServiceServer) AttachNetIface(ctx context.Context, req *pb.AttachNetIfaceRequest) (*empty.Empty, error)

func (*ServiceServer) ChangeCdromMedia 

func (s *ServiceServer) ChangeCdromMedia(ctx context.Context, req *pb.ChangeCdromMediaRequest) (*empty.Empty, error)

func (*ServiceServer) ChangeCloudInitDrive 

func (s *ServiceServer) ChangeCloudInitDrive(ctx context.Context, req *pb.ChangeCloudInitRequest) (*empty.Empty, error)

func (*ServiceServer) Create 

func (s *ServiceServer) Create(ctx context.Context, req *pb.CreateMachineRequest) (*pb.CreateMachineResponse, error)

func (*ServiceServer) Delete 

func (s *ServiceServer) Delete(ctx context.Context, req *pb.DeleteMachineRequest) (*pb.DeleteMachineResponse, error)

func (*ServiceServer) DetachCdrom 

func (s *ServiceServer) DetachCdrom(ctx context.Context, req *pb.DetachCdromRequest) (*empty.Empty, error)

func (*ServiceServer) DetachChannel 

func (s *ServiceServer) DetachChannel(ctx context.Context, req *pb.DetachChannelRequest) (*empty.Empty, error)

func (*ServiceServer) DetachCloudInitDrive 

func (s *ServiceServer) DetachCloudInitDrive(ctx context.Context, req *pb.DetachCloudInitRequest) (*empty.Empty, error)

func (*ServiceServer) DetachDisk 

func (s *ServiceServer) DetachDisk(ctx context.Context, req *pb.DetachDiskRequest) (*empty.Empty, error)

func (*ServiceServer) DetachHostPCIDevice added in v1.3.1 

func (s *ServiceServer) DetachHostPCIDevice(ctx context.Context, req *pb.DetachHostPCIDeviceRequest) (*empty.Empty, error)

func (*ServiceServer) DetachInputDevice 

func (s *ServiceServer) DetachInputDevice(ctx context.Context, req *pb.DetachInputDeviceRequest) (*empty.Empty, error)

func (*ServiceServer) DetachNetIface 

func (s *ServiceServer) DetachNetIface(ctx context.Context, req *pb.DetachNetIfaceRequest) (*empty.Empty, error)

func (*ServiceServer) Get 

func (s *ServiceServer) Get(ctx context.Context, req *pb.GetMachineRequest) (*pb.GetMachineResponse, error)

func (*ServiceServer) GetEvents 

func (s *ServiceServer) GetEvents(ctx context.Context, req *pb.GetMachineRequest) (*pb.GetEventsResponse, error)

func (*ServiceServer) Init 

func (s *ServiceServer) Init(inner *services.ServiceServer)

func (*ServiceServer) List 

func (s *ServiceServer) List(ctx context.Context, req *pb.ListMachinesRequest) (*pb.ListMachinesResponse, error)

func (*ServiceServer) ListNames 

func (s *ServiceServer) ListNames(ctx context.Context, req *pb.ListMachinesRequest) (*pb.ListNamesResponse, error)

func (*ServiceServer) Name 

func (s *ServiceServer) Name() string

func (*ServiceServer) Register 

func (s *ServiceServer) Register(server *grpc.Server)

func (*ServiceServer) RemoveDiskBitmap 

func (s *ServiceServer) RemoveDiskBitmap(ctx context.Context, req *pb.RemoveDiskBitmapRequest) (*empty.Empty, error)

func (*ServiceServer) Reset 

func (s *ServiceServer) Reset(ctx context.Context, req *pb.RestartMachineRequest) (*empty.Empty, error)

func (*ServiceServer) ResizeQemuBlockdev 

func (s *ServiceServer) ResizeQemuBlockdev(ctx context.Context, req *pb.ResizeQemuBlockdevRequest) (*empty.Empty, error)

func (*ServiceServer) Restart 

func (s *ServiceServer) Restart(ctx context.Context, req *pb.RestartMachineRequest) (*empty.Empty, error)

func (*ServiceServer) SetCPULimits 

func (s *ServiceServer) SetCPULimits(ctx context.Context, req *pb.SetCPULimitsRequest) (*empty.Empty, error)

func (*ServiceServer) SetCPUModel 

func (s *ServiceServer) SetCPUModel(ctx context.Context, req *pb.SetCPUModelRequest) (*empty.Empty, error)

func (*ServiceServer) SetCPUQuota 

func (s *ServiceServer) SetCPUQuota(ctx context.Context, req *pb.SetCPUQuotaRequest) (*empty.Empty, error)

func (*ServiceServer) SetCPUSockets 

func (s *ServiceServer) SetCPUSockets(ctx context.Context, req *pb.SetCPUSocketsRequest) (*empty.Empty, error)

func (*ServiceServer) SetDiskLimits 

func (s *ServiceServer) SetDiskLimits(ctx context.Context, req *pb.SetDiskLimitsRequest) (*empty.Empty, error)

func (*ServiceServer) SetExternalKernel 

func (s *ServiceServer) SetExternalKernel(ctx context.Context, req *pb.SetExternalKernelRequest) (*empty.Empty, error)

func (*ServiceServer) SetFirmware added in v1.1.0 

func (s *ServiceServer) SetFirmware(ctx context.Context, req *pb.SetFirmwareRequest) (*empty.Empty, error)

func (*ServiceServer) SetHostPCIMultifunctionOption added in v1.3.1 

func (s *ServiceServer) SetHostPCIMultifunctionOption(ctx context.Context, req *pb.SetHostPCIMultifunctionOptionRequest) (*empty.Empty, error)

func (*ServiceServer) SetHostPCIPrimaryGPUOption added in v1.3.1 

func (s *ServiceServer) SetHostPCIPrimaryGPUOption(ctx context.Context, req *pb.SetHostPCIPrimaryGPUOptionRequest) (*empty.Empty, error)

func (*ServiceServer) SetMemLimits 

func (s *ServiceServer) SetMemLimits(ctx context.Context, req *pb.SetMemLimitsRequest) (*empty.Empty, error)

func (*ServiceServer) SetNetIfaceDownScript 

func (s *ServiceServer) SetNetIfaceDownScript(ctx context.Context, req *pb.SetNetIfaceScriptRequest) (*empty.Empty, error)

func (*ServiceServer) SetNetIfaceLinkState 

func (s *ServiceServer) SetNetIfaceLinkState(ctx context.Context, req *pb.SetNetIfaceLinkRequest) (*empty.Empty, error)

func (*ServiceServer) SetNetIfaceQueues added in v1.3.1 

func (s *ServiceServer) SetNetIfaceQueues(ctx context.Context, req *pb.SetNetIfaceQueuesRequest) (*empty.Empty, error)

func (*ServiceServer) SetNetIfaceUpScript 

func (s *ServiceServer) SetNetIfaceUpScript(ctx context.Context, req *pb.SetNetIfaceScriptRequest) (*empty.Empty, error)

func (*ServiceServer) Start 

func (s *ServiceServer) Start(ctx context.Context, req *pb.StartMachineRequest) (*empty.Empty, error)

func (*ServiceServer) StartDiskBackupProcess 

func (s *ServiceServer) StartDiskBackupProcess(ctx context.Context, req *pb.StartDiskBackupRequest) (*pb.StartBackupResponse, error)

func (*ServiceServer) StartMigrationProcess 

func (s *ServiceServer) StartMigrationProcess(ctx context.Context, req *pb.StartMigrationRequest) (*pb.StartMigrationResponse, error)

func (*ServiceServer) Stop 

func (s *ServiceServer) Stop(ctx context.Context, req *pb.StopMachineRequest) (*empty.Empty, error)

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.