virtualmachine

package
v0.2.134 Latest Latest
Warning

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

 Go to latest Published: Dec 25, 2019 License: BSD-2-Clause Imports: 38 Imported by: 0

Documentation

Overview

Package statik contains static assets.

Index

Constants

View Source 
const (
	QmpMonitorSocketFile   = "monitor.sock"
	VNCWebSocketPortOffset = 6900
)
View Source 
const AnnotationComputeReservedBy = "n0core/provisioning/virtual_machine/virtual_machine/reserved_by"
View Source 
const AnnotationNetworkInterfaceIsGateway = "n0core/provisioning/virtual_machine/is_gateway"
View Source 
const AnnotationVirtualMachineNICIsGateway = "n0core/provisioning/virtual_machine/is_gateway"
View Source 
const AnnotationVirtualMachineRequestNodeName = "n0core/provisioning/virtual_machine/request_node_name"
View Source 
const AnnotationVirtualMachineVncWebSocketPort = "n0core/provisioning/virtual_machine/vnc_websocket_port"

Variables

View Source 
var N0coreVirtualMachineNamespace uuid.UUID
View Source 
var VirtualMachineState_name = map[int32]string{
	0: "FAILED",
	1: "UNKNOWN",
	2: "SHUTDOWN",
	3: "RUNNING",
	4: "PAUSED",
}
View Source 
var VirtualMachineState_value = map[string]int32{
	"FAILED":   0,
	"UNKNOWN":  1,
	"SHUTDOWN": 2,
	"RUNNING":  3,
	"PAUSED":   4,
}

Functions

func GetAPIStateFromAgentState 

func GetAPIStateFromAgentState(s VirtualMachineState) pprovisioning.VirtualMachine_VirtualMachineState

func RegisterVirtualMachineAgentServiceServer 

func RegisterVirtualMachineAgentServiceServer(s *grpc.Server, srv VirtualMachineAgentServiceServer)

func SetPrefix 

func SetPrefix(name string) string

Types

type BlockDev 

type BlockDev struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url                  string   `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	BootIndex            uint32   `protobuf:"varint,3,opt,name=boot_index,json=bootIndex,proto3" json:"boot_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockDev) Descriptor 

func (*BlockDev) Descriptor() ([]byte, []int)

func (*BlockDev) GetBootIndex 

func (m *BlockDev) GetBootIndex() uint32

func (*BlockDev) GetName 

func (m *BlockDev) GetName() string

func (*BlockDev) GetUrl 

func (m *BlockDev) GetUrl() string

func (*BlockDev) ProtoMessage 

func (*BlockDev) ProtoMessage()

func (*BlockDev) Reset 

func (m *BlockDev) Reset()

func (*BlockDev) String 

func (m *BlockDev) String() string

func (*BlockDev) XXX_DiscardUnknown 

func (m *BlockDev) XXX_DiscardUnknown()

func (*BlockDev) XXX_Marshal 

func (m *BlockDev) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockDev) XXX_Merge 

func (m *BlockDev) XXX_Merge(src proto.Message)

func (*BlockDev) XXX_Size 

func (m *BlockDev) XXX_Size() int

func (*BlockDev) XXX_Unmarshal 

func (m *BlockDev) XXX_Unmarshal(b []byte) error

type BootVirtualMachineRequest 

