# 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.configstatus.v1.services import gen_pb2 as arista_dot_configstatus_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/configstatus.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 ConfigDiffServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.configstatus.v1.ConfigDiffService/GetOne',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.configstatus.v1.ConfigDiffService/GetSome',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffSomeRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.configstatus.v1.ConfigDiffService/GetAll',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.configstatus.v1.ConfigDiffService/Subscribe',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.configstatus.v1.ConfigDiffService/GetMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.configstatus.v1.ConfigDiffService/SubscribeMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.configstatus.v1.ConfigDiffService/GetAllBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.configstatus.v1.ConfigDiffService/SubscribeBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class ConfigDiffServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs]
def GetOne(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Subscribe(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAllBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SubscribeBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def add_ConfigDiffServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffSomeRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.configstatus.v1.ConfigDiffService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.configstatus.v1.ConfigDiffService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class ConfigDiffService(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.configstatus.v1.ConfigDiffService/GetOne',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffResponse.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.configstatus.v1.ConfigDiffService/GetSome',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffSomeRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffSomeResponse.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.configstatus.v1.ConfigDiffService/GetAll',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamResponse.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.configstatus.v1.ConfigDiffService/Subscribe',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffStreamResponse.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.configstatus.v1.ConfigDiffService/GetAllBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamResponse.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.configstatus.v1.ConfigDiffService/SubscribeBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigDiffBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class ConfigurationServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.configstatus.v1.ConfigurationService/GetOne',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.configstatus.v1.ConfigurationService/GetSome',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationSomeRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.configstatus.v1.ConfigurationService/GetAll',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.configstatus.v1.ConfigurationService/Subscribe',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.configstatus.v1.ConfigurationService/GetMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.configstatus.v1.ConfigurationService/SubscribeMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.configstatus.v1.ConfigurationService/GetAllBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.configstatus.v1.ConfigurationService/SubscribeBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class ConfigurationServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs]
def GetOne(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Subscribe(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAllBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SubscribeBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def add_ConfigurationServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationSomeRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.configstatus.v1.ConfigurationService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.configstatus.v1.ConfigurationService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class ConfigurationService(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.configstatus.v1.ConfigurationService/GetOne',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationResponse.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.configstatus.v1.ConfigurationService/GetSome',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationSomeRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationSomeResponse.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.configstatus.v1.ConfigurationService/GetAll',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamResponse.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.configstatus.v1.ConfigurationService/Subscribe',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationStreamResponse.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.configstatus.v1.ConfigurationService/GetAllBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamResponse.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.configstatus.v1.ConfigurationService/SubscribeBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.ConfigurationBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class SecurityProfileServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.configstatus.v1.SecurityProfileService/GetOne',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileService/GetSome',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileSomeRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileService/GetAll',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileService/Subscribe',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.configstatus.v1.SecurityProfileService/GetMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileService/SubscribeMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileService/GetAllBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileService/SubscribeBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class SecurityProfileServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs]
def GetOne(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Subscribe(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAllBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SubscribeBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def add_SecurityProfileServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileSomeRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.configstatus.v1.SecurityProfileService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.configstatus.v1.SecurityProfileService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class SecurityProfileService(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.configstatus.v1.SecurityProfileService/GetOne',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileResponse.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.configstatus.v1.SecurityProfileService/GetSome',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileSomeRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileSomeResponse.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.configstatus.v1.SecurityProfileService/GetAll',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamResponse.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.configstatus.v1.SecurityProfileService/Subscribe',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileStreamResponse.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.configstatus.v1.SecurityProfileService/GetAllBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamResponse.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.configstatus.v1.SecurityProfileService/SubscribeBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class SecurityProfileDiffServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.configstatus.v1.SecurityProfileDiffService/GetOne',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffService/GetSome',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSomeRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffService/GetAll',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffService/Subscribe',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.configstatus.v1.SecurityProfileDiffService/GetMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffService/SubscribeMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffService/GetAllBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffService/SubscribeBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class SecurityProfileDiffServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs]
def GetOne(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Subscribe(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAllBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SubscribeBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def add_SecurityProfileDiffServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSomeRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.configstatus.v1.SecurityProfileDiffService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.configstatus.v1.SecurityProfileDiffService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class SecurityProfileDiffService(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.configstatus.v1.SecurityProfileDiffService/GetOne',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffResponse.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.configstatus.v1.SecurityProfileDiffService/GetSome',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSomeRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSomeResponse.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.configstatus.v1.SecurityProfileDiffService/GetAll',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamResponse.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.configstatus.v1.SecurityProfileDiffService/Subscribe',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffStreamResponse.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.configstatus.v1.SecurityProfileDiffService/GetAllBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamResponse.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.configstatus.v1.SecurityProfileDiffService/SubscribeBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class SecurityProfileDiffSummaryServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.configstatus.v1.SecurityProfileDiffSummaryService/GetOne',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffSummaryService/GetSome',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummarySomeRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummarySomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffSummaryService/GetAll',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffSummaryService/Subscribe',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.configstatus.v1.SecurityProfileDiffSummaryService/GetMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffSummaryService/SubscribeMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffSummaryService/GetAllBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.configstatus.v1.SecurityProfileDiffSummaryService/SubscribeBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class SecurityProfileDiffSummaryServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs]
def GetOne(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Subscribe(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAllBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SubscribeBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def add_SecurityProfileDiffSummaryServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummarySomeRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummarySomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.configstatus.v1.SecurityProfileDiffSummaryService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.configstatus.v1.SecurityProfileDiffSummaryService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class SecurityProfileDiffSummaryService(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.configstatus.v1.SecurityProfileDiffSummaryService/GetOne',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryResponse.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.configstatus.v1.SecurityProfileDiffSummaryService/GetSome',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummarySomeRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummarySomeResponse.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.configstatus.v1.SecurityProfileDiffSummaryService/GetAll',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamResponse.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.configstatus.v1.SecurityProfileDiffSummaryService/Subscribe',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryStreamResponse.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.configstatus.v1.SecurityProfileDiffSummaryService/GetAllBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamResponse.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.configstatus.v1.SecurityProfileDiffSummaryService/SubscribeBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SecurityProfileDiffSummaryBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class SummaryServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.configstatus.v1.SummaryService/GetOne',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.configstatus.v1.SummaryService/GetSome',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummarySomeRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummarySomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.configstatus.v1.SummaryService/GetAll',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.configstatus.v1.SummaryService/Subscribe',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.configstatus.v1.SummaryService/GetMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.configstatus.v1.SummaryService/SubscribeMeta',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.configstatus.v1.SummaryService/GetAllBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.configstatus.v1.SummaryService/SubscribeBatched',
request_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class SummaryServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs]
def GetOne(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Subscribe(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAllBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SubscribeBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def add_SummaryServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummarySomeRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummarySomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamRequest.FromString,
response_serializer=arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.configstatus.v1.SummaryService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.configstatus.v1.SummaryService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class SummaryService(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.configstatus.v1.SummaryService/GetOne',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryResponse.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.configstatus.v1.SummaryService/GetSome',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummarySomeRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummarySomeResponse.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.configstatus.v1.SummaryService/GetAll',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamResponse.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.configstatus.v1.SummaryService/Subscribe',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryStreamResponse.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.configstatus.v1.SummaryService/GetAllBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamResponse.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.configstatus.v1.SummaryService/SubscribeBatched',
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamRequest.SerializeToString,
arista_dot_configstatus_dot_v1_dot_services_dot_gen__pb2.SummaryBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)