Versions in this module Expand all Collapse all v0 v0.1.1 Oct 2, 2018 Changes in this version + const AnnotationBlockStoragePath + func RegisterBlockStorageAgentServiceServer(s *grpc.Server, srv BlockStorageAgentServiceServer) + type BlockStorageAPI struct + func CreateBlockStorageAPI(ds datastore.Datastore, na ppool.NodeServiceClient) (*BlockStorageAPI, error) + func (a *BlockStorageAPI) CopyBlockStorage(ctx context.Context, req *pprovisioning.CopyBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) CreateBlockStorage(ctx context.Context, req *pprovisioning.CreateBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) DeleteBlockStorage(ctx context.Context, req *pprovisioning.DeleteBlockStorageRequest) (*empty.Empty, error) + func (a *BlockStorageAPI) FetchBlockStorage(ctx context.Context, req *pprovisioning.FetchBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) GetBlockStorage(ctx context.Context, req *pprovisioning.GetBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) ListBlockStorages(ctx context.Context, req *pprovisioning.ListBlockStoragesRequest) (*pprovisioning.ListBlockStoragesResponse, error) + func (a *BlockStorageAPI) SetAvailableBlockStorage(ctx context.Context, req *pprovisioning.SetAvailableBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) SetInuseBlockStorage(ctx context.Context, req *pprovisioning.SetInuseBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) SetProtectedBlockStorage(ctx context.Context, req *pprovisioning.SetProtectedBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) UpdateBlockStorage(ctx context.Context, req *pprovisioning.UpdateBlockStorageRequest) (*pprovisioning.BlockStorage, error) + type BlockStorageAgent struct + Bytes uint64 + Name string + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BlockStorageAgent) Descriptor() ([]byte, []int) + func (*BlockStorageAgent) ProtoMessage() + func (dst *BlockStorageAgent) XXX_Merge(src proto.Message) + func (m *BlockStorageAgent) GetBytes() uint64 + func (m *BlockStorageAgent) GetName() string + func (m *BlockStorageAgent) GetPath() string + func (m *BlockStorageAgent) Reset() + func (m *BlockStorageAgent) String() string + func (m *BlockStorageAgent) XXX_DiscardUnknown() + func (m *BlockStorageAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BlockStorageAgent) XXX_Size() int + func (m *BlockStorageAgent) XXX_Unmarshal(b []byte) error + type BlockStorageAgentAPI struct + func CreateBlockStorageAgentAPI(basedir string) (*BlockStorageAgentAPI, error) + func (a *BlockStorageAgentAPI) CreateBlockStorageAgentWithDownloading(ctx context.Context, req *CreateBlockStorageAgentWithDownloadingRequest) (*BlockStorageAgent, error) + func (a *BlockStorageAgentAPI) CreateEmptyBlockStorageAgent(ctx context.Context, req *CreateEmptyBlockStorageAgentRequest) (*BlockStorageAgent, error) + func (a *BlockStorageAgentAPI) DeleteBlockStorageAgent(ctx context.Context, req *DeleteBlockStorageAgentRequest) (*empty.Empty, error) + type BlockStorageAgentServiceClient interface + CreateBlockStorageAgentWithDownloading func(ctx context.Context, in *CreateBlockStorageAgentWithDownloadingRequest, ...) (*BlockStorageAgent, error) + CreateEmptyBlockStorageAgent func(ctx context.Context, in *CreateEmptyBlockStorageAgentRequest, ...) (*BlockStorageAgent, error) + DeleteBlockStorageAgent func(ctx context.Context, in *DeleteBlockStorageAgentRequest, ...) (*empty.Empty, error) + func NewBlockStorageAgentServiceClient(cc *grpc.ClientConn) BlockStorageAgentServiceClient + type BlockStorageAgentServiceServer interface + CreateBlockStorageAgentWithDownloading func(context.Context, *CreateBlockStorageAgentWithDownloadingRequest) (*BlockStorageAgent, error) + CreateEmptyBlockStorageAgent func(context.Context, *CreateEmptyBlockStorageAgentRequest) (*BlockStorageAgent, error) + DeleteBlockStorageAgent func(context.Context, *DeleteBlockStorageAgentRequest) (*empty.Empty, error) + type CreateBlockStorageAgentWithDownloadingRequest struct + Bytes uint64 + Name string + SourceUrl string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateBlockStorageAgentWithDownloadingRequest) Descriptor() ([]byte, []int) + func (*CreateBlockStorageAgentWithDownloadingRequest) ProtoMessage() + func (dst *CreateBlockStorageAgentWithDownloadingRequest) XXX_Merge(src proto.Message) + func (m *CreateBlockStorageAgentWithDownloadingRequest) GetBytes() uint64 + func (m *CreateBlockStorageAgentWithDownloadingRequest) GetName() string + func (m *CreateBlockStorageAgentWithDownloadingRequest) GetSourceUrl() string + func (m *CreateBlockStorageAgentWithDownloadingRequest) Reset() + func (m *CreateBlockStorageAgentWithDownloadingRequest) String() string + func (m *CreateBlockStorageAgentWithDownloadingRequest) XXX_DiscardUnknown() + func (m *CreateBlockStorageAgentWithDownloadingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateBlockStorageAgentWithDownloadingRequest) XXX_Size() int + func (m *CreateBlockStorageAgentWithDownloadingRequest) XXX_Unmarshal(b []byte) error + type CreateEmptyBlockStorageAgentRequest struct + Bytes uint64 + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateEmptyBlockStorageAgentRequest) Descriptor() ([]byte, []int) + func (*CreateEmptyBlockStorageAgentRequest) ProtoMessage() + func (dst *CreateEmptyBlockStorageAgentRequest) XXX_Merge(src proto.Message) + func (m *CreateEmptyBlockStorageAgentRequest) GetBytes() uint64 + func (m *CreateEmptyBlockStorageAgentRequest) GetName() string + func (m *CreateEmptyBlockStorageAgentRequest) Reset() + func (m *CreateEmptyBlockStorageAgentRequest) String() string + func (m *CreateEmptyBlockStorageAgentRequest) XXX_DiscardUnknown() + func (m *CreateEmptyBlockStorageAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateEmptyBlockStorageAgentRequest) XXX_Size() int + func (m *CreateEmptyBlockStorageAgentRequest) XXX_Unmarshal(b []byte) error + type DeleteBlockStorageAgentRequest struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteBlockStorageAgentRequest) Descriptor() ([]byte, []int) + func (*DeleteBlockStorageAgentRequest) ProtoMessage() + func (dst *DeleteBlockStorageAgentRequest) XXX_Merge(src proto.Message) + func (m *DeleteBlockStorageAgentRequest) GetPath() string + func (m *DeleteBlockStorageAgentRequest) Reset() + func (m *DeleteBlockStorageAgentRequest) String() string + func (m *DeleteBlockStorageAgentRequest) XXX_DiscardUnknown() + func (m *DeleteBlockStorageAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteBlockStorageAgentRequest) XXX_Size() int + func (m *DeleteBlockStorageAgentRequest) XXX_Unmarshal(b []byte) error + type MockBlockStorageAgentAPI struct + func (a MockBlockStorageAgentAPI) CreateBlockStorageAgentWithDownloading(ctx context.Context, req *CreateBlockStorageAgentWithDownloadingRequest) (*BlockStorageAgent, error) + func (a MockBlockStorageAgentAPI) CreateEmptyBlockStorageAgent(ctx context.Context, req *CreateEmptyBlockStorageAgentRequest) (*BlockStorageAgent, error) + func (a MockBlockStorageAgentAPI) DeleteBlockStorageAgent(ctx context.Context, req *DeleteBlockStorageAgentRequest) (*empty.Empty, error) + type MockVirtualMachineAgentAPI struct + func (a *MockVirtualMachineAgentAPI) BootVirtualMachineAgent(ctx context.Context, req *BootVirtualMachineAgentRequest) (*BootVirtualMachineAgentResponse, error) + func (a *MockVirtualMachineAgentAPI) CreateVirtualMachineAgent(ctx context.Context, req *CreateVirtualMachineAgentRequest) (*VirtualMachineAgent, error) + func (a *MockVirtualMachineAgentAPI) DeleteVirtualMachineAgent(ctx context.Context, req *DeleteVirtualMachineAgentRequest) (*empty.Empty, error) + func (a *MockVirtualMachineAgentAPI) RebootVirtualMachineAgent(ctx context.Context, req *RebootVirtualMachineAgentRequest) (*RebootVirtualMachineAgentResponse, error) + func (a *MockVirtualMachineAgentAPI) ShutdownVirtualMachineAgent(ctx context.Context, req *ShutdownVirtualMachineAgentRequest) (*ShutdownVirtualMachineAgentResponse, error) v0.1.0 Sep 25, 2018 Changes in this version + const AnnotationRequestNodeName + const AnnotationVNCWebSocketPort + const AnnotationVolumePath + const QMPMonitorSocketFile + const VNCWebSocketPortOffset + var N0coreVirtualMachineNamespace uuid.UUID + var VirtualMachineAgentState_name = map[int32]string + var VirtualMachineAgentState_value = map[string]int32 + func GetAPIStateFromAgentState(s VirtualMachineAgentState) pprovisioning.VirtualMachineStatus_VirtualMachineState + func RegisterVirtualMachineAgentServiceServer(s *grpc.Server, srv VirtualMachineAgentServiceServer) + func RegisterVolumeAgentServiceServer(s *grpc.Server, srv VolumeAgentServiceServer) + func TrimNetdevName(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 (dst *BlockDev) XXX_Merge(src proto.Message) + 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_Size() int + func (m *BlockDev) XXX_Unmarshal(b []byte) error + type BootVirtualMachineAgentRequest struct + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BootVirtualMachineAgentRequest) Descriptor() ([]byte, []int) + func (*BootVirtualMachineAgentRequest) ProtoMessage() + func (dst *BootVirtualMachineAgentRequest) XXX_Merge(src proto.Message) + func (m *BootVirtualMachineAgentRequest) GetName() string + func (m *BootVirtualMachineAgentRequest) Reset() + func (m *BootVirtualMachineAgentRequest) String() string + func (m *BootVirtualMachineAgentRequest) XXX_DiscardUnknown() + func (m *BootVirtualMachineAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BootVirtualMachineAgentRequest) XXX_Size() int + func (m *BootVirtualMachineAgentRequest) XXX_Unmarshal(b []byte) error + type BootVirtualMachineAgentResponse struct + State VirtualMachineAgentState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BootVirtualMachineAgentResponse) Descriptor() ([]byte, []int) + func (*BootVirtualMachineAgentResponse) ProtoMessage() + func (dst *BootVirtualMachineAgentResponse) XXX_Merge(src proto.Message) + func (m *BootVirtualMachineAgentResponse) GetState() VirtualMachineAgentState + func (m *BootVirtualMachineAgentResponse) Reset() + func (m *BootVirtualMachineAgentResponse) String() string + func (m *BootVirtualMachineAgentResponse) XXX_DiscardUnknown() + func (m *BootVirtualMachineAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BootVirtualMachineAgentResponse) XXX_Size() int + func (m *BootVirtualMachineAgentResponse) XXX_Unmarshal(b []byte) error + type CreateEmptyVolumeAgentRequest struct + Bytes uint64 + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateEmptyVolumeAgentRequest) Descriptor() ([]byte, []int) + func (*CreateEmptyVolumeAgentRequest) ProtoMessage() + func (dst *CreateEmptyVolumeAgentRequest) XXX_Merge(src proto.Message) + func (m *CreateEmptyVolumeAgentRequest) GetBytes() uint64 + func (m *CreateEmptyVolumeAgentRequest) GetName() string + func (m *CreateEmptyVolumeAgentRequest) Reset() + func (m *CreateEmptyVolumeAgentRequest) String() string + func (m *CreateEmptyVolumeAgentRequest) XXX_DiscardUnknown() + func (m *CreateEmptyVolumeAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateEmptyVolumeAgentRequest) XXX_Size() int + func (m *CreateEmptyVolumeAgentRequest) XXX_Unmarshal(b []byte) error + type CreateVirtualMachineAgentRequest struct + Blockdev []*BlockDev + MemoryBytes uint64 + Name string + Netdev []*NetDev + Vcpus uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateVirtualMachineAgentRequest) Descriptor() ([]byte, []int) + func (*CreateVirtualMachineAgentRequest) ProtoMessage() + func (dst *CreateVirtualMachineAgentRequest) XXX_Merge(src proto.Message) + func (m *CreateVirtualMachineAgentRequest) GetBlockdev() []*BlockDev + func (m *CreateVirtualMachineAgentRequest) GetMemoryBytes() uint64 + func (m *CreateVirtualMachineAgentRequest) GetName() string + func (m *CreateVirtualMachineAgentRequest) GetNetdev() []*NetDev + func (m *CreateVirtualMachineAgentRequest) GetVcpus() uint32 + func (m *CreateVirtualMachineAgentRequest) Reset() + func (m *CreateVirtualMachineAgentRequest) String() string + func (m *CreateVirtualMachineAgentRequest) XXX_DiscardUnknown() + func (m *CreateVirtualMachineAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateVirtualMachineAgentRequest) XXX_Size() int + func (m *CreateVirtualMachineAgentRequest) XXX_Unmarshal(b []byte) error + type CreateVolumeAgentWithDownloadingRequest struct + Bytes uint64 + Name string + SourceUrl string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateVolumeAgentWithDownloadingRequest) Descriptor() ([]byte, []int) + func (*CreateVolumeAgentWithDownloadingRequest) ProtoMessage() + func (dst *CreateVolumeAgentWithDownloadingRequest) XXX_Merge(src proto.Message) + func (m *CreateVolumeAgentWithDownloadingRequest) GetBytes() uint64 + func (m *CreateVolumeAgentWithDownloadingRequest) GetName() string + func (m *CreateVolumeAgentWithDownloadingRequest) GetSourceUrl() string + func (m *CreateVolumeAgentWithDownloadingRequest) Reset() + func (m *CreateVolumeAgentWithDownloadingRequest) String() string + func (m *CreateVolumeAgentWithDownloadingRequest) XXX_DiscardUnknown() + func (m *CreateVolumeAgentWithDownloadingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateVolumeAgentWithDownloadingRequest) XXX_Size() int + func (m *CreateVolumeAgentWithDownloadingRequest) XXX_Unmarshal(b []byte) error + type DeleteVirtualMachineAgentRequest struct + Name string + Netdev []*NetDev + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteVirtualMachineAgentRequest) Descriptor() ([]byte, []int) + func (*DeleteVirtualMachineAgentRequest) ProtoMessage() + func (dst *DeleteVirtualMachineAgentRequest) XXX_Merge(src proto.Message) + func (m *DeleteVirtualMachineAgentRequest) GetName() string + func (m *DeleteVirtualMachineAgentRequest) GetNetdev() []*NetDev + func (m *DeleteVirtualMachineAgentRequest) Reset() + func (m *DeleteVirtualMachineAgentRequest) String() string + func (m *DeleteVirtualMachineAgentRequest) XXX_DiscardUnknown() + func (m *DeleteVirtualMachineAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteVirtualMachineAgentRequest) XXX_Size() int + func (m *DeleteVirtualMachineAgentRequest) XXX_Unmarshal(b []byte) error + type DeleteVolumeAgentRequest struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteVolumeAgentRequest) Descriptor() ([]byte, []int) + func (*DeleteVolumeAgentRequest) ProtoMessage() + func (dst *DeleteVolumeAgentRequest) XXX_Merge(src proto.Message) + func (m *DeleteVolumeAgentRequest) GetPath() string + func (m *DeleteVolumeAgentRequest) Reset() + func (m *DeleteVolumeAgentRequest) String() string + func (m *DeleteVolumeAgentRequest) XXX_DiscardUnknown() + func (m *DeleteVolumeAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteVolumeAgentRequest) XXX_Size() int + func (m *DeleteVolumeAgentRequest) XXX_Unmarshal(b []byte) error + type NetDev struct + HardwareAddress string + Name string + NetworkName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func StructNetDev(nics []*pprovisioning.VirtualMachineSpec_NIC, names []string) []*NetDev + func (*NetDev) Descriptor() ([]byte, []int) + func (*NetDev) ProtoMessage() + func (dst *NetDev) XXX_Merge(src proto.Message) + func (m *NetDev) GetHardwareAddress() string + func (m *NetDev) GetName() 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_Size() int + func (m *NetDev) XXX_Unmarshal(b []byte) error + type RebootVirtualMachineAgentRequest struct + Hard bool + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RebootVirtualMachineAgentRequest) Descriptor() ([]byte, []int) + func (*RebootVirtualMachineAgentRequest) ProtoMessage() + func (dst *RebootVirtualMachineAgentRequest) XXX_Merge(src proto.Message) + func (m *RebootVirtualMachineAgentRequest) GetHard() bool + func (m *RebootVirtualMachineAgentRequest) GetName() string + func (m *RebootVirtualMachineAgentRequest) Reset() + func (m *RebootVirtualMachineAgentRequest) String() string + func (m *RebootVirtualMachineAgentRequest) XXX_DiscardUnknown() + func (m *RebootVirtualMachineAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RebootVirtualMachineAgentRequest) XXX_Size() int + func (m *RebootVirtualMachineAgentRequest) XXX_Unmarshal(b []byte) error + type RebootVirtualMachineAgentResponse struct + State VirtualMachineAgentState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RebootVirtualMachineAgentResponse) Descriptor() ([]byte, []int) + func (*RebootVirtualMachineAgentResponse) ProtoMessage() + func (dst *RebootVirtualMachineAgentResponse) XXX_Merge(src proto.Message) + func (m *RebootVirtualMachineAgentResponse) GetState() VirtualMachineAgentState + func (m *RebootVirtualMachineAgentResponse) Reset() + func (m *RebootVirtualMachineAgentResponse) String() string + func (m *RebootVirtualMachineAgentResponse) XXX_DiscardUnknown() + func (m *RebootVirtualMachineAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RebootVirtualMachineAgentResponse) XXX_Size() int + func (m *RebootVirtualMachineAgentResponse) XXX_Unmarshal(b []byte) error + type ShutdownVirtualMachineAgentRequest struct + Hard bool + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShutdownVirtualMachineAgentRequest) Descriptor() ([]byte, []int) + func (*ShutdownVirtualMachineAgentRequest) ProtoMessage() + func (dst *ShutdownVirtualMachineAgentRequest) XXX_Merge(src proto.Message) + func (m *ShutdownVirtualMachineAgentRequest) GetHard() bool + func (m *ShutdownVirtualMachineAgentRequest) GetName() string + func (m *ShutdownVirtualMachineAgentRequest) Reset() + func (m *ShutdownVirtualMachineAgentRequest) String() string + func (m *ShutdownVirtualMachineAgentRequest) XXX_DiscardUnknown() + func (m *ShutdownVirtualMachineAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShutdownVirtualMachineAgentRequest) XXX_Size() int + func (m *ShutdownVirtualMachineAgentRequest) XXX_Unmarshal(b []byte) error + type ShutdownVirtualMachineAgentResponse struct + State VirtualMachineAgentState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShutdownVirtualMachineAgentResponse) Descriptor() ([]byte, []int) + func (*ShutdownVirtualMachineAgentResponse) ProtoMessage() + func (dst *ShutdownVirtualMachineAgentResponse) XXX_Merge(src proto.Message) + func (m *ShutdownVirtualMachineAgentResponse) GetState() VirtualMachineAgentState + func (m *ShutdownVirtualMachineAgentResponse) Reset() + func (m *ShutdownVirtualMachineAgentResponse) String() string + func (m *ShutdownVirtualMachineAgentResponse) XXX_DiscardUnknown() + func (m *ShutdownVirtualMachineAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShutdownVirtualMachineAgentResponse) XXX_Size() int + func (m *ShutdownVirtualMachineAgentResponse) XXX_Unmarshal(b []byte) error + type VirtualMachineAPI struct + func CreateVirtualMachineAPI(ds datastore.Datastore, noa ppool.NodeServiceClient, ...) (*VirtualMachineAPI, error) + func (a *VirtualMachineAPI) BootVirtualMachine(ctx context.Context, req *pprovisioning.BootVirtualMachineRequest) (*pprovisioning.VirtualMachine, error) + func (a *VirtualMachineAPI) CreateVirtualMachine(ctx context.Context, req *pprovisioning.ApplyVirtualMachineRequest) (*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) 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 + Blockdev []*BlockDev + MemoryBytes uint64 + Name string + Netdev []*NetDev + State VirtualMachineAgentState + Uuid string + Vcpus uint32 + WebsocketPort uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VirtualMachineAgent) Descriptor() ([]byte, []int) + func (*VirtualMachineAgent) ProtoMessage() + func (dst *VirtualMachineAgent) XXX_Merge(src proto.Message) + func (m *VirtualMachineAgent) GetBlockdev() []*BlockDev + func (m *VirtualMachineAgent) GetMemoryBytes() uint64 + func (m *VirtualMachineAgent) GetName() string + func (m *VirtualMachineAgent) GetNetdev() []*NetDev + func (m *VirtualMachineAgent) GetState() VirtualMachineAgentState + func (m *VirtualMachineAgent) GetUuid() string + func (m *VirtualMachineAgent) GetVcpus() uint32 + func (m *VirtualMachineAgent) GetWebsocketPort() uint32 + func (m *VirtualMachineAgent) Reset() + func (m *VirtualMachineAgent) String() string + func (m *VirtualMachineAgent) XXX_DiscardUnknown() + func (m *VirtualMachineAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VirtualMachineAgent) XXX_Size() int + func (m *VirtualMachineAgent) XXX_Unmarshal(b []byte) error + type VirtualMachineAgentAPI struct + func CreateVirtualMachineAgentAPI(basedir string) (*VirtualMachineAgentAPI, error) + func (a VirtualMachineAgentAPI) BootVirtualMachineAgent(ctx context.Context, req *BootVirtualMachineAgentRequest) (*BootVirtualMachineAgentResponse, error) + func (a VirtualMachineAgentAPI) CreateVirtualMachineAgent(ctx context.Context, req *CreateVirtualMachineAgentRequest) (*VirtualMachineAgent, error) + func (a VirtualMachineAgentAPI) DeleteVirtualMachineAgent(ctx context.Context, req *DeleteVirtualMachineAgentRequest) (*empty.Empty, error) + func (a VirtualMachineAgentAPI) GetWorkDirectory(name string) (string, error) + func (a VirtualMachineAgentAPI) RebootVirtualMachineAgent(ctx context.Context, req *RebootVirtualMachineAgentRequest) (*RebootVirtualMachineAgentResponse, error) + func (a VirtualMachineAgentAPI) ShutdownVirtualMachineAgent(ctx context.Context, req *ShutdownVirtualMachineAgentRequest) (*ShutdownVirtualMachineAgentResponse, error) + type VirtualMachineAgentServiceClient interface + BootVirtualMachineAgent func(ctx context.Context, in *BootVirtualMachineAgentRequest, ...) (*BootVirtualMachineAgentResponse, error) + CreateVirtualMachineAgent func(ctx context.Context, in *CreateVirtualMachineAgentRequest, ...) (*VirtualMachineAgent, error) + DeleteVirtualMachineAgent func(ctx context.Context, in *DeleteVirtualMachineAgentRequest, ...) (*empty.Empty, error) + RebootVirtualMachineAgent func(ctx context.Context, in *RebootVirtualMachineAgentRequest, ...) (*RebootVirtualMachineAgentResponse, error) + ShutdownVirtualMachineAgent func(ctx context.Context, in *ShutdownVirtualMachineAgentRequest, ...) (*ShutdownVirtualMachineAgentResponse, error) + func NewVirtualMachineAgentServiceClient(cc *grpc.ClientConn) VirtualMachineAgentServiceClient + type VirtualMachineAgentServiceServer interface + BootVirtualMachineAgent func(context.Context, *BootVirtualMachineAgentRequest) (*BootVirtualMachineAgentResponse, error) + CreateVirtualMachineAgent func(context.Context, *CreateVirtualMachineAgentRequest) (*VirtualMachineAgent, error) + DeleteVirtualMachineAgent func(context.Context, *DeleteVirtualMachineAgentRequest) (*empty.Empty, error) + RebootVirtualMachineAgent func(context.Context, *RebootVirtualMachineAgentRequest) (*RebootVirtualMachineAgentResponse, error) + ShutdownVirtualMachineAgent func(context.Context, *ShutdownVirtualMachineAgentRequest) (*ShutdownVirtualMachineAgentResponse, error) + type VirtualMachineAgentState int32 + const VirtualMachineAgentState_FAILED + const VirtualMachineAgentState_PAUSED + const VirtualMachineAgentState_RUNNING + const VirtualMachineAgentState_SHUTDOWN + const VirtualMachineAgentState_UNKNOWN + func GetAgentStateFromQemuState(s qemu.Status) VirtualMachineAgentState + func (VirtualMachineAgentState) EnumDescriptor() ([]byte, []int) + func (x VirtualMachineAgentState) String() string + type VolumeAPI struct + func CreateVolumeAPI(ds datastore.Datastore, na ppool.NodeServiceClient) (*VolumeAPI, error) + func (a *VolumeAPI) CreateEmptyVolume(ctx context.Context, req *pprovisioning.CreateEmptyVolumeRequest) (*pprovisioning.Volume, error) + func (a *VolumeAPI) CreateVolumeWithDownloading(ctx context.Context, req *pprovisioning.CreateVolumeWithDownloadingRequest) (*pprovisioning.Volume, error) + func (a *VolumeAPI) DeleteVolume(ctx context.Context, req *pprovisioning.DeleteVolumeRequest) (*empty.Empty, error) + func (a *VolumeAPI) GetVolume(ctx context.Context, req *pprovisioning.GetVolumeRequest) (*pprovisioning.Volume, error) + func (a *VolumeAPI) ListVolumes(ctx context.Context, req *pprovisioning.ListVolumesRequest) (*pprovisioning.ListVolumesResponse, error) + func (a *VolumeAPI) SetAvailableVolume(ctx context.Context, req *pprovisioning.SetAvailableVolumeRequest) (*pprovisioning.Volume, error) + func (a *VolumeAPI) SetInuseVolume(ctx context.Context, req *pprovisioning.SetInuseVolumeRequest) (*pprovisioning.Volume, error) + func (a *VolumeAPI) UpdateVolume(ctx context.Context, req *pprovisioning.UpdateVolumeRequest) (*pprovisioning.Volume, error) + type VolumeAgent struct + Bytes uint64 + Name string + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VolumeAgent) Descriptor() ([]byte, []int) + func (*VolumeAgent) ProtoMessage() + func (dst *VolumeAgent) XXX_Merge(src proto.Message) + func (m *VolumeAgent) GetBytes() uint64 + func (m *VolumeAgent) GetName() string + func (m *VolumeAgent) GetPath() string + func (m *VolumeAgent) Reset() + func (m *VolumeAgent) String() string + func (m *VolumeAgent) XXX_DiscardUnknown() + func (m *VolumeAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeAgent) XXX_Size() int + func (m *VolumeAgent) XXX_Unmarshal(b []byte) error + type VolumeAgentAPI struct + func CreateVolumeAgentAPI(basedir string) (*VolumeAgentAPI, error) + func (a *VolumeAgentAPI) CreateEmptyVolumeAgent(ctx context.Context, req *CreateEmptyVolumeAgentRequest) (*VolumeAgent, error) + func (a *VolumeAgentAPI) CreateVolumeAgentWithDownloading(ctx context.Context, req *CreateVolumeAgentWithDownloadingRequest) (*VolumeAgent, error) + func (a *VolumeAgentAPI) DeleteVolumeAgent(ctx context.Context, req *DeleteVolumeAgentRequest) (*empty.Empty, error) + type VolumeAgentServiceClient interface + CreateEmptyVolumeAgent func(ctx context.Context, in *CreateEmptyVolumeAgentRequest, ...) (*VolumeAgent, error) + CreateVolumeAgentWithDownloading func(ctx context.Context, in *CreateVolumeAgentWithDownloadingRequest, ...) (*VolumeAgent, error) + DeleteVolumeAgent func(ctx context.Context, in *DeleteVolumeAgentRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func NewVolumeAgentServiceClient(cc *grpc.ClientConn) VolumeAgentServiceClient + type VolumeAgentServiceServer interface + CreateEmptyVolumeAgent func(context.Context, *CreateEmptyVolumeAgentRequest) (*VolumeAgent, error) + CreateVolumeAgentWithDownloading func(context.Context, *CreateVolumeAgentWithDownloadingRequest) (*VolumeAgent, error) + DeleteVolumeAgent func(context.Context, *DeleteVolumeAgentRequest) (*empty.Empty, error)
Go to main page