type BootVirtualMachineRequest struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uuid                 string      `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Vcpus                uint32      `protobuf:"varint,3,opt,name=vcpus,proto3" json:"vcpus,omitempty"`
	MemoryBytes          uint64      `protobuf:"varint,4,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	Blockdevs            []*BlockDev `protobuf:"bytes,5,rep,name=blockdevs,proto3" json:"blockdevs,omitempty"`
	Netdevs              []*NetDev   `protobuf:"bytes,6,rep,name=netdevs,proto3" json:"netdevs,omitempty"`
	LoginUsername        string      `protobuf:"bytes,7,opt,name=login_username,json=loginUsername,proto3" json:"login_username,omitempty"`
	SshAuthorizedKeys    []string    `protobuf:"bytes,8,rep,name=ssh_authorized_keys,json=sshAuthorizedKeys,proto3" json:"ssh_authorized_keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*BootVirtualMachineRequest) Descriptor 

func (*BootVirtualMachineRequest) Descriptor() ([]byte, []int)

func (*BootVirtualMachineRequest) GetBlockdevs 

func (m *BootVirtualMachineRequest) GetBlockdevs() []*BlockDev

func (*BootVirtualMachineRequest) GetLoginUsername 

func (m *BootVirtualMachineRequest) GetLoginUsername() string

func (*BootVirtualMachineRequest) GetMemoryBytes 

func (m *BootVirtualMachineRequest) GetMemoryBytes() uint64

func (*BootVirtualMachineRequest) GetName 

func (m *BootVirtualMachineRequest) GetName() string

func (*BootVirtualMachineRequest) GetNetdevs 

func (m *BootVirtualMachineRequest) GetNetdevs() []*NetDev

func (*BootVirtualMachineRequest) GetSshAuthorizedKeys 

func (m *BootVirtualMachineRequest) GetSshAuthorizedKeys() []string

func (*BootVirtualMachineRequest) GetUuid 

func (m *BootVirtualMachineRequest) GetUuid() string

func (*BootVirtualMachineRequest) GetVcpus 

func (m *BootVirtualMachineRequest) GetVcpus() uint32

func (*BootVirtualMachineRequest) ProtoMessage 

func (*BootVirtualMachineRequest) ProtoMessage()

func (*BootVirtualMachineRequest) Reset 

func (m *BootVirtualMachineRequest) Reset()

func (*BootVirtualMachineRequest) String 

func (m *BootVirtualMachineRequest) String() string

func (*BootVirtualMachineRequest) XXX_DiscardUnknown 

func (m *BootVirtualMachineRequest) XXX_DiscardUnknown()

func (*BootVirtualMachineRequest) XXX_Marshal 

func (m *BootVirtualMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BootVirtualMachineRequest) XXX_Merge 

func (m *BootVirtualMachineRequest) XXX_Merge(src proto.Message)

func (*BootVirtualMachineRequest) XXX_Size 

func (m *BootVirtualMachineRequest) XXX_Size() int

func (*BootVirtualMachineRequest) XXX_Unmarshal 

func (m *BootVirtualMachineRequest) XXX_Unmarshal(b []byte) error

type BootVirtualMachineResponse 

type BootVirtualMachineResponse struct {
	State                VirtualMachineState `` /* 142-byte string literal not displayed */
	WebsocketPort        uint32              `protobuf:"varint,2,opt,name=websocket_port,json=websocketPort,proto3" json:"websocket_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*BootVirtualMachineResponse) Descriptor 

func (*BootVirtualMachineResponse) Descriptor() ([]byte, []int)

func (*BootVirtualMachineResponse) GetState 

func (m *BootVirtualMachineResponse) GetState() VirtualMachineState

func (*BootVirtualMachineResponse) GetWebsocketPort 

func (m *BootVirtualMachineResponse) GetWebsocketPort() uint32

func (*BootVirtualMachineResponse) ProtoMessage 

func (*BootVirtualMachineResponse) ProtoMessage()

func (*BootVirtualMachineResponse) Reset 

func (m *BootVirtualMachineResponse) Reset()

func (*BootVirtualMachineResponse) String 

func (m *BootVirtualMachineResponse) String() string

func (*BootVirtualMachineResponse) XXX_DiscardUnknown 

func (m *BootVirtualMachineResponse) XXX_DiscardUnknown()

func (*BootVirtualMachineResponse) XXX_Marshal 

func (m *BootVirtualMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BootVirtualMachineResponse) XXX_Merge 

func (m *BootVirtualMachineResponse) XXX_Merge(src proto.Message)

func (*BootVirtualMachineResponse) XXX_Size 

func (m *BootVirtualMachineResponse) XXX_Size() int

func (*BootVirtualMachineResponse) XXX_Unmarshal 

