+# 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.GetSome = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionService/GetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionSomeResponse.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,
+
)
+
self.GetMeta = channel.unary_unary(
+
'/arista.studio.v1.AutofillActionService/GetMeta',
+
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.MetaResponse.FromString,
+
)
+
self.SubscribeMeta = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionService/SubscribeMeta',
+
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.MetaResponse.FromString,
+
)
+
self.GetAllBatched = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionService/GetAllBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamResponse.FromString,
+
)
+
self.SubscribeBatched = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionService/SubscribeBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamResponse.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 GetSome(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 GetAllBatched(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 SubscribeBatched(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,
+
),
+
'GetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.GetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionSomeResponse.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,
+
),
+
'GetMeta': grpc.unary_unary_rpc_method_handler(
+
servicer.GetMeta,
+
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.MetaResponse.SerializeToString,
+
),
+
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeMeta,
+
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.MetaResponse.SerializeToString,
+
),
+
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAllBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamResponse.SerializeToString,
+
),
+
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamResponse.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 GetSome(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/GetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionSomeResponse.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]
+
@staticmethod
+
def GetAllBatched(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/GetAllBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SubscribeBatched(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/SubscribeBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionBatchedStreamResponse.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.GetSome = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/GetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSomeResponse.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.GetMeta = channel.unary_unary(
+
'/arista.studio.v1.AutofillActionConfigService/GetMeta',
+
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.MetaResponse.FromString,
+
)
+
self.SubscribeMeta = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/SubscribeMeta',
+
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.MetaResponse.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.DeleteSome = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/DeleteSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteSomeResponse.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,
+
)
+
self.GetAllBatched = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/GetAllBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamResponse.FromString,
+
)
+
self.SubscribeBatched = channel.unary_stream(
+
'/arista.studio.v1.AutofillActionConfigService/SubscribeBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamResponse.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 GetSome(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 DeleteSome(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 GetAllBatched(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 SubscribeBatched(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,
+
),
+
'GetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.GetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSomeResponse.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,
+
),
+
'GetMeta': grpc.unary_unary_rpc_method_handler(
+
servicer.GetMeta,
+
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.MetaResponse.SerializeToString,
+
),
+
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeMeta,
+
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.MetaResponse.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,
+
),
+
'DeleteSome': grpc.unary_stream_rpc_method_handler(
+
servicer.DeleteSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteSomeResponse.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,
+
),
+
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAllBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamResponse.SerializeToString,
+
),
+
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamResponse.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 GetSome(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/GetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigSomeResponse.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 DeleteSome(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/DeleteSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigDeleteSomeResponse.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]
+
@staticmethod
+
def GetAllBatched(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/GetAllBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SubscribeBatched(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/SubscribeBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigBatchedStreamResponse.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.GetSome = channel.unary_stream(
+
'/arista.studio.v1.StudioService/GetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSomeResponse.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,
+
)
+
self.GetMeta = channel.unary_unary(
+
'/arista.studio.v1.StudioService/GetMeta',
+
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.MetaResponse.FromString,
+
)
+
self.SubscribeMeta = channel.unary_stream(
+
'/arista.studio.v1.StudioService/SubscribeMeta',
+
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.MetaResponse.FromString,
+
)
+
self.GetAllBatched = channel.unary_stream(
+
'/arista.studio.v1.StudioService/GetAllBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamResponse.FromString,
+
)
+
self.SubscribeBatched = channel.unary_stream(
+
'/arista.studio.v1.StudioService/SubscribeBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamResponse.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 GetSome(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 GetAllBatched(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 SubscribeBatched(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,
+
),
+
'GetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.GetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSomeResponse.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,
+
),
+
'GetMeta': grpc.unary_unary_rpc_method_handler(
+
servicer.GetMeta,
+
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.MetaResponse.SerializeToString,
+
),
+
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeMeta,
+
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.MetaResponse.SerializeToString,
+
),
+
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAllBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamResponse.SerializeToString,
+
),
+
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamResponse.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 GetSome(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/GetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSomeResponse.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]
+
@staticmethod
+
def GetAllBatched(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/GetAllBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SubscribeBatched(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/SubscribeBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioBatchedStreamResponse.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.GetSome = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/GetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSomeResponse.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.GetMeta = channel.unary_unary(
+
'/arista.studio.v1.StudioConfigService/GetMeta',
+
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.MetaResponse.FromString,
+
)
+
self.SubscribeMeta = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/SubscribeMeta',
+
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.MetaResponse.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.DeleteSome = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/DeleteSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteSomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteSomeResponse.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,
+
)
+
self.GetAllBatched = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/GetAllBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamResponse.FromString,
+
)
+
self.SubscribeBatched = channel.unary_stream(
+
'/arista.studio.v1.StudioConfigService/SubscribeBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamResponse.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 GetSome(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 DeleteSome(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 GetAllBatched(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 SubscribeBatched(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,
+
),
+
'GetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.GetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSomeResponse.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,
+
),
+
'GetMeta': grpc.unary_unary_rpc_method_handler(
+
servicer.GetMeta,
+
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.MetaResponse.SerializeToString,
+
),
+
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeMeta,
+
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.MetaResponse.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,
+
),
+
'DeleteSome': grpc.unary_stream_rpc_method_handler(
+
servicer.DeleteSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteSomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteSomeResponse.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,
+
),
+
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAllBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamResponse.SerializeToString,
+
),
+
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamResponse.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 GetSome(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/GetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigSomeResponse.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 DeleteSome(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/DeleteSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteSomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigDeleteSomeResponse.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]
+
@staticmethod
+
def GetAllBatched(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/GetAllBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SubscribeBatched(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/SubscribeBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigBatchedStreamResponse.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.GetSome = channel.unary_stream(
+
'/arista.studio.v1.StudioSummaryService/GetSome',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummarySomeRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummarySomeResponse.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,
+
)
+
self.GetMeta = channel.unary_unary(
+
'/arista.studio.v1.StudioSummaryService/GetMeta',
+
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.MetaResponse.FromString,
+
)
+
self.SubscribeMeta = channel.unary_stream(
+
'/arista.studio.v1.StudioSummaryService/SubscribeMeta',
+
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.MetaResponse.FromString,
+
)
+
self.GetAllBatched = channel.unary_stream(
+
'/arista.studio.v1.StudioSummaryService/GetAllBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamResponse.FromString,
+
)
+
self.SubscribeBatched = channel.unary_stream(
+
'/arista.studio.v1.StudioSummaryService/SubscribeBatched',
+
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamRequest.SerializeToString,
+
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamResponse.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 GetSome(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 GetAllBatched(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 SubscribeBatched(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,
+
),
+
'GetSome': grpc.unary_stream_rpc_method_handler(
+
servicer.GetSome,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummarySomeRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummarySomeResponse.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,
+
),
+
'GetMeta': grpc.unary_unary_rpc_method_handler(
+
servicer.GetMeta,
+
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.MetaResponse.SerializeToString,
+
),
+
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeMeta,
+
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.MetaResponse.SerializeToString,
+
),
+
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.GetAllBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamResponse.SerializeToString,
+
),
+
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
+
servicer.SubscribeBatched,
+
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamRequest.FromString,
+
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamResponse.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 GetSome(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/GetSome',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummarySomeRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummarySomeResponse.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]
+
@staticmethod
+
def GetAllBatched(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/GetAllBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+
+
+
[docs]
+
@staticmethod
+
def SubscribeBatched(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/SubscribeBatched',
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamRequest.SerializeToString,
+
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryBatchedStreamResponse.FromString,
+
options, channel_credentials,
+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
