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

refactor: modify spdkrpc rebuilding related APIs 

Longhorn 9488

Signed-off-by: Shuo Wu <shuo.wu@suse.com>
This commit is contained in:
Shuo Wu 2024-11-14 01:36:54 +00:00 committed by Derek Su
parent 2e0ecb487c
commit 0d566342b5
5 changed files with 1388 additions and 1947 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

File diff suppressed because one or more lines are too long

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

@ -70,20 +70,10 @@ class SPDKServiceStub(object):
request_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcFinishRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.ReplicaRebuildingSrcAttach = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaRebuildingSrcAttach',
request_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcAttachRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.ReplicaRebuildingSrcDetach = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaRebuildingSrcDetach',
request_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcDetachRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.ReplicaRebuildingSrcShallowCopyStart = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyStart',
request_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyStartRequest.SerializeToString,
response_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyStartResponse.FromString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.ReplicaRebuildingSrcShallowCopyCheck = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyCheck',
@ -115,11 +105,6 @@ class SPDKServiceStub(object):
request_serializer=spdkrpc_dot_spdk__pb2.SnapshotRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.ReplicaRebuildingDstSnapshotRevert = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaRebuildingDstSnapshotRevert',
request_serializer=spdkrpc_dot_spdk__pb2.SnapshotRequest.SerializeToString,
response_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingDstSnapshotRevertResponse.FromString,
)
self.ReplicaBackupCreate = channel.unary_unary(
'/spdkrpc.SPDKService/ReplicaBackupCreate',
request_serializer=spdkrpc_dot_spdk__pb2.BackupCreateRequest.SerializeToString,
@ -391,18 +376,6 @@ class SPDKServiceServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ReplicaRebuildingSrcAttach(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 ReplicaRebuildingSrcDetach(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 ReplicaRebuildingSrcShallowCopyStart(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -445,12 +418,6 @@ class SPDKServiceServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ReplicaRebuildingDstSnapshotRevert(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 ReplicaBackupCreate(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -749,20 +716,10 @@ def add_SPDKServiceServicer_to_server(servicer, server):
request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcFinishRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'ReplicaRebuildingSrcAttach': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaRebuildingSrcAttach,
request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcAttachRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'ReplicaRebuildingSrcDetach': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaRebuildingSrcDetach,
request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcDetachRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'ReplicaRebuildingSrcShallowCopyStart': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaRebuildingSrcShallowCopyStart,
request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyStartRequest.FromString,
response_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyStartResponse.SerializeToString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'ReplicaRebuildingSrcShallowCopyCheck': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaRebuildingSrcShallowCopyCheck,
@ -794,11 +751,6 @@ def add_SPDKServiceServicer_to_server(servicer, server):
request_deserializer=spdkrpc_dot_spdk__pb2.SnapshotRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'ReplicaRebuildingDstSnapshotRevert': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaRebuildingDstSnapshotRevert,
request_deserializer=spdkrpc_dot_spdk__pb2.SnapshotRequest.FromString,
response_serializer=spdkrpc_dot_spdk__pb2.ReplicaRebuildingDstSnapshotRevertResponse.SerializeToString,
),
'ReplicaBackupCreate': grpc.unary_unary_rpc_method_handler(
servicer.ReplicaBackupCreate,
request_deserializer=spdkrpc_dot_spdk__pb2.BackupCreateRequest.FromString,
@ -1196,40 +1148,6 @@ class SPDKService(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaRebuildingSrcAttach(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/ReplicaRebuildingSrcAttach',
spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcAttachRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaRebuildingSrcDetach(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/ReplicaRebuildingSrcDetach',
spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcDetachRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaRebuildingSrcShallowCopyStart(request,
target,
@ -1243,7 +1161,7 @@ class SPDKService(object):
metadata=None):
return grpc.experimental.unary_unary(request, target, '/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyStart',
spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyStartRequest.SerializeToString,
spdkrpc_dot_spdk__pb2.ReplicaRebuildingSrcShallowCopyStartResponse.FromString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@ -1349,23 +1267,6 @@ class SPDKService(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaRebuildingDstSnapshotRevert(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/ReplicaRebuildingDstSnapshotRevert',
spdkrpc_dot_spdk__pb2.SnapshotRequest.SerializeToString,
spdkrpc_dot_spdk__pb2.ReplicaRebuildingDstSnapshotRevertResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReplicaBackupCreate(request,
target,

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

File diff suppressed because it is too large Load Diff

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

@ -31,8 +31,6 @@ const (
SPDKService_ReplicaWatch_FullMethodName = "/spdkrpc.SPDKService/ReplicaWatch"
SPDKService_ReplicaRebuildingSrcStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcStart"
SPDKService_ReplicaRebuildingSrcFinish_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcFinish"
SPDKService_ReplicaRebuildingSrcAttach_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcAttach"
SPDKService_ReplicaRebuildingSrcDetach_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcDetach"
SPDKService_ReplicaRebuildingSrcShallowCopyStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyStart"
SPDKService_ReplicaRebuildingSrcShallowCopyCheck_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingSrcShallowCopyCheck"
SPDKService_ReplicaRebuildingDstStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstStart"
@ -40,7 +38,6 @@ const (
SPDKService_ReplicaRebuildingDstShallowCopyStart_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstShallowCopyStart"
SPDKService_ReplicaRebuildingDstShallowCopyCheck_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstShallowCopyCheck"
SPDKService_ReplicaRebuildingDstSnapshotCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstSnapshotCreate"
SPDKService_ReplicaRebuildingDstSnapshotRevert_FullMethodName = "/spdkrpc.SPDKService/ReplicaRebuildingDstSnapshotRevert"
SPDKService_ReplicaBackupCreate_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupCreate"
SPDKService_ReplicaBackupStatus_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupStatus"
SPDKService_ReplicaBackupRestore_FullMethodName = "/spdkrpc.SPDKService/ReplicaBackupRestore"
@ -98,16 +95,13 @@ type SPDKServiceClient interface {
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)
ReplicaRebuildingSrcAttach(ctx context.Context, in *ReplicaRebuildingSrcAttachRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaRebuildingSrcDetach(ctx context.Context, in *ReplicaRebuildingSrcDetachRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaRebuildingSrcShallowCopyStart(ctx context.Context, in *ReplicaRebuildingSrcShallowCopyStartRequest, opts ...grpc.CallOption) (*ReplicaRebuildingSrcShallowCopyStartResponse, error)
ReplicaRebuildingSrcShallowCopyStart(ctx context.Context, in *ReplicaRebuildingSrcShallowCopyStartRequest, 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)
ReplicaRebuildingDstShallowCopyStart(ctx context.Context, in *ReplicaRebuildingDstShallowCopyStartRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaRebuildingDstShallowCopyCheck(ctx context.Context, in *ReplicaRebuildingDstShallowCopyCheckRequest, opts ...grpc.CallOption) (*ReplicaRebuildingDstShallowCopyCheckResponse, error)
ReplicaRebuildingDstSnapshotCreate(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaRebuildingDstSnapshotRevert(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*ReplicaRebuildingDstSnapshotRevertResponse, error)
ReplicaBackupCreate(ctx context.Context, in *BackupCreateRequest, opts ...grpc.CallOption) (*BackupCreateResponse, error)
ReplicaBackupStatus(ctx context.Context, in *BackupStatusRequest, opts ...grpc.CallOption) (*BackupStatusResponse, error)
ReplicaBackupRestore(ctx context.Context, in *ReplicaBackupRestoreRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
@ -280,26 +274,8 @@ func (c *sPDKServiceClient) ReplicaRebuildingSrcFinish(ctx context.Context, in *
return out, nil
}
func (c *sPDKServiceClient) ReplicaRebuildingSrcAttach(ctx context.Context, in *ReplicaRebuildingSrcAttachRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
func (c *sPDKServiceClient) ReplicaRebuildingSrcShallowCopyStart(ctx context.Context, in *ReplicaRebuildingSrcShallowCopyStartRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, SPDKService_ReplicaRebuildingSrcAttach_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *sPDKServiceClient) ReplicaRebuildingSrcDetach(ctx context.Context, in *ReplicaRebuildingSrcDetachRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, SPDKService_ReplicaRebuildingSrcDetach_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *sPDKServiceClient) ReplicaRebuildingSrcShallowCopyStart(ctx context.Context, in *ReplicaRebuildingSrcShallowCopyStartRequest, opts ...grpc.CallOption) (*ReplicaRebuildingSrcShallowCopyStartResponse, error) {
out := new(ReplicaRebuildingSrcShallowCopyStartResponse)
err := c.cc.Invoke(ctx, SPDKService_ReplicaRebuildingSrcShallowCopyStart_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
@ -361,15 +337,6 @@ func (c *sPDKServiceClient) ReplicaRebuildingDstSnapshotCreate(ctx context.Conte
return out, nil
}
func (c *sPDKServiceClient) ReplicaRebuildingDstSnapshotRevert(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*ReplicaRebuildingDstSnapshotRevertResponse, error) {
out := new(ReplicaRebuildingDstSnapshotRevertResponse)
err := c.cc.Invoke(ctx, SPDKService_ReplicaRebuildingDstSnapshotRevert_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *sPDKServiceClient) ReplicaBackupCreate(ctx context.Context, in *BackupCreateRequest, opts ...grpc.CallOption) (*BackupCreateResponse, error) {
out := new(BackupCreateResponse)
err := c.cc.Invoke(ctx, SPDKService_ReplicaBackupCreate_FullMethodName, in, out, opts...)
@ -791,16 +758,13 @@ type SPDKServiceServer interface {
ReplicaWatch(*emptypb.Empty, SPDKService_ReplicaWatchServer) error
ReplicaRebuildingSrcStart(context.Context, *ReplicaRebuildingSrcStartRequest) (*ReplicaRebuildingSrcStartResponse, error)
ReplicaRebuildingSrcFinish(context.Context, *ReplicaRebuildingSrcFinishRequest) (*emptypb.Empty, error)
ReplicaRebuildingSrcAttach(context.Context, *ReplicaRebuildingSrcAttachRequest) (*emptypb.Empty, error)
ReplicaRebuildingSrcDetach(context.Context, *ReplicaRebuildingSrcDetachRequest) (*emptypb.Empty, error)
ReplicaRebuildingSrcShallowCopyStart(context.Context, *ReplicaRebuildingSrcShallowCopyStartRequest) (*ReplicaRebuildingSrcShallowCopyStartResponse, error)
ReplicaRebuildingSrcShallowCopyStart(context.Context, *ReplicaRebuildingSrcShallowCopyStartRequest) (*emptypb.Empty, error)
ReplicaRebuildingSrcShallowCopyCheck(context.Context, *ReplicaRebuildingSrcShallowCopyCheckRequest) (*ReplicaRebuildingSrcShallowCopyCheckResponse, error)
ReplicaRebuildingDstStart(context.Context, *ReplicaRebuildingDstStartRequest) (*ReplicaRebuildingDstStartResponse, error)
ReplicaRebuildingDstFinish(context.Context, *ReplicaRebuildingDstFinishRequest) (*emptypb.Empty, error)
ReplicaRebuildingDstShallowCopyStart(context.Context, *ReplicaRebuildingDstShallowCopyStartRequest) (*emptypb.Empty, error)
ReplicaRebuildingDstShallowCopyCheck(context.Context, *ReplicaRebuildingDstShallowCopyCheckRequest) (*ReplicaRebuildingDstShallowCopyCheckResponse, error)
ReplicaRebuildingDstSnapshotCreate(context.Context, *SnapshotRequest) (*emptypb.Empty, error)
ReplicaRebuildingDstSnapshotRevert(context.Context, *SnapshotRequest) (*ReplicaRebuildingDstSnapshotRevertResponse, error)
ReplicaBackupCreate(context.Context, *BackupCreateRequest) (*BackupCreateResponse, error)
ReplicaBackupStatus(context.Context, *BackupStatusRequest) (*BackupStatusResponse, error)
ReplicaBackupRestore(context.Context, *ReplicaBackupRestoreRequest) (*emptypb.Empty, error)
@ -881,13 +845,7 @@ func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcStart(context.Context,
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcFinish(context.Context, *ReplicaRebuildingSrcFinishRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingSrcFinish not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcAttach(context.Context, *ReplicaRebuildingSrcAttachRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingSrcAttach not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcDetach(context.Context, *ReplicaRebuildingSrcDetachRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingSrcDetach not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcShallowCopyStart(context.Context, *ReplicaRebuildingSrcShallowCopyStartRequest) (*ReplicaRebuildingSrcShallowCopyStartResponse, error) {
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcShallowCopyStart(context.Context, *ReplicaRebuildingSrcShallowCopyStartRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingSrcShallowCopyStart not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaRebuildingSrcShallowCopyCheck(context.Context, *ReplicaRebuildingSrcShallowCopyCheckRequest) (*ReplicaRebuildingSrcShallowCopyCheckResponse, error) {
@ -908,9 +866,6 @@ func (UnimplementedSPDKServiceServer) ReplicaRebuildingDstShallowCopyCheck(conte
func (UnimplementedSPDKServiceServer) ReplicaRebuildingDstSnapshotCreate(context.Context, *SnapshotRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingDstSnapshotCreate not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaRebuildingDstSnapshotRevert(context.Context, *SnapshotRequest) (*ReplicaRebuildingDstSnapshotRevertResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaRebuildingDstSnapshotRevert not implemented")
}
func (UnimplementedSPDKServiceServer) ReplicaBackupCreate(context.Context, *BackupCreateRequest) (*BackupCreateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplicaBackupCreate not implemented")
}
@ -1245,42 +1200,6 @@ func _SPDKService_ReplicaRebuildingSrcFinish_Handler(srv interface{}, ctx contex
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaRebuildingSrcAttach_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplicaRebuildingSrcAttachRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SPDKServiceServer).ReplicaRebuildingSrcAttach(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SPDKService_ReplicaRebuildingSrcAttach_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SPDKServiceServer).ReplicaRebuildingSrcAttach(ctx, req.(*ReplicaRebuildingSrcAttachRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaRebuildingSrcDetach_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplicaRebuildingSrcDetachRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SPDKServiceServer).ReplicaRebuildingSrcDetach(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SPDKService_ReplicaRebuildingSrcDetach_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SPDKServiceServer).ReplicaRebuildingSrcDetach(ctx, req.(*ReplicaRebuildingSrcDetachRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaRebuildingSrcShallowCopyStart_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplicaRebuildingSrcShallowCopyStartRequest)
if err := dec(in); err != nil {
@ -1407,24 +1326,6 @@ func _SPDKService_ReplicaRebuildingDstSnapshotCreate_Handler(srv interface{}, ct
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaRebuildingDstSnapshotRevert_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SnapshotRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SPDKServiceServer).ReplicaRebuildingDstSnapshotRevert(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SPDKService_ReplicaRebuildingDstSnapshotRevert_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SPDKServiceServer).ReplicaRebuildingDstSnapshotRevert(ctx, req.(*SnapshotRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SPDKService_ReplicaBackupCreate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(BackupCreateRequest)
if err := dec(in); err != nil {
@ -2198,14 +2099,6 @@ var SPDKService_ServiceDesc = grpc.ServiceDesc{
MethodName: "ReplicaRebuildingSrcFinish",
Handler: _SPDKService_ReplicaRebuildingSrcFinish_Handler,
},
{
MethodName: "ReplicaRebuildingSrcAttach",
Handler: _SPDKService_ReplicaRebuildingSrcAttach_Handler,
},
{
MethodName: "ReplicaRebuildingSrcDetach",
Handler: _SPDKService_ReplicaRebuildingSrcDetach_Handler,
},
{
MethodName: "ReplicaRebuildingSrcShallowCopyStart",
Handler: _SPDKService_ReplicaRebuildingSrcShallowCopyStart_Handler,
@ -2234,10 +2127,6 @@ var SPDKService_ServiceDesc = grpc.ServiceDesc{
MethodName: "ReplicaRebuildingDstSnapshotCreate",
Handler: _SPDKService_ReplicaRebuildingDstSnapshotCreate_Handler,
},
{
MethodName: "ReplicaRebuildingDstSnapshotRevert",
Handler: _SPDKService_ReplicaRebuildingDstSnapshotRevert_Handler,
},
{
MethodName: "ReplicaBackupCreate",
Handler: _SPDKService_ReplicaBackupCreate_Handler,

26
protobuf/spdkrpc/spdk.proto
View File

@ -18,16 +18,13 @@ service SPDKService {
rpc ReplicaWatch(google.protobuf.Empty) returns (stream google.protobuf.Empty) {}
rpc ReplicaRebuildingSrcStart(ReplicaRebuildingSrcStartRequest) returns (ReplicaRebuildingSrcStartResponse) {};
rpc ReplicaRebuildingSrcFinish(ReplicaRebuildingSrcFinishRequest) returns (google.protobuf.Empty) {};
rpc ReplicaRebuildingSrcAttach(ReplicaRebuildingSrcAttachRequest) returns (google.protobuf.Empty) {};
rpc ReplicaRebuildingSrcDetach(ReplicaRebuildingSrcDetachRequest) returns (google.protobuf.Empty) {};
rpc ReplicaRebuildingSrcShallowCopyStart(ReplicaRebuildingSrcShallowCopyStartRequest) returns (ReplicaRebuildingSrcShallowCopyStartResponse);
rpc ReplicaRebuildingSrcShallowCopyStart(ReplicaRebuildingSrcShallowCopyStartRequest) returns (google.protobuf.Empty);
rpc ReplicaRebuildingSrcShallowCopyCheck(ReplicaRebuildingSrcShallowCopyCheckRequest) returns (ReplicaRebuildingSrcShallowCopyCheckResponse) {};
rpc ReplicaRebuildingDstStart(ReplicaRebuildingDstStartRequest) returns (ReplicaRebuildingDstStartResponse) {};
rpc ReplicaRebuildingDstFinish(ReplicaRebuildingDstFinishRequest) returns (google.protobuf.Empty) {};
rpc ReplicaRebuildingDstShallowCopyStart(ReplicaRebuildingDstShallowCopyStartRequest) returns (google.protobuf.Empty);
rpc ReplicaRebuildingDstShallowCopyCheck(ReplicaRebuildingDstShallowCopyCheckRequest) returns (ReplicaRebuildingDstShallowCopyCheckResponse) {};
rpc ReplicaRebuildingDstSnapshotCreate(SnapshotRequest) returns (google.protobuf.Empty);
rpc ReplicaRebuildingDstSnapshotRevert(SnapshotRequest) returns (ReplicaRebuildingDstSnapshotRevertResponse) {};
rpc ReplicaBackupCreate(BackupCreateRequest) returns (BackupCreateResponse) {}
rpc ReplicaBackupStatus(BackupStatusRequest) returns (BackupStatusResponse) {}
rpc ReplicaBackupRestore(ReplicaBackupRestoreRequest) returns (google.protobuf.Empty) {}
@ -148,31 +145,16 @@ message ReplicaRebuildingSrcFinishRequest {
string dst_replica_name = 2;
}
message ReplicaRebuildingSrcAttachRequest {
string name = 1;
string dst_replica_name = 2;
string dst_rebuilding_lvol_address = 3;
}
message ReplicaRebuildingSrcDetachRequest {
string name = 1;
string dst_replica_name = 2;
}
message ReplicaRebuildingSrcShallowCopyStartRequest {
string name = 1;
string snapshot_name = 2;
}
message ReplicaRebuildingSrcShallowCopyStartResponse {
uint32 shallow_copy_op_id = 1;
string dst_rebuilding_lvol_address = 3;
}
message ReplicaRebuildingSrcShallowCopyCheckRequest {
string name = 1;
string dst_replica_name = 2;
string snapshot_name = 3;
uint32 shallow_copy_op_id = 4;
}
message ReplicaRebuildingSrcShallowCopyCheckResponse {
@ -219,10 +201,6 @@ message ReplicaRebuildingDstShallowCopyCheckResponse {
string error = 8;
}
message ReplicaRebuildingDstSnapshotRevertResponse {
string dst_rebuilding_lvol_address = 1;
}
message Engine {
string name = 1;
string volume_name = 2;