func (m *BootVirtualMachineResponse) XXX_Unmarshal(b []byte) error

type DeleteVirtualMachineRequest 

type DeleteVirtualMachineRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// TODO: netdev の情報を QMP から取るまでは、とりあえず渡してもらう
	Netdevs              []*NetDev `protobuf:"bytes,8,rep,name=netdevs,proto3" json:"netdevs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteVirtualMachineRequest) Descriptor 

func (*DeleteVirtualMachineRequest) Descriptor() ([]byte, []int)

func (*DeleteVirtualMachineRequest) GetName 

func (m *DeleteVirtualMachineRequest) GetName() string

func (*DeleteVirtualMachineRequest) GetNetdevs 

func (m *DeleteVirtualMachineRequest) GetNetdevs() []*NetDev

func (*DeleteVirtualMachineRequest) ProtoMessage 

func (*DeleteVirtualMachineRequest) ProtoMessage()

func (*DeleteVirtualMachineRequest) Reset 

func (m *DeleteVirtualMachineRequest) Reset()

func (*DeleteVirtualMachineRequest) String 

func (m *DeleteVirtualMachineRequest) String() string

func (*DeleteVirtualMachineRequest) XXX_DiscardUnknown 

func (m *DeleteVirtualMachineRequest) XXX_DiscardUnknown()

func (*DeleteVirtualMachineRequest) XXX_Marshal 

func (m *DeleteVirtualMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteVirtualMachineRequest) XXX_Merge 

func (m *DeleteVirtualMachineRequest) XXX_Merge(src proto.Message)

func (*DeleteVirtualMachineRequest) XXX_Size 

func (m *DeleteVirtualMachineRequest) XXX_Size() int

func (*DeleteVirtualMachineRequest) XXX_Unmarshal 

func (m *DeleteVirtualMachineRequest) XXX_Unmarshal(b []byte) error

type MockVirtualMachineAPI 

type MockVirtualMachineAPI struct {
	NodeAPI         *node.MockNodeAPI
	NetworkAPI      *network.MockNetworkAPI
	BlockStorageAPI *blockstorage.MockBlockStorageAPI
	// contains filtered or unexported fields
}

func NewMockVirtualMachineAPI 

func NewMockVirtualMachineAPI(datastore *memory.MemoryDatastore) *MockVirtualMachineAPI

func (MockVirtualMachineAPI) BootVirtualMachine 

func (a MockVirtualMachineAPI) BootVirtualMachine(ctx context.Context, in *pprovisioning.BootVirtualMachineRequest, opts ...grpc.CallOption) (*pprovisioning.VirtualMachine, error)

func (MockVirtualMachineAPI) CreateVirtualMachine 

func (a MockVirtualMachineAPI) CreateVirtualMachine(ctx context.Context, in *pprovisioning.CreateVirtualMachineRequest, opts ...grpc.CallOption) (*pprovisioning.VirtualMachine, error)

func (MockVirtualMachineAPI) DeleteVirtualMachine 

func (a MockVirtualMachineAPI) DeleteVirtualMachine(ctx context.Context, in *pprovisioning.DeleteVirtualMachineRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (MockVirtualMachineAPI) GetVirtualMachine 

func (a MockVirtualMachineAPI) GetVirtualMachine(ctx context.Context, in *pprovisioning.GetVirtualMachineRequest, opts ...grpc.CallOption) (*pprovisioning.VirtualMachine, error)

func (MockVirtualMachineAPI) ListVirtualMachines 

func (a MockVirtualMachineAPI) ListVirtualMachines(ctx context.Context, in *pprovisioning.ListVirtualMachinesRequest, opts ...grpc.CallOption) (*pprovisioning.ListVirtualMachinesResponse, error)

func (MockVirtualMachineAPI) OpenConsole 

func (a MockVirtualMachineAPI) OpenConsole(ctx context.Context, in *pprovisioning.OpenConsoleRequest, opts ...grpc.CallOption) (*pprovisioning.OpenConsoleResponse, error)

func (MockVirtualMachineAPI) RebootVirtualMachine 

func (a MockVirtualMachineAPI) RebootVirtualMachine(ctx context.Context, in *pprovisioning.RebootVirtualMachineRequest, opts ...grpc.CallOption) (*pprovisioning.VirtualMachine, error)

func (MockVirtualMachineAPI) SaveVirtualMachine 

func (a MockVirtualMachineAPI) SaveVirtualMachine(ctx context.Context, in *pprovisioning.SaveVirtualMachineRequest, opts ...grpc.CallOption) (*pprovisioning.VirtualMachine, error)

func (MockVirtualMachineAPI) ShutdownVirtualMachine 

func (a MockVirtualMachineAPI) ShutdownVirtualMachine(ctx context.Context, in *pprovisioning.ShutdownVirtualMachineRequest, opts ...grpc.CallOption) (*pprovisioning.VirtualMachine, error)

func (MockVirtualMachineAPI) UpdateVirtualMachine 

func (a MockVirtualMachineAPI) UpdateVirtualMachine(ctx context.Context, in *pprovisioning.UpdateVirtualMachineRequest, opts ...grpc.CallOption) (*pprovisioning.VirtualMachine, error)

type MockVirtualMachineAgentClient 

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

func NewMockVirtualMachineAgentClientMock 

func NewMockVirtualMachineAgentClientMock() *MockVirtualMachineAgentClient

func (MockVirtualMachineAgentClient) BootVirtualMachine 

func (a MockVirtualMachineAgentClient) BootVirtualMachine(ctx context.Context, in *BootVirtualMachineRequest, opts ...grpc.CallOption) (*BootVirtualMachineResponse, error)

func (MockVirtualMachineAgentClient) DeleteVirtualMachine 

func (a MockVirtualMachineAgentClient) DeleteVirtualMachine(ctx context.Context, in *DeleteVirtualMachineRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (MockVirtualMachineAgentClient) RebootVirtualMachine 

func (a MockVirtualMachineAgentClient) RebootVirtualMachine(ctx context.Context, in *RebootVirtualMachineRequest, opts ...grpc.CallOption) (*RebootVirtualMachineResponse, error)

func (MockVirtualMachineAgentClient) ShutdownVirtualMachine 

func (a MockVirtualMachineAgentClient) ShutdownVirtualMachine(ctx context.Context, in *ShutdownVirtualMachineRequest, opts ...grpc.CallOption) (*ShutdownVirtualMachineResponse, error)

type NetDev 

type NetDev struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NetworkName          string   `protobuf:"bytes,2,opt,name=network_name,json=networkName,proto3" json:"network_name,omitempty"`
	HardwareAddress      string   `protobuf:"bytes,3,opt,name=hardware_address,json=hardwareAddress,proto3" json:"hardware_address,omitempty"`
	Ipv4AddressCidr      string   `protobuf:"bytes,4,opt,name=ipv4_address_cidr,json=ipv4AddressCidr,proto3" json:"ipv4_address_cidr,omitempty"`
	Ipv4Gateway          string   `protobuf:"bytes,5,opt,name=ipv4_gateway,json=ipv4Gateway,proto3" json:"ipv4_gateway,omitempty"`
	Nameservers          []string `protobuf:"bytes,6,rep,name=nameservers,proto3" json:"nameservers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NetDev) Descriptor 

