From 9b82c4e44bea3b282209304cc57f848eeac631db Mon Sep 17 00:00:00 2001 From: Arista Jenkins Date: Tue, 9 Apr 2024 21:44:34 +0000 Subject: [PATCH] release/redirector.v1: Update redirector.v1 XXX_SKIP_CHECK_BREAKING [GENERATED_COMMIT] Change-Id: I4be0c606382e3c7a6436b6fdc3c230e2dae83528 --- arista/redirector/v1/redirector_pb2.py | 4 +- arista/redirector/v1/services/gen_pb2.py | 224 ++++++++++++++++-- arista/redirector/v1/services/gen_pb2_grpc.py | 99 ++++++++ 3 files changed, 310 insertions(+), 17 deletions(-) diff --git a/arista/redirector/v1/redirector_pb2.py b/arista/redirector/v1/redirector_pb2.py index 6e2063aa..53a94083 100644 --- a/arista/redirector/v1/redirector_pb2.py +++ b/arista/redirector/v1/redirector_pb2.py @@ -20,9 +20,9 @@ name='arista/redirector.v1/redirector.proto', package='arista.redirector.v1', syntax='proto3', - serialized_options=b'Z0arista/resources/arista/redirector.v1;redirector', + serialized_options=b'ZLgithub.com/aristanetworks/cloudvision-go/api/arista/redirector.v1;redirector', create_key=_descriptor._internal_create_key, - serialized_pb=b'\n%arista/redirector.v1/redirector.proto\x12\x14\x61rista.redirector.v1\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x14\x66mp/extensions.proto\x1a\x12\x66mp/wrappers.proto\"F\n\rAssignmentKey\x12/\n\tsystem_id\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue:\x04\x80\x8e\x19\x01\"x\n\nAssignment\x12\x30\n\x03key\x18\x01 \x01(\x0b\x32#.arista.redirector.v1.AssignmentKey\x12\x30\n\x08\x63lusters\x18\x02 \x01(\x0b\x32\x1e.arista.redirector.v1.Clusters:\x06\xfa\x8d\x19\x02ro\"9\n\x08\x43lusters\x12-\n\x06values\x18\x02 \x03(\x0b\x32\x1d.arista.redirector.v1.Cluster\"Y\n\x07\x43luster\x12*\n\x04name\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\"\n\x05hosts\x18\x02 \x01(\x0b\x32\x13.fmp.RepeatedStringB2Z0arista/resources/arista/redirector.v1;redirectorb\x06proto3' + serialized_pb=b'\n%arista/redirector.v1/redirector.proto\x12\x14\x61rista.redirector.v1\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x14\x66mp/extensions.proto\x1a\x12\x66mp/wrappers.proto\"F\n\rAssignmentKey\x12/\n\tsystem_id\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue:\x04\x80\x8e\x19\x01\"x\n\nAssignment\x12\x30\n\x03key\x18\x01 \x01(\x0b\x32#.arista.redirector.v1.AssignmentKey\x12\x30\n\x08\x63lusters\x18\x02 \x01(\x0b\x32\x1e.arista.redirector.v1.Clusters:\x06\xfa\x8d\x19\x02ro\"9\n\x08\x43lusters\x12-\n\x06values\x18\x02 \x03(\x0b\x32\x1d.arista.redirector.v1.Cluster\"Y\n\x07\x43luster\x12*\n\x04name\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\"\n\x05hosts\x18\x02 \x01(\x0b\x32\x13.fmp.RepeatedStringBNZLgithub.com/aristanetworks/cloudvision-go/api/arista/redirector.v1;redirectorb\x06proto3' , dependencies=[google_dot_protobuf_dot_wrappers__pb2.DESCRIPTOR,fmp_dot_extensions__pb2.DESCRIPTOR,fmp_dot_wrappers__pb2.DESCRIPTOR,]) diff --git a/arista/redirector/v1/services/gen_pb2.py b/arista/redirector/v1/services/gen_pb2.py index e78d22fd..814f1e77 100644 --- a/arista/redirector/v1/services/gen_pb2.py +++ b/arista/redirector/v1/services/gen_pb2.py @@ -15,21 +15,68 @@ from arista.time import time_pb2 as arista_dot_time_dot_time__pb2 from arista.subscriptions import subscriptions_pb2 as arista_dot_subscriptions_dot_subscriptions__pb2 from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2 +from google.protobuf import wrappers_pb2 as google_dot_protobuf_dot_wrappers__pb2 DESCRIPTOR = _descriptor.FileDescriptor( name='arista/redirector.v1/services.gen.proto', package='arista.redirector.v1', syntax='proto3', - serialized_options=b'Z0arista/resources/arista/redirector.v1;redirector', + serialized_options=b'ZLgithub.com/aristanetworks/cloudvision-go/api/arista/redirector.v1;redirector', create_key=_descriptor._internal_create_key, - serialized_pb=b'\n\'arista/redirector.v1/services.gen.proto\x12\x14\x61rista.redirector.v1\x1a%arista/redirector.v1/redirector.proto\x1a\x16\x61rista/time/time.proto\x1a(arista/subscriptions/subscriptions.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"o\n\x11\x41ssignmentRequest\x12\x30\n\x03key\x18\x01 \x01(\x0b\x32#.arista.redirector.v1.AssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"o\n\x12\x41ssignmentResponse\x12/\n\x05value\x18\x01 \x01(\x0b\x32 .arista.redirector.v1.Assignment\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"}\n\x17\x41ssignmentStreamRequest\x12;\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32 .arista.redirector.v1.Assignment\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\xa4\x01\n\x18\x41ssignmentStreamResponse\x12/\n\x05value\x18\x01 \x01(\x0b\x32 .arista.redirector.v1.Assignment\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation2\xc9\x02\n\x11\x41ssignmentService\x12[\n\x06GetOne\x12\'.arista.redirector.v1.AssignmentRequest\x1a(.arista.redirector.v1.AssignmentResponse\x12i\n\x06GetAll\x12-.arista.redirector.v1.AssignmentStreamRequest\x1a..arista.redirector.v1.AssignmentStreamResponse0\x01\x12l\n\tSubscribe\x12-.arista.redirector.v1.AssignmentStreamRequest\x1a..arista.redirector.v1.AssignmentStreamResponse0\x01\x42\x32Z0arista/resources/arista/redirector.v1;redirectorb\x06proto3' + serialized_pb=b'\n\'arista/redirector.v1/services.gen.proto\x12\x14\x61rista.redirector.v1\x1a%arista/redirector.v1/redirector.proto\x1a\x16\x61rista/time/time.proto\x1a(arista/subscriptions/subscriptions.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/wrappers.proto\"\x94\x01\n\x0cMetaResponse\x12(\n\x04time\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x02 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\x12+\n\x05\x63ount\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.UInt32Value\"o\n\x11\x41ssignmentRequest\x12\x30\n\x03key\x18\x01 \x01(\x0b\x32#.arista.redirector.v1.AssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"o\n\x12\x41ssignmentResponse\x12/\n\x05value\x18\x01 \x01(\x0b\x32 .arista.redirector.v1.Assignment\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"t\n\x15\x41ssignmentSomeRequest\x12\x31\n\x04keys\x18\x01 \x03(\x0b\x32#.arista.redirector.v1.AssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xa0\x01\n\x16\x41ssignmentSomeResponse\x12/\n\x05value\x18\x01 \x01(\x0b\x32 .arista.redirector.v1.Assignment\x12+\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12(\n\x04time\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"}\n\x17\x41ssignmentStreamRequest\x12;\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32 .arista.redirector.v1.Assignment\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\xa4\x01\n\x18\x41ssignmentStreamResponse\x12/\n\x05value\x18\x01 \x01(\x0b\x32 .arista.redirector.v1.Assignment\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation2\xf5\x04\n\x11\x41ssignmentService\x12[\n\x06GetOne\x12\'.arista.redirector.v1.AssignmentRequest\x1a(.arista.redirector.v1.AssignmentResponse\x12\x66\n\x07GetSome\x12+.arista.redirector.v1.AssignmentSomeRequest\x1a,.arista.redirector.v1.AssignmentSomeResponse0\x01\x12i\n\x06GetAll\x12-.arista.redirector.v1.AssignmentStreamRequest\x1a..arista.redirector.v1.AssignmentStreamResponse0\x01\x12l\n\tSubscribe\x12-.arista.redirector.v1.AssignmentStreamRequest\x1a..arista.redirector.v1.AssignmentStreamResponse0\x01\x12\\\n\x07GetMeta\x12-.arista.redirector.v1.AssignmentStreamRequest\x1a\".arista.redirector.v1.MetaResponse\x12\x64\n\rSubscribeMeta\x12-.arista.redirector.v1.AssignmentStreamRequest\x1a\".arista.redirector.v1.MetaResponse0\x01\x42NZLgithub.com/aristanetworks/cloudvision-go/api/arista/redirector.v1;redirectorb\x06proto3' , - dependencies=[arista_dot_redirector_dot_v1_dot_redirector__pb2.DESCRIPTOR,arista_dot_time_dot_time__pb2.DESCRIPTOR,arista_dot_subscriptions_dot_subscriptions__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,]) + dependencies=[arista_dot_redirector_dot_v1_dot_redirector__pb2.DESCRIPTOR,arista_dot_time_dot_time__pb2.DESCRIPTOR,arista_dot_subscriptions_dot_subscriptions__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,google_dot_protobuf_dot_wrappers__pb2.DESCRIPTOR,]) +_METARESPONSE = _descriptor.Descriptor( + name='MetaResponse', + full_name='arista.redirector.v1.MetaResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='time', full_name='arista.redirector.v1.MetaResponse.time', index=0, + number=1, type=11, cpp_type=10, label=1, + has_default_value=False, default_value=None, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='type', full_name='arista.redirector.v1.MetaResponse.type', index=1, + number=2, type=14, cpp_type=8, label=1, + has_default_value=False, default_value=0, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='count', full_name='arista.redirector.v1.MetaResponse.count', index=2, + number=3, type=11, cpp_type=10, label=1, + has_default_value=False, default_value=None, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=236, + serialized_end=384, +) + + _ASSIGNMENTREQUEST = _descriptor.Descriptor( name='AssignmentRequest', full_name='arista.redirector.v1.AssignmentRequest', @@ -64,8 +111,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=203, - serialized_end=314, + serialized_start=386, + serialized_end=497, ) @@ -103,8 +150,93 @@ extension_ranges=[], oneofs=[ ], - serialized_start=316, - serialized_end=427, + serialized_start=499, + serialized_end=610, +) + + +_ASSIGNMENTSOMEREQUEST = _descriptor.Descriptor( + name='AssignmentSomeRequest', + full_name='arista.redirector.v1.AssignmentSomeRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='keys', full_name='arista.redirector.v1.AssignmentSomeRequest.keys', index=0, + number=1, type=11, cpp_type=10, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='time', full_name='arista.redirector.v1.AssignmentSomeRequest.time', index=1, + number=2, type=11, cpp_type=10, label=1, + has_default_value=False, default_value=None, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=612, + serialized_end=728, +) + + +_ASSIGNMENTSOMERESPONSE = _descriptor.Descriptor( + name='AssignmentSomeResponse', + full_name='arista.redirector.v1.AssignmentSomeResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='value', full_name='arista.redirector.v1.AssignmentSomeResponse.value', index=0, + number=1, type=11, cpp_type=10, label=1, + has_default_value=False, default_value=None, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='error', full_name='arista.redirector.v1.AssignmentSomeResponse.error', index=1, + number=2, type=11, cpp_type=10, label=1, + has_default_value=False, default_value=None, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='time', full_name='arista.redirector.v1.AssignmentSomeResponse.time', index=2, + number=3, type=11, cpp_type=10, label=1, + has_default_value=False, default_value=None, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=731, + serialized_end=891, ) @@ -142,8 +274,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=429, - serialized_end=554, + serialized_start=893, + serialized_end=1018, ) @@ -188,25 +320,43 @@ extension_ranges=[], oneofs=[ ], - serialized_start=557, - serialized_end=721, + serialized_start=1021, + serialized_end=1185, ) +_METARESPONSE.fields_by_name['time'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP +_METARESPONSE.fields_by_name['type'].enum_type = arista_dot_subscriptions_dot_subscriptions__pb2._OPERATION +_METARESPONSE.fields_by_name['count'].message_type = google_dot_protobuf_dot_wrappers__pb2._UINT32VALUE _ASSIGNMENTREQUEST.fields_by_name['key'].message_type = arista_dot_redirector_dot_v1_dot_redirector__pb2._ASSIGNMENTKEY _ASSIGNMENTREQUEST.fields_by_name['time'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP _ASSIGNMENTRESPONSE.fields_by_name['value'].message_type = arista_dot_redirector_dot_v1_dot_redirector__pb2._ASSIGNMENT _ASSIGNMENTRESPONSE.fields_by_name['time'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP +_ASSIGNMENTSOMEREQUEST.fields_by_name['keys'].message_type = arista_dot_redirector_dot_v1_dot_redirector__pb2._ASSIGNMENTKEY +_ASSIGNMENTSOMEREQUEST.fields_by_name['time'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP +_ASSIGNMENTSOMERESPONSE.fields_by_name['value'].message_type = arista_dot_redirector_dot_v1_dot_redirector__pb2._ASSIGNMENT +_ASSIGNMENTSOMERESPONSE.fields_by_name['error'].message_type = google_dot_protobuf_dot_wrappers__pb2._STRINGVALUE +_ASSIGNMENTSOMERESPONSE.fields_by_name['time'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP _ASSIGNMENTSTREAMREQUEST.fields_by_name['partial_eq_filter'].message_type = arista_dot_redirector_dot_v1_dot_redirector__pb2._ASSIGNMENT _ASSIGNMENTSTREAMREQUEST.fields_by_name['time'].message_type = arista_dot_time_dot_time__pb2._TIMEBOUNDS _ASSIGNMENTSTREAMRESPONSE.fields_by_name['value'].message_type = arista_dot_redirector_dot_v1_dot_redirector__pb2._ASSIGNMENT _ASSIGNMENTSTREAMRESPONSE.fields_by_name['time'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP _ASSIGNMENTSTREAMRESPONSE.fields_by_name['type'].enum_type = arista_dot_subscriptions_dot_subscriptions__pb2._OPERATION +DESCRIPTOR.message_types_by_name['MetaResponse'] = _METARESPONSE DESCRIPTOR.message_types_by_name['AssignmentRequest'] = _ASSIGNMENTREQUEST DESCRIPTOR.message_types_by_name['AssignmentResponse'] = _ASSIGNMENTRESPONSE +DESCRIPTOR.message_types_by_name['AssignmentSomeRequest'] = _ASSIGNMENTSOMEREQUEST +DESCRIPTOR.message_types_by_name['AssignmentSomeResponse'] = _ASSIGNMENTSOMERESPONSE DESCRIPTOR.message_types_by_name['AssignmentStreamRequest'] = _ASSIGNMENTSTREAMREQUEST DESCRIPTOR.message_types_by_name['AssignmentStreamResponse'] = _ASSIGNMENTSTREAMRESPONSE _sym_db.RegisterFileDescriptor(DESCRIPTOR) +MetaResponse = _reflection.GeneratedProtocolMessageType('MetaResponse', (_message.Message,), { + 'DESCRIPTOR' : _METARESPONSE, + '__module__' : 'arista.redirector.v1.services.gen_pb2' + # @@protoc_insertion_point(class_scope:arista.redirector.v1.MetaResponse) + }) +_sym_db.RegisterMessage(MetaResponse) + AssignmentRequest = _reflection.GeneratedProtocolMessageType('AssignmentRequest', (_message.Message,), { 'DESCRIPTOR' : _ASSIGNMENTREQUEST, '__module__' : 'arista.redirector.v1.services.gen_pb2' @@ -221,6 +371,20 @@ }) _sym_db.RegisterMessage(AssignmentResponse) +AssignmentSomeRequest = _reflection.GeneratedProtocolMessageType('AssignmentSomeRequest', (_message.Message,), { + 'DESCRIPTOR' : _ASSIGNMENTSOMEREQUEST, + '__module__' : 'arista.redirector.v1.services.gen_pb2' + # @@protoc_insertion_point(class_scope:arista.redirector.v1.AssignmentSomeRequest) + }) +_sym_db.RegisterMessage(AssignmentSomeRequest) + +AssignmentSomeResponse = _reflection.GeneratedProtocolMessageType('AssignmentSomeResponse', (_message.Message,), { + 'DESCRIPTOR' : _ASSIGNMENTSOMERESPONSE, + '__module__' : 'arista.redirector.v1.services.gen_pb2' + # @@protoc_insertion_point(class_scope:arista.redirector.v1.AssignmentSomeResponse) + }) +_sym_db.RegisterMessage(AssignmentSomeResponse) + AssignmentStreamRequest = _reflection.GeneratedProtocolMessageType('AssignmentStreamRequest', (_message.Message,), { 'DESCRIPTOR' : _ASSIGNMENTSTREAMREQUEST, '__module__' : 'arista.redirector.v1.services.gen_pb2' @@ -245,8 +409,8 @@ index=0, serialized_options=None, create_key=_descriptor._internal_create_key, - serialized_start=724, - serialized_end=1053, + serialized_start=1188, + serialized_end=1817, methods=[ _descriptor.MethodDescriptor( name='GetOne', @@ -258,10 +422,20 @@ serialized_options=None, create_key=_descriptor._internal_create_key, ), + _descriptor.MethodDescriptor( + name='GetSome', + full_name='arista.redirector.v1.AssignmentService.GetSome', + index=1, + containing_service=None, + input_type=_ASSIGNMENTSOMEREQUEST, + output_type=_ASSIGNMENTSOMERESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), _descriptor.MethodDescriptor( name='GetAll', full_name='arista.redirector.v1.AssignmentService.GetAll', - index=1, + index=2, containing_service=None, input_type=_ASSIGNMENTSTREAMREQUEST, output_type=_ASSIGNMENTSTREAMRESPONSE, @@ -271,13 +445,33 @@ _descriptor.MethodDescriptor( name='Subscribe', full_name='arista.redirector.v1.AssignmentService.Subscribe', - index=2, + index=3, containing_service=None, input_type=_ASSIGNMENTSTREAMREQUEST, output_type=_ASSIGNMENTSTREAMRESPONSE, serialized_options=None, create_key=_descriptor._internal_create_key, ), + _descriptor.MethodDescriptor( + name='GetMeta', + full_name='arista.redirector.v1.AssignmentService.GetMeta', + index=4, + containing_service=None, + input_type=_ASSIGNMENTSTREAMREQUEST, + output_type=_METARESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SubscribeMeta', + full_name='arista.redirector.v1.AssignmentService.SubscribeMeta', + index=5, + containing_service=None, + input_type=_ASSIGNMENTSTREAMREQUEST, + output_type=_METARESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), ]) _sym_db.RegisterServiceDescriptor(_ASSIGNMENTSERVICE) diff --git a/arista/redirector/v1/services/gen_pb2_grpc.py b/arista/redirector/v1/services/gen_pb2_grpc.py index de0670b4..428a6250 100644 --- a/arista/redirector/v1/services/gen_pb2_grpc.py +++ b/arista/redirector/v1/services/gen_pb2_grpc.py @@ -19,6 +19,11 @@ def __init__(self, channel): request_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentRequest.SerializeToString, response_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentResponse.FromString, ) + self.GetSome = channel.unary_stream( + '/arista.redirector.v1.AssignmentService/GetSome', + request_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentSomeRequest.SerializeToString, + response_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentSomeResponse.FromString, + ) self.GetAll = channel.unary_stream( '/arista.redirector.v1.AssignmentService/GetAll', request_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.SerializeToString, @@ -29,6 +34,16 @@ def __init__(self, channel): request_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.SerializeToString, response_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamResponse.FromString, ) + self.GetMeta = channel.unary_unary( + '/arista.redirector.v1.AssignmentService/GetMeta', + request_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.SerializeToString, + response_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString, + ) + self.SubscribeMeta = channel.unary_stream( + '/arista.redirector.v1.AssignmentService/SubscribeMeta', + request_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.SerializeToString, + response_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString, + ) class AssignmentServiceServicer(object): @@ -40,6 +55,12 @@ def GetOne(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + 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!') + def GetAll(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) @@ -52,6 +73,18 @@ def Subscribe(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + def GetMeta(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def SubscribeMeta(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + def add_AssignmentServiceServicer_to_server(servicer, server): rpc_method_handlers = { @@ -60,6 +93,11 @@ def add_AssignmentServiceServicer_to_server(servicer, server): request_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentRequest.FromString, response_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentResponse.SerializeToString, ), + 'GetSome': grpc.unary_stream_rpc_method_handler( + servicer.GetSome, + request_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentSomeRequest.FromString, + response_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentSomeResponse.SerializeToString, + ), 'GetAll': grpc.unary_stream_rpc_method_handler( servicer.GetAll, request_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.FromString, @@ -70,6 +108,16 @@ def add_AssignmentServiceServicer_to_server(servicer, server): request_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.FromString, response_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamResponse.SerializeToString, ), + 'GetMeta': grpc.unary_unary_rpc_method_handler( + servicer.GetMeta, + request_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.FromString, + response_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString, + ), + 'SubscribeMeta': grpc.unary_stream_rpc_method_handler( + servicer.SubscribeMeta, + request_deserializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.FromString, + response_serializer=arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.MetaResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( 'arista.redirector.v1.AssignmentService', rpc_method_handlers) @@ -97,6 +145,23 @@ def GetOne(request, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + @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.redirector.v1.AssignmentService/GetSome', + arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentSomeRequest.SerializeToString, + arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentSomeResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + @staticmethod def GetAll(request, target, @@ -130,3 +195,37 @@ def Subscribe(request, arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamResponse.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def GetMeta(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary(request, target, '/arista.redirector.v1.AssignmentService/GetMeta', + arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.SerializeToString, + arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SubscribeMeta(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_stream(request, target, '/arista.redirector.v1.AssignmentService/SubscribeMeta', + arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.AssignmentStreamRequest.SerializeToString, + arista_dot_redirector_dot_v1_dot_services_dot_gen__pb2.MetaResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata)