provisioning

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2018 License: BSD-2-Clause Imports: 26 Imported by: 0

README

Provisioning

Example

Volume
grpc_cli call localhost:20183 n0stack.provisioning.VolumeService/CreateEmptyVolume \
'metadata {
  name: "test-empty-volume"
  annotations {
    key: "n0core/provisioning/request_node_name"
    value: "test"
  }
}
spec {
  request_bytes: 1024
  limit_bytes: 1073741824
}'

grpc_cli call localhost:20183 n0stack.provisioning.VolumeService/CreateVolumeWithDownloading \
'metadata {
  name: "test-ubuntu-volume"
  annotations {
    key: "n0core/provisioning/request_node_name"
    value: "test"
  }
}
spec {
  request_bytes: 1073741824
  limit_bytes: 10737418240
}
source_url: "http://cloud-images.ubuntu.com/xenial/current/xenial-server-cloudimg-amd64-disk1.img"
'

grpc_cli call localhost:20183 n0stack.provisioning.VolumeService/ListVolumes ''

grpc_cli call localhost:20183 n0stack.provisioning.VolumeService/GetVolume 'name: "test-ubuntu-volume"'

grpc_cli call localhost:20183 n0stack.provisioning.VolumeService/SetAvailableVolume 'name: test-ubuntu-volume"'

grpc_cli call localhost:20183 n0stack.provisioning.VolumeService/SetInuseVolume 'name: "test-ubuntu-volume"'
Virtual machine
grpc_cli call localhost:20184 n0stack.provisioning.VirtualMachineService/CreateVirtualMachine \
'metadata {
  name: "test-vm"
  annotations {
    key: "n0core/provisioning/request_node_name"
    value: "test"
  }
}
spec {
  request_cpu_milli_core: 10
  limit_cpu_milli_core: 1000

  request_memory_bytes: 1073741824
  limit_memory_bytes: 1073741824

  volume_names: "test-ubuntu-volume"

  nics {
    network_name: "test-network"
  }
}
'

grpc_cli call localhost:20184 n0stack.provisioning.VirtualMachineService/ListVirtualMachines ''

grpc_cli call localhost:20184 n0stack.provisioning.VirtualMachineService/GetVirtualMachine 'name: "test-vm"'

grpc_cli call localhost:20184 n0stack.provisioning.VirtualMachineService/BootVirtualMachine 'name: "test-vm"'

grpc_cli call localhost:20184 n0stack.provisioning.VirtualMachineService/RebootVirtualMachine '
name: "test-vm"
hard: true
'

grpc_cli call localhost:20184 n0stack.provisioning.VirtualMachineService/ShutdownVirtualMachine '
name: "test-vm"
hard: true
'

Documentation

Index

Constants

View Source 
const (
	QMPMonitorSocketFile   = "monitor.sock"
	VNCWebSocketPortOffset = 6900
)
View Source 
const AnnotationRequestNodeName = "n0core/provisioning/request_node_name"

Create のときに Node を指定したい時に利用

View Source 
const AnnotationVNCWebSocketPort = "n0core/provisioning/virtual_machine_vnc_websocket_port"
View Source 
const (
	// Create のときに自動生成、消されると困る
	AnnotationVolumePath = "n0core/provisioning/volume_url"
)

Variables

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

Functions

func GetAPIStateFromAgentState 

func GetAPIStateFromAgentState(s VirtualMachineAgentState) pprovisioning.VirtualMachineStatus_VirtualMachineState

func RegisterVirtualMachineAgentServiceServer 

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

func RegisterVolumeAgentServiceServer 

func RegisterVolumeAgentServiceServer(s *grpc.Server, srv VolumeAgentServiceServer)

func TrimNetdevName 

func TrimNetdevName(name string) string

Types

type BlockDev 

type BlockDev struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Url                  string   `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
	BootIndex            uint32   `protobuf:"varint,3,opt,name=boot_index,json=bootIndex" 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 (dst *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 BootVirtualMachineAgentRequest 

type BootVirtualMachineAgentRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BootVirtualMachineAgentRequest) Descriptor 

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

func (*BootVirtualMachineAgentRequest) GetName 

func (m *BootVirtualMachineAgentRequest) GetName() string

func (*BootVirtualMachineAgentRequest) ProtoMessage 

func (*BootVirtualMachineAgentRequest) ProtoMessage()

func (*BootVirtualMachineAgentRequest) Reset 