func (*NetDev) Descriptor() ([]byte, []int)

func (*NetDev) GetHardwareAddress 

func (m *NetDev) GetHardwareAddress() string

func (*NetDev) GetIpv4AddressCidr 

func (m *NetDev) GetIpv4AddressCidr() string

func (*NetDev) GetIpv4Gateway 

func (m *NetDev) GetIpv4Gateway() string

func (*NetDev) GetName 

func (m *NetDev) GetName() string

func (*NetDev) GetNameservers 

func (m *NetDev) GetNameservers() []string

func (*NetDev) GetNetworkName 

func (m *NetDev) GetNetworkName() string

func (*NetDev) ProtoMessage 

func (*NetDev) ProtoMessage()

func (*NetDev) Reset 

func (m *NetDev) Reset()

func (*NetDev) String 

func (m *NetDev) String() string

func (*NetDev) XXX_DiscardUnknown 

func (m *NetDev) XXX_DiscardUnknown()

func (*NetDev) XXX_Marshal 

func (m *NetDev) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetDev) XXX_Merge 

func (m *NetDev) XXX_Merge(src proto.Message)

func (*NetDev) XXX_Size 

func (m *NetDev) XXX_Size() int

func (*NetDev) XXX_Unmarshal 

func (m *NetDev) XXX_Unmarshal(b []byte) error

