diff --git a/api/types.go b/api/types.go index 5446553f..bc001c63 100644 --- a/api/types.go +++ b/api/types.go @@ -3,10 +3,9 @@ package api import ( "context" + rpc "github.com/longhorn/types/pkg/bimrpc" "github.com/pkg/errors" "google.golang.org/grpc" - - "github.com/longhorn/backing-image-manager/pkg/rpc" ) type BackingImage struct { diff --git a/generate_grpc.sh b/generate_grpc.sh deleted file mode 100755 index ec8de84c..00000000 --- a/generate_grpc.sh +++ /dev/null @@ -1,26 +0,0 @@ -#!/bin/bash - -set -e - -# check and download dependency for gRPC code generate -if [ ! -e ./proto/vendor/protobuf/src/google/protobuf ]; then - rm -rf ./proto/vendor/protobuf/src/google/protobuf - DIR="./proto/vendor/protobuf/src/google/protobuf" - mkdir -p $DIR - wget https://raw.githubusercontent.com/protocolbuffers/protobuf/v24.3/src/google/protobuf/empty.proto -P $DIR -fi - -# Due to https://github.com/golang/protobuf/issues/1122, our .proto file names must be globally unique to avoid -# namespace conflicts (https://protobuf.dev/reference/go/faq/#namespace-conflict). The best way to achieve this is to -# include the whole Go import path in the name that gets compiled into the .pb.go file (e.g. -# "github.com/longhorn/backing-image-manager/pkg/rpc.proto" instead of "rpc.proto"). This formulation does the -# compilation inside a temporary directory prefixed with the full desired path before copying the .pb.go file out -# (similar to the way https://github.com/container-storage-interface/spec/blob/master/lib/go/Makefile does it). -PKG_DIR="pkg/rpc" -TMP_DIR_BASE=".protobuild" -TMP_DIR="${TMP_DIR_BASE}/github.com/longhorn/backing-image-manager/pkg/rpc" -mkdir -p "${TMP_DIR}" -cp "${PKG_DIR}/rpc.proto" "${TMP_DIR}/rpc.proto" -protoc -I "${TMP_DIR_BASE}" -I "proto/vendor/protobuf/src/" "${TMP_DIR}/rpc.proto" --go_out=plugins=grpc:"${TMP_DIR_BASE}" -mv "${TMP_DIR}/rpc.pb.go" "${PKG_DIR}/rpc.pb.go" -rm -rf "${TMP_DIR_BASE}" diff --git a/pkg/client/manager_client.go b/pkg/client/manager_client.go index 103edde5..2779aed4 100644 --- a/pkg/client/manager_client.go +++ b/pkg/client/manager_client.go @@ -3,6 +3,7 @@ package client import ( "fmt" + rpc "github.com/longhorn/types/pkg/bimrpc" "golang.org/x/net/context" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" @@ -10,7 +11,6 @@ import ( "github.com/longhorn/backing-image-manager/api" "github.com/longhorn/backing-image-manager/pkg/meta" - "github.com/longhorn/backing-image-manager/pkg/rpc" "github.com/longhorn/backing-image-manager/pkg/types" ) diff --git a/pkg/manager/server.go b/pkg/manager/server.go index 42ed7046..ad2d37a8 100644 --- a/pkg/manager/server.go +++ b/pkg/manager/server.go @@ -8,12 +8,12 @@ import ( "os/signal" "syscall" + rpc "github.com/longhorn/types/pkg/bimrpc" "github.com/pkg/errors" "github.com/sirupsen/logrus" "google.golang.org/grpc" "google.golang.org/grpc/reflection" - "github.com/longhorn/backing-image-manager/pkg/rpc" "github.com/longhorn/backing-image-manager/pkg/sync" "github.com/longhorn/backing-image-manager/pkg/util" ) diff --git a/pkg/manager/service.go b/pkg/manager/service.go index 233aea9b..5e921f8b 100644 --- a/pkg/manager/service.go +++ b/pkg/manager/service.go @@ -11,6 +11,8 @@ import ( "time" "github.com/golang/protobuf/ptypes/empty" + butil "github.com/longhorn/backupstore/util" + rpc "github.com/longhorn/types/pkg/bimrpc" "github.com/pkg/errors" "github.com/sirupsen/logrus" "golang.org/x/net/context" @@ -18,18 +20,16 @@ import ( "google.golang.org/grpc/status" "google.golang.org/protobuf/types/known/emptypb" - butil "github.com/longhorn/backupstore/util" - "github.com/longhorn/backing-image-manager/api" "github.com/longhorn/backing-image-manager/pkg/backup" "github.com/longhorn/backing-image-manager/pkg/client" - "github.com/longhorn/backing-image-manager/pkg/rpc" "github.com/longhorn/backing-image-manager/pkg/types" "github.com/longhorn/backing-image-manager/pkg/util" "github.com/longhorn/backing-image-manager/pkg/util/broadcaster" ) type Manager struct { + rpc.UnimplementedBackingImageManagerServiceServer ctx context.Context syncAddress string diff --git a/pkg/manager/version.go b/pkg/manager/version.go index 126656fa..4fc98a29 100644 --- a/pkg/manager/version.go +++ b/pkg/manager/version.go @@ -1,11 +1,11 @@ package manager import ( + rpc "github.com/longhorn/types/pkg/bimrpc" "golang.org/x/net/context" "google.golang.org/protobuf/types/known/emptypb" "github.com/longhorn/backing-image-manager/pkg/meta" - "github.com/longhorn/backing-image-manager/pkg/rpc" ) func (pm *Manager) VersionGet(ctx context.Context, empty *emptypb.Empty) (*rpc.VersionResponse, error) { diff --git a/pkg/rpc/rpc.pb.go b/pkg/rpc/rpc.pb.go deleted file mode 100644 index b3012f62..00000000 --- a/pkg/rpc/rpc.pb.go +++ /dev/null @@ -1,1956 +0,0 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. -// versions: -// protoc-gen-go v1.26.0 -// protoc v4.24.3 -// source: github.com/longhorn/backing-image-manager/pkg/rpc/rpc.proto - -package rpc - -import ( - context "context" - grpc "google.golang.org/grpc" - codes "google.golang.org/grpc/codes" - status "google.golang.org/grpc/status" - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" - emptypb "google.golang.org/protobuf/types/known/emptypb" - 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 BackingImageSpec struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` - Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` - Checksum string `protobuf:"bytes,4,opt,name=checksum,proto3" json:"checksum,omitempty"` -} - -func (x *BackingImageSpec) Reset() { - *x = BackingImageSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *BackingImageSpec) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*BackingImageSpec) ProtoMessage() {} - -func (x *BackingImageSpec) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 BackingImageSpec.ProtoReflect.Descriptor instead. -func (*BackingImageSpec) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{0} -} - -func (x *BackingImageSpec) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *BackingImageSpec) GetUuid() string { - if x != nil { - return x.Uuid - } - return "" -} - -func (x *BackingImageSpec) GetSize() int64 { - if x != nil { - return x.Size - } - return 0 -} - -func (x *BackingImageSpec) GetChecksum() string { - if x != nil { - return x.Checksum - } - return "" -} - -type BackingImageStatus struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` - ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"` - SendingReference int32 `protobuf:"varint,3,opt,name=sending_reference,json=sendingReference,proto3" json:"sending_reference,omitempty"` - SenderManagerAddress string `protobuf:"bytes,4,opt,name=sender_manager_address,json=senderManagerAddress,proto3" json:"sender_manager_address,omitempty"` - Progress int32 `protobuf:"varint,5,opt,name=progress,proto3" json:"progress,omitempty"` - Checksum string `protobuf:"bytes,6,opt,name=checksum,proto3" json:"checksum,omitempty"` -} - -func (x *BackingImageStatus) Reset() { - *x = BackingImageStatus{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *BackingImageStatus) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*BackingImageStatus) ProtoMessage() {} - -func (x *BackingImageStatus) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 BackingImageStatus.ProtoReflect.Descriptor instead. -func (*BackingImageStatus) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{1} -} - -func (x *BackingImageStatus) GetState() string { - if x != nil { - return x.State - } - return "" -} - -func (x *BackingImageStatus) GetErrorMsg() string { - if x != nil { - return x.ErrorMsg - } - return "" -} - -func (x *BackingImageStatus) GetSendingReference() int32 { - if x != nil { - return x.SendingReference - } - return 0 -} - -func (x *BackingImageStatus) GetSenderManagerAddress() string { - if x != nil { - return x.SenderManagerAddress - } - return "" -} - -func (x *BackingImageStatus) GetProgress() int32 { - if x != nil { - return x.Progress - } - return 0 -} - -func (x *BackingImageStatus) GetChecksum() string { - if x != nil { - return x.Checksum - } - return "" -} - -type BackingImageResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Spec *BackingImageSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` - Status *BackingImageStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` -} - -func (x *BackingImageResponse) Reset() { - *x = BackingImageResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[2] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *BackingImageResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*BackingImageResponse) ProtoMessage() {} - -func (x *BackingImageResponse) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 BackingImageResponse.ProtoReflect.Descriptor instead. -func (*BackingImageResponse) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{2} -} - -func (x *BackingImageResponse) GetSpec() *BackingImageSpec { - if x != nil { - return x.Spec - } - return nil -} - -func (x *BackingImageResponse) GetStatus() *BackingImageStatus { - if x != nil { - return x.Status - } - return nil -} - -type DeleteRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` -} - -func (x *DeleteRequest) Reset() { - *x = DeleteRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[3] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DeleteRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DeleteRequest) ProtoMessage() {} - -func (x *DeleteRequest) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 DeleteRequest.ProtoReflect.Descriptor instead. -func (*DeleteRequest) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{3} -} - -func (x *DeleteRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *DeleteRequest) GetUuid() string { - if x != nil { - return x.Uuid - } - return "" -} - -type GetRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` -} - -func (x *GetRequest) Reset() { - *x = GetRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[4] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *GetRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*GetRequest) ProtoMessage() {} - -func (x *GetRequest) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 GetRequest.ProtoReflect.Descriptor instead. -func (*GetRequest) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{4} -} - -func (x *GetRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *GetRequest) GetUuid() string { - if x != nil { - return x.Uuid - } - return "" -} - -type ListResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - BackingImages map[string]*BackingImageResponse `protobuf:"bytes,1,rep,name=backing_images,json=backingImages,proto3" json:"backing_images,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` -} - -func (x *ListResponse) Reset() { - *x = ListResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[5] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *ListResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ListResponse) ProtoMessage() {} - -func (x *ListResponse) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 ListResponse.ProtoReflect.Descriptor instead. -func (*ListResponse) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{5} -} - -func (x *ListResponse) GetBackingImages() map[string]*BackingImageResponse { - if x != nil { - return x.BackingImages - } - return nil -} - -type VersionResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` - GitCommit string `protobuf:"bytes,2,opt,name=gitCommit,proto3" json:"gitCommit,omitempty"` - BuildDate string `protobuf:"bytes,3,opt,name=buildDate,proto3" json:"buildDate,omitempty"` - BackingImageManagerApiVersion int64 `protobuf:"varint,4,opt,name=backing_image_manager_api_version,json=backingImageManagerApiVersion,proto3" json:"backing_image_manager_api_version,omitempty"` - BackingImageManagerApiMinVersion int64 `protobuf:"varint,5,opt,name=backing_image_manager_api_min_version,json=backingImageManagerApiMinVersion,proto3" json:"backing_image_manager_api_min_version,omitempty"` -} - -func (x *VersionResponse) Reset() { - *x = VersionResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[6] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *VersionResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*VersionResponse) ProtoMessage() {} - -func (x *VersionResponse) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 VersionResponse.ProtoReflect.Descriptor instead. -func (*VersionResponse) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{6} -} - -func (x *VersionResponse) GetVersion() string { - if x != nil { - return x.Version - } - return "" -} - -func (x *VersionResponse) GetGitCommit() string { - if x != nil { - return x.GitCommit - } - return "" -} - -func (x *VersionResponse) GetBuildDate() string { - if x != nil { - return x.BuildDate - } - return "" -} - -func (x *VersionResponse) GetBackingImageManagerApiVersion() int64 { - if x != nil { - return x.BackingImageManagerApiVersion - } - return 0 -} - -func (x *VersionResponse) GetBackingImageManagerApiMinVersion() int64 { - if x != nil { - return x.BackingImageManagerApiMinVersion - } - return 0 -} - -type SyncRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Spec *BackingImageSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` - FromAddress string `protobuf:"bytes,2,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"` -} - -func (x *SyncRequest) Reset() { - *x = SyncRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[7] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *SyncRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*SyncRequest) ProtoMessage() {} - -func (x *SyncRequest) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 SyncRequest.ProtoReflect.Descriptor instead. -func (*SyncRequest) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{7} -} - -func (x *SyncRequest) GetSpec() *BackingImageSpec { - if x != nil { - return x.Spec - } - return nil -} - -func (x *SyncRequest) GetFromAddress() string { - if x != nil { - return x.FromAddress - } - return "" -} - -type SendRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` - ToAddress string `protobuf:"bytes,3,opt,name=to_address,json=toAddress,proto3" json:"to_address,omitempty"` -} - -func (x *SendRequest) Reset() { - *x = SendRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[8] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *SendRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*SendRequest) ProtoMessage() {} - -func (x *SendRequest) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 SendRequest.ProtoReflect.Descriptor instead. -func (*SendRequest) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{8} -} - -func (x *SendRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *SendRequest) GetUuid() string { - if x != nil { - return x.Uuid - } - return "" -} - -func (x *SendRequest) GetToAddress() string { - if x != nil { - return x.ToAddress - } - return "" -} - -type FetchRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Spec *BackingImageSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` - DataSourceAddress string `protobuf:"bytes,2,opt,name=data_source_address,json=dataSourceAddress,proto3" json:"data_source_address,omitempty"` -} - -func (x *FetchRequest) Reset() { - *x = FetchRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[9] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *FetchRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*FetchRequest) ProtoMessage() {} - -func (x *FetchRequest) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 FetchRequest.ProtoReflect.Descriptor instead. -func (*FetchRequest) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{9} -} - -func (x *FetchRequest) GetSpec() *BackingImageSpec { - if x != nil { - return x.Spec - } - return nil -} - -func (x *FetchRequest) GetDataSourceAddress() string { - if x != nil { - return x.DataSourceAddress - } - return "" -} - -type PrepareDownloadRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` -} - -func (x *PrepareDownloadRequest) Reset() { - *x = PrepareDownloadRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[10] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *PrepareDownloadRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*PrepareDownloadRequest) ProtoMessage() {} - -func (x *PrepareDownloadRequest) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 PrepareDownloadRequest.ProtoReflect.Descriptor instead. -func (*PrepareDownloadRequest) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{10} -} - -func (x *PrepareDownloadRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *PrepareDownloadRequest) GetUuid() string { - if x != nil { - return x.Uuid - } - return "" -} - -type PrepareDownloadResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - SrcFilePath string `protobuf:"bytes,1,opt,name=src_file_path,json=srcFilePath,proto3" json:"src_file_path,omitempty"` - Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` -} - -func (x *PrepareDownloadResponse) Reset() { - *x = PrepareDownloadResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[11] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *PrepareDownloadResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*PrepareDownloadResponse) ProtoMessage() {} - -func (x *PrepareDownloadResponse) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 PrepareDownloadResponse.ProtoReflect.Descriptor instead. -func (*PrepareDownloadResponse) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{11} -} - -func (x *PrepareDownloadResponse) GetSrcFilePath() string { - if x != nil { - return x.SrcFilePath - } - return "" -} - -func (x *PrepareDownloadResponse) GetAddress() string { - if x != nil { - return x.Address - } - return "" -} - -type BackupCreateRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` - Checksum string `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"` - BackupTarget string `protobuf:"bytes,4,opt,name=backup_target,json=backupTarget,proto3" json:"backup_target,omitempty"` - Labels []string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"` - Credential map[string]string `protobuf:"bytes,6,rep,name=credential,proto3" json:"credential,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` - CompressionMethod string `protobuf:"bytes,7,opt,name=compression_method,json=compressionMethod,proto3" json:"compression_method,omitempty"` - ConcurrentLimit int32 `protobuf:"varint,8,opt,name=concurrent_limit,json=concurrentLimit,proto3" json:"concurrent_limit,omitempty"` -} - -func (x *BackupCreateRequest) Reset() { - *x = BackupCreateRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[12] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *BackupCreateRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*BackupCreateRequest) ProtoMessage() {} - -func (x *BackupCreateRequest) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 BackupCreateRequest.ProtoReflect.Descriptor instead. -func (*BackupCreateRequest) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{12} -} - -func (x *BackupCreateRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *BackupCreateRequest) GetUuid() string { - if x != nil { - return x.Uuid - } - return "" -} - -func (x *BackupCreateRequest) GetChecksum() string { - if x != nil { - return x.Checksum - } - return "" -} - -func (x *BackupCreateRequest) GetBackupTarget() string { - if x != nil { - return x.BackupTarget - } - return "" -} - -func (x *BackupCreateRequest) GetLabels() []string { - if x != nil { - return x.Labels - } - return nil -} - -func (x *BackupCreateRequest) GetCredential() map[string]string { - if x != nil { - return x.Credential - } - return nil -} - -func (x *BackupCreateRequest) GetCompressionMethod() string { - if x != nil { - return x.CompressionMethod - } - return "" -} - -func (x *BackupCreateRequest) GetConcurrentLimit() int32 { - if x != nil { - return x.ConcurrentLimit - } - return 0 -} - -type BackupStatusRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` -} - -func (x *BackupStatusRequest) Reset() { - *x = BackupStatusRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[13] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *BackupStatusRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*BackupStatusRequest) ProtoMessage() {} - -func (x *BackupStatusRequest) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_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 BackupStatusRequest.ProtoReflect.Descriptor instead. -func (*BackupStatusRequest) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{13} -} - -func (x *BackupStatusRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -type BackupStatusResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Progress int32 `protobuf:"varint,1,opt,name=progress,proto3" json:"progress,omitempty"` - BackupUrl string `protobuf:"bytes,2,opt,name=backup_url,json=backupUrl,proto3" json:"backup_url,omitempty"` - Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` - State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"` -} - -func (x *BackupStatusResponse) Reset() { - *x = BackupStatusResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[14] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *BackupStatusResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*BackupStatusResponse) ProtoMessage() {} - -func (x *BackupStatusResponse) ProtoReflect() protoreflect.Message { - mi := &file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[14] - 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 BackupStatusResponse.ProtoReflect.Descriptor instead. -func (*BackupStatusResponse) Descriptor() ([]byte, []int) { - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP(), []int{14} -} - -func (x *BackupStatusResponse) GetProgress() int32 { - if x != nil { - return x.Progress - } - return 0 -} - -func (x *BackupStatusResponse) GetBackupUrl() string { - if x != nil { - return x.BackupUrl - } - return "" -} - -func (x *BackupStatusResponse) GetError() string { - if x != nil { - return x.Error - } - return "" -} - -func (x *BackupStatusResponse) GetState() string { - if x != nil { - return x.State - } - return "" -} - -var File_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto protoreflect.FileDescriptor - -var file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDesc = []byte{ - 0x0a, 0x3b, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x6f, 0x6e, - 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2f, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x2d, 0x69, 0x6d, - 0x61, 0x67, 0x65, 0x2d, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2f, 0x70, 0x6b, 0x67, 0x2f, - 0x72, 0x70, 0x63, 0x2f, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x24, 0x6c, - 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, - 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, - 0x72, 0x70, 0x63, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, - 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x22, 0x6a, 0x0a, 0x10, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, - 0x53, 0x70, 0x65, 0x63, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x12, 0x0a, 0x04, - 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x73, 0x69, 0x7a, 0x65, - 0x12, 0x1a, 0x0a, 0x08, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x73, 0x75, 0x6d, 0x18, 0x04, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x08, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x73, 0x75, 0x6d, 0x22, 0xe2, 0x01, 0x0a, - 0x12, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x53, 0x74, 0x61, - 0x74, 0x75, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x65, 0x72, 0x72, - 0x6f, 0x72, 0x5f, 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x65, 0x72, - 0x72, 0x6f, 0x72, 0x4d, 0x73, 0x67, 0x12, 0x2b, 0x0a, 0x11, 0x73, 0x65, 0x6e, 0x64, 0x69, 0x6e, - 0x67, 0x5f, 0x72, 0x65, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, - 0x05, 0x52, 0x10, 0x73, 0x65, 0x6e, 0x64, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x66, 0x65, 0x72, 0x65, - 0x6e, 0x63, 0x65, 0x12, 0x34, 0x0a, 0x16, 0x73, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x5f, 0x6d, 0x61, - 0x6e, 0x61, 0x67, 0x65, 0x72, 0x5f, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x04, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x14, 0x73, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x4d, 0x61, 0x6e, 0x61, 0x67, - 0x65, 0x72, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x6f, - 0x67, 0x72, 0x65, 0x73, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x72, 0x6f, - 0x67, 0x72, 0x65, 0x73, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x73, 0x75, - 0x6d, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x73, 0x75, - 0x6d, 0x22, 0xb4, 0x01, 0x0a, 0x14, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, - 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4a, 0x0a, 0x04, 0x73, 0x70, - 0x65, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, - 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, - 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, - 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x53, 0x70, 0x65, 0x63, - 0x52, 0x04, 0x73, 0x70, 0x65, 0x63, 0x12, 0x50, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x38, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, - 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, - 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x61, - 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, - 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x22, 0x37, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, - 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, - 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, - 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, - 0x64, 0x22, 0x34, 0x0a, 0x0a, 0x47, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, - 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, - 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x22, 0xfa, 0x01, 0x0a, 0x0c, 0x4c, 0x69, 0x73, 0x74, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x6c, 0x0a, 0x0e, 0x62, 0x61, 0x63, 0x6b, - 0x69, 0x6e, 0x67, 0x5f, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, - 0x32, 0x45, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, - 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, - 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, - 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, - 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0d, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, - 0x49, 0x6d, 0x61, 0x67, 0x65, 0x73, 0x1a, 0x7c, 0x0a, 0x12, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, - 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, - 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x50, - 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3a, 0x2e, - 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, - 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, - 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, - 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, - 0x3a, 0x02, 0x38, 0x01, 0x22, 0x82, 0x02, 0x0a, 0x0f, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, - 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, - 0x6f, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 0x67, 0x69, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x18, - 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x67, 0x69, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, - 0x12, 0x1c, 0x0a, 0x09, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x44, 0x61, 0x74, 0x65, 0x18, 0x03, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x44, 0x61, 0x74, 0x65, 0x12, 0x48, - 0x0a, 0x21, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x5f, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x5f, - 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x5f, 0x61, 0x70, 0x69, 0x5f, 0x76, 0x65, 0x72, 0x73, - 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x1d, 0x62, 0x61, 0x63, 0x6b, 0x69, - 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x4d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x41, 0x70, - 0x69, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x4f, 0x0a, 0x25, 0x62, 0x61, 0x63, 0x6b, - 0x69, 0x6e, 0x67, 0x5f, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x5f, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, - 0x72, 0x5f, 0x61, 0x70, 0x69, 0x5f, 0x6d, 0x69, 0x6e, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, - 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x20, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, - 0x49, 0x6d, 0x61, 0x67, 0x65, 0x4d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x41, 0x70, 0x69, 0x4d, - 0x69, 0x6e, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x7c, 0x0a, 0x0b, 0x53, 0x79, 0x6e, - 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4a, 0x0a, 0x04, 0x73, 0x70, 0x65, 0x63, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, - 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, - 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x61, - 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x53, 0x70, 0x65, 0x63, 0x52, 0x04, - 0x73, 0x70, 0x65, 0x63, 0x12, 0x21, 0x0a, 0x0c, 0x66, 0x72, 0x6f, 0x6d, 0x5f, 0x61, 0x64, 0x64, - 0x72, 0x65, 0x73, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x66, 0x72, 0x6f, 0x6d, - 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x22, 0x54, 0x0a, 0x0b, 0x53, 0x65, 0x6e, 0x64, 0x52, - 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, - 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x1d, - 0x0a, 0x0a, 0x74, 0x6f, 0x5f, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x03, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x09, 0x74, 0x6f, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x22, 0x8a, 0x01, - 0x0a, 0x0c, 0x46, 0x65, 0x74, 0x63, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4a, - 0x0a, 0x04, 0x73, 0x70, 0x65, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e, 0x6c, - 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, - 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, - 0x72, 0x70, 0x63, 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, - 0x53, 0x70, 0x65, 0x63, 0x52, 0x04, 0x73, 0x70, 0x65, 0x63, 0x12, 0x2e, 0x0a, 0x13, 0x64, 0x61, - 0x74, 0x61, 0x5f, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x5f, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, - 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x64, 0x61, 0x74, 0x61, 0x53, 0x6f, 0x75, - 0x72, 0x63, 0x65, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x22, 0x40, 0x0a, 0x16, 0x50, 0x72, - 0x65, 0x70, 0x61, 0x72, 0x65, 0x44, 0x6f, 0x77, 0x6e, 0x6c, 0x6f, 0x61, 0x64, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x22, 0x57, 0x0a, 0x17, - 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x44, 0x6f, 0x77, 0x6e, 0x6c, 0x6f, 0x61, 0x64, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x22, 0x0a, 0x0d, 0x73, 0x72, 0x63, 0x5f, 0x66, - 0x69, 0x6c, 0x65, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, - 0x73, 0x72, 0x63, 0x46, 0x69, 0x6c, 0x65, 0x50, 0x61, 0x74, 0x68, 0x12, 0x18, 0x0a, 0x07, 0x61, - 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x64, - 0x64, 0x72, 0x65, 0x73, 0x73, 0x22, 0x9a, 0x03, 0x0a, 0x13, 0x42, 0x61, 0x63, 0x6b, 0x75, 0x70, - 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, - 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, - 0x65, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x73, 0x75, - 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x73, 0x75, - 0x6d, 0x12, 0x23, 0x0a, 0x0d, 0x62, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x5f, 0x74, 0x61, 0x72, 0x67, - 0x65, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x62, 0x61, 0x63, 0x6b, 0x75, 0x70, - 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, - 0x18, 0x05, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x69, - 0x0a, 0x0a, 0x63, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x18, 0x06, 0x20, 0x03, - 0x28, 0x0b, 0x32, 0x49, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, - 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, - 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x75, 0x70, - 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x43, 0x72, - 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0a, 0x63, - 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x12, 0x2d, 0x0a, 0x12, 0x63, 0x6f, 0x6d, - 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x18, - 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x63, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, - 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x12, 0x29, 0x0a, 0x10, 0x63, 0x6f, 0x6e, 0x63, - 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x08, 0x20, 0x01, - 0x28, 0x05, 0x52, 0x0f, 0x63, 0x6f, 0x6e, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x4c, 0x69, - 0x6d, 0x69, 0x74, 0x1a, 0x3d, 0x0a, 0x0f, 0x43, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, - 0x6c, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, - 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, - 0x38, 0x01, 0x22, 0x29, 0x0a, 0x13, 0x42, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x53, 0x74, 0x61, 0x74, - 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, - 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x7d, 0x0a, - 0x14, 0x42, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 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, 0x05, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, - 0x73, 0x12, 0x1d, 0x0a, 0x0a, 0x62, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x5f, 0x75, 0x72, 0x6c, 0x18, - 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x62, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x55, 0x72, 0x6c, - 0x12, 0x14, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, - 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x32, 0xa7, 0x09, 0x0a, - 0x1a, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x4d, 0x61, 0x6e, - 0x61, 0x67, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x57, 0x0a, 0x06, 0x44, - 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x33, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, - 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, - 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x6c, - 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, - 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, - 0x74, 0x79, 0x22, 0x00, 0x12, 0x75, 0x0a, 0x03, 0x47, 0x65, 0x74, 0x12, 0x30, 0x2e, 0x6c, 0x6f, - 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, - 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, - 0x70, 0x63, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, - 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, - 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, - 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, - 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x54, 0x0a, 0x04, 0x4c, - 0x69, 0x73, 0x74, 0x12, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, - 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x32, 0x2e, 0x6c, 0x6f, - 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, - 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, - 0x70, 0x63, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, - 0x00, 0x12, 0x5b, 0x0a, 0x0a, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x47, 0x65, 0x74, 0x12, - 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, - 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x35, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, - 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, - 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x56, - 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x77, - 0x0a, 0x04, 0x53, 0x79, 0x6e, 0x63, 0x12, 0x31, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, - 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, - 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x79, - 0x6e, 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, - 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, - 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, - 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x53, 0x0a, 0x04, 0x53, 0x65, 0x6e, 0x64, 0x12, - 0x31, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, - 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, - 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, - 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x79, 0x0a, 0x05, - 0x46, 0x65, 0x74, 0x63, 0x68, 0x12, 0x32, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, - 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, - 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x46, 0x65, 0x74, - 0x63, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, - 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, - 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, - 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x90, 0x01, 0x0a, 0x0f, 0x50, 0x72, 0x65, 0x70, - 0x61, 0x72, 0x65, 0x44, 0x6f, 0x77, 0x6e, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x3c, 0x2e, 0x6c, 0x6f, - 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, - 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, - 0x70, 0x63, 0x2e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x44, 0x6f, 0x77, 0x6e, 0x6c, 0x6f, - 0x61, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3d, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, - 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, - 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, - 0x2e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x44, 0x6f, 0x77, 0x6e, 0x6c, 0x6f, 0x61, 0x64, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x63, 0x0a, 0x0c, 0x42, 0x61, - 0x63, 0x6b, 0x75, 0x70, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x12, 0x39, 0x2e, 0x6c, 0x6f, 0x6e, - 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, - 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, - 0x63, 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, - 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, - 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, - 0x87, 0x01, 0x0a, 0x0c, 0x42, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, - 0x12, 0x39, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, - 0x69, 0x6e, 0x67, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, - 0x70, 0x6b, 0x67, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x53, 0x74, - 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, 0x6c, 0x6f, - 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2e, 0x62, 0x61, 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x69, 0x6d, - 0x61, 0x67, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x70, 0x6b, 0x67, 0x2e, 0x72, - 0x70, 0x63, 0x2e, 0x42, 0x61, 0x63, 0x6b, 0x75, 0x70, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x3b, 0x0a, 0x05, 0x57, 0x61, 0x74, - 0x63, 0x68, 0x12, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, - 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, - 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, - 0x74, 0x79, 0x22, 0x00, 0x30, 0x01, 0x42, 0x33, 0x5a, 0x31, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, - 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x6f, 0x6e, 0x67, 0x68, 0x6f, 0x72, 0x6e, 0x2f, 0x62, 0x61, - 0x63, 0x6b, 0x69, 0x6e, 0x67, 0x2d, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x2d, 0x6d, 0x61, 0x6e, 0x61, - 0x67, 0x65, 0x72, 0x2f, 0x70, 0x6b, 0x67, 0x2f, 0x72, 0x70, 0x63, 0x62, 0x06, 0x70, 0x72, 0x6f, - 0x74, 0x6f, 0x33, -} - -var ( - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescOnce sync.Once - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescData = file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDesc -) - -func file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescGZIP() []byte { - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescOnce.Do(func() { - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescData = protoimpl.X.CompressGZIP(file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescData) - }) - return file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDescData -} - -var file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes = make([]protoimpl.MessageInfo, 17) -var file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_goTypes = []interface{}{ - (*BackingImageSpec)(nil), // 0: longhorn.backingimagemanager.pkg.rpc.BackingImageSpec - (*BackingImageStatus)(nil), // 1: longhorn.backingimagemanager.pkg.rpc.BackingImageStatus - (*BackingImageResponse)(nil), // 2: longhorn.backingimagemanager.pkg.rpc.BackingImageResponse - (*DeleteRequest)(nil), // 3: longhorn.backingimagemanager.pkg.rpc.DeleteRequest - (*GetRequest)(nil), // 4: longhorn.backingimagemanager.pkg.rpc.GetRequest - (*ListResponse)(nil), // 5: longhorn.backingimagemanager.pkg.rpc.ListResponse - (*VersionResponse)(nil), // 6: longhorn.backingimagemanager.pkg.rpc.VersionResponse - (*SyncRequest)(nil), // 7: longhorn.backingimagemanager.pkg.rpc.SyncRequest - (*SendRequest)(nil), // 8: longhorn.backingimagemanager.pkg.rpc.SendRequest - (*FetchRequest)(nil), // 9: longhorn.backingimagemanager.pkg.rpc.FetchRequest - (*PrepareDownloadRequest)(nil), // 10: longhorn.backingimagemanager.pkg.rpc.PrepareDownloadRequest - (*PrepareDownloadResponse)(nil), // 11: longhorn.backingimagemanager.pkg.rpc.PrepareDownloadResponse - (*BackupCreateRequest)(nil), // 12: longhorn.backingimagemanager.pkg.rpc.BackupCreateRequest - (*BackupStatusRequest)(nil), // 13: longhorn.backingimagemanager.pkg.rpc.BackupStatusRequest - (*BackupStatusResponse)(nil), // 14: longhorn.backingimagemanager.pkg.rpc.BackupStatusResponse - nil, // 15: longhorn.backingimagemanager.pkg.rpc.ListResponse.BackingImagesEntry - nil, // 16: longhorn.backingimagemanager.pkg.rpc.BackupCreateRequest.CredentialEntry - (*emptypb.Empty)(nil), // 17: google.protobuf.Empty -} -var file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_depIdxs = []int32{ - 0, // 0: longhorn.backingimagemanager.pkg.rpc.BackingImageResponse.spec:type_name -> longhorn.backingimagemanager.pkg.rpc.BackingImageSpec - 1, // 1: longhorn.backingimagemanager.pkg.rpc.BackingImageResponse.status:type_name -> longhorn.backingimagemanager.pkg.rpc.BackingImageStatus - 15, // 2: longhorn.backingimagemanager.pkg.rpc.ListResponse.backing_images:type_name -> longhorn.backingimagemanager.pkg.rpc.ListResponse.BackingImagesEntry - 0, // 3: longhorn.backingimagemanager.pkg.rpc.SyncRequest.spec:type_name -> longhorn.backingimagemanager.pkg.rpc.BackingImageSpec - 0, // 4: longhorn.backingimagemanager.pkg.rpc.FetchRequest.spec:type_name -> longhorn.backingimagemanager.pkg.rpc.BackingImageSpec - 16, // 5: longhorn.backingimagemanager.pkg.rpc.BackupCreateRequest.credential:type_name -> longhorn.backingimagemanager.pkg.rpc.BackupCreateRequest.CredentialEntry - 2, // 6: longhorn.backingimagemanager.pkg.rpc.ListResponse.BackingImagesEntry.value:type_name -> longhorn.backingimagemanager.pkg.rpc.BackingImageResponse - 3, // 7: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Delete:input_type -> longhorn.backingimagemanager.pkg.rpc.DeleteRequest - 4, // 8: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Get:input_type -> longhorn.backingimagemanager.pkg.rpc.GetRequest - 17, // 9: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.List:input_type -> google.protobuf.Empty - 17, // 10: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.VersionGet:input_type -> google.protobuf.Empty - 7, // 11: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Sync:input_type -> longhorn.backingimagemanager.pkg.rpc.SyncRequest - 8, // 12: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Send:input_type -> longhorn.backingimagemanager.pkg.rpc.SendRequest - 9, // 13: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Fetch:input_type -> longhorn.backingimagemanager.pkg.rpc.FetchRequest - 10, // 14: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.PrepareDownload:input_type -> longhorn.backingimagemanager.pkg.rpc.PrepareDownloadRequest - 12, // 15: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.BackupCreate:input_type -> longhorn.backingimagemanager.pkg.rpc.BackupCreateRequest - 13, // 16: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.BackupStatus:input_type -> longhorn.backingimagemanager.pkg.rpc.BackupStatusRequest - 17, // 17: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Watch:input_type -> google.protobuf.Empty - 17, // 18: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Delete:output_type -> google.protobuf.Empty - 2, // 19: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Get:output_type -> longhorn.backingimagemanager.pkg.rpc.BackingImageResponse - 5, // 20: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.List:output_type -> longhorn.backingimagemanager.pkg.rpc.ListResponse - 6, // 21: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.VersionGet:output_type -> longhorn.backingimagemanager.pkg.rpc.VersionResponse - 2, // 22: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Sync:output_type -> longhorn.backingimagemanager.pkg.rpc.BackingImageResponse - 17, // 23: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Send:output_type -> google.protobuf.Empty - 2, // 24: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Fetch:output_type -> longhorn.backingimagemanager.pkg.rpc.BackingImageResponse - 11, // 25: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.PrepareDownload:output_type -> longhorn.backingimagemanager.pkg.rpc.PrepareDownloadResponse - 17, // 26: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.BackupCreate:output_type -> google.protobuf.Empty - 14, // 27: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.BackupStatus:output_type -> longhorn.backingimagemanager.pkg.rpc.BackupStatusResponse - 17, // 28: longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService.Watch:output_type -> google.protobuf.Empty - 18, // [18:29] is the sub-list for method output_type - 7, // [7:18] is the sub-list for method input_type - 7, // [7:7] is the sub-list for extension type_name - 7, // [7:7] is the sub-list for extension extendee - 0, // [0:7] is the sub-list for field type_name -} - -func init() { file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_init() } -func file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_init() { - if File_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto != nil { - return - } - if !protoimpl.UnsafeEnabled { - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*BackingImageSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*BackingImageStatus); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*BackingImageResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DeleteRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ListResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*VersionResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*SyncRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*SendRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*FetchRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PrepareDownloadRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PrepareDownloadResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*BackupCreateRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*BackupStatusRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*BackupStatusResponse); 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_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDesc, - NumEnums: 0, - NumMessages: 17, - NumExtensions: 0, - NumServices: 1, - }, - GoTypes: file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_goTypes, - DependencyIndexes: file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_depIdxs, - MessageInfos: file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_msgTypes, - }.Build() - File_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto = out.File - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_rawDesc = nil - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_goTypes = nil - file_github_com_longhorn_backing_image_manager_pkg_rpc_rpc_proto_depIdxs = nil -} - -// Reference imports to suppress errors if they are not otherwise used. -var _ context.Context -var _ grpc.ClientConnInterface - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the grpc package it is being compiled against. -const _ = grpc.SupportPackageIsVersion6 - -// BackingImageManagerServiceClient is the client API for BackingImageManagerService service. -// -// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. -type BackingImageManagerServiceClient interface { - Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) - Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*BackingImageResponse, error) - List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListResponse, error) - VersionGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VersionResponse, error) - Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*BackingImageResponse, error) - Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) - Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (*BackingImageResponse, error) - PrepareDownload(ctx context.Context, in *PrepareDownloadRequest, opts ...grpc.CallOption) (*PrepareDownloadResponse, error) - BackupCreate(ctx context.Context, in *BackupCreateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) - BackupStatus(ctx context.Context, in *BackupStatusRequest, opts ...grpc.CallOption) (*BackupStatusResponse, error) - Watch(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (BackingImageManagerService_WatchClient, error) -} - -type backingImageManagerServiceClient struct { - cc grpc.ClientConnInterface -} - -func NewBackingImageManagerServiceClient(cc grpc.ClientConnInterface) BackingImageManagerServiceClient { - return &backingImageManagerServiceClient{cc} -} - -func (c *backingImageManagerServiceClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { - out := new(emptypb.Empty) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Delete", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*BackingImageResponse, error) { - out := new(BackingImageResponse) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Get", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListResponse, error) { - out := new(ListResponse) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/List", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) VersionGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VersionResponse, error) { - out := new(VersionResponse) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/VersionGet", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*BackingImageResponse, error) { - out := new(BackingImageResponse) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Sync", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { - out := new(emptypb.Empty) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Send", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (*BackingImageResponse, error) { - out := new(BackingImageResponse) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Fetch", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) PrepareDownload(ctx context.Context, in *PrepareDownloadRequest, opts ...grpc.CallOption) (*PrepareDownloadResponse, error) { - out := new(PrepareDownloadResponse) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/PrepareDownload", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) BackupCreate(ctx context.Context, in *BackupCreateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { - out := new(emptypb.Empty) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/BackupCreate", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) BackupStatus(ctx context.Context, in *BackupStatusRequest, opts ...grpc.CallOption) (*BackupStatusResponse, error) { - out := new(BackupStatusResponse) - err := c.cc.Invoke(ctx, "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/BackupStatus", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *backingImageManagerServiceClient) Watch(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (BackingImageManagerService_WatchClient, error) { - stream, err := c.cc.NewStream(ctx, &_BackingImageManagerService_serviceDesc.Streams[0], "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Watch", opts...) - if err != nil { - return nil, err - } - x := &backingImageManagerServiceWatchClient{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 -} - -type BackingImageManagerService_WatchClient interface { - Recv() (*emptypb.Empty, error) - grpc.ClientStream -} - -type backingImageManagerServiceWatchClient struct { - grpc.ClientStream -} - -func (x *backingImageManagerServiceWatchClient) Recv() (*emptypb.Empty, error) { - m := new(emptypb.Empty) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} - -// BackingImageManagerServiceServer is the server API for BackingImageManagerService service. -type BackingImageManagerServiceServer interface { - Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error) - Get(context.Context, *GetRequest) (*BackingImageResponse, error) - List(context.Context, *emptypb.Empty) (*ListResponse, error) - VersionGet(context.Context, *emptypb.Empty) (*VersionResponse, error) - Sync(context.Context, *SyncRequest) (*BackingImageResponse, error) - Send(context.Context, *SendRequest) (*emptypb.Empty, error) - Fetch(context.Context, *FetchRequest) (*BackingImageResponse, error) - PrepareDownload(context.Context, *PrepareDownloadRequest) (*PrepareDownloadResponse, error) - BackupCreate(context.Context, *BackupCreateRequest) (*emptypb.Empty, error) - BackupStatus(context.Context, *BackupStatusRequest) (*BackupStatusResponse, error) - Watch(*emptypb.Empty, BackingImageManagerService_WatchServer) error -} - -// UnimplementedBackingImageManagerServiceServer can be embedded to have forward compatible implementations. -type UnimplementedBackingImageManagerServiceServer struct { -} - -func (*UnimplementedBackingImageManagerServiceServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error) { - return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) Get(context.Context, *GetRequest) (*BackingImageResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Get not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) List(context.Context, *emptypb.Empty) (*ListResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method List not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) VersionGet(context.Context, *emptypb.Empty) (*VersionResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method VersionGet not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) Sync(context.Context, *SyncRequest) (*BackingImageResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Sync not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) Send(context.Context, *SendRequest) (*emptypb.Empty, error) { - return nil, status.Errorf(codes.Unimplemented, "method Send not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) Fetch(context.Context, *FetchRequest) (*BackingImageResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Fetch not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) PrepareDownload(context.Context, *PrepareDownloadRequest) (*PrepareDownloadResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method PrepareDownload not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) BackupCreate(context.Context, *BackupCreateRequest) (*emptypb.Empty, error) { - return nil, status.Errorf(codes.Unimplemented, "method BackupCreate not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) BackupStatus(context.Context, *BackupStatusRequest) (*BackupStatusResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method BackupStatus not implemented") -} -func (*UnimplementedBackingImageManagerServiceServer) Watch(*emptypb.Empty, BackingImageManagerService_WatchServer) error { - return status.Errorf(codes.Unimplemented, "method Watch not implemented") -} - -func RegisterBackingImageManagerServiceServer(s *grpc.Server, srv BackingImageManagerServiceServer) { - s.RegisterService(&_BackingImageManagerService_serviceDesc, srv) -} - -func _BackingImageManagerService_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DeleteRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).Delete(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Delete", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).Delete(ctx, req.(*DeleteRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(GetRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).Get(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Get", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).Get(ctx, req.(*GetRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(emptypb.Empty) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).List(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/List", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).List(ctx, req.(*emptypb.Empty)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_VersionGet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(emptypb.Empty) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).VersionGet(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/VersionGet", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).VersionGet(ctx, req.(*emptypb.Empty)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_Sync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(SyncRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).Sync(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Sync", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).Sync(ctx, req.(*SyncRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_Send_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(SendRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).Send(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Send", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).Send(ctx, req.(*SendRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_Fetch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(FetchRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).Fetch(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/Fetch", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).Fetch(ctx, req.(*FetchRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_PrepareDownload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(PrepareDownloadRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).PrepareDownload(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/PrepareDownload", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).PrepareDownload(ctx, req.(*PrepareDownloadRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_BackupCreate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(BackupCreateRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).BackupCreate(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/BackupCreate", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).BackupCreate(ctx, req.(*BackupCreateRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_BackupStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(BackupStatusRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(BackingImageManagerServiceServer).BackupStatus(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService/BackupStatus", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(BackingImageManagerServiceServer).BackupStatus(ctx, req.(*BackupStatusRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _BackingImageManagerService_Watch_Handler(srv interface{}, stream grpc.ServerStream) error { - m := new(emptypb.Empty) - if err := stream.RecvMsg(m); err != nil { - return err - } - return srv.(BackingImageManagerServiceServer).Watch(m, &backingImageManagerServiceWatchServer{stream}) -} - -type BackingImageManagerService_WatchServer interface { - Send(*emptypb.Empty) error - grpc.ServerStream -} - -type backingImageManagerServiceWatchServer struct { - grpc.ServerStream -} - -func (x *backingImageManagerServiceWatchServer) Send(m *emptypb.Empty) error { - return x.ServerStream.SendMsg(m) -} - -var _BackingImageManagerService_serviceDesc = grpc.ServiceDesc{ - ServiceName: "longhorn.backingimagemanager.pkg.rpc.BackingImageManagerService", - HandlerType: (*BackingImageManagerServiceServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "Delete", - Handler: _BackingImageManagerService_Delete_Handler, - }, - { - MethodName: "Get", - Handler: _BackingImageManagerService_Get_Handler, - }, - { - MethodName: "List", - Handler: _BackingImageManagerService_List_Handler, - }, - { - MethodName: "VersionGet", - Handler: _BackingImageManagerService_VersionGet_Handler, - }, - { - MethodName: "Sync", - Handler: _BackingImageManagerService_Sync_Handler, - }, - { - MethodName: "Send", - Handler: _BackingImageManagerService_Send_Handler, - }, - { - MethodName: "Fetch", - Handler: _BackingImageManagerService_Fetch_Handler, - }, - { - MethodName: "PrepareDownload", - Handler: _BackingImageManagerService_PrepareDownload_Handler, - }, - { - MethodName: "BackupCreate", - Handler: _BackingImageManagerService_BackupCreate_Handler, - }, - { - MethodName: "BackupStatus", - Handler: _BackingImageManagerService_BackupStatus_Handler, - }, - }, - Streams: []grpc.StreamDesc{ - { - StreamName: "Watch", - Handler: _BackingImageManagerService_Watch_Handler, - ServerStreams: true, - }, - }, - Metadata: "github.com/longhorn/backing-image-manager/pkg/rpc/rpc.proto", -} diff --git a/pkg/rpc/rpc.proto b/pkg/rpc/rpc.proto deleted file mode 100644 index 9dbf137b..00000000 --- a/pkg/rpc/rpc.proto +++ /dev/null @@ -1,114 +0,0 @@ -syntax="proto3"; - -package longhorn.backingimagemanager.pkg.rpc; - -import "google/protobuf/empty.proto"; - -option go_package = "github.com/longhorn/backing-image-manager/pkg/rpc"; - -service BackingImageManagerService { - rpc Delete(DeleteRequest) returns (google.protobuf.Empty) {} - rpc Get(GetRequest) returns (BackingImageResponse) {} - rpc List(google.protobuf.Empty) returns (ListResponse) {} - rpc VersionGet(google.protobuf.Empty) returns(VersionResponse); - rpc Sync(SyncRequest) returns (BackingImageResponse) {} - rpc Send(SendRequest) returns (google.protobuf.Empty) {} - rpc Fetch(FetchRequest) returns (BackingImageResponse) {} - rpc PrepareDownload(PrepareDownloadRequest) returns (PrepareDownloadResponse) {} - rpc BackupCreate(BackupCreateRequest) returns (google.protobuf.Empty) {} - rpc BackupStatus(BackupStatusRequest) returns (BackupStatusResponse) {} - - rpc Watch(google.protobuf.Empty) returns (stream google.protobuf.Empty) {} -} - -message BackingImageSpec { - string name = 1; - string uuid = 2; - int64 size = 3; - string checksum = 4; -} - -message BackingImageStatus { - string state = 1; - string error_msg = 2; - int32 sending_reference = 3; - string sender_manager_address = 4; - int32 progress = 5; - string checksum = 6; -} - -message BackingImageResponse { - BackingImageSpec spec = 1; - BackingImageStatus status = 2; -} - -message DeleteRequest { - string name = 1; - string uuid = 2; -} - -message GetRequest { - string name = 1; - string uuid = 2; -} - -message ListResponse{ - map backing_images = 1; -} - -message VersionResponse { - string version = 1; - string gitCommit = 2; - string buildDate = 3; - - int64 backing_image_manager_api_version = 4; - int64 backing_image_manager_api_min_version = 5; -} - -message SyncRequest { - BackingImageSpec spec = 1; - string from_address = 2; -} - -message SendRequest { - string name = 1; - string uuid = 2; - string to_address = 3; -} - -message FetchRequest { - BackingImageSpec spec = 1; - string data_source_address = 2; -} - -message PrepareDownloadRequest { - string name = 1; - string uuid = 2; -} - -message PrepareDownloadResponse { - string src_file_path = 1; - string address = 2; -} - -message BackupCreateRequest { - string name = 1; - string uuid = 2; - string checksum = 3; - string backup_target = 4; - repeated string labels = 5; - map credential = 6; - string compression_method = 7; - int32 concurrent_limit = 8; -} - -message BackupStatusRequest { - string name = 1; -} - -message BackupStatusResponse { - int32 progress = 1; - string backup_url = 2; - string error = 3; - string state = 4; -} diff --git a/proto/vendor/protobuf/src/google/protobuf/empty.proto b/proto/vendor/protobuf/src/google/protobuf/empty.proto deleted file mode 100644 index b87c89dc..00000000 --- a/proto/vendor/protobuf/src/google/protobuf/empty.proto +++ /dev/null @@ -1,51 +0,0 @@ -// Protocol Buffers - Google's data interchange format -// Copyright 2008 Google Inc. All rights reserved. -// https://developers.google.com/protocol-buffers/ -// -// Redistribution and use in source and binary forms, with or without -// modification, are permitted provided that the following conditions are -// met: -// -// * Redistributions of source code must retain the above copyright -// notice, this list of conditions and the following disclaimer. -// * Redistributions in binary form must reproduce the above -// copyright notice, this list of conditions and the following disclaimer -// in the documentation and/or other materials provided with the -// distribution. -// * Neither the name of Google Inc. nor the names of its -// contributors may be used to endorse or promote products derived from -// this software without specific prior written permission. -// -// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS -// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT -// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR -// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT -// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, -// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT -// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, -// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY -// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT -// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE -// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - -syntax = "proto3"; - -package google.protobuf; - -option go_package = "google.golang.org/protobuf/types/known/emptypb"; -option java_package = "com.google.protobuf"; -option java_outer_classname = "EmptyProto"; -option java_multiple_files = true; -option objc_class_prefix = "GPB"; -option csharp_namespace = "Google.Protobuf.WellKnownTypes"; -option cc_enable_arenas = true; - -// A generic empty message that you can re-use to avoid defining duplicated -// empty messages in your APIs. A typical example is to use it as the request -// or the response type of an API method. For instance: -// -// service Foo { -// rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); -// } -// -message Empty {}