longhorn
/
types
mirror of https://github.com/longhorn/types.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat: add v2 range shallow copy APIs 

Longhorn 10037

Signed-off-by: Shuo Wu <shuo.wu@suse.com>
This commit is contained in:
Shuo Wu 2025-05-06 21:46:07 +00:00 committed by Derek Su
parent 4e3148aa85
commit b79d2bcff0
5 changed files with 2218 additions and 1745 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

320
generated-py/spdkrpc/spdk_pb2.py
View File

File diff suppressed because one or more lines are too long

66
generated-py/spdkrpc/spdk_pb2_grpc.py
View File

@ -70,6 +70,11 @@ class SPDKServiceStub(object):
request_serializer=spdkrpc_dot_spdk__pb2.SnapshotHashLockStateRequest.SerializeToString,
response_deserializer=spdkrpc_dot_spdk__pb2.SnapshotHashLockStateResponse.FromString,
)
self.ReplicaSnapshotRangeHashGet = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaSnapshotRangeHashGet',
request_serializer=spdkrpc_dot_spdk__pb2.ReplicaSnapshotRangeHashGetRequest.SerializeToString,
response_deserializer=spdkrpc_dot_spdk__pb2.ReplicaSnapshotRangeHashGetResponse.FromString,
)
self.ReplicaList = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaList',
request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
@ -95,6 +100,11 @@ class SPDKServiceStub(object):
request_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyStartRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.ReplicaRebuildingSrcRangeShallowCopyStart = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaRebuildingSrcRangeShallowCopyStart',
request_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcRangeShallowCopyStartRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.ReplicaRebuildingSrcShallowCopyCheck = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyCheck',
request_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyCheckRequest.SerializeToString,
@ -426,6 +436,12 @@ class SPDKServiceServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ReplicaSnapshotRangeHashGet(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ReplicaList(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -456,6 +472,12 @@ class SPDKServiceServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ReplicaRebuildingSrcRangeShallowCopyStart(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ReplicaRebuildingSrcShallowCopyCheck(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -826,6 +848,11 @@ def add_SPDKServiceServicer_to_server(servicer, server):
request_deserializer=spdkrpc_dot_spdk__pb2.SnapshotHashLockStateRequest.FromString,
response_serializer=spdkrpc_dot_spdk__pb2.SnapshotHashLockStateResponse.SerializeToString,
),
'ReplicaSnapshotRangeHashGet': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaSnapshotRangeHashGet,
request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaSnapshotRangeHashGetRequest.FromString,
response_serializer=spdkrpc_dot_spdk__pb2.ReplicaSnapshotRangeHashGetResponse.SerializeToString,
),
'ReplicaList': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaList,
request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
@ -851,6 +878,11 @@ def add_SPDKServiceServicer_to_server(servicer, server):
request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyStartRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'ReplicaRebuildingSrcRangeShallowCopyStart': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaRebuildingSrcRangeShallowCopyStart,
request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcRangeShallowCopyStartRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'ReplicaRebuildingSrcShallowCopyCheck': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaRebuildingSrcShallowCopyCheck,
request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyCheckRequest.FromString,
@ -1308,6 +1340,23 @@ class SPDKService(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaSnapshotRangeHashGet(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/spdkrpc.SPDKService/ReplicaSnapshotRangeHashGet',
spdkrpc_dot_spdk__pb2.ReplicaSnapshotRangeHashGetRequest.SerializeToString,
spdkrpc_dot_spdk__pb2.ReplicaSnapshotRangeHashGetResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaList(request,
target,
@ -1393,6 +1442,23 @@ class SPDKService(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaRebuildingSrcRangeShallowCopyStart(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/spdkrpc.SPDKService/ReplicaRebuildingSrcRangeShallowCopyStart',
spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcRangeShallowCopyStartRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaRebuildingSrcShallowCopyCheck(request,
target,

3342
pkg/generated/spdkrpc/spdk.pb.go
View File

File diff suppressed because it is too large Load Diff

210
pkg/generated/spdkrpc/spdk_grpc.pb.go
View File

@ -20,74 +20,76 @@ import (
const _ = grpc.SupportPackageIsVersion7
const (
SPDKService_ReplicaCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaCreate"
SPDKService_ReplicaDelete_FullMethodName = "/spdkrpc.SPDKService/ReplicaDelete"
SPDKService_ReplicaGet_FullMethodName = "/spdkrpc.SPDKService/ReplicaGet"
SPDKService_ReplicaSnapshotCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotCreate"
SPDKService_ReplicaSnapshotDelete_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotDelete"
SPDKService_ReplicaSnapshotRevert_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotRevert"
SPDKService_ReplicaSnapshotPurge_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotPurge"
SPDKService_ReplicaSnapshotHash_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotHash"
SPDKService_ReplicaSnapshotHashStatus_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotHashStatus"
SPDKService_ReplicaSnapshotHashCancel_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotHashCancel"
SPDKService_ReplicaSnapshotHashLockState_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotHashLockState"
SPDKService_ReplicaList_FullMethodName = "/spdkrpc.SPDKService/ReplicaList"
SPDKService_ReplicaWatch_FullMethodName = "/spdkrpc.SPDKService/ReplicaWatch"
SPDKService_ReplicaRebuildingSrcStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcStart"
SPDKService_ReplicaRebuildingSrcFinish_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcFinish"
SPDKService_ReplicaRebuildingSrcShallowCopyStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyStart"
SPDKService_ReplicaRebuildingSrcShallowCopyCheck_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyCheck"
SPDKService_ReplicaRebuildingDstStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstStart"
SPDKService_ReplicaRebuildingDstFinish_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstFinish"
SPDKService_ReplicaRebuildingDstShallowCopyStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstShallowCopyStart"
SPDKService_ReplicaRebuildingDstShallowCopyCheck_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstShallowCopyCheck"
SPDKService_ReplicaRebuildingDstSnapshotCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstSnapshotCreate"
SPDKService_ReplicaRebuildingDstSetQosLimit_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstSetQosLimit"
SPDKService_ReplicaBackupCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupCreate"
SPDKService_ReplicaBackupStatus_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupStatus"
SPDKService_ReplicaBackupRestore_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupRestore"
SPDKService_ReplicaRestoreStatus_FullMethodName = "/spdkrpc.SPDKService/ReplicaRestoreStatus"
SPDKService_EngineCreate_FullMethodName = "/spdkrpc.SPDKService/EngineCreate"
SPDKService_EngineDelete_FullMethodName = "/spdkrpc.SPDKService/EngineDelete"
SPDKService_EngineGet_FullMethodName = "/spdkrpc.SPDKService/EngineGet"
SPDKService_EngineSuspend_FullMethodName = "/spdkrpc.SPDKService/EngineSuspend"
SPDKService_EngineResume_FullMethodName = "/spdkrpc.SPDKService/EngineResume"
SPDKService_EngineSwitchOverTarget_FullMethodName = "/spdkrpc.SPDKService/EngineSwitchOverTarget"
SPDKService_EngineDeleteTarget_FullMethodName = "/spdkrpc.SPDKService/EngineDeleteTarget"
SPDKService_EngineSnapshotCreate_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotCreate"
SPDKService_EngineSnapshotDelete_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotDelete"
SPDKService_EngineSnapshotRevert_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotRevert"
SPDKService_EngineSnapshotPurge_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotPurge"
SPDKService_EngineSnapshotHash_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotHash"
SPDKService_EngineSnapshotHashStatus_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotHashStatus"
SPDKService_EngineSnapshotHashCancel_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotHashCancel"
SPDKService_EngineSnapshotHashLockState_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotHashLockState"
SPDKService_EngineList_FullMethodName = "/spdkrpc.SPDKService/EngineList"
SPDKService_EngineWatch_FullMethodName = "/spdkrpc.SPDKService/EngineWatch"
SPDKService_EngineReplicaList_FullMethodName = "/spdkrpc.SPDKService/EngineReplicaList"
SPDKService_EngineReplicaAdd_FullMethodName = "/spdkrpc.SPDKService/EngineReplicaAdd"
SPDKService_EngineReplicaDelete_FullMethodName = "/spdkrpc.SPDKService/EngineReplicaDelete"
SPDKService_EngineBackupCreate_FullMethodName = "/spdkrpc.SPDKService/EngineBackupCreate"
SPDKService_EngineBackupStatus_FullMethodName = "/spdkrpc.SPDKService/EngineBackupStatus"
SPDKService_EngineBackupRestore_FullMethodName = "/spdkrpc.SPDKService/EngineBackupRestore"
SPDKService_EngineBackupRestoreFinish_FullMethodName = "/spdkrpc.SPDKService/EngineBackupRestoreFinish"
SPDKService_EngineRestoreStatus_FullMethodName = "/spdkrpc.SPDKService/EngineRestoreStatus"
SPDKService_BackingImageCreate_FullMethodName = "/spdkrpc.SPDKService/BackingImageCreate"
SPDKService_BackingImageDelete_FullMethodName = "/spdkrpc.SPDKService/BackingImageDelete"
SPDKService_BackingImageGet_FullMethodName = "/spdkrpc.SPDKService/BackingImageGet"
SPDKService_BackingImageList_FullMethodName = "/spdkrpc.SPDKService/BackingImageList"
SPDKService_BackingImageWatch_FullMethodName = "/spdkrpc.SPDKService/BackingImageWatch"
SPDKService_BackingImageExpose_FullMethodName = "/spdkrpc.SPDKService/BackingImageExpose"
SPDKService_BackingImageUnexpose_FullMethodName = "/spdkrpc.SPDKService/BackingImageUnexpose"
SPDKService_DiskCreate_FullMethodName = "/spdkrpc.SPDKService/DiskCreate"
SPDKService_DiskDelete_FullMethodName = "/spdkrpc.SPDKService/DiskDelete"
SPDKService_DiskGet_FullMethodName = "/spdkrpc.SPDKService/DiskGet"
SPDKService_LogSetLevel_FullMethodName = "/spdkrpc.SPDKService/LogSetLevel"
SPDKService_LogSetFlags_FullMethodName = "/spdkrpc.SPDKService/LogSetFlags"
SPDKService_LogGetLevel_FullMethodName = "/spdkrpc.SPDKService/LogGetLevel"
SPDKService_LogGetFlags_FullMethodName = "/spdkrpc.SPDKService/LogGetFlags"
SPDKService_VersionDetailGet_FullMethodName = "/spdkrpc.SPDKService/VersionDetailGet"
SPDKService_MetricsGet_FullMethodName = "/spdkrpc.SPDKService/MetricsGet"
SPDKService_ReplicaCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaCreate"
SPDKService_ReplicaDelete_FullMethodName = "/spdkrpc.SPDKService/ReplicaDelete"
SPDKService_ReplicaGet_FullMethodName = "/spdkrpc.SPDKService/ReplicaGet"
SPDKService_ReplicaSnapshotCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotCreate"
SPDKService_ReplicaSnapshotDelete_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotDelete"
SPDKService_ReplicaSnapshotRevert_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotRevert"
SPDKService_ReplicaSnapshotPurge_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotPurge"
SPDKService_ReplicaSnapshotHash_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotHash"
SPDKService_ReplicaSnapshotHashStatus_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotHashStatus"
SPDKService_ReplicaSnapshotHashCancel_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotHashCancel"
SPDKService_ReplicaSnapshotHashLockState_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotHashLockState"
SPDKService_ReplicaSnapshotRangeHashGet_FullMethodName = "/spdkrpc.SPDKService/ReplicaSnapshotRangeHashGet"
SPDKService_ReplicaList_FullMethodName = "/spdkrpc.SPDKService/ReplicaList"
SPDKService_ReplicaWatch_FullMethodName = "/spdkrpc.SPDKService/ReplicaWatch"
SPDKService_ReplicaRebuildingSrcStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcStart"
SPDKService_ReplicaRebuildingSrcFinish_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcFinish"
SPDKService_ReplicaRebuildingSrcShallowCopyStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyStart"
SPDKService_ReplicaRebuildingSrcRangeShallowCopyStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcRangeShallowCopyStart"
SPDKService_ReplicaRebuildingSrcShallowCopyCheck_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyCheck"
SPDKService_ReplicaRebuildingDstStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstStart"
SPDKService_ReplicaRebuildingDstFinish_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstFinish"
SPDKService_ReplicaRebuildingDstShallowCopyStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstShallowCopyStart"
SPDKService_ReplicaRebuildingDstShallowCopyCheck_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstShallowCopyCheck"
SPDKService_ReplicaRebuildingDstSnapshotCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstSnapshotCreate"
SPDKService_ReplicaRebuildingDstSetQosLimit_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstSetQosLimit"
SPDKService_ReplicaBackupCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupCreate"
SPDKService_ReplicaBackupStatus_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupStatus"
SPDKService_ReplicaBackupRestore_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupRestore"
SPDKService_ReplicaRestoreStatus_FullMethodName = "/spdkrpc.SPDKService/ReplicaRestoreStatus"
SPDKService_EngineCreate_FullMethodName = "/spdkrpc.SPDKService/EngineCreate"
SPDKService_EngineDelete_FullMethodName = "/spdkrpc.SPDKService/EngineDelete"
SPDKService_EngineGet_FullMethodName = "/spdkrpc.SPDKService/EngineGet"
SPDKService_EngineSuspend_FullMethodName = "/spdkrpc.SPDKService/EngineSuspend"
SPDKService_EngineResume_FullMethodName = "/spdkrpc.SPDKService/EngineResume"
SPDKService_EngineSwitchOverTarget_FullMethodName = "/spdkrpc.SPDKService/EngineSwitchOverTarget"
SPDKService_EngineDeleteTarget_FullMethodName = "/spdkrpc.SPDKService/EngineDeleteTarget"
SPDKService_EngineSnapshotCreate_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotCreate"
SPDKService_EngineSnapshotDelete_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotDelete"
SPDKService_EngineSnapshotRevert_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotRevert"
SPDKService_EngineSnapshotPurge_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotPurge"
SPDKService_EngineSnapshotHash_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotHash"
SPDKService_EngineSnapshotHashStatus_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotHashStatus"
SPDKService_EngineSnapshotHashCancel_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotHashCancel"
SPDKService_EngineSnapshotHashLockState_FullMethodName = "/spdkrpc.SPDKService/EngineSnapshotHashLockState"
SPDKService_EngineList_FullMethodName = "/spdkrpc.SPDKService/EngineList"
SPDKService_EngineWatch_FullMethodName = "/spdkrpc.SPDKService/EngineWatch"
SPDKService_EngineReplicaList_FullMethodName = "/spdkrpc.SPDKService/EngineReplicaList"
SPDKService_EngineReplicaAdd_FullMethodName = "/spdkrpc.SPDKService/EngineReplicaAdd"
SPDKService_EngineReplicaDelete_FullMethodName = "/spdkrpc.SPDKService/EngineReplicaDelete"
SPDKService_EngineBackupCreate_FullMethodName = "/spdkrpc.SPDKService/EngineBackupCreate"
SPDKService_EngineBackupStatus_FullMethodName = "/spdkrpc.SPDKService/EngineBackupStatus"
SPDKService_EngineBackupRestore_FullMethodName = "/spdkrpc.SPDKService/EngineBackupRestore"
SPDKService_EngineBackupRestoreFinish_FullMethodName = "/spdkrpc.SPDKService/EngineBackupRestoreFinish"
SPDKService_EngineRestoreStatus_FullMethodName = "/spdkrpc.SPDKService/EngineRestoreStatus"
SPDKService_BackingImageCreate_FullMethodName = "/spdkrpc.SPDKService/BackingImageCreate"
SPDKService_BackingImageDelete_FullMethodName = "/spdkrpc.SPDKService/BackingImageDelete"
SPDKService_BackingImageGet_FullMethodName = "/spdkrpc.SPDKService/BackingImageGet"
SPDKService_BackingImageList_FullMethodName = "/spdkrpc.SPDKService/BackingImageList"
SPDKService_BackingImageWatch_FullMethodName = "/spdkrpc.SPDKService/BackingImageWatch"
SPDKService_BackingImageExpose_FullMethodName = "/spdkrpc.SPDKService/BackingImageExpose"
SPDKService_BackingImageUnexpose_FullMethodName = "/spdkrpc.SPDKService/BackingImageUnexpose"
SPDKService_DiskCreate_FullMethodName = "/spdkrpc.SPDKService/DiskCreate"
SPDKService_DiskDelete_FullMethodName = "/spdkrpc.SPDKService/DiskDelete"
SPDKService_DiskGet_FullMethodName = "/spdkrpc.SPDKService/DiskGet"
SPDKService_LogSetLevel_FullMethodName = "/spdkrpc.SPDKService/LogSetLevel"
SPDKService_LogSetFlags_FullMethodName = "/spdkrpc.SPDKService/LogSetFlags"
SPDKService_LogGetLevel_FullMethodName = "/spdkrpc.SPDKService/LogGetLevel"
SPDKService_LogGetFlags_FullMethodName = "/spdkrpc.SPDKService/LogGetFlags"
SPDKService_VersionDetailGet_FullMethodName = "/spdkrpc.SPDKService/VersionDetailGet"
SPDKService_MetricsGet_FullMethodName = "/spdkrpc.SPDKService/MetricsGet"
)
// SPDKServiceClient is the client API for SPDKService service.
@ -105,11 +107,13 @@ type SPDKServiceClient interface {
ReplicaSnapshotHashStatus(ctx context.Context, in *SnapshotHashStatusRequest, opts ...grpc.CallOption) (*ReplicaSnapshotHashStatusResponse, error)
ReplicaSnapshotHashCancel(ctx context.Context, in *SnapshotHashCancelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaSnapshotHashLockState(ctx context.Context, in *SnapshotHashLockStateRequest, opts ...grpc.CallOption) (*SnapshotHashLockStateResponse, error)
ReplicaSnapshotRangeHashGet(ctx context.Context, in *ReplicaSnapshotRangeHashGetRequest, opts ...grpc.CallOption) (*ReplicaSnapshotRangeHashGetResponse, error)
ReplicaList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReplicaListResponse, error)
ReplicaWatch(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (SPDKService_ReplicaWatchClient, error)
ReplicaRebuildingSrcStart(ctx context.Context, in *ReplicaRebuildingSrcStartRequest, opts ...grpc.CallOption) (*ReplicaRebuildingSrcStartResponse, error)
ReplicaRebuildingSrcFinish(ctx context.Context, in *ReplicaRebuildingSrcFinishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaRebuildingSrcShallowCopyStart(ctx context.Context, in *ReplicaRebuildingSrcShallowCopyStartRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaRebuildingSrcRangeShallowCopyStart(ctx context.Context, in *ReplicaRebuildingSrcRangeShallowCopyStartRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaRebuildingSrcShallowCopyCheck(ctx context.Context, in *ReplicaRebuildingSrcShallowCopyCheckRequest, opts ...grpc.CallOption) (*ReplicaRebuildingSrcShallowCopyCheckResponse, error)
ReplicaRebuildingDstStart(ctx context.Context, in *ReplicaRebuildingDstStartRequest, opts ...grpc.CallOption) (*ReplicaRebuildingDstStartResponse, error)
ReplicaRebuildingDstFinish(ctx context.Context, in *ReplicaRebuildingDstFinishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
@ -271,6 +275,15 @@ func (c *sPDKServiceClient) ReplicaSnapshotHashLockState(ctx context.Context, in
return out, nil
}
func (c *sPDKServiceClient) ReplicaSnapshotRangeHashGet(ctx context.Context, in *ReplicaSnapshotRangeHashGetRequest, opts ...grpc.CallOption) (*ReplicaSnapshotRangeHashGetResponse, error) {
out := new(ReplicaSnapshotRangeHashGetResponse)
err := c.cc.Invoke(ctx, SPDKService_ReplicaSnapshotRangeHashGet_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *sPDKServiceClient) ReplicaList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReplicaListResponse, error) {
out := new(ReplicaListResponse)
err := c.cc.Invoke(ctx, SPDKService_ReplicaList_FullMethodName, in, out, opts...)
@ -339,6 +352,15 @@ func (c *sPDKServiceClient) ReplicaRebuildingSrcShallowCopyStart(ctx context.Con
return out, nil
}
func (c *sPDKServiceClient) ReplicaRebuildingSrcRangeShallowCopyStart(ctx context.Context, in *ReplicaRebuildingSrcRangeShallowCopyStartRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, SPDKService_ReplicaRebuildingSrcRangeShallowCopyStart_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *sPDKServiceClient) ReplicaRebuildingSrcShallowCopyCheck(ctx context.Context, in *ReplicaRebuildingSrcShallowCopyCheckRequest, opts ...grpc.CallOption) (*ReplicaRebuildingSrcShallowCopyCheckResponse, error) {
out := new(ReplicaRebuildingSrcShallowCopyCheckResponse)
err := c.cc.Invoke(ctx, SPDKService_ReplicaRebuildingSrcShallowCopyCheck_FullMethodName, in, out, opts...)
@ -868,11 +890,13 @@ type SPDKServiceServer interface {
ReplicaSnapshotHashStatus(context.Context, *SnapshotHashStatusRequest) (*ReplicaSnapshotHashStatusResponse, error)
ReplicaSnapshotHashCancel(context.Context, *SnapshotHashCancelRequest) (*emptypb.Empty, error)
ReplicaSnapshotHashLockState(context.Context, *SnapshotHashLockStateRequest) (*SnapshotHashLockStateResponse, error)
ReplicaSnapshotRangeHashGet(context.Context, *ReplicaSnapshotRangeHashGetRequest) (*ReplicaSnapshotRangeHashGetResponse, error)
ReplicaList(context.Context, *emptypb.Empty) (*ReplicaListResponse, error)
ReplicaWatch(*emptypb.Empty, SPDKService_ReplicaWatchServer) error
ReplicaRebuildingSrcStart(context.Context, *ReplicaRebuildingSrcStartRequest) (*ReplicaRebuildingSrcStartResponse, error)
ReplicaRebuildingSrcFinish(context.Context, *ReplicaRebuildingSrcFinishRequest) (*emptypb.Empty, error)
ReplicaRebuildingSrcShallowCopyStart(context.Context, *ReplicaRebuildingSrcShallowCopyStartRequest) (*emptypb.Empty, error)
ReplicaRebuildingSrcRangeShallowCopyStart(context.Context, *ReplicaRebuildingSrcRangeShallowCopyStartRequest) (*emptypb.Empty, error)
ReplicaRebuildingSrcShallowCopyCheck(context.Context, *ReplicaRebuildingSrcShallowCopyCheckRequest) (*ReplicaRebuildingSrcShallowCopyCheckResponse, error)
ReplicaRebuildingDstStart(context.Context, *ReplicaRebuildingDstStartRequest) (*ReplicaRebuildingDstStartResponse, error)
ReplicaRebuildingDstFinish(context.Context, *ReplicaRebuildingDstFinishRequest) (*emptypb.Empty, error)
@ -965,6 +989,9 @@ func (UnimplementedSPDKServiceServer) ReplicaSnapshotHashCancel(context.Context,
func (UnimplementedSPDKServiceServer) ReplicaSnapshotHashLockState(context.Context, *SnapshotHashLockStateRequest) (*SnapshotHashLockStateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaSnapshotHashLockState not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaSnapshotRangeHashGet(context.Context, *ReplicaSnapshotRangeHashGetRequest) (*ReplicaSnapshotRangeHashGetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaSnapshotRangeHashGet not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaList(context.Context, *emptypb.Empty) (*ReplicaListResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaList not implemented")
}
@ -980,6 +1007,9 @@ func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcFinish(context.Context
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcShallowCopyStart(context.Context, *ReplicaRebuildingSrcShallowCopyStartRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingSrcShallowCopyStart not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcRangeShallowCopyStart(context.Context, *ReplicaRebuildingSrcRangeShallowCopyStartRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingSrcRangeShallowCopyStart not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcShallowCopyCheck(context.Context, *ReplicaRebuildingSrcShallowCopyCheckRequest) (*ReplicaRebuildingSrcShallowCopyCheckResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingSrcShallowCopyCheck not implemented")
}
@ -1347,6 +1377,24 @@ func _SPDKService_ReplicaSnapshotHashLockState_Handler(srv interface{}, ctx cont
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaSnapshotRangeHashGet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplicaSnapshotRangeHashGetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SPDKServiceServer).ReplicaSnapshotRangeHashGet(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SPDKService_ReplicaSnapshotRangeHashGet_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SPDKServiceServer).ReplicaSnapshotRangeHashGet(ctx, req.(*ReplicaSnapshotRangeHashGetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaList_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 {
@ -1440,6 +1488,24 @@ func _SPDKService_ReplicaRebuildingSrcShallowCopyStart_Handler(srv interface{},
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaRebuildingSrcRangeShallowCopyStart_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplicaRebuildingSrcRangeShallowCopyStartRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SPDKServiceServer).ReplicaRebuildingSrcRangeShallowCopyStart(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SPDKService_ReplicaRebuildingSrcRangeShallowCopyStart_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SPDKServiceServer).ReplicaRebuildingSrcRangeShallowCopyStart(ctx, req.(*ReplicaRebuildingSrcRangeShallowCopyStartRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaRebuildingSrcShallowCopyCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplicaRebuildingSrcShallowCopyCheckRequest)
if err := dec(in); err != nil {
@ -2433,6 +2499,10 @@ var SPDKService_ServiceDesc = grpc.ServiceDesc{
MethodName: "ReplicaSnapshotHashLockState",
Handler: _SPDKService_ReplicaSnapshotHashLockState_Handler,
},
{
MethodName: "ReplicaSnapshotRangeHashGet",
Handler: _SPDKService_ReplicaSnapshotRangeHashGet_Handler,
},
{
MethodName: "ReplicaList",
Handler: _SPDKService_ReplicaList_Handler,
@ -2449,6 +2519,10 @@ var SPDKService_ServiceDesc = grpc.ServiceDesc{
MethodName: "ReplicaRebuildingSrcShallowCopyStart",
Handler: _SPDKService_ReplicaRebuildingSrcShallowCopyStart_Handler,
},
{
MethodName: "ReplicaRebuildingSrcRangeShallowCopyStart",
Handler: _SPDKService_ReplicaRebuildingSrcRangeShallowCopyStart_Handler,
},
{
MethodName: "ReplicaRebuildingSrcShallowCopyCheck",
Handler: _SPDKService_ReplicaRebuildingSrcShallowCopyCheck_Handler,

25
protobuf/spdkrpc/spdk.proto
View File

@ -18,11 +18,13 @@ service SPDKService {
rpc ReplicaSnapshotHashStatus(SnapshotHashStatusRequest) returns (ReplicaSnapshotHashStatusResponse) {};
rpc ReplicaSnapshotHashCancel(SnapshotHashCancelRequest) returns (google.protobuf.Empty) {};
rpc ReplicaSnapshotHashLockState(SnapshotHashLockStateRequest) returns (SnapshotHashLockStateResponse) {};
rpc ReplicaSnapshotRangeHashGet(ReplicaSnapshotRangeHashGetRequest) returns (ReplicaSnapshotRangeHashGetResponse) {};
rpc ReplicaList(google.protobuf.Empty) returns (ReplicaListResponse);
rpc ReplicaWatch(google.protobuf.Empty) returns (stream google.protobuf.Empty) {}
rpc ReplicaRebuildingSrcStart(ReplicaRebuildingSrcStartRequest) returns (ReplicaRebuildingSrcStartResponse) {};
rpc ReplicaRebuildingSrcFinish(ReplicaRebuildingSrcFinishRequest) returns (google.protobuf.Empty) {};
rpc ReplicaRebuildingSrcShallowCopyStart(ReplicaRebuildingSrcShallowCopyStartRequest) returns (google.protobuf.Empty);
rpc ReplicaRebuildingSrcRangeShallowCopyStart(ReplicaRebuildingSrcRangeShallowCopyStartRequest) returns (google.protobuf.Empty);
rpc ReplicaRebuildingSrcShallowCopyCheck(ReplicaRebuildingSrcShallowCopyCheckRequest) returns (ReplicaRebuildingSrcShallowCopyCheckResponse) {};
rpc ReplicaRebuildingDstStart(ReplicaRebuildingDstStartRequest) returns (ReplicaRebuildingDstStartResponse) {};
rpc ReplicaRebuildingDstFinish(ReplicaRebuildingDstFinishRequest) returns (google.protobuf.Empty) {};
@ -163,6 +165,13 @@ message ReplicaRebuildingSrcShallowCopyStartRequest {
string dst_rebuilding_lvol_address = 3;
}
message ReplicaRebuildingSrcRangeShallowCopyStartRequest {
string name = 1;
string snapshot_name = 2;
string dst_rebuilding_lvol_address = 3;
repeated uint64 mismatching_cluster_list = 4;
}
message ReplicaRebuildingSrcShallowCopyCheckRequest {
string name = 1;
string dst_replica_name = 2;
@ -171,9 +180,12 @@ message ReplicaRebuildingSrcShallowCopyCheckRequest {
message ReplicaRebuildingSrcShallowCopyCheckResponse {
string state = 1;
uint64 copied_clusters = 2;
uint64 total_clusters = 3;
string error_msg = 4;
uint64 handled_clusters = 5;
// copied_clusters is deprecated and replaced by handled_clusters.
uint64 copied_clusters = 2;
}
message ReplicaRebuildingDstStartRequest {
@ -361,6 +373,17 @@ message SnapshotHashLockStateRequest {
string name = 1;
}
message ReplicaSnapshotRangeHashGetRequest {
string name = 1;
string snapshot_name = 2;
uint64 cluster_start_index = 3;
uint64 cluster_count = 4;
}
message ReplicaSnapshotRangeHashGetResponse {
map<uint64, uint64> range_hash_map = 1;
}
message SnapshotHashLockStateResponse {
bool is_locked = 1;
}