type RebootVirtualMachineRequest 

type RebootVirtualMachineRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Hard                 bool     `protobuf:"varint,2,opt,name=hard,proto3" json:"hard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RebootVirtualMachineRequest) Descriptor 

func (*RebootVirtualMachineRequest) Descriptor() ([]byte, []int)

func (*RebootVirtualMachineRequest) GetHard 

func (m *RebootVirtualMachineRequest) GetHard() bool

func (*RebootVirtualMachineRequest) GetName 

func (m *RebootVirtualMachineRequest) GetName() string

func (*RebootVirtualMachineRequest) ProtoMessage 

func (*RebootVirtualMachineRequest) ProtoMessage()

func (*RebootVirtualMachineRequest) Reset 

func (m *RebootVirtualMachineRequest) Reset()

func (*RebootVirtualMachineRequest) String 

func (m *RebootVirtualMachineRequest) String() string

func (*RebootVirtualMachineRequest) XXX_DiscardUnknown 

func (m *RebootVirtualMachineRequest) XXX_DiscardUnknown()

func (*RebootVirtualMachineRequest) XXX_Marshal 

func (m *RebootVirtualMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RebootVirtualMachineRequest) XXX_Merge 

func (m *RebootVirtualMachineRequest) XXX_Merge(src proto.Message)

func (*RebootVirtualMachineRequest) XXX_Size 

func (m *RebootVirtualMachineRequest) XXX_Size() int

func (*RebootVirtualMachineRequest) XXX_Unmarshal 

func (m *RebootVirtualMachineRequest) XXX_Unmarshal(b []byte) error

type RebootVirtualMachineResponse 

type RebootVirtualMachineResponse struct {
	State                VirtualMachineState `` /* 142-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RebootVirtualMachineResponse) Descriptor 

func (*RebootVirtualMachineResponse) Descriptor() ([]byte, []int)

func (*RebootVirtualMachineResponse) GetState 

func (m *RebootVirtualMachineResponse) GetState() VirtualMachineState

func (*RebootVirtualMachineResponse) ProtoMessage 

func (*RebootVirtualMachineResponse) ProtoMessage()

func (*RebootVirtualMachineResponse) Reset 

func (m *RebootVirtualMachineResponse) Reset()

func (*RebootVirtualMachineResponse) String 

func (m *RebootVirtualMachineResponse) String() string

func (*RebootVirtualMachineResponse) XXX_DiscardUnknown 

func (m *RebootVirtualMachineResponse) XXX_DiscardUnknown()

func (*RebootVirtualMachineResponse) XXX_Marshal 

func (m *RebootVirtualMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RebootVirtualMachineResponse) XXX_Merge 

func (m *RebootVirtualMachineResponse) XXX_Merge(src proto.Message)

func (*RebootVirtualMachineResponse) XXX_Size 

func (m *RebootVirtualMachineResponse) XXX_Size() int

func (*RebootVirtualMachineResponse) XXX_Unmarshal 

func (m *RebootVirtualMachineResponse) XXX_Unmarshal(b []byte) error

type ShutdownVirtualMachineRequest 

type ShutdownVirtualMachineRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Hard                 bool     `protobuf:"varint,2,opt,name=hard,proto3" json:"hard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShutdownVirtualMachineRequest) Descriptor 

func (*ShutdownVirtualMachineRequest) Descriptor() ([]byte, []int)

func (*ShutdownVirtualMachineRequest) GetHard 

func (m *ShutdownVirtualMachineRequest) GetHard() bool

