From 98937e97a09c71fea12beb893b322bcae1417ca8 Mon Sep 17 00:00:00 2001 From: Mickael BOURNEUF Date: Thu, 13 Feb 2025 15:16:41 +0100 Subject: [PATCH] =?UTF-8?q?D=C3=A9marrage=20initial=20de=20l'API=20GRPC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cmd/compute_api/api/domain.go | 45 ++ cmd/compute_api/api/server.go | 44 ++ cmd/compute_api/main.go | 13 + cmd/compute_api/proto/domain.pb.go | 989 ++++++++++++++++++++++++ cmd/compute_api/proto/domain.proto | 80 ++ cmd/compute_api/proto/domain_grpc.pb.go | 383 +++++++++ cmd/compute_api/proto/network.pb.go | 62 ++ cmd/compute_api/proto/network.proto | 4 + cmd/compute_api/proto/storage.pb.go | 62 ++ cmd/compute_api/proto/storage.proto | 4 + 10 files changed, 1686 insertions(+) create mode 100644 cmd/compute_api/api/domain.go create mode 100644 cmd/compute_api/api/server.go create mode 100644 cmd/compute_api/main.go create mode 100644 cmd/compute_api/proto/domain.pb.go create mode 100644 cmd/compute_api/proto/domain.proto create mode 100644 cmd/compute_api/proto/domain_grpc.pb.go create mode 100644 cmd/compute_api/proto/network.pb.go create mode 100644 cmd/compute_api/proto/network.proto create mode 100644 cmd/compute_api/proto/storage.pb.go create mode 100644 cmd/compute_api/proto/storage.proto diff --git a/cmd/compute_api/api/domain.go b/cmd/compute_api/api/domain.go new file mode 100644 index 0000000..4f1ec41 --- /dev/null +++ b/cmd/compute_api/api/domain.go @@ -0,0 +1,45 @@ +package api + +import ( + "context" + "regexp" + "time" + + "deevirt.fr/compute/cmd/compute_api/proto" + "deevirt.fr/compute/pkg/config" + clientv3 "go.etcd.io/etcd/client/v3" +) + +type Domain struct { + Config *config.Config + Etcd *clientv3.Client + proto.UnimplementedDomainServer +} + +func (d *Domain) ListAll(ctx context.Context, in *proto.DomainListAllRequest) (*proto.DomainListAllResponse, error) { + var domains = []*proto.DomainListResponse{} + + ctx_etcd, cancel := context.WithTimeout(context.Background(), 5*time.Second) + resp, _ := d.Etcd.Get(ctx_etcd, "/cluster/"+d.Config.ClusterID+"/domain", clientv3.WithPrefix()) + cancel() + + re := regexp.MustCompile(`domain/(?P[a-zA-Z1-9-]+)$`) + + for _, data := range resp.Kvs { + key := string(data.Key[:]) + + if re.MatchString(key) { + matches := re.FindStringSubmatch(key) + index := re.SubexpIndex("domainID") + + domains = append(domains, &proto.DomainListResponse{ + DomainID: matches[index], + }) + } + + } + + return &proto.DomainListAllResponse{ + All: domains, + }, nil +} diff --git a/cmd/compute_api/api/server.go b/cmd/compute_api/api/server.go new file mode 100644 index 0000000..03d9a67 --- /dev/null +++ b/cmd/compute_api/api/server.go @@ -0,0 +1,44 @@ +package api + +import ( + "log" + "net" + "strings" + "time" + + "deevirt.fr/compute/cmd/compute_api/proto" + "deevirt.fr/compute/pkg/config" + clientv3 "go.etcd.io/etcd/client/v3" + "google.golang.org/grpc" + "google.golang.org/grpc/reflection" +) + +func Server() { + config, _ := config.NewConfig() + + //listen on the port + lis, err := net.Listen("tcp", ":8080") + if err != nil { + log.Fatalf("Failed to start server %v", err) + } + + etcd, err := clientv3.New(clientv3.Config{ + Endpoints: strings.Split(config.EtcdURI, ","), + DialTimeout: 5 * time.Second, + }) + if err != nil { + log.Fatalf("Error connexion to etcd: %v", err) + } + defer etcd.Close() + + grpcServer := grpc.NewServer() + proto.RegisterDomainServer(grpcServer, &Domain{ + Config: config, + Etcd: etcd, + }) + reflection.Register(grpcServer) + log.Printf("Server started at %v", lis.Addr()) + if err := grpcServer.Serve(lis); err != nil { + log.Fatalf("Failed to start: %v", err) + } +} diff --git a/cmd/compute_api/main.go b/cmd/compute_api/main.go new file mode 100644 index 0000000..23a8604 --- /dev/null +++ b/cmd/compute_api/main.go @@ -0,0 +1,13 @@ +package main + +/* +protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative *.pro +*/ + +import ( + "deevirt.fr/compute/cmd/compute_api/api" +) + +func main() { + api.Server() +} diff --git a/cmd/compute_api/proto/domain.pb.go b/cmd/compute_api/proto/domain.pb.go new file mode 100644 index 0000000..edc3851 --- /dev/null +++ b/cmd/compute_api/proto/domain.pb.go @@ -0,0 +1,989 @@ +// 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 + + All []*DomainListResponse `protobuf:"bytes,1,rep,name=all,proto3" json:"all,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) GetAll() []*DomainListResponse { + if x != nil { + return x.All + } + return nil +} + +type DomainListResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + DomainID string `protobuf:"bytes,1,opt,name=domainID,json=domain_id,proto3" json:"domainID,omitempty"` +} + +func (x *DomainListResponse) Reset() { + *x = DomainListResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_proto_domain_proto_msgTypes[2] + 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[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 DomainListResponse.ProtoReflect.Descriptor instead. +func (*DomainListResponse) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{2} +} + +func (x *DomainListResponse) GetDomainID() string { + if x != nil { + return x.DomainID + } + return "" +} + +type DomainCreateRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Config []byte `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[3] + 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[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 DomainCreateRequest.ProtoReflect.Descriptor instead. +func (*DomainCreateRequest) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{3} +} + +func (x *DomainCreateRequest) GetConfig() []byte { + if x != nil { + return x.Config + } + return nil +} + +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[4] + 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[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 DomainCreateResponse.ProtoReflect.Descriptor instead. +func (*DomainCreateResponse) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{4} +} + +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[5] + 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[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 DomainUpdateRequest.ProtoReflect.Descriptor instead. +func (*DomainUpdateRequest) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{5} +} + +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[6] + 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[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 DomainUpdateResponse.ProtoReflect.Descriptor instead. +func (*DomainUpdateResponse) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{6} +} + +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[7] + 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[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 DomainDeleteRequest.ProtoReflect.Descriptor instead. +func (*DomainDeleteRequest) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{7} +} + +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[8] + 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[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 DomainDeleteResponse.ProtoReflect.Descriptor instead. +func (*DomainDeleteResponse) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{8} +} + +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[9] + 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[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 DomainPowerRequest.ProtoReflect.Descriptor instead. +func (*DomainPowerRequest) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{9} +} + +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[10] + 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[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 DomainPowerResponse.ProtoReflect.Descriptor instead. +func (*DomainPowerResponse) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{10} +} + +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[11] + 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[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 DomainDevicesGraphicsConsoleRequest.ProtoReflect.Descriptor instead. +func (*DomainDevicesGraphicsConsoleRequest) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{11} +} + +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[12] + 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[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 DomainDevicesGraphicsConsoleResponse.ProtoReflect.Descriptor instead. +func (*DomainDevicesGraphicsConsoleResponse) Descriptor() ([]byte, []int) { + return file_proto_domain_proto_rawDescGZIP(), []int{12} +} + +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, 0x45, 0x0a, 0x15, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, + 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2c, 0x0a, + 0x03, 0x61, 0x6c, 0x6c, 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, 0x03, 0x61, 0x6c, 0x6c, 0x22, 0x31, 0x0a, 0x12, 0x44, + 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, + 0x65, 0x12, 0x1b, 0x0a, 0x08, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x49, 0x44, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x09, 0x64, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x5f, 0x69, 0x64, 0x22, 0x2d, + 0x0a, 0x13, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x0c, 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, 0xed, 0x02, 0x0a, 0x06, 0x44, 0x6f, 0x6d, 0x61, 0x69, 0x6e, 0x12, 0x48, 0x0a, 0x07, 0x4c, + 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 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, 0x47, 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, 0x30, 0x01, 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, 13) +var file_proto_domain_proto_goTypes = []interface{}{ + (DomainPower)(0), // 0: domain.DomainPower + (*DomainListAllRequest)(nil), // 1: domain.DomainListAllRequest + (*DomainListAllResponse)(nil), // 2: domain.DomainListAllResponse + (*DomainListResponse)(nil), // 3: domain.DomainListResponse + (*DomainCreateRequest)(nil), // 4: domain.DomainCreateRequest + (*DomainCreateResponse)(nil), // 5: domain.DomainCreateResponse + (*DomainUpdateRequest)(nil), // 6: domain.DomainUpdateRequest + (*DomainUpdateResponse)(nil), // 7: domain.DomainUpdateResponse + (*DomainDeleteRequest)(nil), // 8: domain.DomainDeleteRequest + (*DomainDeleteResponse)(nil), // 9: domain.DomainDeleteResponse + (*DomainPowerRequest)(nil), // 10: domain.DomainPowerRequest + (*DomainPowerResponse)(nil), // 11: domain.DomainPowerResponse + (*DomainDevicesGraphicsConsoleRequest)(nil), // 12: domain.DomainDevicesGraphicsConsoleRequest + (*DomainDevicesGraphicsConsoleResponse)(nil), // 13: domain.DomainDevicesGraphicsConsoleResponse +} +var file_proto_domain_proto_depIdxs = []int32{ + 3, // 0: domain.DomainListAllResponse.all:type_name -> domain.DomainListResponse + 0, // 1: domain.DomainPowerRequest.action:type_name -> domain.DomainPower + 1, // 2: domain.Domain.ListAll:input_type -> domain.DomainListAllRequest + 4, // 3: domain.Domain.Create:input_type -> domain.DomainCreateRequest + 6, // 4: domain.Domain.Update:input_type -> domain.DomainUpdateRequest + 8, // 5: domain.Domain.Delete:input_type -> domain.DomainDeleteRequest + 10, // 6: domain.Domain.Power:input_type -> domain.DomainPowerRequest + 12, // 7: domain.DomainDevicesGraphics.Console:input_type -> domain.DomainDevicesGraphicsConsoleRequest + 2, // 8: domain.Domain.ListAll:output_type -> domain.DomainListAllResponse + 5, // 9: domain.Domain.Create:output_type -> domain.DomainCreateResponse + 7, // 10: domain.Domain.Update:output_type -> domain.DomainUpdateResponse + 9, // 11: domain.Domain.Delete:output_type -> domain.DomainDeleteResponse + 11, // 12: domain.Domain.Power:output_type -> domain.DomainPowerResponse + 13, // 13: domain.DomainDevicesGraphics.Console:output_type -> domain.DomainDevicesGraphicsConsoleResponse + 8, // [8:14] is the sub-list for method output_type + 2, // [2:8] 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.(*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[3].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[4].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[5].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[6].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[7].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[8].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[9].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[10].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[11].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[12].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: 13, + 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 new file mode 100644 index 0000000..d37713a --- /dev/null +++ b/cmd/compute_api/proto/domain.proto @@ -0,0 +1,80 @@ +syntax="proto3"; + +option go_package = "./proto"; +package domain; + +// The greeting service definition. +service Domain { + rpc ListAll (DomainListAllRequest) returns (DomainListAllResponse) {} + rpc Create (DomainCreateRequest) returns (stream DomainCreateResponse) {} + rpc Update (DomainUpdateRequest) returns (DomainUpdateResponse) {} + rpc Delete (DomainDeleteRequest) returns (DomainDeleteResponse) {} + + rpc Power (DomainPowerRequest) returns (DomainPowerResponse) {} + +} + +message DomainListAllRequest {} + +message DomainListAllResponse { + repeated DomainListResponse all = 1; +} + +message DomainListResponse { + string domainID = 1 [json_name="domain_id"]; +} + +service DomainDevicesGraphics { + rpc Console (DomainDevicesGraphicsConsoleRequest) returns (DomainDevicesGraphicsConsoleResponse) {} +} + +message DomainCreateRequest { + bytes config = 2; +} + +message DomainCreateResponse { + int64 progress = 1; +} + +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 new file mode 100644 index 0000000..a80b459 --- /dev/null +++ b/cmd/compute_api/proto/domain_grpc.pb.go @@ -0,0 +1,383 @@ +// 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_ListAll_FullMethodName = "/domain.Domain/ListAll" + 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 { + ListAll(ctx context.Context, in *DomainListAllRequest, opts ...grpc.CallOption) (*DomainListAllResponse, error) + Create(ctx context.Context, in *DomainCreateRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[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) ListAll(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_ListAll_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) (grpc.ServerStreamingClient[DomainCreateResponse], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &Domain_ServiceDesc.Streams[0], Domain_Create_FullMethodName, cOpts...) + if err != nil { + return nil, err + } + x := &grpc.GenericClientStream[DomainCreateRequest, DomainCreateResponse]{ClientStream: stream} + if err := x.ClientStream.SendMsg(in); err != nil { + return nil, err + } + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err + } + return x, nil +} + +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type Domain_CreateClient = grpc.ServerStreamingClient[DomainCreateResponse] + +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 { + ListAll(context.Context, *DomainListAllRequest) (*DomainListAllResponse, error) + Create(*DomainCreateRequest, grpc.ServerStreamingServer[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) ListAll(context.Context, *DomainListAllRequest) (*DomainListAllResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method ListAll not implemented") +} +func (UnimplementedDomainServer) Create(*DomainCreateRequest, grpc.ServerStreamingServer[DomainCreateResponse]) error { + return 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_ListAll_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).ListAll(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Domain_ListAll_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(DomainServer).ListAll(ctx, req.(*DomainListAllRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Domain_Create_Handler(srv interface{}, stream grpc.ServerStream) error { + m := new(DomainCreateRequest) + if err := stream.RecvMsg(m); err != nil { + return err + } + return srv.(DomainServer).Create(m, &grpc.GenericServerStream[DomainCreateRequest, DomainCreateResponse]{ServerStream: stream}) +} + +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type Domain_CreateServer = grpc.ServerStreamingServer[DomainCreateResponse] + +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: "ListAll", + Handler: _Domain_ListAll_Handler, + }, + { + MethodName: "Update", + Handler: _Domain_Update_Handler, + }, + { + MethodName: "Delete", + Handler: _Domain_Delete_Handler, + }, + { + MethodName: "Power", + Handler: _Domain_Power_Handler, + }, + }, + Streams: []grpc.StreamDesc{ + { + StreamName: "Create", + Handler: _Domain_Create_Handler, + ServerStreams: true, + }, + }, + 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 new file mode 100644 index 0000000..c6c27f5 --- /dev/null +++ b/cmd/compute_api/proto/network.pb.go @@ -0,0 +1,62 @@ +// 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 new file mode 100644 index 0000000..92e11c6 --- /dev/null +++ b/cmd/compute_api/proto/network.proto @@ -0,0 +1,4 @@ +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 new file mode 100644 index 0000000..9b6e018 --- /dev/null +++ b/cmd/compute_api/proto/storage.pb.go @@ -0,0 +1,62 @@ +// 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 new file mode 100644 index 0000000..cb0af50 --- /dev/null +++ b/cmd/compute_api/proto/storage.proto @@ -0,0 +1,4 @@ +syntax="proto3"; + +option go_package = "./proto"; +package storage; \ No newline at end of file