+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+
+from arista.studio.v1.services import gen_pb2 as arista_dot_studio_dot_v1_dot_services_dot_gen__pb2
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ # This class is part of an EXPERIMENTAL API.
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ # This class is part of an EXPERIMENTAL API.
+
+
+
+
+
+
[docs]
+
class AutofillActionServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.AutofillActionService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamResponse.FromString,
+
)
+
[docs]
+
class AutofillActionServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
[docs]
+
def add_AutofillActionServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.AutofillActionService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class AutofillActionService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.AutofillActionService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.AutofillActionService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.AutofillActionService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
[docs]
+
class AutofillActionConfigServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.AutofillActionConfigService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamResponse.FromString,
+
)
+
self.Set = channel.unary_unary(
+
'/arista.studio.v1.AutofillActionConfigService/Set',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetResponse.FromString,
+
)
+
self.SetSome = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/SetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetSomeResponse.FromString,
+
)
+
self.Delete = channel.unary_unary(
+
'/arista.studio.v1.AutofillActionConfigService/Delete',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteResponse.FromString,
+
)
+
self.DeleteAll = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/DeleteAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteAllRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteAllResponse.FromString,
+
)
+
[docs]
+
class AutofillActionConfigServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
+
+
[docs]
+
def Set(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!')
+
+
+
+
[docs]
+
def SetSome(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!')
+
+
+
+
[docs]
+
def Delete(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!')
+
+
+
+
[docs]
+
def DeleteAll(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!')
+
+
[docs]
+
def add_AutofillActionConfigServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamResponse.SerializeToString,
+
),
+
'Set': grpc.unary_unary_rpc_method_handler(
+
servicer.Set,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetResponse.SerializeToString,
+
),
+
'SetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.SetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetSomeResponse.SerializeToString,
+
),
+
'Delete': grpc.unary_unary_rpc_method_handler(
+
servicer.Delete,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteResponse.SerializeToString,
+
),
+
'DeleteAll': grpc.unary_stream_rpc_method_handler(
+
servicer.DeleteAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteAllRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteAllResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.AutofillActionConfigService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class AutofillActionConfigService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.AutofillActionConfigService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.AutofillActionConfigService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.AutofillActionConfigService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Set(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, '/arista.studio.v1.AutofillActionConfigService/Set',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SetSome(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_stream(request, target, '/arista.studio.v1.AutofillActionConfigService/SetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSetSomeResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Delete(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, '/arista.studio.v1.AutofillActionConfigService/Delete',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def DeleteAll(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_stream(request, target, '/arista.studio.v1.AutofillActionConfigService/DeleteAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteAllRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteAllResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
[docs]
+
class StudioServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.StudioService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.StudioService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.StudioService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamResponse.FromString,
+
)
+
[docs]
+
class StudioServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
[docs]
+
def add_StudioServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.StudioService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class StudioService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.StudioService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.StudioService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.StudioService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
[docs]
+
class StudioConfigServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.StudioConfigService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamResponse.FromString,
+
)
+
self.Set = channel.unary_unary(
+
'/arista.studio.v1.StudioConfigService/Set',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetResponse.FromString,
+
)
+
self.SetSome = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/SetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetSomeResponse.FromString,
+
)
+
self.Delete = channel.unary_unary(
+
'/arista.studio.v1.StudioConfigService/Delete',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteResponse.FromString,
+
)
+
self.DeleteAll = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/DeleteAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteAllRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteAllResponse.FromString,
+
)
+
[docs]
+
class StudioConfigServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
+
+
[docs]
+
def Set(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!')
+
+
+
+
[docs]
+
def SetSome(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!')
+
+
+
+
[docs]
+
def Delete(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!')
+
+
+
+
[docs]
+
def DeleteAll(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!')
+
+
[docs]
+
def add_StudioConfigServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamResponse.SerializeToString,
+
),
+
'Set': grpc.unary_unary_rpc_method_handler(
+
servicer.Set,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetResponse.SerializeToString,
+
),
+
'SetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.SetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetSomeResponse.SerializeToString,
+
),
+
'Delete': grpc.unary_unary_rpc_method_handler(
+
servicer.Delete,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteResponse.SerializeToString,
+
),
+
'DeleteAll': grpc.unary_stream_rpc_method_handler(
+
servicer.DeleteAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteAllRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteAllResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.StudioConfigService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class StudioConfigService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.StudioConfigService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.StudioConfigService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.StudioConfigService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Set(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, '/arista.studio.v1.StudioConfigService/Set',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SetSome(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_stream(request, target, '/arista.studio.v1.StudioConfigService/SetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSetSomeResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Delete(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, '/arista.studio.v1.StudioConfigService/Delete',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def DeleteAll(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_stream(request, target, '/arista.studio.v1.StudioConfigService/DeleteAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteAllRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteAllResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
[docs]
+
class StudioSummaryServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.StudioSummaryService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.StudioSummaryService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.StudioSummaryService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamResponse.FromString,
+
)
+
[docs]
+
class StudioSummaryServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
[docs]
+
def add_StudioSummaryServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.StudioSummaryService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class StudioSummaryService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.StudioSummaryService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.StudioSummaryService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.StudioSummaryService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
[docs]
+
class TopologyUpdateServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.TopologyUpdateService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamResponse.FromString,
+
)
+
[docs]
+
class TopologyUpdateServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
[docs]
+
def add_TopologyUpdateServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.TopologyUpdateService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class TopologyUpdateService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.TopologyUpdateService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.TopologyUpdateService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.TopologyUpdateService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
[docs]
+
class TopologyUpdateConfigServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.TopologyUpdateConfigService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateConfigService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateConfigService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamResponse.FromString,
+
)
+
self.Set = channel.unary_unary(
+
'/arista.studio.v1.TopologyUpdateConfigService/Set',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetResponse.FromString,
+
)
+
self.SetSome = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateConfigService/SetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetSomeResponse.FromString,
+
)
+
self.Delete = channel.unary_unary(
+
'/arista.studio.v1.TopologyUpdateConfigService/Delete',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteResponse.FromString,
+
)
+
self.DeleteAll = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateConfigService/DeleteAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteAllRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteAllResponse.FromString,
+
)
+
[docs]
+
class TopologyUpdateConfigServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
+
+
[docs]
+
def Set(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!')
+
+
+
+
[docs]
+
def SetSome(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!')
+
+
+
+
[docs]
+
def Delete(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!')
+
+
+
+
[docs]
+
def DeleteAll(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!')
+
+
[docs]
+
def add_TopologyUpdateConfigServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamResponse.SerializeToString,
+
),
+
'Set': grpc.unary_unary_rpc_method_handler(
+
servicer.Set,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetResponse.SerializeToString,
+
),
+
'SetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.SetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetSomeResponse.SerializeToString,
+
),
+
'Delete': grpc.unary_unary_rpc_method_handler(
+
servicer.Delete,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteResponse.SerializeToString,
+
),
+
'DeleteAll': grpc.unary_stream_rpc_method_handler(
+
servicer.DeleteAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteAllRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteAllResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.TopologyUpdateConfigService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class TopologyUpdateConfigService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.TopologyUpdateConfigService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.TopologyUpdateConfigService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.TopologyUpdateConfigService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Set(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, '/arista.studio.v1.TopologyUpdateConfigService/Set',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SetSome(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_stream(request, target, '/arista.studio.v1.TopologyUpdateConfigService/SetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigSetSomeResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Delete(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, '/arista.studio.v1.TopologyUpdateConfigService/Delete',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def DeleteAll(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_stream(request, target, '/arista.studio.v1.TopologyUpdateConfigService/DeleteAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteAllRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateConfigDeleteAllResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
[docs]
+
class TopologyUpdateSyncServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.TopologyUpdateSyncService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateSyncService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateSyncService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamResponse.FromString,
+
)
+
[docs]
+
class TopologyUpdateSyncServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
[docs]
+
def add_TopologyUpdateSyncServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.TopologyUpdateSyncService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class TopologyUpdateSyncService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.TopologyUpdateSyncService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.TopologyUpdateSyncService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.TopologyUpdateSyncService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
[docs]
+
class TopologyUpdateSyncConfigServiceStub(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
def __init__(self, channel):
+
"""Constructor.
+
+
Args:
+
channel: A grpc.Channel.
+
"""
+
self.GetOne = channel.unary_unary(
+
'/arista.studio.v1.TopologyUpdateSyncConfigService/GetOne',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigResponse.FromString,
+
)
+
self.GetAll = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateSyncConfigService/GetAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamResponse.FromString,
+
)
+
self.Subscribe = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateSyncConfigService/Subscribe',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamResponse.FromString,
+
)
+
self.Set = channel.unary_unary(
+
'/arista.studio.v1.TopologyUpdateSyncConfigService/Set',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetResponse.FromString,
+
)
+
self.SetSome = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateSyncConfigService/SetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetSomeResponse.FromString,
+
)
+
self.Delete = channel.unary_unary(
+
'/arista.studio.v1.TopologyUpdateSyncConfigService/Delete',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteResponse.FromString,
+
)
+
self.DeleteAll = channel.unary_stream(
+
'/arista.studio.v1.TopologyUpdateSyncConfigService/DeleteAll',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteAllRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteAllResponse.FromString,
+
)
+
[docs]
+
class TopologyUpdateSyncConfigServiceServicer(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
def GetOne(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!')
+
+
+
+
[docs]
+
def GetAll(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!')
+
+
+
+
[docs]
+
def Subscribe(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!')
+
+
+
+
[docs]
+
def Set(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!')
+
+
+
+
[docs]
+
def SetSome(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!')
+
+
+
+
[docs]
+
def Delete(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!')
+
+
+
+
[docs]
+
def DeleteAll(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!')
+
+
[docs]
+
def add_TopologyUpdateSyncConfigServiceServicer_to_server(servicer, server):
+
rpc_method_handlers = {
+
'GetOne': grpc.unary_unary_rpc_method_handler(
+
servicer.GetOne,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigResponse.SerializeToString,
+
),
+
'GetAll': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamResponse.SerializeToString,
+
),
+
'Subscribe': grpc.unary_stream_rpc_method_handler(
+
servicer.Subscribe,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamResponse.SerializeToString,
+
),
+
'Set': grpc.unary_unary_rpc_method_handler(
+
servicer.Set,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetResponse.SerializeToString,
+
),
+
'SetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.SetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetSomeResponse.SerializeToString,
+
),
+
'Delete': grpc.unary_unary_rpc_method_handler(
+
servicer.Delete,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteResponse.SerializeToString,
+
),
+
'DeleteAll': grpc.unary_stream_rpc_method_handler(
+
servicer.DeleteAll,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteAllRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteAllResponse.SerializeToString,
+
),
+
}
+
generic_handler = grpc.method_handlers_generic_handler(
+
'arista.studio.v1.TopologyUpdateSyncConfigService', rpc_method_handlers)
+
server.add_generic_rpc_handlers((generic_handler,))
+
[docs]
+
class TopologyUpdateSyncConfigService(object):
+
"""Missing associated documentation comment in .proto file."""
+
+
+
[docs]
+
@staticmethod
+
def GetOne(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, '/arista.studio.v1.TopologyUpdateSyncConfigService/GetOne',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def GetAll(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_stream(request, target, '/arista.studio.v1.TopologyUpdateSyncConfigService/GetAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Subscribe(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_stream(request, target, '/arista.studio.v1.TopologyUpdateSyncConfigService/Subscribe',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Set(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, '/arista.studio.v1.TopologyUpdateSyncConfigService/Set',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SetSome(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_stream(request, target, '/arista.studio.v1.TopologyUpdateSyncConfigService/SetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigSetSomeResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def Delete(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, '/arista.studio.v1.TopologyUpdateSyncConfigService/Delete',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def DeleteAll(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_stream(request, target, '/arista.studio.v1.TopologyUpdateSyncConfigService/DeleteAll',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteAllRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.TopologyUpdateSyncConfigDeleteAllResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