func (*ShutdownVirtualMachineRequest) GetName 

func (m *ShutdownVirtualMachineRequest) GetName() string

func (*ShutdownVirtualMachineRequest) ProtoMessage 

func (*ShutdownVirtualMachineRequest) ProtoMessage()

func (*ShutdownVirtualMachineRequest) Reset 

func (m *ShutdownVirtualMachineRequest) Reset()

func (*ShutdownVirtualMachineRequest) String 

func (m *ShutdownVirtualMachineRequest) String() string

func (*ShutdownVirtualMachineRequest) XXX_DiscardUnknown 

func (m *ShutdownVirtualMachineRequest) XXX_DiscardUnknown()

func (*ShutdownVirtualMachineRequest) XXX_Marshal 

func (m *ShutdownVirtualMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShutdownVirtualMachineRequest) XXX_Merge 

func (m *ShutdownVirtualMachineRequest) XXX_Merge(src proto.Message)

func (*ShutdownVirtualMachineRequest) XXX_Size 

func (m *ShutdownVirtualMachineRequest) XXX_Size() int

func (*ShutdownVirtualMachineRequest) XXX_Unmarshal 

func (m *ShutdownVirtualMachineRequest) XXX_Unmarshal(b []byte) error

type ShutdownVirtualMachineResponse 

