Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add methods and messages for v2 volume live upgrade #7

Merged
merged 1 commit into from
Jul 3, 2024
Merged

Add methods and messages for v2 volume live upgrade #7

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
80 changes: 44 additions & 36 deletions generated-py/imrpc/instance_pb2.py
View file
Open in desktop

Large diffs are not rendered by default.

132 changes: 132 additions & 0 deletions generated-py/imrpc/instance_pb2_grpc.py
View file
Open in desktop
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
Open in desktop

Large diffs are not rendered by default.

132 changes: 132 additions & 0 deletions generated-py/spdkrpc/spdk_pb2_grpc.py
View file
Open in desktop
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