diff --git a/cmd/compute_api/api/domain.go b/cmd/compute_api/api/domain.go index cf958ab..047d25d 100644 --- a/cmd/compute_api/api/domain.go +++ b/cmd/compute_api/api/domain.go @@ -6,7 +6,7 @@ import ( "strconv" "time" - "deevirt.fr/compute/cmd/compute_api/proto" + "deevirt.fr/compute/pkg/api/proto" "deevirt.fr/compute/pkg/config" clientv3 "go.etcd.io/etcd/client/v3" ) diff --git a/cmd/compute_api/api/server.go b/cmd/compute_api/api/server.go index 03d9a67..d2597b6 100644 --- a/cmd/compute_api/api/server.go +++ b/cmd/compute_api/api/server.go @@ -6,7 +6,7 @@ import ( "strings" "time" - "deevirt.fr/compute/cmd/compute_api/proto" + "deevirt.fr/compute/pkg/api/proto" "deevirt.fr/compute/pkg/config" clientv3 "go.etcd.io/etcd/client/v3" "google.golang.org/grpc" @@ -14,7 +14,7 @@ import ( ) func Server() { - config, _ := config.NewConfig() + config, _ := config.New() //listen on the port lis, err := net.Listen("tcp", ":8080") diff --git a/cmd/compute_api/proto/domain.pb.go b/cmd/compute_api/proto/domain.pb.go deleted file mode 100644 index 806319f..0000000 --- a/cmd/compute_api/proto/domain.pb.go +++ /dev/null @@ -1,1086 +0,0 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. -// versions: -// protoc-gen-go v1.31.0 -// protoc v3.14.0 -// source: proto/domain.proto - -package proto - -import ( - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" - reflect "reflect" - sync "sync" -) - -const ( - // Verify that this generated code is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) - // Verify that runtime/protoimpl is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) -) - -type DomainPower int32 - -const ( - DomainPower_UNDEFINED DomainPower = 0 - DomainPower_START DomainPower = 1 - DomainPower_REBOOT DomainPower = 2 - DomainPower_SHUTDOWN DomainPower = 3 - DomainPower_PAUSE DomainPower = 4 - DomainPower_RESUME DomainPower = 5 - DomainPower_RESET DomainPower = 6 - DomainPower_DESTROY DomainPower = 7 -) - -// Enum value maps for DomainPower. -var ( - DomainPower_name = map[int32]string{ - 0: "UNDEFINED", - 1: "START", - 2: "REBOOT", - 3: "SHUTDOWN", - 4: "PAUSE", - 5: "RESUME", - 6: "RESET", - 7: "DESTROY", - } - DomainPower_value = map[string]int32{ - "UNDEFINED": 0, - "START": 1, - "REBOOT": 2, - "SHUTDOWN": 3, - "PAUSE": 4, - "RESUME": 5, - "RESET": 6, - "DESTROY": 7, - } -) - -func (x DomainPower) Enum() *DomainPower { - p := new(DomainPower) - *p = x - return p -} - -func (x DomainPower) String() string { - return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) -} - -func (DomainPower) Descriptor() protoreflect.EnumDescriptor { - return file_proto_domain_proto_enumTypes[0].Descriptor() -} - -func (DomainPower) Type() protoreflect.EnumType { - return &file_proto_domain_proto_enumTypes[0] -} - -func (x DomainPower) Number() protoreflect.EnumNumber { - return protoreflect.EnumNumber(x) -} - -// Deprecated: Use DomainPower.Descriptor instead. -func (DomainPower) EnumDescriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{0} -} - -type DomainListAllRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields -} - -func (x *DomainListAllRequest) Reset() { - *x = DomainListAllRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainListAllRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainListAllRequest) ProtoMessage() {} - -func (x *DomainListAllRequest) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[0] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainListAllRequest.ProtoReflect.Descriptor instead. -func (*DomainListAllRequest) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{0} -} - -type DomainListAllResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Domains []*DomainListResponse `protobuf:"bytes,1,rep,name=domains,proto3" json:"domains,omitempty"` -} - -func (x *DomainListAllResponse) Reset() { - *x = DomainListAllResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainListAllResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainListAllResponse) ProtoMessage() {} - -func (x *DomainListAllResponse) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[1] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainListAllResponse.ProtoReflect.Descriptor instead. -func (*DomainListAllResponse) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{1} -} - -func (x *DomainListAllResponse) GetDomains() []*DomainListResponse { - if x != nil { - return x.Domains - } - return nil -} - -type DomainListRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - DomainId string `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` -} - -func (x *DomainListRequest) Reset() { - *x = DomainListRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[2] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainListRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainListRequest) ProtoMessage() {} - -func (x *DomainListRequest) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[2] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainListRequest.ProtoReflect.Descriptor instead. -func (*DomainListRequest) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{2} -} - -func (x *DomainListRequest) GetDomainId() string { - if x != nil { - return x.DomainId - } - return "" -} - -type DomainListResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - DomainId string `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` - Config string `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` - State int64 `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"` -} - -func (x *DomainListResponse) Reset() { - *x = DomainListResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[3] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainListResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainListResponse) ProtoMessage() {} - -func (x *DomainListResponse) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[3] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainListResponse.ProtoReflect.Descriptor instead. -func (*DomainListResponse) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{3} -} - -func (x *DomainListResponse) GetDomainId() string { - if x != nil { - return x.DomainId - } - return "" -} - -func (x *DomainListResponse) GetConfig() string { - if x != nil { - return x.Config - } - return "" -} - -func (x *DomainListResponse) GetState() int64 { - if x != nil { - return x.State - } - return 0 -} - -type DomainCreateRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` - Config string `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` -} - -func (x *DomainCreateRequest) Reset() { - *x = DomainCreateRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[4] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainCreateRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainCreateRequest) ProtoMessage() {} - -func (x *DomainCreateRequest) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[4] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainCreateRequest.ProtoReflect.Descriptor instead. -func (*DomainCreateRequest) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{4} -} - -func (x *DomainCreateRequest) GetNodeId() string { - if x != nil { - return x.NodeId - } - return "" -} - -func (x *DomainCreateRequest) GetConfig() string { - if x != nil { - return x.Config - } - return "" -} - -type DomainCreateResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Progress int64 `protobuf:"varint,1,opt,name=progress,proto3" json:"progress,omitempty"` -} - -func (x *DomainCreateResponse) Reset() { - *x = DomainCreateResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[5] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainCreateResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainCreateResponse) ProtoMessage() {} - -func (x *DomainCreateResponse) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[5] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainCreateResponse.ProtoReflect.Descriptor instead. -func (*DomainCreateResponse) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{5} -} - -func (x *DomainCreateResponse) GetProgress() int64 { - if x != nil { - return x.Progress - } - return 0 -} - -type DomainUpdateRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - VmId string `protobuf:"bytes,1,opt,name=vm_id,json=vmId,proto3" json:"vm_id,omitempty"` -} - -func (x *DomainUpdateRequest) Reset() { - *x = DomainUpdateRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[6] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainUpdateRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainUpdateRequest) ProtoMessage() {} - -func (x *DomainUpdateRequest) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[6] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainUpdateRequest.ProtoReflect.Descriptor instead. -func (*DomainUpdateRequest) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{6} -} - -func (x *DomainUpdateRequest) GetVmId() string { - if x != nil { - return x.VmId - } - return "" -} - -type DomainUpdateResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields -} - -func (x *DomainUpdateResponse) Reset() { - *x = DomainUpdateResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[7] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainUpdateResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainUpdateResponse) ProtoMessage() {} - -func (x *DomainUpdateResponse) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[7] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainUpdateResponse.ProtoReflect.Descriptor instead. -func (*DomainUpdateResponse) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{7} -} - -type DomainDeleteRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - VmId string `protobuf:"bytes,1,opt,name=vm_id,json=vmId,proto3" json:"vm_id,omitempty"` -} - -func (x *DomainDeleteRequest) Reset() { - *x = DomainDeleteRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[8] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainDeleteRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainDeleteRequest) ProtoMessage() {} - -func (x *DomainDeleteRequest) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[8] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainDeleteRequest.ProtoReflect.Descriptor instead. -func (*DomainDeleteRequest) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{8} -} - -func (x *DomainDeleteRequest) GetVmId() string { - if x != nil { - return x.VmId - } - return "" -} - -type DomainDeleteResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields -} - -func (x *DomainDeleteResponse) Reset() { - *x = DomainDeleteResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[9] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainDeleteResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainDeleteResponse) ProtoMessage() {} - -func (x *DomainDeleteResponse) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[9] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainDeleteResponse.ProtoReflect.Descriptor instead. -func (*DomainDeleteResponse) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{9} -} - -type DomainPowerRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - VmId []byte `protobuf:"bytes,1,opt,name=vm_id,json=vmId,proto3" json:"vm_id,omitempty"` - Action DomainPower `protobuf:"varint,2,opt,name=action,proto3,enum=domain.DomainPower" json:"action,omitempty"` -} - -func (x *DomainPowerRequest) Reset() { - *x = DomainPowerRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[10] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainPowerRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainPowerRequest) ProtoMessage() {} - -func (x *DomainPowerRequest) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[10] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainPowerRequest.ProtoReflect.Descriptor instead. -func (*DomainPowerRequest) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{10} -} - -func (x *DomainPowerRequest) GetVmId() []byte { - if x != nil { - return x.VmId - } - return nil -} - -func (x *DomainPowerRequest) GetAction() DomainPower { - if x != nil { - return x.Action - } - return DomainPower_UNDEFINED -} - -type DomainPowerResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields -} - -func (x *DomainPowerResponse) Reset() { - *x = DomainPowerResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[11] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainPowerResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainPowerResponse) ProtoMessage() {} - -func (x *DomainPowerResponse) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[11] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainPowerResponse.ProtoReflect.Descriptor instead. -func (*DomainPowerResponse) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{11} -} - -type DomainDevicesGraphicsConsoleRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - VmId []byte `protobuf:"bytes,1,opt,name=vm_id,json=vmId,proto3" json:"vm_id,omitempty"` -} - -func (x *DomainDevicesGraphicsConsoleRequest) Reset() { - *x = DomainDevicesGraphicsConsoleRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[12] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainDevicesGraphicsConsoleRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainDevicesGraphicsConsoleRequest) ProtoMessage() {} - -func (x *DomainDevicesGraphicsConsoleRequest) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[12] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainDevicesGraphicsConsoleRequest.ProtoReflect.Descriptor instead. -func (*DomainDevicesGraphicsConsoleRequest) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{12} -} - -func (x *DomainDevicesGraphicsConsoleRequest) GetVmId() []byte { - if x != nil { - return x.VmId - } - return nil -} - -type DomainDevicesGraphicsConsoleResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"` -} - -func (x *DomainDevicesGraphicsConsoleResponse) Reset() { - *x = DomainDevicesGraphicsConsoleResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_proto_domain_proto_msgTypes[13] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainDevicesGraphicsConsoleResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainDevicesGraphicsConsoleResponse) ProtoMessage() {} - -func (x *DomainDevicesGraphicsConsoleResponse) ProtoReflect() protoreflect.Message { - mi := &file_proto_domain_proto_msgTypes[13] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainDevicesGraphicsConsoleResponse.ProtoReflect.Descriptor instead. -func (*DomainDevicesGraphicsConsoleResponse) Descriptor() ([]byte, []int) { - return file_proto_domain_proto_rawDescGZIP(), []int{13} -} - -func (x *DomainDevicesGraphicsConsoleResponse) GetUri() string { - if x != nil { - return x.Uri - } - return "" -} - -var File_proto_domain_proto protoreflect.FileDescriptor - -var file_proto_domain_proto_rawDesc = []byte{ - 0x0a, 0x12, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x70, - 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x06, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x22, 0x16, 0x0a, 0x14, - 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x22, 0x4d, 0x0a, 0x15, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, - 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x34, 0x0a, - 0x07, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1a, - 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, - 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x52, 0x07, 0x64, 0x6f, 0x6d, 0x61, - 0x69, 0x6e, 0x73, 0x22, 0x30, 0x0a, 0x11, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, 0x73, - 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x64, 0x6f, 0x6d, 0x61, - 0x69, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x64, 0x6f, 0x6d, - 0x61, 0x69, 0x6e, 0x49, 0x64, 0x22, 0x5f, 0x0a, 0x12, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, - 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x64, - 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, - 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x63, 0x6f, 0x6e, 0x66, - 0x69, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, - 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, - 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x22, 0x46, 0x0a, 0x13, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, - 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x17, 0x0a, - 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, - 0x6e, 0x6f, 0x64, 0x65, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22, 0x32, - 0x0a, 0x14, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, - 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, - 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, - 0x73, 0x73, 0x22, 0x2a, 0x0a, 0x13, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x55, 0x70, 0x64, 0x61, - 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x13, 0x0a, 0x05, 0x76, 0x6d, 0x5f, - 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x76, 0x6d, 0x49, 0x64, 0x22, 0x16, - 0x0a, 0x14, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, - 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2a, 0x0a, 0x13, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, - 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x13, 0x0a, - 0x05, 0x76, 0x6d, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x76, 0x6d, - 0x49, 0x64, 0x22, 0x16, 0x0a, 0x14, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x44, 0x65, 0x6c, 0x65, - 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x56, 0x0a, 0x12, 0x44, 0x6f, - 0x6d, 0x61, 0x69, 0x6e, 0x50, 0x6f, 0x77, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x12, 0x13, 0x0a, 0x05, 0x76, 0x6d, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, - 0x04, 0x76, 0x6d, 0x49, 0x64, 0x12, 0x2b, 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, - 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x13, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, - 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x50, 0x6f, 0x77, 0x65, 0x72, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, - 0x6f, 0x6e, 0x22, 0x15, 0x0a, 0x13, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x50, 0x6f, 0x77, 0x65, - 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x3a, 0x0a, 0x23, 0x44, 0x6f, 0x6d, - 0x61, 0x69, 0x6e, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x73, 0x47, 0x72, 0x61, 0x70, 0x68, 0x69, - 0x63, 0x73, 0x43, 0x6f, 0x6e, 0x73, 0x6f, 0x6c, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x12, 0x13, 0x0a, 0x05, 0x76, 0x6d, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, - 0x04, 0x76, 0x6d, 0x49, 0x64, 0x22, 0x38, 0x0a, 0x24, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x44, - 0x65, 0x76, 0x69, 0x63, 0x65, 0x73, 0x47, 0x72, 0x61, 0x70, 0x68, 0x69, 0x63, 0x73, 0x43, 0x6f, - 0x6e, 0x73, 0x6f, 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a, - 0x03, 0x75, 0x72, 0x69, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x75, 0x72, 0x69, 0x2a, - 0x70, 0x0a, 0x0b, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x50, 0x6f, 0x77, 0x65, 0x72, 0x12, 0x0d, - 0x0a, 0x09, 0x55, 0x4e, 0x44, 0x45, 0x46, 0x49, 0x4e, 0x45, 0x44, 0x10, 0x00, 0x12, 0x09, 0x0a, - 0x05, 0x53, 0x54, 0x41, 0x52, 0x54, 0x10, 0x01, 0x12, 0x0a, 0x0a, 0x06, 0x52, 0x45, 0x42, 0x4f, - 0x4f, 0x54, 0x10, 0x02, 0x12, 0x0c, 0x0a, 0x08, 0x53, 0x48, 0x55, 0x54, 0x44, 0x4f, 0x57, 0x4e, - 0x10, 0x03, 0x12, 0x09, 0x0a, 0x05, 0x50, 0x41, 0x55, 0x53, 0x45, 0x10, 0x04, 0x12, 0x0a, 0x0a, - 0x06, 0x52, 0x45, 0x53, 0x55, 0x4d, 0x45, 0x10, 0x05, 0x12, 0x09, 0x0a, 0x05, 0x52, 0x45, 0x53, - 0x45, 0x54, 0x10, 0x06, 0x12, 0x0b, 0x0a, 0x07, 0x44, 0x45, 0x53, 0x54, 0x52, 0x4f, 0x59, 0x10, - 0x07, 0x32, 0xa8, 0x03, 0x0a, 0x06, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x12, 0x45, 0x0a, 0x04, - 0x4c, 0x69, 0x73, 0x74, 0x12, 0x1c, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, - 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, - 0x69, 0x6e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, - 0x65, 0x22, 0x00, 0x12, 0x3e, 0x0a, 0x03, 0x47, 0x65, 0x74, 0x12, 0x19, 0x2e, 0x64, 0x6f, 0x6d, - 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, - 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, - 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, - 0x65, 0x22, 0x00, 0x12, 0x45, 0x0a, 0x06, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x2e, - 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x43, 0x72, 0x65, - 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x64, 0x6f, 0x6d, - 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x45, 0x0a, 0x06, 0x55, 0x70, - 0x64, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, - 0x6d, 0x61, 0x69, 0x6e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, - 0x74, 0x1a, 0x1c, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, - 0x6e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, - 0x00, 0x12, 0x45, 0x0a, 0x06, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x1b, 0x2e, 0x64, 0x6f, - 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x44, 0x65, 0x6c, 0x65, 0x74, - 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, - 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, - 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x42, 0x0a, 0x05, 0x50, 0x6f, 0x77, 0x65, - 0x72, 0x12, 0x1a, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, - 0x6e, 0x50, 0x6f, 0x77, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, - 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x50, 0x6f, 0x77, - 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x32, 0x7f, 0x0a, 0x15, - 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x73, 0x47, 0x72, 0x61, - 0x70, 0x68, 0x69, 0x63, 0x73, 0x12, 0x66, 0x0a, 0x07, 0x43, 0x6f, 0x6e, 0x73, 0x6f, 0x6c, 0x65, - 0x12, 0x2b, 0x2e, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, - 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x73, 0x47, 0x72, 0x61, 0x70, 0x68, 0x69, 0x63, 0x73, 0x43, - 0x6f, 0x6e, 0x73, 0x6f, 0x6c, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2c, 0x2e, - 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x44, 0x65, 0x76, - 0x69, 0x63, 0x65, 0x73, 0x47, 0x72, 0x61, 0x70, 0x68, 0x69, 0x63, 0x73, 0x43, 0x6f, 0x6e, 0x73, - 0x6f, 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x09, 0x5a, - 0x07, 0x2e, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -} - -var ( - file_proto_domain_proto_rawDescOnce sync.Once - file_proto_domain_proto_rawDescData = file_proto_domain_proto_rawDesc -) - -func file_proto_domain_proto_rawDescGZIP() []byte { - file_proto_domain_proto_rawDescOnce.Do(func() { - file_proto_domain_proto_rawDescData = protoimpl.X.CompressGZIP(file_proto_domain_proto_rawDescData) - }) - return file_proto_domain_proto_rawDescData -} - -var file_proto_domain_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_proto_domain_proto_msgTypes = make([]protoimpl.MessageInfo, 14) -var file_proto_domain_proto_goTypes = []interface{}{ - (DomainPower)(0), // 0: domain.DomainPower - (*DomainListAllRequest)(nil), // 1: domain.DomainListAllRequest - (*DomainListAllResponse)(nil), // 2: domain.DomainListAllResponse - (*DomainListRequest)(nil), // 3: domain.DomainListRequest - (*DomainListResponse)(nil), // 4: domain.DomainListResponse - (*DomainCreateRequest)(nil), // 5: domain.DomainCreateRequest - (*DomainCreateResponse)(nil), // 6: domain.DomainCreateResponse - (*DomainUpdateRequest)(nil), // 7: domain.DomainUpdateRequest - (*DomainUpdateResponse)(nil), // 8: domain.DomainUpdateResponse - (*DomainDeleteRequest)(nil), // 9: domain.DomainDeleteRequest - (*DomainDeleteResponse)(nil), // 10: domain.DomainDeleteResponse - (*DomainPowerRequest)(nil), // 11: domain.DomainPowerRequest - (*DomainPowerResponse)(nil), // 12: domain.DomainPowerResponse - (*DomainDevicesGraphicsConsoleRequest)(nil), // 13: domain.DomainDevicesGraphicsConsoleRequest - (*DomainDevicesGraphicsConsoleResponse)(nil), // 14: domain.DomainDevicesGraphicsConsoleResponse -} -var file_proto_domain_proto_depIdxs = []int32{ - 4, // 0: domain.DomainListAllResponse.domains:type_name -> domain.DomainListResponse - 0, // 1: domain.DomainPowerRequest.action:type_name -> domain.DomainPower - 1, // 2: domain.Domain.List:input_type -> domain.DomainListAllRequest - 3, // 3: domain.Domain.Get:input_type -> domain.DomainListRequest - 5, // 4: domain.Domain.Create:input_type -> domain.DomainCreateRequest - 7, // 5: domain.Domain.Update:input_type -> domain.DomainUpdateRequest - 9, // 6: domain.Domain.Delete:input_type -> domain.DomainDeleteRequest - 11, // 7: domain.Domain.Power:input_type -> domain.DomainPowerRequest - 13, // 8: domain.DomainDevicesGraphics.Console:input_type -> domain.DomainDevicesGraphicsConsoleRequest - 2, // 9: domain.Domain.List:output_type -> domain.DomainListAllResponse - 4, // 10: domain.Domain.Get:output_type -> domain.DomainListResponse - 6, // 11: domain.Domain.Create:output_type -> domain.DomainCreateResponse - 8, // 12: domain.Domain.Update:output_type -> domain.DomainUpdateResponse - 10, // 13: domain.Domain.Delete:output_type -> domain.DomainDeleteResponse - 12, // 14: domain.Domain.Power:output_type -> domain.DomainPowerResponse - 14, // 15: domain.DomainDevicesGraphics.Console:output_type -> domain.DomainDevicesGraphicsConsoleResponse - 9, // [9:16] is the sub-list for method output_type - 2, // [2:9] is the sub-list for method input_type - 2, // [2:2] is the sub-list for extension type_name - 2, // [2:2] is the sub-list for extension extendee - 0, // [0:2] is the sub-list for field type_name -} - -func init() { file_proto_domain_proto_init() } -func file_proto_domain_proto_init() { - if File_proto_domain_proto != nil { - return - } - if !protoimpl.UnsafeEnabled { - file_proto_domain_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainListAllRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainListAllResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainListRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainListResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainCreateRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainCreateResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainUpdateRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainUpdateResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainDeleteRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainDeleteResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainPowerRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainPowerResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainDevicesGraphicsConsoleRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_proto_domain_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainDevicesGraphicsConsoleResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - } - type x struct{} - out := protoimpl.TypeBuilder{ - File: protoimpl.DescBuilder{ - GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_proto_domain_proto_rawDesc, - NumEnums: 1, - NumMessages: 14, - NumExtensions: 0, - NumServices: 2, - }, - GoTypes: file_proto_domain_proto_goTypes, - DependencyIndexes: file_proto_domain_proto_depIdxs, - EnumInfos: file_proto_domain_proto_enumTypes, - MessageInfos: file_proto_domain_proto_msgTypes, - }.Build() - File_proto_domain_proto = out.File - file_proto_domain_proto_rawDesc = nil - file_proto_domain_proto_goTypes = nil - file_proto_domain_proto_depIdxs = nil -} diff --git a/cmd/compute_api/proto/domain.proto b/cmd/compute_api/proto/domain.proto deleted file mode 100644 index 1fd4178..0000000 --- a/cmd/compute_api/proto/domain.proto +++ /dev/null @@ -1,90 +0,0 @@ -syntax="proto3"; - -option go_package = "./proto"; -package domain; - -// The greeting service definition. -service Domain { - rpc List (DomainListAllRequest) returns (DomainListAllResponse) {} - rpc Get (DomainListRequest) returns (DomainListResponse) {} - rpc Create (DomainCreateRequest) returns (DomainCreateResponse) {} - rpc Update (DomainUpdateRequest) returns (DomainUpdateResponse) {} - rpc Delete (DomainDeleteRequest) returns (DomainDeleteResponse) {} - - rpc Power (DomainPowerRequest) returns (DomainPowerResponse) {} - -} - -message DomainListAllRequest {} - -message DomainListAllResponse { - repeated DomainListResponse domains = 1; -} - -message DomainListRequest { - string domain_id = 1; -} - -message DomainListResponse { - string domain_id = 1; - string config = 2; - int64 state = 3; -} - -message DomainCreateRequest { - string node_id = 1; - string config = 2; -} - -message DomainCreateResponse { - int64 progress = 1; -} - -service DomainDevicesGraphics { - rpc Console (DomainDevicesGraphicsConsoleRequest) returns (DomainDevicesGraphicsConsoleResponse) {} -} - - - -message DomainUpdateRequest { - string vm_id = 1; -} - -message DomainUpdateResponse { -} - -message DomainDeleteRequest { - string vm_id = 1; -} - -message DomainDeleteResponse { -} - -enum DomainPower { - UNDEFINED = 0; - START = 1; - REBOOT = 2; - SHUTDOWN = 3; - PAUSE = 4; - RESUME = 5; - RESET = 6; - DESTROY = 7; -} - -message DomainPowerRequest { - bytes vm_id = 1; - DomainPower action = 2; -} - -message DomainPowerResponse { -} - -message DomainDevicesGraphicsConsoleRequest { - bytes vm_id = 1; -} - -message DomainDevicesGraphicsConsoleResponse { - string uri = 1; -} - - diff --git a/cmd/compute_api/proto/domain_grpc.pb.go b/cmd/compute_api/proto/domain_grpc.pb.go deleted file mode 100644 index 488f471..0000000 --- a/cmd/compute_api/proto/domain_grpc.pb.go +++ /dev/null @@ -1,417 +0,0 @@ -// Code generated by protoc-gen-go-grpc. DO NOT EDIT. -// versions: -// - protoc-gen-go-grpc v1.5.1 -// - protoc v3.14.0 -// source: proto/domain.proto - -package proto - -import ( - context "context" - grpc "google.golang.org/grpc" - codes "google.golang.org/grpc/codes" - status "google.golang.org/grpc/status" -) - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.64.0 or later. -const _ = grpc.SupportPackageIsVersion9 - -const ( - Domain_List_FullMethodName = "/domain.Domain/List" - Domain_Get_FullMethodName = "/domain.Domain/Get" - Domain_Create_FullMethodName = "/domain.Domain/Create" - Domain_Update_FullMethodName = "/domain.Domain/Update" - Domain_Delete_FullMethodName = "/domain.Domain/Delete" - Domain_Power_FullMethodName = "/domain.Domain/Power" -) - -// DomainClient is the client API for Domain service. -// -// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. -// -// The greeting service definition. -type DomainClient interface { - List(ctx context.Context, in *DomainListAllRequest, opts ...grpc.CallOption) (*DomainListAllResponse, error) - Get(ctx context.Context, in *DomainListRequest, opts ...grpc.CallOption) (*DomainListResponse, error) - Create(ctx context.Context, in *DomainCreateRequest, opts ...grpc.CallOption) (*DomainCreateResponse, error) - Update(ctx context.Context, in *DomainUpdateRequest, opts ...grpc.CallOption) (*DomainUpdateResponse, error) - Delete(ctx context.Context, in *DomainDeleteRequest, opts ...grpc.CallOption) (*DomainDeleteResponse, error) - Power(ctx context.Context, in *DomainPowerRequest, opts ...grpc.CallOption) (*DomainPowerResponse, error) -} - -type domainClient struct { - cc grpc.ClientConnInterface -} - -func NewDomainClient(cc grpc.ClientConnInterface) DomainClient { - return &domainClient{cc} -} - -func (c *domainClient) List(ctx context.Context, in *DomainListAllRequest, opts ...grpc.CallOption) (*DomainListAllResponse, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - out := new(DomainListAllResponse) - err := c.cc.Invoke(ctx, Domain_List_FullMethodName, in, out, cOpts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *domainClient) Get(ctx context.Context, in *DomainListRequest, opts ...grpc.CallOption) (*DomainListResponse, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - out := new(DomainListResponse) - err := c.cc.Invoke(ctx, Domain_Get_FullMethodName, in, out, cOpts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *domainClient) Create(ctx context.Context, in *DomainCreateRequest, opts ...grpc.CallOption) (*DomainCreateResponse, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - out := new(DomainCreateResponse) - err := c.cc.Invoke(ctx, Domain_Create_FullMethodName, in, out, cOpts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *domainClient) Update(ctx context.Context, in *DomainUpdateRequest, opts ...grpc.CallOption) (*DomainUpdateResponse, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - out := new(DomainUpdateResponse) - err := c.cc.Invoke(ctx, Domain_Update_FullMethodName, in, out, cOpts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *domainClient) Delete(ctx context.Context, in *DomainDeleteRequest, opts ...grpc.CallOption) (*DomainDeleteResponse, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - out := new(DomainDeleteResponse) - err := c.cc.Invoke(ctx, Domain_Delete_FullMethodName, in, out, cOpts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *domainClient) Power(ctx context.Context, in *DomainPowerRequest, opts ...grpc.CallOption) (*DomainPowerResponse, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - out := new(DomainPowerResponse) - err := c.cc.Invoke(ctx, Domain_Power_FullMethodName, in, out, cOpts...) - if err != nil { - return nil, err - } - return out, nil -} - -// DomainServer is the server API for Domain service. -// All implementations must embed UnimplementedDomainServer -// for forward compatibility. -// -// The greeting service definition. -type DomainServer interface { - List(context.Context, *DomainListAllRequest) (*DomainListAllResponse, error) - Get(context.Context, *DomainListRequest) (*DomainListResponse, error) - Create(context.Context, *DomainCreateRequest) (*DomainCreateResponse, error) - Update(context.Context, *DomainUpdateRequest) (*DomainUpdateResponse, error) - Delete(context.Context, *DomainDeleteRequest) (*DomainDeleteResponse, error) - Power(context.Context, *DomainPowerRequest) (*DomainPowerResponse, error) - mustEmbedUnimplementedDomainServer() -} - -// UnimplementedDomainServer must be embedded to have -// forward compatible implementations. -// -// NOTE: this should be embedded by value instead of pointer to avoid a nil -// pointer dereference when methods are called. -type UnimplementedDomainServer struct{} - -func (UnimplementedDomainServer) List(context.Context, *DomainListAllRequest) (*DomainListAllResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method List not implemented") -} -func (UnimplementedDomainServer) Get(context.Context, *DomainListRequest) (*DomainListResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Get not implemented") -} -func (UnimplementedDomainServer) Create(context.Context, *DomainCreateRequest) (*DomainCreateResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") -} -func (UnimplementedDomainServer) Update(context.Context, *DomainUpdateRequest) (*DomainUpdateResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Update not implemented") -} -func (UnimplementedDomainServer) Delete(context.Context, *DomainDeleteRequest) (*DomainDeleteResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented") -} -func (UnimplementedDomainServer) Power(context.Context, *DomainPowerRequest) (*DomainPowerResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Power not implemented") -} -func (UnimplementedDomainServer) mustEmbedUnimplementedDomainServer() {} -func (UnimplementedDomainServer) testEmbeddedByValue() {} - -// UnsafeDomainServer may be embedded to opt out of forward compatibility for this service. -// Use of this interface is not recommended, as added methods to DomainServer will -// result in compilation errors. -type UnsafeDomainServer interface { - mustEmbedUnimplementedDomainServer() -} - -func RegisterDomainServer(s grpc.ServiceRegistrar, srv DomainServer) { - // If the following call pancis, it indicates UnimplementedDomainServer was - // embedded by pointer and is nil. This will cause panics if an - // unimplemented method is ever invoked, so we test this at initialization - // time to prevent it from happening at runtime later due to I/O. - if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { - t.testEmbeddedByValue() - } - s.RegisterService(&Domain_ServiceDesc, srv) -} - -func _Domain_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DomainListAllRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(DomainServer).List(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: Domain_List_FullMethodName, - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DomainServer).List(ctx, req.(*DomainListAllRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _Domain_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DomainListRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(DomainServer).Get(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: Domain_Get_FullMethodName, - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DomainServer).Get(ctx, req.(*DomainListRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _Domain_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DomainCreateRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(DomainServer).Create(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: Domain_Create_FullMethodName, - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DomainServer).Create(ctx, req.(*DomainCreateRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _Domain_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DomainUpdateRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(DomainServer).Update(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: Domain_Update_FullMethodName, - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DomainServer).Update(ctx, req.(*DomainUpdateRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _Domain_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DomainDeleteRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(DomainServer).Delete(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: Domain_Delete_FullMethodName, - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DomainServer).Delete(ctx, req.(*DomainDeleteRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _Domain_Power_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DomainPowerRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(DomainServer).Power(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: Domain_Power_FullMethodName, - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DomainServer).Power(ctx, req.(*DomainPowerRequest)) - } - return interceptor(ctx, in, info, handler) -} - -// Domain_ServiceDesc is the grpc.ServiceDesc for Domain service. -// It's only intended for direct use with grpc.RegisterService, -// and not to be introspected or modified (even as a copy) -var Domain_ServiceDesc = grpc.ServiceDesc{ - ServiceName: "domain.Domain", - HandlerType: (*DomainServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "List", - Handler: _Domain_List_Handler, - }, - { - MethodName: "Get", - Handler: _Domain_Get_Handler, - }, - { - MethodName: "Create", - Handler: _Domain_Create_Handler, - }, - { - MethodName: "Update", - Handler: _Domain_Update_Handler, - }, - { - MethodName: "Delete", - Handler: _Domain_Delete_Handler, - }, - { - MethodName: "Power", - Handler: _Domain_Power_Handler, - }, - }, - Streams: []grpc.StreamDesc{}, - Metadata: "proto/domain.proto", -} - -const ( - DomainDevicesGraphics_Console_FullMethodName = "/domain.DomainDevicesGraphics/Console" -) - -// DomainDevicesGraphicsClient is the client API for DomainDevicesGraphics service. -// -// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. -type DomainDevicesGraphicsClient interface { - Console(ctx context.Context, in *DomainDevicesGraphicsConsoleRequest, opts ...grpc.CallOption) (*DomainDevicesGraphicsConsoleResponse, error) -} - -type domainDevicesGraphicsClient struct { - cc grpc.ClientConnInterface -} - -func NewDomainDevicesGraphicsClient(cc grpc.ClientConnInterface) DomainDevicesGraphicsClient { - return &domainDevicesGraphicsClient{cc} -} - -func (c *domainDevicesGraphicsClient) Console(ctx context.Context, in *DomainDevicesGraphicsConsoleRequest, opts ...grpc.CallOption) (*DomainDevicesGraphicsConsoleResponse, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - out := new(DomainDevicesGraphicsConsoleResponse) - err := c.cc.Invoke(ctx, DomainDevicesGraphics_Console_FullMethodName, in, out, cOpts...) - if err != nil { - return nil, err - } - return out, nil -} - -// DomainDevicesGraphicsServer is the server API for DomainDevicesGraphics service. -// All implementations must embed UnimplementedDomainDevicesGraphicsServer -// for forward compatibility. -type DomainDevicesGraphicsServer interface { - Console(context.Context, *DomainDevicesGraphicsConsoleRequest) (*DomainDevicesGraphicsConsoleResponse, error) - mustEmbedUnimplementedDomainDevicesGraphicsServer() -} - -// UnimplementedDomainDevicesGraphicsServer must be embedded to have -// forward compatible implementations. -// -// NOTE: this should be embedded by value instead of pointer to avoid a nil -// pointer dereference when methods are called. -type UnimplementedDomainDevicesGraphicsServer struct{} - -func (UnimplementedDomainDevicesGraphicsServer) Console(context.Context, *DomainDevicesGraphicsConsoleRequest) (*DomainDevicesGraphicsConsoleResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Console not implemented") -} -func (UnimplementedDomainDevicesGraphicsServer) mustEmbedUnimplementedDomainDevicesGraphicsServer() {} -func (UnimplementedDomainDevicesGraphicsServer) testEmbeddedByValue() {} - -// UnsafeDomainDevicesGraphicsServer may be embedded to opt out of forward compatibility for this service. -// Use of this interface is not recommended, as added methods to DomainDevicesGraphicsServer will -// result in compilation errors. -type UnsafeDomainDevicesGraphicsServer interface { - mustEmbedUnimplementedDomainDevicesGraphicsServer() -} - -func RegisterDomainDevicesGraphicsServer(s grpc.ServiceRegistrar, srv DomainDevicesGraphicsServer) { - // If the following call pancis, it indicates UnimplementedDomainDevicesGraphicsServer was - // embedded by pointer and is nil. This will cause panics if an - // unimplemented method is ever invoked, so we test this at initialization - // time to prevent it from happening at runtime later due to I/O. - if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { - t.testEmbeddedByValue() - } - s.RegisterService(&DomainDevicesGraphics_ServiceDesc, srv) -} - -func _DomainDevicesGraphics_Console_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DomainDevicesGraphicsConsoleRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(DomainDevicesGraphicsServer).Console(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: DomainDevicesGraphics_Console_FullMethodName, - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DomainDevicesGraphicsServer).Console(ctx, req.(*DomainDevicesGraphicsConsoleRequest)) - } - return interceptor(ctx, in, info, handler) -} - -// DomainDevicesGraphics_ServiceDesc is the grpc.ServiceDesc for DomainDevicesGraphics service. -// It's only intended for direct use with grpc.RegisterService, -// and not to be introspected or modified (even as a copy) -var DomainDevicesGraphics_ServiceDesc = grpc.ServiceDesc{ - ServiceName: "domain.DomainDevicesGraphics", - HandlerType: (*DomainDevicesGraphicsServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "Console", - Handler: _DomainDevicesGraphics_Console_Handler, - }, - }, - Streams: []grpc.StreamDesc{}, - Metadata: "proto/domain.proto", -} diff --git a/cmd/compute_api/proto/network.pb.go b/cmd/compute_api/proto/network.pb.go deleted file mode 100644 index c6c27f5..0000000 --- a/cmd/compute_api/proto/network.pb.go +++ /dev/null @@ -1,62 +0,0 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. -// versions: -// protoc-gen-go v1.31.0 -// protoc v3.14.0 -// source: proto/network.proto - -package proto - -import ( - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" - reflect "reflect" -) - -const ( - // Verify that this generated code is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) - // Verify that runtime/protoimpl is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) -) - -var File_proto_network_proto protoreflect.FileDescriptor - -var file_proto_network_proto_rawDesc = []byte{ - 0x0a, 0x13, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x6e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x2e, - 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x07, 0x6e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x42, 0x09, - 0x5a, 0x07, 0x2e, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x33, -} - -var file_proto_network_proto_goTypes = []interface{}{} -var file_proto_network_proto_depIdxs = []int32{ - 0, // [0:0] is the sub-list for method output_type - 0, // [0:0] is the sub-list for method input_type - 0, // [0:0] is the sub-list for extension type_name - 0, // [0:0] is the sub-list for extension extendee - 0, // [0:0] is the sub-list for field type_name -} - -func init() { file_proto_network_proto_init() } -func file_proto_network_proto_init() { - if File_proto_network_proto != nil { - return - } - type x struct{} - out := protoimpl.TypeBuilder{ - File: protoimpl.DescBuilder{ - GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_proto_network_proto_rawDesc, - NumEnums: 0, - NumMessages: 0, - NumExtensions: 0, - NumServices: 0, - }, - GoTypes: file_proto_network_proto_goTypes, - DependencyIndexes: file_proto_network_proto_depIdxs, - }.Build() - File_proto_network_proto = out.File - file_proto_network_proto_rawDesc = nil - file_proto_network_proto_goTypes = nil - file_proto_network_proto_depIdxs = nil -} diff --git a/cmd/compute_api/proto/network.proto b/cmd/compute_api/proto/network.proto deleted file mode 100644 index 92e11c6..0000000 --- a/cmd/compute_api/proto/network.proto +++ /dev/null @@ -1,4 +0,0 @@ -syntax="proto3"; - -option go_package = "./proto"; -package network; \ No newline at end of file diff --git a/cmd/compute_api/proto/storage.pb.go b/cmd/compute_api/proto/storage.pb.go deleted file mode 100644 index 9b6e018..0000000 --- a/cmd/compute_api/proto/storage.pb.go +++ /dev/null @@ -1,62 +0,0 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. -// versions: -// protoc-gen-go v1.31.0 -// protoc v3.14.0 -// source: proto/storage.proto - -package proto - -import ( - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" - reflect "reflect" -) - -const ( - // Verify that this generated code is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) - // Verify that runtime/protoimpl is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) -) - -var File_proto_storage_proto protoreflect.FileDescriptor - -var file_proto_storage_proto_rawDesc = []byte{ - 0x0a, 0x13, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, - 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x07, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x42, 0x09, - 0x5a, 0x07, 0x2e, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x33, -} - -var file_proto_storage_proto_goTypes = []interface{}{} -var file_proto_storage_proto_depIdxs = []int32{ - 0, // [0:0] is the sub-list for method output_type - 0, // [0:0] is the sub-list for method input_type - 0, // [0:0] is the sub-list for extension type_name - 0, // [0:0] is the sub-list for extension extendee - 0, // [0:0] is the sub-list for field type_name -} - -func init() { file_proto_storage_proto_init() } -func file_proto_storage_proto_init() { - if File_proto_storage_proto != nil { - return - } - type x struct{} - out := protoimpl.TypeBuilder{ - File: protoimpl.DescBuilder{ - GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_proto_storage_proto_rawDesc, - NumEnums: 0, - NumMessages: 0, - NumExtensions: 0, - NumServices: 0, - }, - GoTypes: file_proto_storage_proto_goTypes, - DependencyIndexes: file_proto_storage_proto_depIdxs, - }.Build() - File_proto_storage_proto = out.File - file_proto_storage_proto_rawDesc = nil - file_proto_storage_proto_goTypes = nil - file_proto_storage_proto_depIdxs = nil -} diff --git a/cmd/compute_api/proto/storage.proto b/cmd/compute_api/proto/storage.proto deleted file mode 100644 index cb0af50..0000000 --- a/cmd/compute_api/proto/storage.proto +++ /dev/null @@ -1,4 +0,0 @@ -syntax="proto3"; - -option go_package = "./proto"; -package storage; \ No newline at end of file diff --git a/cmd/compute_qemu/events/events.go b/cmd/compute_qemu/events/events.go index c6076f6..a9b44fd 100644 --- a/cmd/compute_qemu/events/events.go +++ b/cmd/compute_qemu/events/events.go @@ -36,7 +36,7 @@ func MigrationIteration(c *libvirt.Connect, d *libvirt.Domain, e *libvirt.Domain func Lifecyle(c *libvirt.Connect, d *libvirt.Domain, e *libvirt.DomainEventLifecycle) { var detail, event string - config, _ := config.NewConfig() + config, _ := config.New() domainID, _ := d.GetUUIDString() etcd, err := clientv3.New(clientv3.Config{ diff --git a/cmd/compute_qemu/metrics/domains.go b/cmd/compute_qemu/metrics/domains.go index f4bc725..4331f49 100644 --- a/cmd/compute_qemu/metrics/domains.go +++ b/cmd/compute_qemu/metrics/domains.go @@ -231,7 +231,7 @@ var ( ) func CollectDomain(ch chan<- prometheus.Metric, stat libvirt.DomainStats, hostname string) error { - config, err := config.NewConfig() + config, err := config.New() if err != nil { log.Fatalln(err) }