Source code for arista.studio.v1.services.gen_pb2_grpc
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from arista.studio.v1.services import gen_pb2 as arista_dot_studio_dot_v1_dot_services_dot_gen__pb2
GRPC_GENERATED_VERSION = '1.67.1'
GRPC_VERSION = grpc.__version__
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
raise RuntimeError(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in arista/studio.v1/services.gen_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
)
[docs]
class AssignedTagsServiceStub(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.AssignedTagsService/GetOne',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.studio.v1.AssignedTagsService/GetSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.studio.v1.AssignedTagsService/GetAll',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.studio.v1.AssignedTagsService/Subscribe',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.studio.v1.AssignedTagsService/GetMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.studio.v1.AssignedTagsService/SubscribeMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.studio.v1.AssignedTagsService/GetAllBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.studio.v1.AssignedTagsService/SubscribeBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class AssignedTagsServiceServicer(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 GetMeta(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 SubscribeMeta(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_AssignedTagsServiceServicer_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.AssignedTagsRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.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.AssignedTagsStreamRequest.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.AssignedTagsBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.studio.v1.AssignedTagsService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.studio.v1.AssignedTagsService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class AssignedTagsService(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.AssignedTagsService/GetOne',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsService/GetSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsService/GetAll',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsService/Subscribe',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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.AssignedTagsService/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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.AssignedTagsService/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsService/GetAllBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsService/SubscribeBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class AssignedTagsConfigServiceStub(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.AssignedTagsConfigService/GetOne',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/GetSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/GetAll',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/Subscribe',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.studio.v1.AssignedTagsConfigService/GetMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/SubscribeMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.Set = channel.unary_unary(
'/arista.studio.v1.AssignedTagsConfigService/Set',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetResponse.FromString,
_registered_method=True)
self.SetSome = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/SetSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetSomeResponse.FromString,
_registered_method=True)
self.Delete = channel.unary_unary(
'/arista.studio.v1.AssignedTagsConfigService/Delete',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteResponse.FromString,
_registered_method=True)
self.DeleteSome = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/DeleteSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteSomeResponse.FromString,
_registered_method=True)
self.DeleteAll = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/DeleteAll',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteAllRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteAllResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/GetAllBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.studio.v1.AssignedTagsConfigService/SubscribeBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class AssignedTagsConfigServiceServicer(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 GetMeta(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 SubscribeMeta(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_AssignedTagsConfigServiceServicer_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.AssignedTagsConfigRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.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.AssignedTagsConfigStreamRequest.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.AssignedTagsConfigSetRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetResponse.SerializeToString,
),
'SetSome': grpc.unary_stream_rpc_method_handler(
servicer.SetSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetSomeResponse.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteResponse.SerializeToString,
),
'DeleteSome': grpc.unary_stream_rpc_method_handler(
servicer.DeleteSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteSomeResponse.SerializeToString,
),
'DeleteAll': grpc.unary_stream_rpc_method_handler(
servicer.DeleteAll,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteAllRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteAllResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.studio.v1.AssignedTagsConfigService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.studio.v1.AssignedTagsConfigService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class AssignedTagsConfigService(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.AssignedTagsConfigService/GetOne',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/GetSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/GetAll',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/Subscribe',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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.AssignedTagsConfigService/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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.AssignedTagsConfigService/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/Set',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/SetSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigSetSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/Delete',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/DeleteSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/DeleteAll',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteAllRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigDeleteAllResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/GetAllBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.AssignedTagsConfigService/SubscribeBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AssignedTagsConfigBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
[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 GetMeta(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 SubscribeMeta(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,))
server.add_registered_method_handlers('arista.studio.v1.AutofillActionService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
[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 GetMeta(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 SubscribeMeta(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,))
server.add_registered_method_handlers('arista.studio.v1.AutofillActionConfigService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.AutofillActionConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[docs]
class InputsServiceStub(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.InputsService/GetOne',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.studio.v1.InputsService/GetSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.studio.v1.InputsService/GetAll',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.studio.v1.InputsService/Subscribe',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.studio.v1.InputsService/GetMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.studio.v1.InputsService/SubscribeMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.studio.v1.InputsService/GetAllBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.studio.v1.InputsService/SubscribeBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class InputsServiceServicer(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 GetMeta(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 SubscribeMeta(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_InputsServiceServicer_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.InputsRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.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.InputsStreamRequest.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.InputsBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.studio.v1.InputsService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.studio.v1.InputsService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class InputsService(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.InputsService/GetOne',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsService/GetSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsService/GetAll',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsService/Subscribe',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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.InputsService/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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.InputsService/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsService/GetAllBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsService/SubscribeBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class InputsConfigServiceStub(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.InputsConfigService/GetOne',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/GetSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/GetAll',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/Subscribe',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.studio.v1.InputsConfigService/GetMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/SubscribeMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.Set = channel.unary_unary(
'/arista.studio.v1.InputsConfigService/Set',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetResponse.FromString,
_registered_method=True)
self.SetSome = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/SetSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetSomeResponse.FromString,
_registered_method=True)
self.Delete = channel.unary_unary(
'/arista.studio.v1.InputsConfigService/Delete',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteResponse.FromString,
_registered_method=True)
self.DeleteSome = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/DeleteSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteSomeResponse.FromString,
_registered_method=True)
self.DeleteAll = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/DeleteAll',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteAllRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteAllResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/GetAllBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.studio.v1.InputsConfigService/SubscribeBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class InputsConfigServiceServicer(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 GetMeta(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 SubscribeMeta(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_InputsConfigServiceServicer_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.InputsConfigRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.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.InputsConfigStreamRequest.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.InputsConfigSetRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetResponse.SerializeToString,
),
'SetSome': grpc.unary_stream_rpc_method_handler(
servicer.SetSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetSomeResponse.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteResponse.SerializeToString,
),
'DeleteSome': grpc.unary_stream_rpc_method_handler(
servicer.DeleteSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteSomeResponse.SerializeToString,
),
'DeleteAll': grpc.unary_stream_rpc_method_handler(
servicer.DeleteAll,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteAllRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteAllResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.studio.v1.InputsConfigService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.studio.v1.InputsConfigService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class InputsConfigService(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.InputsConfigService/GetOne',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/GetSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/GetAll',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/Subscribe',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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.InputsConfigService/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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.InputsConfigService/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/Set',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/SetSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigSetSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/Delete',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/DeleteSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/DeleteAll',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteAllRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigDeleteAllResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/GetAllBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.InputsConfigService/SubscribeBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.InputsConfigBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class SecretInputServiceStub(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.SecretInputService/GetOne',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.studio.v1.SecretInputService/GetSome',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputSomeRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.studio.v1.SecretInputService/GetAll',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.studio.v1.SecretInputService/Subscribe',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.studio.v1.SecretInputService/GetMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.studio.v1.SecretInputService/SubscribeMeta',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.studio.v1.SecretInputService/GetAllBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.studio.v1.SecretInputService/SubscribeBatched',
request_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class SecretInputServiceServicer(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 GetMeta(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 SubscribeMeta(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_SecretInputServiceServicer_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.SecretInputRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputSomeRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.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.SecretInputStreamRequest.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.SecretInputBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamRequest.FromString,
response_serializer=arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.studio.v1.SecretInputService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.studio.v1.SecretInputService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class SecretInputService(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.SecretInputService/GetOne',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.SecretInputService/GetSome',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputSomeRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputSomeResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.SecretInputService/GetAll',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.SecretInputService/Subscribe',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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.SecretInputService/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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.SecretInputService/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.SecretInputService/GetAllBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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.SecretInputService/SubscribeBatched',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.SecretInputBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
[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 GetMeta(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 SubscribeMeta(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,))
server.add_registered_method_handlers('arista.studio.v1.StudioService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
[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 GetMeta(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 SubscribeMeta(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,))
server.add_registered_method_handlers('arista.studio.v1.StudioConfigService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioConfigStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
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,
_registered_method=True)
[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 GetMeta(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 SubscribeMeta(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,))
server.add_registered_method_handlers('arista.studio.v1.StudioSummaryService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)
[docs]
@staticmethod
def GetMeta(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/GetMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def SubscribeMeta(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/SubscribeMeta',
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.StudioSummaryStreamRequest.SerializeToString,
arista_dot_studio_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[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,
_registered_method=True)
[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,
_registered_method=True)