Skip to content

Commit

Permalink
Add methods for v2 volume live upgrade
Browse files Browse the repository at this point in the history 
Longhorn 6001

Signed-off-by: Derek Su <derek.su@suse.com>
  • Loading branch information
@derekbit
derekbit committed Jun 4, 2024
1 parent ab949bb commit 687558f
Show file tree
Hide file tree
Showing 10 changed files with 2,180 additions and 1,116 deletions.
78 changes: 42 additions & 36 deletions generated-py/imrpc/instance_pb2.py
View file

Large diffs are not rendered by default.

99 changes: 99 additions & 0 deletions generated-py/imrpc/instance_pb2_grpc.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,21 @@ def __init__(self, channel):
request_serializer=imrpc_dot_instance__pb2.InstanceReplaceRequest.SerializeToString,
response_deserializer=imrpc_dot_instance__pb2.InstanceResponse.FromString,
)
self.InstanceSuspend = channel.unary_unary(
'/imrpc.InstanceService/InstanceSuspend',
request_serializer=imrpc_dot_instance__pb2.InstanceSuspendRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.InstanceResume = channel.unary_unary(
'/imrpc.InstanceService/InstanceResume',
request_serializer=imrpc_dot_instance__pb2.InstanceResumeRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.InstanceSwitchOver = channel.unary_unary(
'/imrpc.InstanceService/InstanceSwitchOver',
request_serializer=imrpc_dot_instance__pb2.InstanceSwitchOverRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.LogSetLevel = channel.unary_unary(
'/imrpc.InstanceService/LogSetLevel',
request_serializer=imrpc_dot_instance__pb2.LogSetLevelRequest.SerializeToString,
Expand Down Expand Up @@ -123,6 +138,24 @@ def InstanceReplace(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def InstanceSuspend(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 InstanceResume(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 InstanceSwitchOver(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 LogSetLevel(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
Expand Down Expand Up @@ -191,6 +224,21 @@ def add_InstanceServiceServicer_to_server(servicer, server):
request_deserializer=imrpc_dot_instance__pb2.InstanceReplaceRequest.FromString,
response_serializer=imrpc_dot_instance__pb2.InstanceResponse.SerializeToString,
),
'InstanceSuspend': grpc.unary_unary_rpc_method_handler(
servicer.InstanceSuspend,
request_deserializer=imrpc_dot_instance__pb2.InstanceSuspendRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'InstanceResume': grpc.unary_unary_rpc_method_handler(
servicer.InstanceResume,
request_deserializer=imrpc_dot_instance__pb2.InstanceResumeRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'InstanceSwitchOver': grpc.unary_unary_rpc_method_handler(
servicer.InstanceSwitchOver,
request_deserializer=imrpc_dot_instance__pb2.InstanceSwitchOverRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'LogSetLevel': grpc.unary_unary_rpc_method_handler(
servicer.LogSetLevel,
request_deserializer=imrpc_dot_instance__pb2.LogSetLevelRequest.FromString,
Expand Down Expand Up @@ -345,6 +393,57 @@ def InstanceReplace(request,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def InstanceSuspend(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.InstanceService/InstanceSuspend',
imrpc_dot_instance__pb2.InstanceSuspendRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def InstanceResume(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.InstanceService/InstanceResume',
imrpc_dot_instance__pb2.InstanceResumeRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def InstanceSwitchOver(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.InstanceService/InstanceSwitchOver',
imrpc_dot_instance__pb2.InstanceSwitchOverRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def LogSetLevel(request,
target,
Expand Down
182 changes: 94 additions & 88 deletions generated-py/spdkrpc/spdk_pb2.py
View file

Large diffs are not rendered by default.

99 changes: 99 additions & 0 deletions generated-py/spdkrpc/spdk_pb2_grpc.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -135,6 +135,21 @@ def __init__(self, channel):
request_serializer=spdkrpc_dot_spdk__pb2.EngineGetRequest.SerializeToString,
response_deserializer=spdkrpc_dot_spdk__pb2.Engine.FromString,
)
self.EngineSuspend = channel.unary_unary(
'/spdkrpc.SPDKService/EngineSuspend',
request_serializer=spdkrpc_dot_spdk__pb2.EngineSuspendRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.EngineResume = channel.unary_unary(
'/spdkrpc.SPDKService/EngineResume',
request_serializer=spdkrpc_dot_spdk__pb2.EngineResumeRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.EngineSwitchOver = channel.unary_unary(
'/spdkrpc.SPDKService/EngineSwitchOver',
request_serializer=spdkrpc_dot_spdk__pb2.EngineSwitchOverRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.EngineSnapshotCreate = channel.unary_unary(
'/spdkrpc.SPDKService/EngineSnapshotCreate',
request_serializer=spdkrpc_dot_spdk__pb2.SnapshotRequest.SerializeToString,
Expand Down Expand Up @@ -389,6 +404,24 @@ def EngineGet(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def EngineSuspend(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 EngineResume(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 EngineSwitchOver(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 EngineSnapshotCreate(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
Expand Down Expand Up @@ -638,6 +671,21 @@ def add_SPDKServiceServicer_to_server(servicer, server):
request_deserializer=spdkrpc_dot_spdk__pb2.EngineGetRequest.FromString,
response_serializer=spdkrpc_dot_spdk__pb2.Engine.SerializeToString,
),
'EngineSuspend': grpc.unary_unary_rpc_method_handler(
servicer.EngineSuspend,
request_deserializer=spdkrpc_dot_spdk__pb2.EngineSuspendRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'EngineResume': grpc.unary_unary_rpc_method_handler(
servicer.EngineResume,
request_deserializer=spdkrpc_dot_spdk__pb2.EngineResumeRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'EngineSwitchOver': grpc.unary_unary_rpc_method_handler(
servicer.EngineSwitchOver,
request_deserializer=spdkrpc_dot_spdk__pb2.EngineSwitchOverRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'EngineSnapshotCreate': grpc.unary_unary_rpc_method_handler(
servicer.EngineSnapshotCreate,
request_deserializer=spdkrpc_dot_spdk__pb2.SnapshotRequest.FromString,
Expand Down Expand Up @@ -1161,6 +1209,57 @@ def EngineGet(request,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def EngineSuspend(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/EngineSuspend',
spdkrpc_dot_spdk__pb2.EngineSuspendRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def EngineResume(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/EngineResume',
spdkrpc_dot_spdk__pb2.EngineResumeRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def EngineSwitchOver(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/EngineSwitchOver',
spdkrpc_dot_spdk__pb2.EngineSwitchOverRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def EngineSnapshotCreate(request,
target,
Expand Down
Loading

0 comments on commit 687558f

Please sign in to comment.