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

(chore): run generate_grpc 

longhorn/longhorn-6613

Signed-off-by: Chin-Ya Huang <chin-ya.huang@suse.com>
This commit is contained in:
Chin-Ya Huang 2024-08-26 10:26:25 +08:00 committed by Derek Su
parent a08eedd4c1
commit af8f10eb57
8 changed files with 1108 additions and 1400 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
generated-py/imrpc/proxy_pb2.py
View File

File diff suppressed because one or more lines are too long

33
generated-py/imrpc/proxy_pb2_grpc.py
View File

@ -125,11 +125,6 @@ class ProxyEngineServiceStub(object):
request_serializer=imrpc_dot_proxy__pb2.ProxyEngineRequest.SerializeToString,
response_deserializer=imrpc_dot_proxy__pb2.EngineBackupRestoreStatusProxyResponse.FromString,
)
self.BackupRestoreFinish = channel.unary_unary(
'/imrpc.ProxyEngineService/BackupRestoreFinish',
request_serializer=imrpc_dot_proxy__pb2.EngineBackupRestoreFinishRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.CleanupBackupMountPoints = channel.unary_unary(
'/imrpc.ProxyEngineService/CleanupBackupMountPoints',
request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
@ -312,12 +307,6 @@ class ProxyEngineServiceServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def BackupRestoreFinish(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 CleanupBackupMountPoints(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -485,11 +474,6 @@ def add_ProxyEngineServiceServicer_to_server(servicer, server):
request_deserializer=imrpc_dot_proxy__pb2.ProxyEngineRequest.FromString,
response_serializer=imrpc_dot_proxy__pb2.EngineBackupRestoreStatusProxyResponse.SerializeToString,
),
'BackupRestoreFinish': grpc.unary_unary_rpc_method_handler(
servicer.BackupRestoreFinish,
request_deserializer=imrpc_dot_proxy__pb2.EngineBackupRestoreFinishRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'CleanupBackupMountPoints': grpc.unary_unary_rpc_method_handler(
servicer.CleanupBackupMountPoints,
request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
@ -919,23 +903,6 @@ class ProxyEngineService(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def BackupRestoreFinish(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, '/imrpc.ProxyEngineService/BackupRestoreFinish',
imrpc_dot_proxy__pb2.EngineBackupRestoreFinishRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def CleanupBackupMountPoints(request,
target,

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

File diff suppressed because one or more lines are too long

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

@ -235,11 +235,6 @@ class SPDKServiceStub(object):
request_serializer=spdkrpc_dot_spdk__pb2.EngineBackupRestoreRequest.SerializeToString,
response_deserializer=spdkrpc_dot_spdk__pb2.EngineBackupRestoreResponse.FromString,
)
self.EngineBackupRestoreFinish = channel.unary_unary(
'/spdkrpc.SPDKService/EngineBackupRestoreFinish',
request_serializer=spdkrpc_dot_spdk__pb2.EngineBackupRestoreFinishRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.EngineRestoreStatus = channel.unary_unary(
'/spdkrpc.SPDKService/EngineRestoreStatus',
request_serializer=spdkrpc_dot_spdk__pb2.RestoreStatusRequest.SerializeToString,
@ -554,12 +549,6 @@ class SPDKServiceServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def EngineBackupRestoreFinish(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 EngineRestoreStatus(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -837,11 +826,6 @@ def add_SPDKServiceServicer_to_server(servicer, server):
request_deserializer=spdkrpc_dot_spdk__pb2.EngineBackupRestoreRequest.FromString,
response_serializer=spdkrpc_dot_spdk__pb2.EngineBackupRestoreResponse.SerializeToString,
),
'EngineBackupRestoreFinish': grpc.unary_unary_rpc_method_handler(
servicer.EngineBackupRestoreFinish,
request_deserializer=spdkrpc_dot_spdk__pb2.EngineBackupRestoreFinishRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'EngineRestoreStatus': grpc.unary_unary_rpc_method_handler(
servicer.EngineRestoreStatus,
request_deserializer=spdkrpc_dot_spdk__pb2.RestoreStatusRequest.FromString,
@ -1645,23 +1629,6 @@ class SPDKService(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def EngineBackupRestoreFinish(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/EngineBackupRestoreFinish',
spdkrpc_dot_spdk__pb2.EngineBackupRestoreFinishRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def EngineRestoreStatus(request,
target,

1044
pkg/generated/imrpc/proxy.pb.go
View File

File diff suppressed because it is too large Load Diff

37
pkg/generated/imrpc/proxy_grpc.pb.go
View File

@ -42,7 +42,6 @@ const (
ProxyEngineService_SnapshotBackupStatus_FullMethodName = "/imrpc.ProxyEngineService/SnapshotBackupStatus"
ProxyEngineService_BackupRestore_FullMethodName = "/imrpc.ProxyEngineService/BackupRestore"
ProxyEngineService_BackupRestoreStatus_FullMethodName = "/imrpc.ProxyEngineService/BackupRestoreStatus"
ProxyEngineService_BackupRestoreFinish_FullMethodName = "/imrpc.ProxyEngineService/BackupRestoreFinish"
ProxyEngineService_CleanupBackupMountPoints_FullMethodName = "/imrpc.ProxyEngineService/CleanupBackupMountPoints"
ProxyEngineService_ReplicaAdd_FullMethodName = "/imrpc.ProxyEngineService/ReplicaAdd"
ProxyEngineService_ReplicaList_FullMethodName = "/imrpc.ProxyEngineService/ReplicaList"
@ -80,7 +79,6 @@ type ProxyEngineServiceClient interface {
SnapshotBackupStatus(ctx context.Context, in *EngineSnapshotBackupStatusRequest, opts ...grpc.CallOption) (*EngineSnapshotBackupStatusProxyResponse, error)
BackupRestore(ctx context.Context, in *EngineBackupRestoreRequest, opts ...grpc.CallOption) (*EngineBackupRestoreProxyResponse, error)
BackupRestoreStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineBackupRestoreStatusProxyResponse, error)
BackupRestoreFinish(ctx context.Context, in *EngineBackupRestoreFinishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
CleanupBackupMountPoints(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaAdd(ctx context.Context, in *EngineReplicaAddRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReplicaList(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineReplicaListProxyResponse, error)
@ -298,15 +296,6 @@ func (c *proxyEngineServiceClient) BackupRestoreStatus(ctx context.Context, in *
return out, nil
}
func (c *proxyEngineServiceClient) BackupRestoreFinish(ctx context.Context, in *EngineBackupRestoreFinishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, ProxyEngineService_BackupRestoreFinish_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *proxyEngineServiceClient) CleanupBackupMountPoints(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, ProxyEngineService_CleanupBackupMountPoints_FullMethodName, in, out, opts...)
@ -414,7 +403,6 @@ type ProxyEngineServiceServer interface {
SnapshotBackupStatus(context.Context, *EngineSnapshotBackupStatusRequest) (*EngineSnapshotBackupStatusProxyResponse, error)
BackupRestore(context.Context, *EngineBackupRestoreRequest) (*EngineBackupRestoreProxyResponse, error)
BackupRestoreStatus(context.Context, *ProxyEngineRequest) (*EngineBackupRestoreStatusProxyResponse, error)
BackupRestoreFinish(context.Context, *EngineBackupRestoreFinishRequest) (*emptypb.Empty, error)
CleanupBackupMountPoints(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
ReplicaAdd(context.Context, *EngineReplicaAddRequest) (*emptypb.Empty, error)
ReplicaList(context.Context, *ProxyEngineRequest) (*EngineReplicaListProxyResponse, error)
@ -497,9 +485,6 @@ func (UnimplementedProxyEngineServiceServer) BackupRestore(context.Context, *Eng
func (UnimplementedProxyEngineServiceServer) BackupRestoreStatus(context.Context, *ProxyEngineRequest) (*EngineBackupRestoreStatusProxyResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method BackupRestoreStatus not implemented")
}
func (UnimplementedProxyEngineServiceServer) BackupRestoreFinish(context.Context, *EngineBackupRestoreFinishRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method BackupRestoreFinish not implemented")
}
func (UnimplementedProxyEngineServiceServer) CleanupBackupMountPoints(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CleanupBackupMountPoints not implemented")
}
@ -936,24 +921,6 @@ func _ProxyEngineService_BackupRestoreStatus_Handler(srv interface{}, ctx contex
return interceptor(ctx, in, info, handler)
}
func _ProxyEngineService_BackupRestoreFinish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EngineBackupRestoreFinishRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ProxyEngineServiceServer).BackupRestoreFinish(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: ProxyEngineService_BackupRestoreFinish_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ProxyEngineServiceServer).BackupRestoreFinish(ctx, req.(*EngineBackupRestoreFinishRequest))
}
return interceptor(ctx, in, info, handler)
}
func _ProxyEngineService_CleanupBackupMountPoints_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 {
@ -1211,10 +1178,6 @@ var ProxyEngineService_ServiceDesc = grpc.ServiceDesc{
MethodName: "BackupRestoreStatus",
Handler: _ProxyEngineService_BackupRestoreStatus_Handler,
},
{
MethodName: "BackupRestoreFinish",
Handler: _ProxyEngineService_BackupRestoreFinish_Handler,
},
{
MethodName: "CleanupBackupMountPoints",
Handler: _ProxyEngineService_CleanupBackupMountPoints_Handler,

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

File diff suppressed because it is too large Load Diff

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

@ -64,7 +64,6 @@ const (
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_DiskCreate_FullMethodName = "/spdkrpc.SPDKService/DiskCreate"
SPDKService_DiskDelete_FullMethodName = "/spdkrpc.SPDKService/DiskDelete"
@ -124,7 +123,6 @@ type SPDKServiceClient interface {
EngineBackupCreate(ctx context.Context, in *BackupCreateRequest, opts ...grpc.CallOption) (*BackupCreateResponse, error)
EngineBackupStatus(ctx context.Context, in *BackupStatusRequest, opts ...grpc.CallOption) (*BackupStatusResponse, error)
EngineBackupRestore(ctx context.Context, in *EngineBackupRestoreRequest, opts ...grpc.CallOption) (*EngineBackupRestoreResponse, error)
EngineBackupRestoreFinish(ctx context.Context, in *EngineBackupRestoreFinishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
EngineRestoreStatus(ctx context.Context, in *RestoreStatusRequest, opts ...grpc.CallOption) (*RestoreStatusResponse, error)
DiskCreate(ctx context.Context, in *DiskCreateRequest, opts ...grpc.CallOption) (*Disk, error)
DiskDelete(ctx context.Context, in *DiskDeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
@ -586,15 +584,6 @@ func (c *sPDKServiceClient) EngineBackupRestore(ctx context.Context, in *EngineB
return out, nil
}
func (c *sPDKServiceClient) EngineBackupRestoreFinish(ctx context.Context, in *EngineBackupRestoreFinishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, SPDKService_EngineBackupRestoreFinish_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *sPDKServiceClient) EngineRestoreStatus(ctx context.Context, in *RestoreStatusRequest, opts ...grpc.CallOption) (*RestoreStatusResponse, error) {
out := new(RestoreStatusResponse)
err := c.cc.Invoke(ctx, SPDKService_EngineRestoreStatus_FullMethodName, in, out, opts...)
@ -724,7 +713,6 @@ type SPDKServiceServer interface {
EngineBackupCreate(context.Context, *BackupCreateRequest) (*BackupCreateResponse, error)
EngineBackupStatus(context.Context, *BackupStatusRequest) (*BackupStatusResponse, error)
EngineBackupRestore(context.Context, *EngineBackupRestoreRequest) (*EngineBackupRestoreResponse, error)
EngineBackupRestoreFinish(context.Context, *EngineBackupRestoreFinishRequest) (*emptypb.Empty, error)
EngineRestoreStatus(context.Context, *RestoreStatusRequest) (*RestoreStatusResponse, error)
DiskCreate(context.Context, *DiskCreateRequest) (*Disk, error)
DiskDelete(context.Context, *DiskDeleteRequest) (*emptypb.Empty, error)
@ -873,9 +861,6 @@ func (UnimplementedSPDKServiceServer) EngineBackupStatus(context.Context, *Backu
func (UnimplementedSPDKServiceServer) EngineBackupRestore(context.Context, *EngineBackupRestoreRequest) (*EngineBackupRestoreResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method EngineBackupRestore not implemented")
}
func (UnimplementedSPDKServiceServer) EngineBackupRestoreFinish(context.Context, *EngineBackupRestoreFinishRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method EngineBackupRestoreFinish not implemented")
}
func (UnimplementedSPDKServiceServer) EngineRestoreStatus(context.Context, *RestoreStatusRequest) (*RestoreStatusResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method EngineRestoreStatus not implemented")
}
@ -1714,24 +1699,6 @@ func _SPDKService_EngineBackupRestore_Handler(srv interface{}, ctx context.Conte
return interceptor(ctx, in, info, handler)
}
func _SPDKService_EngineBackupRestoreFinish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EngineBackupRestoreFinishRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SPDKServiceServer).EngineBackupRestoreFinish(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SPDKService_EngineBackupRestoreFinish_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SPDKServiceServer).EngineBackupRestoreFinish(ctx, req.(*EngineBackupRestoreFinishRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SPDKService_EngineRestoreStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RestoreStatusRequest)
if err := dec(in); err != nil {
@ -2069,10 +2036,6 @@ var SPDKService_ServiceDesc = grpc.ServiceDesc{
MethodName: "EngineBackupRestore",
Handler: _SPDKService_EngineBackupRestore_Handler,
},
{
MethodName: "EngineBackupRestoreFinish",
Handler: _SPDKService_EngineBackupRestoreFinish_Handler,
},
{
MethodName: "EngineRestoreStatus",
Handler: _SPDKService_EngineRestoreStatus_Handler,