func (m *BootVirtualMachineAgentRequest) Reset()

func (*BootVirtualMachineAgentRequest) String 

func (m *BootVirtualMachineAgentRequest) String() string

func (*BootVirtualMachineAgentRequest) XXX_DiscardUnknown 

func (m *BootVirtualMachineAgentRequest) XXX_DiscardUnknown()

func (*BootVirtualMachineAgentRequest) XXX_Marshal 

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

func (*BootVirtualMachineAgentRequest) XXX_Merge 

func (dst *BootVirtualMachineAgentRequest) XXX_Merge(src proto.Message)

func (*BootVirtualMachineAgentRequest) XXX_Size 

func (m *BootVirtualMachineAgentRequest) XXX_Size() int

func (*BootVirtualMachineAgentRequest) XXX_Unmarshal 

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

type BootVirtualMachineAgentResponse 

type BootVirtualMachineAgentResponse struct {
	State                VirtualMachineAgentState `protobuf:"varint,1,opt,name=state,enum=n0stack.internal.n0core.provisioning.VirtualMachineAgentState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*BootVirtualMachineAgentResponse) Descriptor 

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

func (*BootVirtualMachineAgentResponse) GetState 

func (m *BootVirtualMachineAgentResponse) GetState() VirtualMachineAgentState

func (*BootVirtualMachineAgentResponse) ProtoMessage 

func (*BootVirtualMachineAgentResponse) ProtoMessage()

func (*BootVirtualMachineAgentResponse) Reset 

func (m *BootVirtualMachineAgentResponse) Reset()

func (*BootVirtualMachineAgentResponse) String 

func (m *BootVirtualMachineAgentResponse) String() string

func (*BootVirtualMachineAgentResponse) XXX_DiscardUnknown 

func (m *BootVirtualMachineAgentResponse) XXX_DiscardUnknown()

func (*BootVirtualMachineAgentResponse) XXX_Marshal 

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

func (*BootVirtualMachineAgentResponse) XXX_Merge 

func (dst *BootVirtualMachineAgentResponse) XXX_Merge(src proto.Message)

func (*BootVirtualMachineAgentResponse) XXX_Size 

func (m *BootVirtualMachineAgentResponse) XXX_Size() int

func (*BootVirtualMachineAgentResponse) XXX_Unmarshal 

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

type CreateEmptyVolumeAgentRequest 

type CreateEmptyVolumeAgentRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Bytes                uint64   `protobuf:"varint,2,opt,name=bytes" json:"bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateEmptyVolumeAgentRequest) Descriptor 

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

func (*CreateEmptyVolumeAgentRequest) GetBytes 

func (m *CreateEmptyVolumeAgentRequest) GetBytes() uint64

func (*CreateEmptyVolumeAgentRequest) GetName 

func (m *CreateEmptyVolumeAgentRequest) GetName() string

func (*CreateEmptyVolumeAgentRequest) ProtoMessage 

func (*CreateEmptyVolumeAgentRequest) ProtoMessage()

func (*CreateEmptyVolumeAgentRequest) Reset 

func (m *CreateEmptyVolumeAgentRequest) Reset()

func (*CreateEmptyVolumeAgentRequest) String 

func (m *CreateEmptyVolumeAgentRequest) String() string

func (*CreateEmptyVolumeAgentRequest) XXX_DiscardUnknown 

func (m *CreateEmptyVolumeAgentRequest) XXX_DiscardUnknown()

func (*CreateEmptyVolumeAgentRequest) XXX_Marshal 

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

func (*CreateEmptyVolumeAgentRequest) XXX_Merge 

func (dst *CreateEmptyVolumeAgentRequest) XXX_Merge(src proto.Message)

func (*CreateEmptyVolumeAgentRequest) XXX_Size 

func (m *CreateEmptyVolumeAgentRequest) XXX_Size() int

func (*CreateEmptyVolumeAgentRequest) XXX_Unmarshal 

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

type CreateVirtualMachineAgentRequest 

type CreateVirtualMachineAgentRequest struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Vcpus                uint32      `protobuf:"varint,4,opt,name=vcpus" json:"vcpus,omitempty"`
	MemoryBytes          uint64      `protobuf:"varint,5,opt,name=memory_bytes,json=memoryBytes" json:"memory_bytes,omitempty"`
	Blockdev             []*BlockDev `protobuf:"bytes,6,rep,name=blockdev" json:"blockdev,omitempty"`
	Netdev               []*NetDev   `protobuf:"bytes,7,rep,name=netdev" json:"netdev,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CreateVirtualMachineAgentRequest) Descriptor 

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

func (*CreateVirtualMachineAgentRequest) GetBlockdev 

func (m *CreateVirtualMachineAgentRequest) GetBlockdev() []*BlockDev

func (*CreateVirtualMachineAgentRequest) GetMemoryBytes 

func (m *CreateVirtualMachineAgentRequest) GetMemoryBytes() uint64

func (*CreateVirtualMachineAgentRequest) GetName 

func (m *CreateVirtualMachineAgentRequest) GetName() string

func (*CreateVirtualMachineAgentRequest) GetNetdev 

func (m *CreateVirtualMachineAgentRequest) GetNetdev() []*NetDev

func (*CreateVirtualMachineAgentRequest) GetVcpus 

func (m *CreateVirtualMachineAgentRequest) GetVcpus() uint32

func (*CreateVirtualMachineAgentRequest) ProtoMessage 

func (*CreateVirtualMachineAgentRequest) ProtoMessage()

func (*CreateVirtualMachineAgentRequest) Reset 

func (m *CreateVirtualMachineAgentRequest) Reset()

func (*CreateVirtualMachineAgentRequest) String 

func (m *CreateVirtualMachineAgentRequest) String() string

func (*CreateVirtualMachineAgentRequest) XXX_DiscardUnknown 

func (m *CreateVirtualMachineAgentRequest) XXX_DiscardUnknown()

func (*CreateVirtualMachineAgentRequest) XXX_Marshal 

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

func (*CreateVirtualMachineAgentRequest) XXX_Merge 

func (dst *CreateVirtualMachineAgentRequest) XXX_Merge(src proto.Message)

func (*CreateVirtualMachineAgentRequest) XXX_Size 

func (m *CreateVirtualMachineAgentRequest) XXX_Size() int

func (*CreateVirtualMachineAgentRequest) XXX_Unmarshal 

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

type CreateVolumeAgentWithDownloadingRequest 

type CreateVolumeAgentWithDownloadingRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Bytes                uint64   `protobuf:"varint,2,opt,name=bytes" json:"bytes,omitempty"`
	SourceUrl            string   `protobuf:"bytes,4,opt,name=source_url,json=sourceUrl" json:"source_url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateVolumeAgentWithDownloadingRequest) Descriptor 

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

func (*CreateVolumeAgentWithDownloadingRequest) GetBytes 

func (m *CreateVolumeAgentWithDownloadingRequest) GetBytes() uint64

func (*CreateVolumeAgentWithDownloadingRequest) GetName 

func (m *CreateVolumeAgentWithDownloadingRequest) GetName() string

func (*CreateVolumeAgentWithDownloadingRequest) GetSourceUrl 

func (m *CreateVolumeAgentWithDownloadingRequest) GetSourceUrl() string

func (*CreateVolumeAgentWithDownloadingRequest) ProtoMessage 

func (*CreateVolumeAgentWithDownloadingRequest) ProtoMessage()

func (*CreateVolumeAgentWithDownloadingRequest) Reset 

func (m *CreateVolumeAgentWithDownloadingRequest) Reset()

func (*CreateVolumeAgentWithDownloadingRequest) String 

func (m *CreateVolumeAgentWithDownloadingRequest) String() string

func (*CreateVolumeAgentWithDownloadingRequest) XXX_DiscardUnknown 

func (m *CreateVolumeAgentWithDownloadingRequest) XXX_DiscardUnknown()

func (*CreateVolumeAgentWithDownloadingRequest) XXX_Marshal 

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

func (*CreateVolumeAgentWithDownloadingRequest) XXX_Merge 

func (dst *CreateVolumeAgentWithDownloadingRequest) XXX_Merge(src proto.Message)

func (*CreateVolumeAgentWithDownloadingRequest) XXX_Size 

func (m *CreateVolumeAgentWithDownloadingRequest) XXX_Size() int

func (*CreateVolumeAgentWithDownloadingRequest) XXX_Unmarshal 

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

type DeleteVirtualMachineAgentRequest 

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

func (*DeleteVirtualMachineAgentRequest) Descriptor 

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

func (*DeleteVirtualMachineAgentRequest) GetName 

func (m *DeleteVirtualMachineAgentRequest) GetName() string

func (*DeleteVirtualMachineAgentRequest) GetNetdev 

func (m *DeleteVirtualMachineAgentRequest) GetNetdev() []*NetDev

func (*DeleteVirtualMachineAgentRequest) ProtoMessage 

func (*DeleteVirtualMachineAgentRequest) ProtoMessage()

func (*DeleteVirtualMachineAgentRequest) Reset 

func (m *DeleteVirtualMachineAgentRequest) Reset()

func (*DeleteVirtualMachineAgentRequest) String 

func (m *DeleteVirtualMachineAgentRequest) String() string

func (*DeleteVirtualMachineAgentRequest) XXX_DiscardUnknown 

func (m *DeleteVirtualMachineAgentRequest) XXX_DiscardUnknown()

func (*DeleteVirtualMachineAgentRequest) XXX_Marshal 

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

func (*DeleteVirtualMachineAgentRequest) XXX_Merge 

func (dst *DeleteVirtualMachineAgentRequest) XXX_Merge(src proto.Message)

func (*DeleteVirtualMachineAgentRequest) XXX_Size 

func (m *DeleteVirtualMachineAgentRequest) XXX_Size() int

func (*DeleteVirtualMachineAgentRequest) XXX_Unmarshal 

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

type DeleteVolumeAgentRequest 

type DeleteVolumeAgentRequest struct {
	Path                 string   `protobuf:"bytes,3,opt,name=path" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteVolumeAgentRequest) Descriptor 

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

func (*DeleteVolumeAgentRequest) GetPath 

func (m *DeleteVolumeAgentRequest) GetPath() string

func (*DeleteVolumeAgentRequest) ProtoMessage 

func (*DeleteVolumeAgentRequest) ProtoMessage()

func (*DeleteVolumeAgentRequest) Reset 

func (m *DeleteVolumeAgentRequest) Reset()

func (*DeleteVolumeAgentRequest) String 

func (m *DeleteVolumeAgentRequest) String() string

func (*DeleteVolumeAgentRequest) XXX_DiscardUnknown 

func (m *DeleteVolumeAgentRequest) XXX_DiscardUnknown()

func (*DeleteVolumeAgentRequest) XXX_Marshal 

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

func (*DeleteVolumeAgentRequest) XXX_Merge 

func (dst *DeleteVolumeAgentRequest) XXX_Merge(src proto.Message)

func (*DeleteVolumeAgentRequest) XXX_Size 

func (m *DeleteVolumeAgentRequest) XXX_Size() int

func (*DeleteVolumeAgentRequest) XXX_Unmarshal 

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

type NetDev 

type NetDev struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	NetworkName          string   `protobuf:"bytes,2,opt,name=network_name,json=networkName" json:"network_name,omitempty"`
	HardwareAddress      string   `protobuf:"bytes,3,opt,name=hardware_address,json=hardwareAddress" json:"hardware_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func StructNetDev 

func StructNetDev(nics []*pprovisioning.VirtualMachineSpec_NIC, names []string) []*NetDev

func (*NetDev) Descriptor 

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

func (*NetDev) GetHardwareAddress 

func (m *NetDev) GetHardwareAddress() string

func (*NetDev) GetName 

func (m *NetDev) GetName() 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 (dst *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 RebootVirtualMachineAgentRequest 

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

func (*RebootVirtualMachineAgentRequest) Descriptor 

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

func (*RebootVirtualMachineAgentRequest) GetHard 

func (m *RebootVirtualMachineAgentRequest) GetHard() bool

func (*RebootVirtualMachineAgentRequest) GetName 

func (m *RebootVirtualMachineAgentRequest) GetName() string

func (*RebootVirtualMachineAgentRequest) ProtoMessage 

func (*RebootVirtualMachineAgentRequest) ProtoMessage()

func (*RebootVirtualMachineAgentRequest) Reset 

func (m *RebootVirtualMachineAgentRequest) Reset()

func (*RebootVirtualMachineAgentRequest) String 

func (m *RebootVirtualMachineAgentRequest) String() string

func (*RebootVirtualMachineAgentRequest) XXX_DiscardUnknown 

func (m *RebootVirtualMachineAgentRequest) XXX_DiscardUnknown()

func (*RebootVirtualMachineAgentRequest) XXX_Marshal 

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

func (*RebootVirtualMachineAgentRequest) XXX_Merge 

func (dst *RebootVirtualMachineAgentRequest) XXX_Merge(src proto.Message)

func (*RebootVirtualMachineAgentRequest) XXX_Size 

func (m *RebootVirtualMachineAgentRequest) XXX_Size() int

func (*RebootVirtualMachineAgentRequest) XXX_Unmarshal 

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

type RebootVirtualMachineAgentResponse 

type RebootVirtualMachineAgentResponse struct {
	State                VirtualMachineAgentState `protobuf:"varint,1,opt,name=state,enum=n0stack.internal.n0core.provisioning.VirtualMachineAgentState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*RebootVirtualMachineAgentResponse) Descriptor 

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

func (*RebootVirtualMachineAgentResponse) GetState 

func (m *RebootVirtualMachineAgentResponse) GetState() VirtualMachineAgentState

func (*RebootVirtualMachineAgentResponse) ProtoMessage 

func (*RebootVirtualMachineAgentResponse) ProtoMessage()

func (*RebootVirtualMachineAgentResponse) Reset 

func (m *RebootVirtualMachineAgentResponse) Reset()

func (*RebootVirtualMachineAgentResponse) String 

func (m *RebootVirtualMachineAgentResponse) String() string

func (*RebootVirtualMachineAgentResponse) XXX_DiscardUnknown 

func (m *RebootVirtualMachineAgentResponse) XXX_DiscardUnknown()

func (*RebootVirtualMachineAgentResponse) XXX_Marshal 

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

func (*RebootVirtualMachineAgentResponse) XXX_Merge 

func (dst *RebootVirtualMachineAgentResponse) XXX_Merge(src proto.Message)

func (*RebootVirtualMachineAgentResponse) XXX_Size 

func (m *RebootVirtualMachineAgentResponse) XXX_Size() int

func (*RebootVirtualMachineAgentResponse) XXX_Unmarshal 

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

type ShutdownVirtualMachineAgentRequest 

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

func (*ShutdownVirtualMachineAgentRequest) Descriptor 

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

func (*ShutdownVirtualMachineAgentRequest) GetHard 

func (m *ShutdownVirtualMachineAgentRequest) GetHard() bool

func (*ShutdownVirtualMachineAgentRequest) GetName 

func (m *ShutdownVirtualMachineAgentRequest) GetName() string

func (*ShutdownVirtualMachineAgentRequest) ProtoMessage 

func (*ShutdownVirtualMachineAgentRequest) ProtoMessage()

func (*ShutdownVirtualMachineAgentRequest) Reset 

func (m *ShutdownVirtualMachineAgentRequest) Reset()

func (*ShutdownVirtualMachineAgentRequest) String 

func (m *ShutdownVirtualMachineAgentRequest) String() string

func (*ShutdownVirtualMachineAgentRequest) XXX_DiscardUnknown 

func (m *ShutdownVirtualMachineAgentRequest) XXX_DiscardUnknown()

func (*ShutdownVirtualMachineAgentRequest) XXX_Marshal 

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

func (*ShutdownVirtualMachineAgentRequest) XXX_Merge 

func (dst *ShutdownVirtualMachineAgentRequest) XXX_Merge(src proto.Message)

func (*ShutdownVirtualMachineAgentRequest) XXX_Size 

func (m *ShutdownVirtualMachineAgentRequest) XXX_Size() int

func (*ShutdownVirtualMachineAgentRequest) XXX_Unmarshal 

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

type ShutdownVirtualMachineAgentResponse 

type ShutdownVirtualMachineAgentResponse struct {
	State                VirtualMachineAgentState `protobuf:"varint,1,opt,name=state,enum=n0stack.internal.n0core.provisioning.VirtualMachineAgentState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ShutdownVirtualMachineAgentResponse) Descriptor 

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

func (*ShutdownVirtualMachineAgentResponse) GetState 

func (m *ShutdownVirtualMachineAgentResponse) GetState() VirtualMachineAgentState

func (*ShutdownVirtualMachineAgentResponse) ProtoMessage 

func (*ShutdownVirtualMachineAgentResponse) ProtoMessage()

func (*ShutdownVirtualMachineAgentResponse) Reset 

func (m *ShutdownVirtualMachineAgentResponse) Reset()

func (*ShutdownVirtualMachineAgentResponse) String 

func (m *ShutdownVirtualMachineAgentResponse) String() string

func (*ShutdownVirtualMachineAgentResponse) XXX_DiscardUnknown 

func (m *ShutdownVirtualMachineAgentResponse) XXX_DiscardUnknown()

func (*ShutdownVirtualMachineAgentResponse) XXX_Marshal 

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

func (*ShutdownVirtualMachineAgentResponse) XXX_Merge 

func (dst *ShutdownVirtualMachineAgentResponse) XXX_Merge(src proto.Message)

func (*ShutdownVirtualMachineAgentResponse) XXX_Size 

func (m *ShutdownVirtualMachineAgentResponse) XXX_Size() int

func (*ShutdownVirtualMachineAgentResponse) XXX_Unmarshal 

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

type VirtualMachineAPI 

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

func CreateVirtualMachineAPI 

func CreateVirtualMachineAPI(ds datastore.Datastore, noa ppool.NodeServiceClient, nea ppool.NetworkServiceClient, va pprovisioning.VolumeServiceClient) (*VirtualMachineAPI, error)

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.ApplyVirtualMachineRequest) (*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) 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 {
	Name                 string                   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Uuid                 string                   `protobuf:"bytes,2,opt,name=uuid" json:"uuid,omitempty"`
	State                VirtualMachineAgentState `protobuf:"varint,3,opt,name=state,enum=n0stack.internal.n0core.provisioning.VirtualMachineAgentState" json:"state,omitempty"`
	Vcpus                uint32                   `protobuf:"varint,4,opt,name=vcpus" json:"vcpus,omitempty"`
	MemoryBytes          uint64                   `protobuf:"varint,5,opt,name=memory_bytes,json=memoryBytes" json:"memory_bytes,omitempty"`
	Blockdev             []*BlockDev              `protobuf:"bytes,6,rep,name=blockdev" json:"blockdev,omitempty"`
	Netdev               []*NetDev                `protobuf:"bytes,7,rep,name=netdev" json:"netdev,omitempty"`
	WebsocketPort        uint32                   `protobuf:"varint,8,opt,name=websocket_port,json=websocketPort" json:"websocket_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*VirtualMachineAgent) Descriptor 

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

func (*VirtualMachineAgent) GetBlockdev 

func (m *VirtualMachineAgent) GetBlockdev() []*BlockDev

func (*VirtualMachineAgent) GetMemoryBytes 

func (m *VirtualMachineAgent) GetMemoryBytes() uint64

func (*VirtualMachineAgent) GetName 

func (m *VirtualMachineAgent) GetName() string

func (*VirtualMachineAgent) GetNetdev 

func (m *VirtualMachineAgent) GetNetdev() []*NetDev

func (*VirtualMachineAgent) GetState 

func (m *VirtualMachineAgent) GetState() VirtualMachineAgentState

func (*VirtualMachineAgent) GetUuid 

func (m *VirtualMachineAgent) GetUuid() string

func (*VirtualMachineAgent) GetVcpus 

func (m *VirtualMachineAgent) GetVcpus() uint32

func (*VirtualMachineAgent) GetWebsocketPort 

func (m *VirtualMachineAgent) GetWebsocketPort() uint32

func (*VirtualMachineAgent) ProtoMessage 

func (*VirtualMachineAgent) ProtoMessage()

func (*VirtualMachineAgent) Reset 

func (m *VirtualMachineAgent) Reset()

func (*VirtualMachineAgent) String 

func (m *VirtualMachineAgent) String() string

func (*VirtualMachineAgent) XXX_DiscardUnknown 

func (m *VirtualMachineAgent) XXX_DiscardUnknown()

func (*VirtualMachineAgent) XXX_Marshal 

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

func (*VirtualMachineAgent) XXX_Merge 

func (dst *VirtualMachineAgent) XXX_Merge(src proto.Message)

func (*VirtualMachineAgent) XXX_Size 

func (m *VirtualMachineAgent) XXX_Size() int

func (*VirtualMachineAgent) XXX_Unmarshal 

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

type VirtualMachineAgentAPI 

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

func CreateVirtualMachineAgentAPI 

func CreateVirtualMachineAgentAPI(basedir string) (*VirtualMachineAgentAPI, error)

func (VirtualMachineAgentAPI) BootVirtualMachineAgent 

func (a VirtualMachineAgentAPI) BootVirtualMachineAgent(ctx context.Context, req *BootVirtualMachineAgentRequest) (*BootVirtualMachineAgentResponse, error)

func (VirtualMachineAgentAPI) CreateVirtualMachineAgent 

func (a VirtualMachineAgentAPI) CreateVirtualMachineAgent(ctx context.Context, req *CreateVirtualMachineAgentRequest) (*VirtualMachineAgent, error)

func (VirtualMachineAgentAPI) DeleteVirtualMachineAgent 

func (a VirtualMachineAgentAPI) DeleteVirtualMachineAgent(ctx context.Context, req *DeleteVirtualMachineAgentRequest) (*empty.Empty, error)

func (VirtualMachineAgentAPI) GetWorkDirectory 

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

func (VirtualMachineAgentAPI) RebootVirtualMachineAgent 

func (a VirtualMachineAgentAPI) RebootVirtualMachineAgent(ctx context.Context, req *RebootVirtualMachineAgentRequest) (*RebootVirtualMachineAgentResponse, error)

func (VirtualMachineAgentAPI) ShutdownVirtualMachineAgent 

func (a VirtualMachineAgentAPI) ShutdownVirtualMachineAgent(ctx context.Context, req *ShutdownVirtualMachineAgentRequest) (*ShutdownVirtualMachineAgentResponse, error)

type VirtualMachineAgentServiceClient 

type VirtualMachineAgentServiceClient interface {
	CreateVirtualMachineAgent(ctx context.Context, in *CreateVirtualMachineAgentRequest, opts ...grpc.CallOption) (*VirtualMachineAgent, error)
	DeleteVirtualMachineAgent(ctx context.Context, in *DeleteVirtualMachineAgentRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	BootVirtualMachineAgent(ctx context.Context, in *BootVirtualMachineAgentRequest, opts ...grpc.CallOption) (*BootVirtualMachineAgentResponse, error)
	RebootVirtualMachineAgent(ctx context.Context, in *RebootVirtualMachineAgentRequest, opts ...grpc.CallOption) (*RebootVirtualMachineAgentResponse, error)
	ShutdownVirtualMachineAgent(ctx context.Context, in *ShutdownVirtualMachineAgentRequest, opts ...grpc.CallOption) (*ShutdownVirtualMachineAgentResponse, error)
}

func NewVirtualMachineAgentServiceClient 

func NewVirtualMachineAgentServiceClient(cc *grpc.ClientConn) VirtualMachineAgentServiceClient

type VirtualMachineAgentServiceServer 

type VirtualMachineAgentServiceServer interface {
	CreateVirtualMachineAgent(context.Context, *CreateVirtualMachineAgentRequest) (*VirtualMachineAgent, error)
	DeleteVirtualMachineAgent(context.Context, *DeleteVirtualMachineAgentRequest) (*empty.Empty, error)
	BootVirtualMachineAgent(context.Context, *BootVirtualMachineAgentRequest) (*BootVirtualMachineAgentResponse, error)
	RebootVirtualMachineAgent(context.Context, *RebootVirtualMachineAgentRequest) (*RebootVirtualMachineAgentResponse, error)
	ShutdownVirtualMachineAgent(context.Context, *ShutdownVirtualMachineAgentRequest) (*ShutdownVirtualMachineAgentResponse, error)
}

type VirtualMachineAgentState 

type VirtualMachineAgentState int32
const (
	VirtualMachineAgentState_FAILED   VirtualMachineAgentState = 0
	VirtualMachineAgentState_UNKNOWN  VirtualMachineAgentState = 1
	VirtualMachineAgentState_SHUTDOWN VirtualMachineAgentState = 2
	VirtualMachineAgentState_RUNNING  VirtualMachineAgentState = 3
	VirtualMachineAgentState_PAUSED   VirtualMachineAgentState = 4
)

func GetAgentStateFromQemuState 

func GetAgentStateFromQemuState(s qemu.Status) VirtualMachineAgentState

func (VirtualMachineAgentState) EnumDescriptor 

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

func (VirtualMachineAgentState) String 

func (x VirtualMachineAgentState) String() string

type VolumeAPI 

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

func CreateVolumeAPI 

func CreateVolumeAPI(ds datastore.Datastore, na ppool.NodeServiceClient) (*VolumeAPI, error)

func (*VolumeAPI) CreateEmptyVolume 

func (a *VolumeAPI) CreateEmptyVolume(ctx context.Context, req *pprovisioning.CreateEmptyVolumeRequest) (*pprovisioning.Volume, error)

func (*VolumeAPI) CreateVolumeWithDownloading 

func (a *VolumeAPI) CreateVolumeWithDownloading(ctx context.Context, req *pprovisioning.CreateVolumeWithDownloadingRequest) (*pprovisioning.Volume, error)

func (*VolumeAPI) DeleteVolume 

func (a *VolumeAPI) DeleteVolume(ctx context.Context, req *pprovisioning.DeleteVolumeRequest) (*empty.Empty, error)

func (*VolumeAPI) GetVolume 

func (a *VolumeAPI) GetVolume(ctx context.Context, req *pprovisioning.GetVolumeRequest) (*pprovisioning.Volume, error)

func (*VolumeAPI) ListVolumes 

func (a *VolumeAPI) ListVolumes(ctx context.Context, req *pprovisioning.ListVolumesRequest) (*pprovisioning.ListVolumesResponse, error)

func (*VolumeAPI) SetAvailableVolume 

func (a *VolumeAPI) SetAvailableVolume(ctx context.Context, req *pprovisioning.SetAvailableVolumeRequest) (*pprovisioning.Volume, error)

func (*VolumeAPI) SetInuseVolume 

func (a *VolumeAPI) SetInuseVolume(ctx context.Context, req *pprovisioning.SetInuseVolumeRequest) (*pprovisioning.Volume, error)

func (*VolumeAPI) UpdateVolume 

func (a *VolumeAPI) UpdateVolume(ctx context.Context, req *pprovisioning.UpdateVolumeRequest) (*pprovisioning.Volume, error)

type VolumeAgent 

type VolumeAgent struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Bytes                uint64   `protobuf:"varint,2,opt,name=bytes" json:"bytes,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeAgent) Descriptor 

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

func (*VolumeAgent) GetBytes 

func (m *VolumeAgent) GetBytes() uint64

func (*VolumeAgent) GetName 

func (m *VolumeAgent) GetName() string

func (*VolumeAgent) GetPath 

func (m *VolumeAgent) GetPath() string

func (*VolumeAgent) ProtoMessage 

func (*VolumeAgent) ProtoMessage()

func (*VolumeAgent) Reset 

func (m *VolumeAgent) Reset()

func (*VolumeAgent) String 

func (m *VolumeAgent) String() string

func (*VolumeAgent) XXX_DiscardUnknown 

func (m *VolumeAgent) XXX_DiscardUnknown()

func (*VolumeAgent) XXX_Marshal 

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

func (*VolumeAgent) XXX_Merge 

func (dst *VolumeAgent) XXX_Merge(src proto.Message)

func (*VolumeAgent) XXX_Size 

func (m *VolumeAgent) XXX_Size() int

func (*VolumeAgent) XXX_Unmarshal 

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

type VolumeAgentAPI 

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

func CreateVolumeAgentAPI 

func CreateVolumeAgentAPI(basedir string) (*VolumeAgentAPI, error)

func (*VolumeAgentAPI) CreateEmptyVolumeAgent 

func (a *VolumeAgentAPI) CreateEmptyVolumeAgent(ctx context.Context, req *CreateEmptyVolumeAgentRequest) (*VolumeAgent, error)

func (*VolumeAgentAPI) CreateVolumeAgentWithDownloading 

func (a *VolumeAgentAPI) CreateVolumeAgentWithDownloading(ctx context.Context, req *CreateVolumeAgentWithDownloadingRequest) (*VolumeAgent, error)

タイムアウトが心配

func (*VolumeAgentAPI) DeleteVolumeAgent 

func (a *VolumeAgentAPI) DeleteVolumeAgent(ctx context.Context, req *DeleteVolumeAgentRequest) (*empty.Empty, error)

type VolumeAgentServiceClient 

type VolumeAgentServiceClient interface {
	CreateEmptyVolumeAgent(ctx context.Context, in *CreateEmptyVolumeAgentRequest, opts ...grpc.CallOption) (*VolumeAgent, error)
	CreateVolumeAgentWithDownloading(ctx context.Context, in *CreateVolumeAgentWithDownloadingRequest, opts ...grpc.CallOption) (*VolumeAgent, error)
	DeleteVolumeAgent(ctx context.Context, in *DeleteVolumeAgentRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

func NewVolumeAgentServiceClient 

func NewVolumeAgentServiceClient(cc *grpc.ClientConn) VolumeAgentServiceClient

type VolumeAgentServiceServer 

type VolumeAgentServiceServer interface {
	CreateEmptyVolumeAgent(context.Context, *CreateEmptyVolumeAgentRequest) (*VolumeAgent, error)
	CreateVolumeAgentWithDownloading(context.Context, *CreateVolumeAgentWithDownloadingRequest) (*VolumeAgent, error)
	DeleteVolumeAgent(context.Context, *DeleteVolumeAgentRequest) (*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.