type ShutdownVirtualMachineResponse struct {
	State                VirtualMachineState `` /* 142-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ShutdownVirtualMachineResponse) Descriptor 

func (*ShutdownVirtualMachineResponse) Descriptor() ([]byte, []int)

func (*ShutdownVirtualMachineResponse) GetState 

func (m *ShutdownVirtualMachineResponse) GetState() VirtualMachineState

func (*ShutdownVirtualMachineResponse) ProtoMessage 

func (*ShutdownVirtualMachineResponse) ProtoMessage()

func (*ShutdownVirtualMachineResponse) Reset 

func (m *ShutdownVirtualMachineResponse) Reset()

func (*ShutdownVirtualMachineResponse) String 

func (m *ShutdownVirtualMachineResponse) String() string

func (*ShutdownVirtualMachineResponse) XXX_DiscardUnknown 

func (m *ShutdownVirtualMachineResponse) XXX_DiscardUnknown()

func (*ShutdownVirtualMachineResponse) XXX_Marshal 

func (m *ShutdownVirtualMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShutdownVirtualMachineResponse) XXX_Merge 

func (m *ShutdownVirtualMachineResponse) XXX_Merge(src proto.Message)

func (*ShutdownVirtualMachineResponse) XXX_Size 

func (m *ShutdownVirtualMachineResponse) XXX_Size() int

func (*ShutdownVirtualMachineResponse) XXX_Unmarshal 

func (m *ShutdownVirtualMachineResponse) XXX_Unmarshal(b []byte) error

type UnimplementedVirtualMachineAgentServiceServer 

type UnimplementedVirtualMachineAgentServiceServer struct {
}

UnimplementedVirtualMachineAgentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVirtualMachineAgentServiceServer) BootVirtualMachine 

func (*UnimplementedVirtualMachineAgentServiceServer) BootVirtualMachine(ctx context.Context, req *BootVirtualMachineRequest) (*BootVirtualMachineResponse, error)

func (*UnimplementedVirtualMachineAgentServiceServer) DeleteVirtualMachine 

func (*UnimplementedVirtualMachineAgentServiceServer) DeleteVirtualMachine(ctx context.Context, req *DeleteVirtualMachineRequest) (*empty.Empty, error)

func (*UnimplementedVirtualMachineAgentServiceServer) RebootVirtualMachine 

func (*UnimplementedVirtualMachineAgentServiceServer) RebootVirtualMachine(ctx context.Context, req *RebootVirtualMachineRequest) (*RebootVirtualMachineResponse, error)

func (*UnimplementedVirtualMachineAgentServiceServer) ShutdownVirtualMachine 

func (*UnimplementedVirtualMachineAgentServiceServer) ShutdownVirtualMachine(ctx context.Context, req *ShutdownVirtualMachineRequest) (*ShutdownVirtualMachineResponse, error)

type VirtualMachineAPI 

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

func CreateVirtualMachineAPI 

func CreateVirtualMachineAPI(ds datastore.Datastore, noa ppool.NodeServiceClient, nea ppool.NetworkServiceClient, bsa pprovisioning.BlockStorageServiceClient) *VirtualMachineAPI

func (*VirtualMachineAPI) BootVirtualMachine 

func (a *VirtualMachineAPI) BootVirtualMachine(ctx context.Context, req *pprovisioning.BootVirtualMachineRequest) (*pprovisioning.VirtualMachine, error)

func (*VirtualMachineAPI) CreateVirtualMachine 

func (a *VirtualMachineAPI) CreateVirtualMachine(ctx context.Context, req *pprovisioning.CreateVirtualMachineRequest) (*pprovisioning.VirtualMachine, error)

func (*VirtualMachineAPI) DeleteVirtualMachine 

func (a *VirtualMachineAPI) DeleteVirtualMachine(ctx context.Context, req *pprovisioning.DeleteVirtualMachineRequest) (*empty.Empty, error)

func (*VirtualMachineAPI) GetVirtualMachine 

func (a *VirtualMachineAPI) GetVirtualMachine(ctx context.Context, req *pprovisioning.GetVirtualMachineRequest) (*pprovisioning.VirtualMachine, error)

func (*VirtualMachineAPI) ListVirtualMachines 

func (a *VirtualMachineAPI) ListVirtualMachines(ctx context.Context, req *pprovisioning.ListVirtualMachinesRequest) (*pprovisioning.ListVirtualMachinesResponse, error)

func (*VirtualMachineAPI) OpenConsole 

func (a *VirtualMachineAPI) OpenConsole(ctx context.Context, req *pprovisioning.OpenConsoleRequest) (*pprovisioning.OpenConsoleResponse, error)

TODO: めんどくさいので n0core コマンドで定義した URL に一時的に依存している、治す必要あり

func (*VirtualMachineAPI) ProxyWebsocket 

func (a *VirtualMachineAPI) ProxyWebsocket() func(echo.Context) error

func (*VirtualMachineAPI) RebootVirtualMachine 

func (a *VirtualMachineAPI) RebootVirtualMachine(ctx context.Context, req *pprovisioning.RebootVirtualMachineRequest) (*pprovisioning.VirtualMachine, error)

func (*VirtualMachineAPI) SaveVirtualMachine 

func (a *VirtualMachineAPI) SaveVirtualMachine(ctx context.Context, req *pprovisioning.SaveVirtualMachineRequest) (*pprovisioning.VirtualMachine, error)

func (*VirtualMachineAPI) ShutdownVirtualMachine 

func (a *VirtualMachineAPI) ShutdownVirtualMachine(ctx context.Context, req *pprovisioning.ShutdownVirtualMachineRequest) (*pprovisioning.VirtualMachine, error)

func (*VirtualMachineAPI) UpdateVirtualMachine 

func (a *VirtualMachineAPI) UpdateVirtualMachine(ctx context.Context, req *pprovisioning.UpdateVirtualMachineRequest) (*pprovisioning.VirtualMachine, error)

type VirtualMachineAgent 

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

func CreateVirtualMachineAgent 

func CreateVirtualMachineAgent(basedir string) (*VirtualMachineAgent, error)

func (VirtualMachineAgent) BootVirtualMachine 

func (a VirtualMachineAgent) BootVirtualMachine(ctx context.Context, req *BootVirtualMachineRequest) (*BootVirtualMachineResponse, error)

func (VirtualMachineAgent) DeleteVirtualMachine 

func (a VirtualMachineAgent) DeleteVirtualMachine(ctx context.Context, req *DeleteVirtualMachineRequest) (*empty.Empty, error)

func (VirtualMachineAgent) DeleteWorkDirectory 

func (a VirtualMachineAgent) DeleteWorkDirectory(name string) error

func (VirtualMachineAgent) GetWorkDirectory 

func (a VirtualMachineAgent) GetWorkDirectory(name string) (string, error)

func (VirtualMachineAgent) RebootVirtualMachine 

func (a VirtualMachineAgent) RebootVirtualMachine(ctx context.Context, req *RebootVirtualMachineRequest) (*RebootVirtualMachineResponse, error)

func (VirtualMachineAgent) ShutdownVirtualMachine 

func (a VirtualMachineAgent) ShutdownVirtualMachine(ctx context.Context, req *ShutdownVirtualMachineRequest) (*ShutdownVirtualMachineResponse, error)

type VirtualMachineAgentMock 

type VirtualMachineAgentMock struct{}

func (VirtualMachineAgentMock) BootVirtualMachine 

func (a VirtualMachineAgentMock) BootVirtualMachine(ctx context.Context, req *BootVirtualMachineRequest) (*BootVirtualMachineResponse, error)

func (VirtualMachineAgentMock) DeleteVirtualMachine 

func (a VirtualMachineAgentMock) DeleteVirtualMachine(ctx context.Context, req *DeleteVirtualMachineRequest) (*empty.Empty, error)

func (VirtualMachineAgentMock) RebootVirtualMachine 

func (a VirtualMachineAgentMock) RebootVirtualMachine(ctx context.Context, req *RebootVirtualMachineRequest) (*RebootVirtualMachineResponse, error)

func (VirtualMachineAgentMock) ShutdownVirtualMachine 

func (a VirtualMachineAgentMock) ShutdownVirtualMachine(ctx context.Context, req *ShutdownVirtualMachineRequest) (*ShutdownVirtualMachineResponse, error)

type VirtualMachineAgentServiceClient 

type VirtualMachineAgentServiceClient interface {
	BootVirtualMachine(ctx context.Context, in *BootVirtualMachineRequest, opts ...grpc.CallOption) (*BootVirtualMachineResponse, error)
	RebootVirtualMachine(ctx context.Context, in *RebootVirtualMachineRequest, opts ...grpc.CallOption) (*RebootVirtualMachineResponse, error)
	ShutdownVirtualMachine(ctx context.Context, in *ShutdownVirtualMachineRequest, opts ...grpc.CallOption) (*ShutdownVirtualMachineResponse, error)
	DeleteVirtualMachine(ctx context.Context, in *DeleteVirtualMachineRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

VirtualMachineAgentServiceClient is the client API for VirtualMachineAgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVirtualMachineAgentServiceClient 

func NewVirtualMachineAgentServiceClient(cc *grpc.ClientConn) VirtualMachineAgentServiceClient

type VirtualMachineAgentServiceServer 

type VirtualMachineAgentServiceServer interface {
	BootVirtualMachine(context.Context, *BootVirtualMachineRequest) (*BootVirtualMachineResponse, error)
	RebootVirtualMachine(context.Context, *RebootVirtualMachineRequest) (*RebootVirtualMachineResponse, error)
	ShutdownVirtualMachine(context.Context, *ShutdownVirtualMachineRequest) (*ShutdownVirtualMachineResponse, error)
	DeleteVirtualMachine(context.Context, *DeleteVirtualMachineRequest) (*empty.Empty, error)
}

VirtualMachineAgentServiceServer is the server API for VirtualMachineAgentService service.

type VirtualMachineState 

type VirtualMachineState int32
const (
	VirtualMachineState_FAILED   VirtualMachineState = 0
	VirtualMachineState_UNKNOWN  VirtualMachineState = 1
	VirtualMachineState_SHUTDOWN VirtualMachineState = 2
	VirtualMachineState_RUNNING  VirtualMachineState = 3
	VirtualMachineState_PAUSED   VirtualMachineState = 4
)

func GetAgentStateFromQemuState 

func GetAgentStateFromQemuState(s qemu.Status) VirtualMachineState

func (VirtualMachineState) EnumDescriptor 

func (VirtualMachineState) EnumDescriptor() ([]byte, []int)

func (VirtualMachineState) String 

func (x VirtualMachineState) String() string

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.