# 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.asset_manager.v1.services import gen_pb2 as arista_dot_asset__manager_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/asset_manager.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 AllowedTenantsServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.asset_manager.v1.AllowedTenantsService/GetOne',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.asset_manager.v1.AllowedTenantsService/GetSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.asset_manager.v1.AllowedTenantsService/GetAll',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.asset_manager.v1.AllowedTenantsService/Subscribe',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.asset_manager.v1.AllowedTenantsService/GetMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.asset_manager.v1.AllowedTenantsService/SubscribeMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.asset_manager.v1.AllowedTenantsService/GetAllBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.asset_manager.v1.AllowedTenantsService/SubscribeBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class AllowedTenantsServiceServicer(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_AllowedTenantsServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.asset_manager.v1.AllowedTenantsService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.asset_manager.v1.AllowedTenantsService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class AllowedTenantsService(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.asset_manager.v1.AllowedTenantsService/GetOne',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsResponse.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.asset_manager.v1.AllowedTenantsService/GetSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsSomeResponse.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.asset_manager.v1.AllowedTenantsService/GetAll',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamResponse.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.asset_manager.v1.AllowedTenantsService/Subscribe',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsStreamResponse.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.asset_manager.v1.AllowedTenantsService/GetAllBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamResponse.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.asset_manager.v1.AllowedTenantsService/SubscribeBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.AllowedTenantsBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class DeviceTenantAssignConfigServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/GetOne',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/GetSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/GetAll',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/Subscribe',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/GetMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/SubscribeMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.Set = channel.unary_unary(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/Set',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetResponse.FromString,
_registered_method=True)
self.SetSome = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/SetSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetSomeResponse.FromString,
_registered_method=True)
self.Delete = channel.unary_unary(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/Delete',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteResponse.FromString,
_registered_method=True)
self.DeleteSome = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/DeleteSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteSomeResponse.FromString,
_registered_method=True)
self.DeleteAll = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/DeleteAll',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteAllRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteAllResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/GetAllBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignConfigService/SubscribeBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class DeviceTenantAssignConfigServiceServicer(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_DeviceTenantAssignConfigServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'Set': grpc.unary_unary_rpc_method_handler(
servicer.Set,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetResponse.SerializeToString,
),
'SetSome': grpc.unary_stream_rpc_method_handler(
servicer.SetSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetSomeResponse.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteResponse.SerializeToString,
),
'DeleteSome': grpc.unary_stream_rpc_method_handler(
servicer.DeleteSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteSomeResponse.SerializeToString,
),
'DeleteAll': grpc.unary_stream_rpc_method_handler(
servicer.DeleteAll,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteAllRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteAllResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.asset_manager.v1.DeviceTenantAssignConfigService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.asset_manager.v1.DeviceTenantAssignConfigService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class DeviceTenantAssignConfigService(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.asset_manager.v1.DeviceTenantAssignConfigService/GetOne',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/GetSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSomeResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/GetAll',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/Subscribe',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigStreamResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/Set',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/SetSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigSetSomeResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/Delete',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/DeleteSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteSomeResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/DeleteAll',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteAllRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigDeleteAllResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/GetAllBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamResponse.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.asset_manager.v1.DeviceTenantAssignConfigService/SubscribeBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignConfigBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class DeviceTenantAssignmentServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/GetOne',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/GetSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/GetAll',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/Subscribe',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/GetMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/SubscribeMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/GetAllBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/SubscribeBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamResponse.FromString,
_registered_method=True)
self.GetPage = channel.unary_stream(
'/arista.asset_manager.v1.DeviceTenantAssignmentService/GetPage',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentPageRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentResponse.FromString,
_registered_method=True)
[docs]
class DeviceTenantAssignmentServiceServicer(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 GetPage(self, request, context):
"""Missing associated 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_DeviceTenantAssignmentServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamResponse.SerializeToString,
),
'GetPage': grpc.unary_stream_rpc_method_handler(
servicer.GetPage,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentPageRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.asset_manager.v1.DeviceTenantAssignmentService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.asset_manager.v1.DeviceTenantAssignmentService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class DeviceTenantAssignmentService(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.asset_manager.v1.DeviceTenantAssignmentService/GetOne',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentResponse.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.asset_manager.v1.DeviceTenantAssignmentService/GetSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentSomeResponse.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.asset_manager.v1.DeviceTenantAssignmentService/GetAll',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamResponse.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.asset_manager.v1.DeviceTenantAssignmentService/Subscribe',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentStreamResponse.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.asset_manager.v1.DeviceTenantAssignmentService/GetAllBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamResponse.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.asset_manager.v1.DeviceTenantAssignmentService/SubscribeBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def GetPage(request,
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.asset_manager.v1.DeviceTenantAssignmentService/GetPage',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentPageRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.DeviceTenantAssignmentResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class LicenseTenantAssignConfigServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/GetOne',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/GetSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/GetAll',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/Subscribe',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/GetMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/SubscribeMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.Set = channel.unary_unary(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/Set',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetResponse.FromString,
_registered_method=True)
self.SetSome = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/SetSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetSomeResponse.FromString,
_registered_method=True)
self.Delete = channel.unary_unary(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/Delete',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteResponse.FromString,
_registered_method=True)
self.DeleteSome = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/DeleteSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteSomeResponse.FromString,
_registered_method=True)
self.DeleteAll = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/DeleteAll',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteAllRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteAllResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/GetAllBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignConfigService/SubscribeBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class LicenseTenantAssignConfigServiceServicer(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_LicenseTenantAssignConfigServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'Set': grpc.unary_unary_rpc_method_handler(
servicer.Set,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetResponse.SerializeToString,
),
'SetSome': grpc.unary_stream_rpc_method_handler(
servicer.SetSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetSomeResponse.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteResponse.SerializeToString,
),
'DeleteSome': grpc.unary_stream_rpc_method_handler(
servicer.DeleteSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteSomeResponse.SerializeToString,
),
'DeleteAll': grpc.unary_stream_rpc_method_handler(
servicer.DeleteAll,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteAllRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteAllResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.asset_manager.v1.LicenseTenantAssignConfigService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.asset_manager.v1.LicenseTenantAssignConfigService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class LicenseTenantAssignConfigService(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.asset_manager.v1.LicenseTenantAssignConfigService/GetOne',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/GetSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSomeResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/GetAll',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/Subscribe',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigStreamResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/Set',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/SetSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigSetSomeResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/Delete',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/DeleteSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteSomeResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/DeleteAll',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteAllRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigDeleteAllResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/GetAllBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamResponse.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.asset_manager.v1.LicenseTenantAssignConfigService/SubscribeBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignConfigBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class LicenseTenantAssignmentServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/GetOne',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/GetSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/GetAll',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/Subscribe',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/GetMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/SubscribeMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/GetAllBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/SubscribeBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamResponse.FromString,
_registered_method=True)
self.GetPage = channel.unary_stream(
'/arista.asset_manager.v1.LicenseTenantAssignmentService/GetPage',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentPageRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentResponse.FromString,
_registered_method=True)
[docs]
class LicenseTenantAssignmentServiceServicer(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 GetPage(self, request, context):
"""Missing associated 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_LicenseTenantAssignmentServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamResponse.SerializeToString,
),
'GetPage': grpc.unary_stream_rpc_method_handler(
servicer.GetPage,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentPageRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.asset_manager.v1.LicenseTenantAssignmentService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.asset_manager.v1.LicenseTenantAssignmentService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class LicenseTenantAssignmentService(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.asset_manager.v1.LicenseTenantAssignmentService/GetOne',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentResponse.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.asset_manager.v1.LicenseTenantAssignmentService/GetSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentSomeResponse.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.asset_manager.v1.LicenseTenantAssignmentService/GetAll',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamResponse.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.asset_manager.v1.LicenseTenantAssignmentService/Subscribe',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentStreamResponse.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.asset_manager.v1.LicenseTenantAssignmentService/GetAllBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamResponse.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.asset_manager.v1.LicenseTenantAssignmentService/SubscribeBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
@staticmethod
def GetPage(request,
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.asset_manager.v1.LicenseTenantAssignmentService/GetPage',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentPageRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.LicenseTenantAssignmentResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
[docs]
class SalesOrderServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetOne = channel.unary_unary(
'/arista.asset_manager.v1.SalesOrderService/GetOne',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderResponse.FromString,
_registered_method=True)
self.GetSome = channel.unary_stream(
'/arista.asset_manager.v1.SalesOrderService/GetSome',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderSomeRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderSomeResponse.FromString,
_registered_method=True)
self.GetAll = channel.unary_stream(
'/arista.asset_manager.v1.SalesOrderService/GetAll',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamResponse.FromString,
_registered_method=True)
self.Subscribe = channel.unary_stream(
'/arista.asset_manager.v1.SalesOrderService/Subscribe',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamResponse.FromString,
_registered_method=True)
self.GetMeta = channel.unary_unary(
'/arista.asset_manager.v1.SalesOrderService/GetMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.SubscribeMeta = channel.unary_stream(
'/arista.asset_manager.v1.SalesOrderService/SubscribeMeta',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString,
_registered_method=True)
self.GetAllBatched = channel.unary_stream(
'/arista.asset_manager.v1.SalesOrderService/GetAllBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamResponse.FromString,
_registered_method=True)
self.SubscribeBatched = channel.unary_stream(
'/arista.asset_manager.v1.SalesOrderService/SubscribeBatched',
request_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamRequest.SerializeToString,
response_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamResponse.FromString,
_registered_method=True)
[docs]
class SalesOrderServiceServicer(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_SalesOrderServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetOne': grpc.unary_unary_rpc_method_handler(
servicer.GetOne,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderResponse.SerializeToString,
),
'GetSome': grpc.unary_stream_rpc_method_handler(
servicer.GetSome,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderSomeRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderSomeResponse.SerializeToString,
),
'GetAll': grpc.unary_stream_rpc_method_handler(
servicer.GetAll,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamResponse.SerializeToString,
),
'Subscribe': grpc.unary_stream_rpc_method_handler(
servicer.Subscribe,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamResponse.SerializeToString,
),
'GetMeta': grpc.unary_unary_rpc_method_handler(
servicer.GetMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'SubscribeMeta': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeMeta,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString,
),
'GetAllBatched': grpc.unary_stream_rpc_method_handler(
servicer.GetAllBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamResponse.SerializeToString,
),
'SubscribeBatched': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBatched,
request_deserializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamRequest.FromString,
response_serializer=arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'arista.asset_manager.v1.SalesOrderService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('arista.asset_manager.v1.SalesOrderService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
[docs]
class SalesOrderService(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.asset_manager.v1.SalesOrderService/GetOne',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderResponse.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.asset_manager.v1.SalesOrderService/GetSome',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderSomeRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderSomeResponse.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.asset_manager.v1.SalesOrderService/GetAll',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamResponse.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.asset_manager.v1.SalesOrderService/Subscribe',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderStreamResponse.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.asset_manager.v1.SalesOrderService/GetAllBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamResponse.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.asset_manager.v1.SalesOrderService/SubscribeBatched',
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamRequest.SerializeToString,
arista_dot_asset__manager_dot_v1_dot_services_dot_gen__pb2.SalesOrderBatchedStreamResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)