Skip to content

Commit

Permalink
Add methods and messages 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 Jul 3, 2024
1 parent 949485b commit 3d18ca1
Show file tree
Hide file tree
Showing 711 changed files with 392,803 additions and 1,166 deletions.
80 changes: 44 additions & 36 deletions generated-py/imrpc/instance_pb2.py
View file

Large diffs are not rendered by default.

132 changes: 132 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,26 @@ 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.InstanceSwitchOverTarget = channel.unary_unary(
'/imrpc.InstanceService/InstanceSwitchOverTarget',
request_serializer=imrpc_dot_instance__pb2.InstanceSwitchOverTargetRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.InstanceDeleteTarget = channel.unary_unary(
'/imrpc.InstanceService/InstanceDeleteTarget',
request_serializer=imrpc_dot_instance__pb2.InstanceDeleteTargetRequest.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 +143,30 @@ 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 InstanceSwitchOverTarget(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 InstanceDeleteTarget(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 +235,26 @@ 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,
),
'InstanceSwitchOverTarget': grpc.unary_unary_rpc_method_handler(
servicer.InstanceSwitchOverTarget,
request_deserializer=imrpc_dot_instance__pb2.InstanceSwitchOverTargetRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'InstanceDeleteTarget': grpc.unary_unary_rpc_method_handler(
servicer.InstanceDeleteTarget,
request_deserializer=imrpc_dot_instance__pb2.InstanceDeleteTargetRequest.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 +409,74 @@ 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 InstanceSwitchOverTarget(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/InstanceSwitchOverTarget',
imrpc_dot_instance__pb2.InstanceSwitchOverTargetRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def InstanceDeleteTarget(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/InstanceDeleteTarget',
imrpc_dot_instance__pb2.InstanceDeleteTargetRequest.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
184 changes: 96 additions & 88 deletions generated-py/spdkrpc/spdk_pb2.py
View file

Large diffs are not rendered by default.

132 changes: 132 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,26 @@ 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.EngineSwitchOverTarget = channel.unary_unary(
'/spdkrpc.SPDKService/EngineSwitchOverTarget',
request_serializer=spdkrpc_dot_spdk__pb2.EngineSwitchOverTargetRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
)
self.EngineDeleteTarget = channel.unary_unary(
'/spdkrpc.SPDKService/EngineDeleteTarget',
request_serializer=spdkrpc_dot_spdk__pb2.EngineDeleteTargetRequest.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 +409,30 @@ 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 EngineSwitchOverTarget(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 EngineDeleteTarget(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 +682,26 @@ 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,
),
'EngineSwitchOverTarget': grpc.unary_unary_rpc_method_handler(
servicer.EngineSwitchOverTarget,
request_deserializer=spdkrpc_dot_spdk__pb2.EngineSwitchOverTargetRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
),
'EngineDeleteTarget': grpc.unary_unary_rpc_method_handler(
servicer.EngineDeleteTarget,
request_deserializer=spdkrpc_dot_spdk__pb2.EngineDeleteTargetRequest.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 +1225,74 @@ 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 EngineSwitchOverTarget(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/EngineSwitchOverTarget',
spdkrpc_dot_spdk__pb2.EngineSwitchOverTargetRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def EngineDeleteTarget(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/EngineDeleteTarget',
spdkrpc_dot_spdk__pb2.EngineDeleteTargetRequest.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 3d18ca1

Please sign in to comment.