Versions in this module Expand all Collapse all v0 v0.2.134 Dec 25, 2019 Changes in this version + const AnnotationComputeReservedBy + const AnnotationNetworkInterfaceIsGateway + const AnnotationVirtualMachineNICIsGateway + const AnnotationVirtualMachineRequestNodeName + const AnnotationVirtualMachineVncWebSocketPort + const QmpMonitorSocketFile + const VNCWebSocketPortOffset + var N0coreVirtualMachineNamespace uuid.UUID + var VirtualMachineState_name = map[int32]string + var VirtualMachineState_value = map[string]int32 + func GetAPIStateFromAgentState(s VirtualMachineState) pprovisioning.VirtualMachine_VirtualMachineState + func RegisterVirtualMachineAgentServiceServer(s *grpc.Server, srv VirtualMachineAgentServiceServer) + func SetPrefix(name string) string + type BlockDev struct + BootIndex uint32 + Name string + Url string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BlockDev) Descriptor() ([]byte, []int) + func (*BlockDev) ProtoMessage() + func (m *BlockDev) GetBootIndex() uint32 + func (m *BlockDev) GetName() string + func (m *BlockDev) GetUrl() string + func (m *BlockDev) Reset() + func (m *BlockDev) String() string + func (m *BlockDev) XXX_DiscardUnknown() + func (m *BlockDev) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BlockDev) XXX_Merge(src proto.Message) + func (m *BlockDev) XXX_Size() int + func (m *BlockDev) XXX_Unmarshal(b []byte) error + type BootVirtualMachineRequest struct + Blockdevs []*BlockDev + LoginUsername string + MemoryBytes uint64 + Name string + Netdevs []*NetDev + SshAuthorizedKeys []string + Uuid string + Vcpus uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BootVirtualMachineRequest) Descriptor() ([]byte, []int) + func (*BootVirtualMachineRequest) ProtoMessage() + func (m *BootVirtualMachineRequest) GetBlockdevs() []*BlockDev + func (m *BootVirtualMachineRequest) GetLoginUsername() string + func (m *BootVirtualMachineRequest) GetMemoryBytes() uint64 + func (m *BootVirtualMachineRequest) GetName() string + func (m *BootVirtualMachineRequest) GetNetdevs() []*NetDev + func (m *BootVirtualMachineRequest) GetSshAuthorizedKeys() []string + func (m *BootVirtualMachineRequest) GetUuid() string + func (m *BootVirtualMachineRequest) GetVcpus() uint32 + func (m *BootVirtualMachineRequest) Reset() + func (m *BootVirtualMachineRequest) String() string + func (m *BootVirtualMachineRequest) XXX_DiscardUnknown() + func (m *BootVirtualMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BootVirtualMachineRequest) XXX_Merge(src proto.Message) + func (m *BootVirtualMachineRequest) XXX_Size() int + func (m *BootVirtualMachineRequest) XXX_Unmarshal(b []byte) error + type BootVirtualMachineResponse struct + State VirtualMachineState + WebsocketPort uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BootVirtualMachineResponse) Descriptor() ([]byte, []int) + func (*BootVirtualMachineResponse) ProtoMessage() + func (m *BootVirtualMachineResponse) GetState() VirtualMachineState + func (m *BootVirtualMachineResponse) GetWebsocketPort() uint32 + func (m *BootVirtualMachineResponse) Reset() + func (m *BootVirtualMachineResponse) String() string + func (m *BootVirtualMachineResponse) XXX_DiscardUnknown() + func (m *BootVirtualMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BootVirtualMachineResponse) XXX_Merge(src proto.Message) + func (m *BootVirtualMachineResponse) XXX_Size() int + func (m *BootVirtualMachineResponse) XXX_Unmarshal(b []byte) error + type DeleteVirtualMachineRequest struct + Name string + Netdevs []*NetDev + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteVirtualMachineRequest) Descriptor() ([]byte, []int) + func (*DeleteVirtualMachineRequest) ProtoMessage() + func (m *DeleteVirtualMachineRequest) GetName() string + func (m *DeleteVirtualMachineRequest) GetNetdevs() []*NetDev + func (m *DeleteVirtualMachineRequest) Reset() + func (m *DeleteVirtualMachineRequest) String() string + func (m *DeleteVirtualMachineRequest) XXX_DiscardUnknown() + func (m *DeleteVirtualMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteVirtualMachineRequest) XXX_Merge(src proto.Message) + func (m *DeleteVirtualMachineRequest) XXX_Size() int + func (m *DeleteVirtualMachineRequest) XXX_Unmarshal(b []byte) error + type MockVirtualMachineAPI struct + BlockStorageAPI *blockstorage.MockBlockStorageAPI + NetworkAPI *network.MockNetworkAPI + NodeAPI *node.MockNodeAPI + func NewMockVirtualMachineAPI(datastore *memory.MemoryDatastore) *MockVirtualMachineAPI + func (a MockVirtualMachineAPI) BootVirtualMachine(ctx context.Context, in *pprovisioning.BootVirtualMachineRequest, ...) (*pprovisioning.VirtualMachine, error) + func (a MockVirtualMachineAPI) CreateVirtualMachine(ctx context.Context, in *pprovisioning.CreateVirtualMachineRequest, ...) (*pprovisioning.VirtualMachine, error) + func (a MockVirtualMachineAPI) DeleteVirtualMachine(ctx context.Context, in *pprovisioning.DeleteVirtualMachineRequest, ...) (*empty.Empty, error) + func (a MockVirtualMachineAPI) GetVirtualMachine(ctx context.Context, in *pprovisioning.GetVirtualMachineRequest, ...) (*pprovisioning.VirtualMachine, error) + func (a MockVirtualMachineAPI) ListVirtualMachines(ctx context.Context, in *pprovisioning.ListVirtualMachinesRequest, ...) (*pprovisioning.ListVirtualMachinesResponse, error) + func (a MockVirtualMachineAPI) OpenConsole(ctx context.Context, in *pprovisioning.OpenConsoleRequest, ...) (*pprovisioning.OpenConsoleResponse, error) + func (a MockVirtualMachineAPI) RebootVirtualMachine(ctx context.Context, in *pprovisioning.RebootVirtualMachineRequest, ...) (*pprovisioning.VirtualMachine, error) + func (a MockVirtualMachineAPI) SaveVirtualMachine(ctx context.Context, in *pprovisioning.SaveVirtualMachineRequest, ...) (*pprovisioning.VirtualMachine, error) + func (a MockVirtualMachineAPI) ShutdownVirtualMachine(ctx context.Context, in *pprovisioning.ShutdownVirtualMachineRequest, ...) (*pprovisioning.VirtualMachine, error) + func (a MockVirtualMachineAPI) UpdateVirtualMachine(ctx context.Context, in *pprovisioning.UpdateVirtualMachineRequest, ...) (*pprovisioning.VirtualMachine, error) + type MockVirtualMachineAgentClient struct + func NewMockVirtualMachineAgentClientMock() *MockVirtualMachineAgentClient + func (a MockVirtualMachineAgentClient) BootVirtualMachine(ctx context.Context, in *BootVirtualMachineRequest, opts ...grpc.CallOption) (*BootVirtualMachineResponse, error) + func (a MockVirtualMachineAgentClient) DeleteVirtualMachine(ctx context.Context, in *DeleteVirtualMachineRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (a MockVirtualMachineAgentClient) RebootVirtualMachine(ctx context.Context, in *RebootVirtualMachineRequest, opts ...grpc.CallOption) (*RebootVirtualMachineResponse, error) + func (a MockVirtualMachineAgentClient) ShutdownVirtualMachine(ctx context.Context, in *ShutdownVirtualMachineRequest, ...) (*ShutdownVirtualMachineResponse, error) + type NetDev struct + HardwareAddress string + Ipv4AddressCidr string + Ipv4Gateway string + Name string + Nameservers []string + NetworkName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NetDev) Descriptor() ([]byte, []int) + func (*NetDev) ProtoMessage() + func (m *NetDev) GetHardwareAddress() string + func (m *NetDev) GetIpv4AddressCidr() string + func (m *NetDev) GetIpv4Gateway() string + func (m *NetDev) GetName() string + func (m *NetDev) GetNameservers() []string + func (m *NetDev) GetNetworkName() string + func (m *NetDev) Reset() + func (m *NetDev) String() string + func (m *NetDev) XXX_DiscardUnknown() + func (m *NetDev) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NetDev) XXX_Merge(src proto.Message) + func (m *NetDev) XXX_Size() int + func (m *NetDev) XXX_Unmarshal(b []byte) error + type RebootVirtualMachineRequest struct + Hard bool + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RebootVirtualMachineRequest) Descriptor() ([]byte, []int) + func (*RebootVirtualMachineRequest) ProtoMessage() + func (m *RebootVirtualMachineRequest) GetHard() bool + func (m *RebootVirtualMachineRequest) GetName() string + func (m *RebootVirtualMachineRequest) Reset() + func (m *RebootVirtualMachineRequest) String() string + func (m *RebootVirtualMachineRequest) XXX_DiscardUnknown() + func (m *RebootVirtualMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RebootVirtualMachineRequest) XXX_Merge(src proto.Message) + func (m *RebootVirtualMachineRequest) XXX_Size() int + func (m *RebootVirtualMachineRequest) XXX_Unmarshal(b []byte) error + type RebootVirtualMachineResponse struct + State VirtualMachineState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RebootVirtualMachineResponse) Descriptor() ([]byte, []int) + func (*RebootVirtualMachineResponse) ProtoMessage() + func (m *RebootVirtualMachineResponse) GetState() VirtualMachineState + func (m *RebootVirtualMachineResponse) Reset() + func (m *RebootVirtualMachineResponse) String() string + func (m *RebootVirtualMachineResponse) XXX_DiscardUnknown() + func (m *RebootVirtualMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RebootVirtualMachineResponse) XXX_Merge(src proto.Message) + func (m *RebootVirtualMachineResponse) XXX_Size() int + func (m *RebootVirtualMachineResponse) XXX_Unmarshal(b []byte) error + type ShutdownVirtualMachineRequest struct + Hard bool + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShutdownVirtualMachineRequest) Descriptor() ([]byte, []int) + func (*ShutdownVirtualMachineRequest) ProtoMessage() + func (m *ShutdownVirtualMachineRequest) GetHard() bool + func (m *ShutdownVirtualMachineRequest) GetName() string + func (m *ShutdownVirtualMachineRequest) Reset() + func (m *ShutdownVirtualMachineRequest) String() string + func (m *ShutdownVirtualMachineRequest) XXX_DiscardUnknown() + func (m *ShutdownVirtualMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShutdownVirtualMachineRequest) XXX_Merge(src proto.Message) + func (m *ShutdownVirtualMachineRequest) XXX_Size() int + func (m *ShutdownVirtualMachineRequest) XXX_Unmarshal(b []byte) error + type ShutdownVirtualMachineResponse struct + State VirtualMachineState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShutdownVirtualMachineResponse) Descriptor() ([]byte, []int) + func (*ShutdownVirtualMachineResponse) ProtoMessage() + func (m *ShutdownVirtualMachineResponse) GetState() VirtualMachineState + func (m *ShutdownVirtualMachineResponse) Reset() + func (m *ShutdownVirtualMachineResponse) String() string + func (m *ShutdownVirtualMachineResponse) XXX_DiscardUnknown() + func (m *ShutdownVirtualMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShutdownVirtualMachineResponse) XXX_Merge(src proto.Message) + func (m *ShutdownVirtualMachineResponse) XXX_Size() int + func (m *ShutdownVirtualMachineResponse) XXX_Unmarshal(b []byte) error + type UnimplementedVirtualMachineAgentServiceServer struct + func (*UnimplementedVirtualMachineAgentServiceServer) BootVirtualMachine(ctx context.Context, req *BootVirtualMachineRequest) (*BootVirtualMachineResponse, error) + func (*UnimplementedVirtualMachineAgentServiceServer) DeleteVirtualMachine(ctx context.Context, req *DeleteVirtualMachineRequest) (*empty.Empty, error) + func (*UnimplementedVirtualMachineAgentServiceServer) RebootVirtualMachine(ctx context.Context, req *RebootVirtualMachineRequest) (*RebootVirtualMachineResponse, error) + func (*UnimplementedVirtualMachineAgentServiceServer) ShutdownVirtualMachine(ctx context.Context, req *ShutdownVirtualMachineRequest) (*ShutdownVirtualMachineResponse, error) + type VirtualMachineAPI struct + func CreateVirtualMachineAPI(ds datastore.Datastore, noa ppool.NodeServiceClient, ...) *VirtualMachineAPI + func (a *VirtualMachineAPI) BootVirtualMachine(ctx context.Context, req *pprovisioning.BootVirtualMachineRequest) (*pprovisioning.VirtualMachine, error) + func (a *VirtualMachineAPI) CreateVirtualMachine(ctx context.Context, req *pprovisioning.CreateVirtualMachineRequest) (*pprovisioning.VirtualMachine, error) + func (a *VirtualMachineAPI) DeleteVirtualMachine(ctx context.Context, req *pprovisioning.DeleteVirtualMachineRequest) (*empty.Empty, error) + func (a *VirtualMachineAPI) GetVirtualMachine(ctx context.Context, req *pprovisioning.GetVirtualMachineRequest) (*pprovisioning.VirtualMachine, error) + func (a *VirtualMachineAPI) ListVirtualMachines(ctx context.Context, req *pprovisioning.ListVirtualMachinesRequest) (*pprovisioning.ListVirtualMachinesResponse, error) + func (a *VirtualMachineAPI) OpenConsole(ctx context.Context, req *pprovisioning.OpenConsoleRequest) (*pprovisioning.OpenConsoleResponse, error) + func (a *VirtualMachineAPI) ProxyWebsocket() func(echo.Context) error + func (a *VirtualMachineAPI) RebootVirtualMachine(ctx context.Context, req *pprovisioning.RebootVirtualMachineRequest) (*pprovisioning.VirtualMachine, error) + func (a *VirtualMachineAPI) SaveVirtualMachine(ctx context.Context, req *pprovisioning.SaveVirtualMachineRequest) (*pprovisioning.VirtualMachine, error) + func (a *VirtualMachineAPI) ShutdownVirtualMachine(ctx context.Context, req *pprovisioning.ShutdownVirtualMachineRequest) (*pprovisioning.VirtualMachine, error) + func (a *VirtualMachineAPI) UpdateVirtualMachine(ctx context.Context, req *pprovisioning.UpdateVirtualMachineRequest) (*pprovisioning.VirtualMachine, error) + type VirtualMachineAgent struct + func CreateVirtualMachineAgent(basedir string) (*VirtualMachineAgent, error) + func (a VirtualMachineAgent) BootVirtualMachine(ctx context.Context, req *BootVirtualMachineRequest) (*BootVirtualMachineResponse, error) + func (a VirtualMachineAgent) DeleteVirtualMachine(ctx context.Context, req *DeleteVirtualMachineRequest) (*empty.Empty, error) + func (a VirtualMachineAgent) DeleteWorkDirectory(name string) error + func (a VirtualMachineAgent) GetWorkDirectory(name string) (string, error) + func (a VirtualMachineAgent) RebootVirtualMachine(ctx context.Context, req *RebootVirtualMachineRequest) (*RebootVirtualMachineResponse, error) + func (a VirtualMachineAgent) ShutdownVirtualMachine(ctx context.Context, req *ShutdownVirtualMachineRequest) (*ShutdownVirtualMachineResponse, error) + type VirtualMachineAgentMock struct + func (a VirtualMachineAgentMock) BootVirtualMachine(ctx context.Context, req *BootVirtualMachineRequest) (*BootVirtualMachineResponse, error) + func (a VirtualMachineAgentMock) DeleteVirtualMachine(ctx context.Context, req *DeleteVirtualMachineRequest) (*empty.Empty, error) + func (a VirtualMachineAgentMock) RebootVirtualMachine(ctx context.Context, req *RebootVirtualMachineRequest) (*RebootVirtualMachineResponse, error) + func (a VirtualMachineAgentMock) ShutdownVirtualMachine(ctx context.Context, req *ShutdownVirtualMachineRequest) (*ShutdownVirtualMachineResponse, error) + type VirtualMachineAgentServiceClient interface + BootVirtualMachine func(ctx context.Context, in *BootVirtualMachineRequest, opts ...grpc.CallOption) (*BootVirtualMachineResponse, error) + DeleteVirtualMachine func(ctx context.Context, in *DeleteVirtualMachineRequest, opts ...grpc.CallOption) (*empty.Empty, error) + RebootVirtualMachine func(ctx context.Context, in *RebootVirtualMachineRequest, opts ...grpc.CallOption) (*RebootVirtualMachineResponse, error) + ShutdownVirtualMachine func(ctx context.Context, in *ShutdownVirtualMachineRequest, ...) (*ShutdownVirtualMachineResponse, error) + func NewVirtualMachineAgentServiceClient(cc *grpc.ClientConn) VirtualMachineAgentServiceClient + type VirtualMachineAgentServiceServer interface + BootVirtualMachine func(context.Context, *BootVirtualMachineRequest) (*BootVirtualMachineResponse, error) + DeleteVirtualMachine func(context.Context, *DeleteVirtualMachineRequest) (*empty.Empty, error) + RebootVirtualMachine func(context.Context, *RebootVirtualMachineRequest) (*RebootVirtualMachineResponse, error) + ShutdownVirtualMachine func(context.Context, *ShutdownVirtualMachineRequest) (*ShutdownVirtualMachineResponse, error) + type VirtualMachineState int32 + const VirtualMachineState_FAILED + const VirtualMachineState_PAUSED + const VirtualMachineState_RUNNING + const VirtualMachineState_SHUTDOWN + const VirtualMachineState_UNKNOWN + func GetAgentStateFromQemuState(s qemu.Status) VirtualMachineState + func (VirtualMachineState) EnumDescriptor() ([]byte, []int) + func (x VirtualMachineState) String() string