# 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.workspace.v1.services import gen_pb2 as arista_dot_workspace_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/workspace.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 StudioGeneratedConfigurationServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.workspace.v1.StudioGeneratedConfigurationService/GetOne',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.workspace.v1.StudioGeneratedConfigurationService/GetSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.workspace.v1.StudioGeneratedConfigurationService/GetAll',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.workspace.v1.StudioGeneratedConfigurationService/Subscribe',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.workspace.v1.StudioGeneratedConfigurationService/GetMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.workspace.v1.StudioGeneratedConfigurationService/SubscribeMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.workspace.v1.StudioGeneratedConfigurationService/GetAllBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.workspace.v1.StudioGeneratedConfigurationService/SubscribeBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class StudioGeneratedConfigurationServiceServicer(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_StudioGeneratedConfigurationServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.workspace.v1.StudioGeneratedConfigurationService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.workspace.v1.StudioGeneratedConfigurationService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class StudioGeneratedConfigurationService(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.workspace.v1.StudioGeneratedConfigurationService/GetOne',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationResponse.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.workspace.v1.StudioGeneratedConfigurationService/GetSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationSomeResponse.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.workspace.v1.StudioGeneratedConfigurationService/GetAll',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamResponse.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.workspace.v1.StudioGeneratedConfigurationService/Subscribe',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationStreamResponse.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.workspace.v1.StudioGeneratedConfigurationService/GetAllBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamResponse.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.workspace.v1.StudioGeneratedConfigurationService/SubscribeBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.StudioGeneratedConfigurationBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class WorkspaceServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.workspace.v1.WorkspaceService/GetOne',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceService/GetSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.workspace.v1.WorkspaceService/GetAll',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.workspace.v1.WorkspaceService/Subscribe',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.workspace.v1.WorkspaceService/GetMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.workspace.v1.WorkspaceService/SubscribeMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceService/GetAllBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceService/SubscribeBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class WorkspaceServiceServicer(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_WorkspaceServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.workspace.v1.WorkspaceService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.workspace.v1.WorkspaceService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class WorkspaceService(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.workspace.v1.WorkspaceService/GetOne',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceResponse.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.workspace.v1.WorkspaceService/GetSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSomeResponse.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.workspace.v1.WorkspaceService/GetAll',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamResponse.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.workspace.v1.WorkspaceService/Subscribe',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceStreamResponse.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.workspace.v1.WorkspaceService/GetAllBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamResponse.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.workspace.v1.WorkspaceService/SubscribeBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class WorkspaceBuildServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.workspace.v1.WorkspaceBuildService/GetOne',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildService/GetSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildService/GetAll',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildService/Subscribe',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.workspace.v1.WorkspaceBuildService/GetMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildService/SubscribeMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildService/GetAllBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildService/SubscribeBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class WorkspaceBuildServiceServicer(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_WorkspaceBuildServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.workspace.v1.WorkspaceBuildService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.workspace.v1.WorkspaceBuildService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class WorkspaceBuildService(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.workspace.v1.WorkspaceBuildService/GetOne',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildResponse.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.workspace.v1.WorkspaceBuildService/GetSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildSomeResponse.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.workspace.v1.WorkspaceBuildService/GetAll',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamResponse.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.workspace.v1.WorkspaceBuildService/Subscribe',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildStreamResponse.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.workspace.v1.WorkspaceBuildService/GetAllBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamResponse.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.workspace.v1.WorkspaceBuildService/SubscribeBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class WorkspaceBuildDetailsServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.workspace.v1.WorkspaceBuildDetailsService/GetOne',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildDetailsService/GetSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildDetailsService/GetAll',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildDetailsService/Subscribe',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.workspace.v1.WorkspaceBuildDetailsService/GetMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildDetailsService/SubscribeMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildDetailsService/GetAllBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceBuildDetailsService/SubscribeBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class WorkspaceBuildDetailsServiceServicer(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_WorkspaceBuildDetailsServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.workspace.v1.WorkspaceBuildDetailsService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.workspace.v1.WorkspaceBuildDetailsService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class WorkspaceBuildDetailsService(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.workspace.v1.WorkspaceBuildDetailsService/GetOne',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsResponse.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.workspace.v1.WorkspaceBuildDetailsService/GetSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsSomeResponse.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.workspace.v1.WorkspaceBuildDetailsService/GetAll',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamResponse.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.workspace.v1.WorkspaceBuildDetailsService/Subscribe',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsStreamResponse.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.workspace.v1.WorkspaceBuildDetailsService/GetAllBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamResponse.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.workspace.v1.WorkspaceBuildDetailsService/SubscribeBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceBuildDetailsBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class WorkspaceConfigServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.workspace.v1.WorkspaceConfigService/GetOne',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/GetSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/GetAll',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/Subscribe',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.workspace.v1.WorkspaceConfigService/GetMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/SubscribeMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.Set = channel.unary_unary(
'/arista.workspace.v1.WorkspaceConfigService/Set',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetResponse.FromString,
_registered_method=True)
self.SetSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/SetSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetSomeResponse.FromString,
_registered_method=True)
self.Delete = channel.unary_unary(
'/arista.workspace.v1.WorkspaceConfigService/Delete',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteResponse.FromString,
_registered_method=True)
self.DeleteSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/DeleteSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteSomeResponse.FromString,
_registered_method=True)
self.DeleteAll = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/DeleteAll',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteAllRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteAllResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/GetAllBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceConfigService/SubscribeBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class WorkspaceConfigServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs]
def GetOne(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Subscribe(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Set(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Delete(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def DeleteSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def DeleteAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAllBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SubscribeBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def add_WorkspaceConfigServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'Set': grpc.unary_unary_rpc_method_handler(
servicer.Set,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetResponse.SerializeToString,
),
'SetSome': grpc.unary_stream_rpc_method_handler(
servicer.SetSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetSomeResponse.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteResponse.SerializeToString,
),
'DeleteSome': grpc.unary_stream_rpc_method_handler(
servicer.DeleteSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteSomeResponse.SerializeToString,
),
'DeleteAll': grpc.unary_stream_rpc_method_handler(
servicer.DeleteAll,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteAllRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteAllResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.workspace.v1.WorkspaceConfigService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.workspace.v1.WorkspaceConfigService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class WorkspaceConfigService(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.workspace.v1.WorkspaceConfigService/GetOne',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigResponse.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.workspace.v1.WorkspaceConfigService/GetSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSomeResponse.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.workspace.v1.WorkspaceConfigService/GetAll',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamResponse.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.workspace.v1.WorkspaceConfigService/Subscribe',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigStreamResponse.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.workspace.v1.WorkspaceConfigService/Set',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetResponse.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.workspace.v1.WorkspaceConfigService/SetSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigSetSomeResponse.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.workspace.v1.WorkspaceConfigService/Delete',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteResponse.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.workspace.v1.WorkspaceConfigService/DeleteSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteSomeResponse.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.workspace.v1.WorkspaceConfigService/DeleteAll',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteAllRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigDeleteAllResponse.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.workspace.v1.WorkspaceConfigService/GetAllBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamResponse.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.workspace.v1.WorkspaceConfigService/SubscribeBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceConfigBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class WorkspaceSyncConfigServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.workspace.v1.WorkspaceSyncConfigService/GetOne',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/GetSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/GetAll',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/Subscribe',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.workspace.v1.WorkspaceSyncConfigService/GetMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/SubscribeMeta',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.Set = channel.unary_unary(
'/arista.workspace.v1.WorkspaceSyncConfigService/Set',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetResponse.FromString,
_registered_method=True)
self.SetSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/SetSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetSomeResponse.FromString,
_registered_method=True)
self.Delete = channel.unary_unary(
'/arista.workspace.v1.WorkspaceSyncConfigService/Delete',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteResponse.FromString,
_registered_method=True)
self.DeleteSome = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/DeleteSome',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteSomeRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteSomeResponse.FromString,
_registered_method=True)
self.DeleteAll = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/DeleteAll',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteAllRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteAllResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/GetAllBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.workspace.v1.WorkspaceSyncConfigService/SubscribeBatched',
request_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class WorkspaceSyncConfigServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs]
def GetOne(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Subscribe(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Set(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SetSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def Delete(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def DeleteSome(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def DeleteAll(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def GetAllBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def SubscribeBatched(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs]
def add_WorkspaceSyncConfigServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'Set': grpc.unary_unary_rpc_method_handler(
servicer.Set,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetResponse.SerializeToString,
),
'SetSome': grpc.unary_stream_rpc_method_handler(
servicer.SetSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetSomeResponse.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteResponse.SerializeToString,
),
'DeleteSome': grpc.unary_stream_rpc_method_handler(
servicer.DeleteSome,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteSomeRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteSomeResponse.SerializeToString,
),
'DeleteAll': grpc.unary_stream_rpc_method_handler(
servicer.DeleteAll,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteAllRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteAllResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.workspace.v1.WorkspaceSyncConfigService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.workspace.v1.WorkspaceSyncConfigService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class WorkspaceSyncConfigService(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.workspace.v1.WorkspaceSyncConfigService/GetOne',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigResponse.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.workspace.v1.WorkspaceSyncConfigService/GetSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSomeResponse.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.workspace.v1.WorkspaceSyncConfigService/GetAll',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamResponse.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.workspace.v1.WorkspaceSyncConfigService/Subscribe',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigStreamResponse.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.workspace.v1.WorkspaceSyncConfigService/Set',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetResponse.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.workspace.v1.WorkspaceSyncConfigService/SetSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigSetSomeResponse.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.workspace.v1.WorkspaceSyncConfigService/Delete',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteResponse.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.workspace.v1.WorkspaceSyncConfigService/DeleteSome',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteSomeRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteSomeResponse.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.workspace.v1.WorkspaceSyncConfigService/DeleteAll',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteAllRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigDeleteAllResponse.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.workspace.v1.WorkspaceSyncConfigService/GetAllBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamResponse.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.workspace.v1.WorkspaceSyncConfigService/SubscribeBatched',
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamRequest.SerializeToString,
arista_dot_workspace_dot_v1_dot_services_dot_gen__pb2.WorkspaceSyncConfigBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)