diff --git a/arista/tag/v2/services/gen_pb2.py b/arista/tag/v2/services/gen_pb2.py index 6d3e3b72..16e04a78 100644 --- a/arista/tag/v2/services/gen_pb2.py +++ b/arista/tag/v2/services/gen_pb2.py @@ -20,7 +20,7 @@ from google.protobuf import wrappers_pb2 as google_dot_protobuf_dot_wrappers__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n arista/tag.v2/services.gen.proto\x12\rarista.tag.v2\x1a\x17\x61rista/tag.v2/tag.proto\x1a\x16\x61rista/time/time.proto\x1a(arista/subscriptions/subscriptions.proto\x1a\x11\x66mp/deletes.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\"Z\n\nTagRequest\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"Z\n\x0bTagResponse\x12!\n\x05value\x18\x01 \x01(\x0b\x32\x12.arista.tag.v2.Tag\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"_\n\x0eTagSomeRequest\x12#\n\x04keys\x18\x01 \x03(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x8b\x01\n\x0fTagSomeResponse\x12!\n\x05value\x18\x01 \x01(\x0b\x32\x12.arista.tag.v2.Tag\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\"h\n\x10TagStreamRequest\x12-\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x12.arista.tag.v2.Tag\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\x8f\x01\n\x11TagStreamResponse\x12!\n\x05value\x18\x01 \x01(\x0b\x32\x12.arista.tag.v2.Tag\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\"n\n\x14TagAssignmentRequest\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"n\n\x15TagAssignmentResponse\x12+\n\x05value\x18\x01 \x01(\x0b\x32\x1c.arista.tag.v2.TagAssignment\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"s\n\x18TagAssignmentSomeRequest\x12-\n\x04keys\x18\x01 \x03(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x9f\x01\n\x19TagAssignmentSomeResponse\x12+\n\x05value\x18\x01 \x01(\x0b\x32\x1c.arista.tag.v2.TagAssignment\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\x1aTagAssignmentStreamRequest\x12\x37\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x1c.arista.tag.v2.TagAssignment\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\xa3\x01\n\x1bTagAssignmentStreamResponse\x12+\n\x05value\x18\x01 \x01(\x0b\x32\x1c.arista.tag.v2.TagAssignment\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\"t\n\x1aTagAssignmentConfigRequest\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"z\n\x1bTagAssignmentConfigResponse\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"y\n\x1eTagAssignmentConfigSomeRequest\x12-\n\x04keys\x18\x01 \x03(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xab\x01\n\x1fTagAssignmentConfigSomeResponse\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\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\"\x88\x01\n TagAssignmentConfigStreamRequest\x12=\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\xaf\x01\n!TagAssignmentConfigStreamResponse\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\"R\n\x1dTagAssignmentConfigSetRequest\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\"}\n\x1eTagAssignmentConfigSetResponse\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"W\n!TagAssignmentConfigSetSomeRequest\x12\x32\n\x06values\x18\x01 \x03(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\"a\n\"TagAssignmentConfigSetSomeResponse\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"P\n TagAssignmentConfigDeleteRequest\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\"{\n!TagAssignmentConfigDeleteResponse\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"U\n$TagAssignmentConfigDeleteSomeRequest\x12-\n\x04keys\x18\x01 \x03(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\"d\n%TagAssignmentConfigDeleteSomeResponse\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"%\n#TagAssignmentConfigDeleteAllRequest\"\xcb\x01\n$TagAssignmentConfigDeleteAllResponse\x12\x1e\n\x04type\x18\x01 \x01(\x0e\x32\x10.fmp.DeleteError\x12+\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12,\n\x03key\x18\x03 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"`\n\x10TagConfigRequest\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"f\n\x11TagConfigResponse\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"e\n\x14TagConfigSomeRequest\x12#\n\x04keys\x18\x01 \x03(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x97\x01\n\x15TagConfigSomeResponse\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\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\"t\n\x16TagConfigStreamRequest\x12\x33\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x18.arista.tag.v2.TagConfig\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\x9b\x01\n\x17TagConfigStreamResponse\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\">\n\x13TagConfigSetRequest\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\"i\n\x14TagConfigSetResponse\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"C\n\x17TagConfigSetSomeRequest\x12(\n\x06values\x18\x01 \x03(\x0b\x32\x18.arista.tag.v2.TagConfig\"M\n\x18TagConfigSetSomeResponse\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"<\n\x16TagConfigDeleteRequest\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\"g\n\x17TagConfigDeleteResponse\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"A\n\x1aTagConfigDeleteSomeRequest\x12#\n\x04keys\x18\x01 \x03(\x0b\x32\x15.arista.tag.v2.TagKey\"P\n\x1bTagConfigDeleteSomeResponse\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"\x1b\n\x19TagConfigDeleteAllRequest\"\xb7\x01\n\x1aTagConfigDeleteAllResponse\x12\x1e\n\x04type\x18\x01 \x01(\x0e\x32\x10.fmp.DeleteError\x12+\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\"\n\x03key\x18\x03 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp2\xd4\x03\n\nTagService\x12?\n\x06GetOne\x12\x19.arista.tag.v2.TagRequest\x1a\x1a.arista.tag.v2.TagResponse\x12J\n\x07GetSome\x12\x1d.arista.tag.v2.TagSomeRequest\x1a\x1e.arista.tag.v2.TagSomeResponse0\x01\x12M\n\x06GetAll\x12\x1f.arista.tag.v2.TagStreamRequest\x1a .arista.tag.v2.TagStreamResponse0\x01\x12P\n\tSubscribe\x12\x1f.arista.tag.v2.TagStreamRequest\x1a .arista.tag.v2.TagStreamResponse0\x01\x12G\n\x07GetMeta\x12\x1f.arista.tag.v2.TagStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse\x12O\n\rSubscribeMeta\x12\x1f.arista.tag.v2.TagStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse0\x01\x32\xc2\x04\n\x14TagAssignmentService\x12S\n\x06GetOne\x12#.arista.tag.v2.TagAssignmentRequest\x1a$.arista.tag.v2.TagAssignmentResponse\x12^\n\x07GetSome\x12\'.arista.tag.v2.TagAssignmentSomeRequest\x1a(.arista.tag.v2.TagAssignmentSomeResponse0\x01\x12\x61\n\x06GetAll\x12).arista.tag.v2.TagAssignmentStreamRequest\x1a*.arista.tag.v2.TagAssignmentStreamResponse0\x01\x12\x64\n\tSubscribe\x12).arista.tag.v2.TagAssignmentStreamRequest\x1a*.arista.tag.v2.TagAssignmentStreamResponse0\x01\x12Q\n\x07GetMeta\x12).arista.tag.v2.TagAssignmentStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse\x12Y\n\rSubscribeMeta\x12).arista.tag.v2.TagAssignmentStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse0\x01\x32\xba\t\n\x1aTagAssignmentConfigService\x12_\n\x06GetOne\x12).arista.tag.v2.TagAssignmentConfigRequest\x1a*.arista.tag.v2.TagAssignmentConfigResponse\x12j\n\x07GetSome\x12-.arista.tag.v2.TagAssignmentConfigSomeRequest\x1a..arista.tag.v2.TagAssignmentConfigSomeResponse0\x01\x12m\n\x06GetAll\x12/.arista.tag.v2.TagAssignmentConfigStreamRequest\x1a\x30.arista.tag.v2.TagAssignmentConfigStreamResponse0\x01\x12p\n\tSubscribe\x12/.arista.tag.v2.TagAssignmentConfigStreamRequest\x1a\x30.arista.tag.v2.TagAssignmentConfigStreamResponse0\x01\x12W\n\x07GetMeta\x12/.arista.tag.v2.TagAssignmentConfigStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse\x12_\n\rSubscribeMeta\x12/.arista.tag.v2.TagAssignmentConfigStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse0\x01\x12\x62\n\x03Set\x12,.arista.tag.v2.TagAssignmentConfigSetRequest\x1a-.arista.tag.v2.TagAssignmentConfigSetResponse\x12p\n\x07SetSome\x12\x30.arista.tag.v2.TagAssignmentConfigSetSomeRequest\x1a\x31.arista.tag.v2.TagAssignmentConfigSetSomeResponse0\x01\x12k\n\x06\x44\x65lete\x12/.arista.tag.v2.TagAssignmentConfigDeleteRequest\x1a\x30.arista.tag.v2.TagAssignmentConfigDeleteResponse\x12y\n\nDeleteSome\x12\x33.arista.tag.v2.TagAssignmentConfigDeleteSomeRequest\x1a\x34.arista.tag.v2.TagAssignmentConfigDeleteSomeResponse0\x01\x12v\n\tDeleteAll\x12\x32.arista.tag.v2.TagAssignmentConfigDeleteAllRequest\x1a\x33.arista.tag.v2.TagAssignmentConfigDeleteAllResponse0\x01\x32\xe8\x07\n\x10TagConfigService\x12K\n\x06GetOne\x12\x1f.arista.tag.v2.TagConfigRequest\x1a .arista.tag.v2.TagConfigResponse\x12V\n\x07GetSome\x12#.arista.tag.v2.TagConfigSomeRequest\x1a$.arista.tag.v2.TagConfigSomeResponse0\x01\x12Y\n\x06GetAll\x12%.arista.tag.v2.TagConfigStreamRequest\x1a&.arista.tag.v2.TagConfigStreamResponse0\x01\x12\\\n\tSubscribe\x12%.arista.tag.v2.TagConfigStreamRequest\x1a&.arista.tag.v2.TagConfigStreamResponse0\x01\x12M\n\x07GetMeta\x12%.arista.tag.v2.TagConfigStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse\x12U\n\rSubscribeMeta\x12%.arista.tag.v2.TagConfigStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse0\x01\x12N\n\x03Set\x12\".arista.tag.v2.TagConfigSetRequest\x1a#.arista.tag.v2.TagConfigSetResponse\x12\\\n\x07SetSome\x12&.arista.tag.v2.TagConfigSetSomeRequest\x1a\'.arista.tag.v2.TagConfigSetSomeResponse0\x01\x12W\n\x06\x44\x65lete\x12%.arista.tag.v2.TagConfigDeleteRequest\x1a&.arista.tag.v2.TagConfigDeleteResponse\x12\x65\n\nDeleteSome\x12).arista.tag.v2.TagConfigDeleteSomeRequest\x1a*.arista.tag.v2.TagConfigDeleteSomeResponse0\x01\x12\x62\n\tDeleteAll\x12(.arista.tag.v2.TagConfigDeleteAllRequest\x1a).arista.tag.v2.TagConfigDeleteAllResponse0\x01\x42@Z>github.com/aristanetworks/cloudvision-go/api/arista/tag.v2;tagb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n arista/tag.v2/services.gen.proto\x12\rarista.tag.v2\x1a\x17\x61rista/tag.v2/tag.proto\x1a\x16\x61rista/time/time.proto\x1a(arista/subscriptions/subscriptions.proto\x1a\x11\x66mp/deletes.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\"Z\n\nTagRequest\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"Z\n\x0bTagResponse\x12!\n\x05value\x18\x01 \x01(\x0b\x32\x12.arista.tag.v2.Tag\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"_\n\x0eTagSomeRequest\x12#\n\x04keys\x18\x01 \x03(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x8b\x01\n\x0fTagSomeResponse\x12!\n\x05value\x18\x01 \x01(\x0b\x32\x12.arista.tag.v2.Tag\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\"h\n\x10TagStreamRequest\x12-\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x12.arista.tag.v2.Tag\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\x8f\x01\n\x11TagStreamResponse\x12!\n\x05value\x18\x01 \x01(\x0b\x32\x12.arista.tag.v2.Tag\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\"\xa3\x01\n\x17TagBatchedStreamRequest\x12-\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x12.arista.tag.v2.Tag\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\x12\x32\n\x0cmax_messages\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.UInt32Value\"O\n\x18TagBatchedStreamResponse\x12\x33\n\tresponses\x18\x01 \x03(\x0b\x32 .arista.tag.v2.TagStreamResponse\"n\n\x14TagAssignmentRequest\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"n\n\x15TagAssignmentResponse\x12+\n\x05value\x18\x01 \x01(\x0b\x32\x1c.arista.tag.v2.TagAssignment\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"s\n\x18TagAssignmentSomeRequest\x12-\n\x04keys\x18\x01 \x03(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x9f\x01\n\x19TagAssignmentSomeResponse\x12+\n\x05value\x18\x01 \x01(\x0b\x32\x1c.arista.tag.v2.TagAssignment\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\x1aTagAssignmentStreamRequest\x12\x37\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x1c.arista.tag.v2.TagAssignment\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\xa3\x01\n\x1bTagAssignmentStreamResponse\x12+\n\x05value\x18\x01 \x01(\x0b\x32\x1c.arista.tag.v2.TagAssignment\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\"\xb7\x01\n!TagAssignmentBatchedStreamRequest\x12\x37\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x1c.arista.tag.v2.TagAssignment\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\x12\x32\n\x0cmax_messages\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.UInt32Value\"c\n\"TagAssignmentBatchedStreamResponse\x12=\n\tresponses\x18\x01 \x03(\x0b\x32*.arista.tag.v2.TagAssignmentStreamResponse\"t\n\x1aTagAssignmentConfigRequest\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"z\n\x1bTagAssignmentConfigResponse\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"y\n\x1eTagAssignmentConfigSomeRequest\x12-\n\x04keys\x18\x01 \x03(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xab\x01\n\x1fTagAssignmentConfigSomeResponse\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\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\"\x88\x01\n TagAssignmentConfigStreamRequest\x12=\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\xaf\x01\n!TagAssignmentConfigStreamResponse\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\"\xc3\x01\n\'TagAssignmentConfigBatchedStreamRequest\x12=\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\x12\x32\n\x0cmax_messages\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.UInt32Value\"o\n(TagAssignmentConfigBatchedStreamResponse\x12\x43\n\tresponses\x18\x01 \x03(\x0b\x32\x30.arista.tag.v2.TagAssignmentConfigStreamResponse\"R\n\x1dTagAssignmentConfigSetRequest\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\"}\n\x1eTagAssignmentConfigSetResponse\x12\x31\n\x05value\x18\x01 \x01(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"W\n!TagAssignmentConfigSetSomeRequest\x12\x32\n\x06values\x18\x01 \x03(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\"a\n\"TagAssignmentConfigSetSomeResponse\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"P\n TagAssignmentConfigDeleteRequest\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\"{\n!TagAssignmentConfigDeleteResponse\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"U\n$TagAssignmentConfigDeleteSomeRequest\x12-\n\x04keys\x18\x01 \x03(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\"d\n%TagAssignmentConfigDeleteSomeResponse\x12,\n\x03key\x18\x01 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"d\n#TagAssignmentConfigDeleteAllRequest\x12=\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\".arista.tag.v2.TagAssignmentConfig\"\xcb\x01\n$TagAssignmentConfigDeleteAllResponse\x12\x1e\n\x04type\x18\x01 \x01(\x0e\x32\x10.fmp.DeleteError\x12+\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12,\n\x03key\x18\x03 \x01(\x0b\x32\x1f.arista.tag.v2.TagAssignmentKey\x12(\n\x04time\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"`\n\x10TagConfigRequest\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"f\n\x11TagConfigResponse\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"e\n\x14TagConfigSomeRequest\x12#\n\x04keys\x18\x01 \x03(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x97\x01\n\x15TagConfigSomeResponse\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\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\"t\n\x16TagConfigStreamRequest\x12\x33\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x18.arista.tag.v2.TagConfig\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\"\x9b\x01\n\x17TagConfigStreamResponse\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x1f.arista.subscriptions.Operation\"\xaf\x01\n\x1dTagConfigBatchedStreamRequest\x12\x33\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x18.arista.tag.v2.TagConfig\x12%\n\x04time\x18\x03 \x01(\x0b\x32\x17.arista.time.TimeBounds\x12\x32\n\x0cmax_messages\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.UInt32Value\"[\n\x1eTagConfigBatchedStreamResponse\x12\x39\n\tresponses\x18\x01 \x03(\x0b\x32&.arista.tag.v2.TagConfigStreamResponse\">\n\x13TagConfigSetRequest\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\"i\n\x14TagConfigSetResponse\x12\'\n\x05value\x18\x01 \x01(\x0b\x32\x18.arista.tag.v2.TagConfig\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"C\n\x17TagConfigSetSomeRequest\x12(\n\x06values\x18\x01 \x03(\x0b\x32\x18.arista.tag.v2.TagConfig\"M\n\x18TagConfigSetSomeResponse\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"<\n\x16TagConfigDeleteRequest\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\"g\n\x17TagConfigDeleteResponse\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"A\n\x1aTagConfigDeleteSomeRequest\x12#\n\x04keys\x18\x01 \x03(\x0b\x32\x15.arista.tag.v2.TagKey\"P\n\x1bTagConfigDeleteSomeResponse\x12\"\n\x03key\x18\x01 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"P\n\x19TagConfigDeleteAllRequest\x12\x33\n\x11partial_eq_filter\x18\x01 \x03(\x0b\x32\x18.arista.tag.v2.TagConfig\"\xb7\x01\n\x1aTagConfigDeleteAllResponse\x12\x1e\n\x04type\x18\x01 \x01(\x0e\x32\x10.fmp.DeleteError\x12+\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\"\n\x03key\x18\x03 \x01(\x0b\x32\x15.arista.tag.v2.TagKey\x12(\n\x04time\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp2\x9f\x05\n\nTagService\x12?\n\x06GetOne\x12\x19.arista.tag.v2.TagRequest\x1a\x1a.arista.tag.v2.TagResponse\x12J\n\x07GetSome\x12\x1d.arista.tag.v2.TagSomeRequest\x1a\x1e.arista.tag.v2.TagSomeResponse0\x01\x12M\n\x06GetAll\x12\x1f.arista.tag.v2.TagStreamRequest\x1a .arista.tag.v2.TagStreamResponse0\x01\x12P\n\tSubscribe\x12\x1f.arista.tag.v2.TagStreamRequest\x1a .arista.tag.v2.TagStreamResponse0\x01\x12G\n\x07GetMeta\x12\x1f.arista.tag.v2.TagStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse\x12O\n\rSubscribeMeta\x12\x1f.arista.tag.v2.TagStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse0\x01\x12\x62\n\rGetAllBatched\x12&.arista.tag.v2.TagBatchedStreamRequest\x1a\'.arista.tag.v2.TagBatchedStreamResponse0\x01\x12\x65\n\x10SubscribeBatched\x12&.arista.tag.v2.TagBatchedStreamRequest\x1a\'.arista.tag.v2.TagBatchedStreamResponse0\x01\x32\xb5\x06\n\x14TagAssignmentService\x12S\n\x06GetOne\x12#.arista.tag.v2.TagAssignmentRequest\x1a$.arista.tag.v2.TagAssignmentResponse\x12^\n\x07GetSome\x12\'.arista.tag.v2.TagAssignmentSomeRequest\x1a(.arista.tag.v2.TagAssignmentSomeResponse0\x01\x12\x61\n\x06GetAll\x12).arista.tag.v2.TagAssignmentStreamRequest\x1a*.arista.tag.v2.TagAssignmentStreamResponse0\x01\x12\x64\n\tSubscribe\x12).arista.tag.v2.TagAssignmentStreamRequest\x1a*.arista.tag.v2.TagAssignmentStreamResponse0\x01\x12Q\n\x07GetMeta\x12).arista.tag.v2.TagAssignmentStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse\x12Y\n\rSubscribeMeta\x12).arista.tag.v2.TagAssignmentStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse0\x01\x12v\n\rGetAllBatched\x12\x30.arista.tag.v2.TagAssignmentBatchedStreamRequest\x1a\x31.arista.tag.v2.TagAssignmentBatchedStreamResponse0\x01\x12y\n\x10SubscribeBatched\x12\x30.arista.tag.v2.TagAssignmentBatchedStreamRequest\x1a\x31.arista.tag.v2.TagAssignmentBatchedStreamResponse0\x01\x32\xc7\x0b\n\x1aTagAssignmentConfigService\x12_\n\x06GetOne\x12).arista.tag.v2.TagAssignmentConfigRequest\x1a*.arista.tag.v2.TagAssignmentConfigResponse\x12j\n\x07GetSome\x12-.arista.tag.v2.TagAssignmentConfigSomeRequest\x1a..arista.tag.v2.TagAssignmentConfigSomeResponse0\x01\x12m\n\x06GetAll\x12/.arista.tag.v2.TagAssignmentConfigStreamRequest\x1a\x30.arista.tag.v2.TagAssignmentConfigStreamResponse0\x01\x12p\n\tSubscribe\x12/.arista.tag.v2.TagAssignmentConfigStreamRequest\x1a\x30.arista.tag.v2.TagAssignmentConfigStreamResponse0\x01\x12W\n\x07GetMeta\x12/.arista.tag.v2.TagAssignmentConfigStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse\x12_\n\rSubscribeMeta\x12/.arista.tag.v2.TagAssignmentConfigStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse0\x01\x12\x62\n\x03Set\x12,.arista.tag.v2.TagAssignmentConfigSetRequest\x1a-.arista.tag.v2.TagAssignmentConfigSetResponse\x12p\n\x07SetSome\x12\x30.arista.tag.v2.TagAssignmentConfigSetSomeRequest\x1a\x31.arista.tag.v2.TagAssignmentConfigSetSomeResponse0\x01\x12k\n\x06\x44\x65lete\x12/.arista.tag.v2.TagAssignmentConfigDeleteRequest\x1a\x30.arista.tag.v2.TagAssignmentConfigDeleteResponse\x12y\n\nDeleteSome\x12\x33.arista.tag.v2.TagAssignmentConfigDeleteSomeRequest\x1a\x34.arista.tag.v2.TagAssignmentConfigDeleteSomeResponse0\x01\x12v\n\tDeleteAll\x12\x32.arista.tag.v2.TagAssignmentConfigDeleteAllRequest\x1a\x33.arista.tag.v2.TagAssignmentConfigDeleteAllResponse0\x01\x12\x82\x01\n\rGetAllBatched\x12\x36.arista.tag.v2.TagAssignmentConfigBatchedStreamRequest\x1a\x37.arista.tag.v2.TagAssignmentConfigBatchedStreamResponse0\x01\x12\x85\x01\n\x10SubscribeBatched\x12\x36.arista.tag.v2.TagAssignmentConfigBatchedStreamRequest\x1a\x37.arista.tag.v2.TagAssignmentConfigBatchedStreamResponse0\x01\x32\xcb\t\n\x10TagConfigService\x12K\n\x06GetOne\x12\x1f.arista.tag.v2.TagConfigRequest\x1a .arista.tag.v2.TagConfigResponse\x12V\n\x07GetSome\x12#.arista.tag.v2.TagConfigSomeRequest\x1a$.arista.tag.v2.TagConfigSomeResponse0\x01\x12Y\n\x06GetAll\x12%.arista.tag.v2.TagConfigStreamRequest\x1a&.arista.tag.v2.TagConfigStreamResponse0\x01\x12\\\n\tSubscribe\x12%.arista.tag.v2.TagConfigStreamRequest\x1a&.arista.tag.v2.TagConfigStreamResponse0\x01\x12M\n\x07GetMeta\x12%.arista.tag.v2.TagConfigStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse\x12U\n\rSubscribeMeta\x12%.arista.tag.v2.TagConfigStreamRequest\x1a\x1b.arista.tag.v2.MetaResponse0\x01\x12N\n\x03Set\x12\".arista.tag.v2.TagConfigSetRequest\x1a#.arista.tag.v2.TagConfigSetResponse\x12\\\n\x07SetSome\x12&.arista.tag.v2.TagConfigSetSomeRequest\x1a\'.arista.tag.v2.TagConfigSetSomeResponse0\x01\x12W\n\x06\x44\x65lete\x12%.arista.tag.v2.TagConfigDeleteRequest\x1a&.arista.tag.v2.TagConfigDeleteResponse\x12\x65\n\nDeleteSome\x12).arista.tag.v2.TagConfigDeleteSomeRequest\x1a*.arista.tag.v2.TagConfigDeleteSomeResponse0\x01\x12\x62\n\tDeleteAll\x12(.arista.tag.v2.TagConfigDeleteAllRequest\x1a).arista.tag.v2.TagConfigDeleteAllResponse0\x01\x12n\n\rGetAllBatched\x12,.arista.tag.v2.TagConfigBatchedStreamRequest\x1a-.arista.tag.v2.TagConfigBatchedStreamResponse0\x01\x12q\n\x10SubscribeBatched\x12,.arista.tag.v2.TagConfigBatchedStreamRequest\x1a-.arista.tag.v2.TagConfigBatchedStreamResponse0\x01\x42@Z>github.com/aristanetworks/cloudvision-go/api/arista/tag.v2;tagb\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -42,88 +42,104 @@ _globals['_TAGSTREAMREQUEST']._serialized_end=904 _globals['_TAGSTREAMRESPONSE']._serialized_start=907 _globals['_TAGSTREAMRESPONSE']._serialized_end=1050 - _globals['_TAGASSIGNMENTREQUEST']._serialized_start=1052 - _globals['_TAGASSIGNMENTREQUEST']._serialized_end=1162 - _globals['_TAGASSIGNMENTRESPONSE']._serialized_start=1164 - _globals['_TAGASSIGNMENTRESPONSE']._serialized_end=1274 - _globals['_TAGASSIGNMENTSOMEREQUEST']._serialized_start=1276 - _globals['_TAGASSIGNMENTSOMEREQUEST']._serialized_end=1391 - _globals['_TAGASSIGNMENTSOMERESPONSE']._serialized_start=1394 - _globals['_TAGASSIGNMENTSOMERESPONSE']._serialized_end=1553 - _globals['_TAGASSIGNMENTSTREAMREQUEST']._serialized_start=1555 - _globals['_TAGASSIGNMENTSTREAMREQUEST']._serialized_end=1679 - _globals['_TAGASSIGNMENTSTREAMRESPONSE']._serialized_start=1682 - _globals['_TAGASSIGNMENTSTREAMRESPONSE']._serialized_end=1845 - _globals['_TAGASSIGNMENTCONFIGREQUEST']._serialized_start=1847 - _globals['_TAGASSIGNMENTCONFIGREQUEST']._serialized_end=1963 - _globals['_TAGASSIGNMENTCONFIGRESPONSE']._serialized_start=1965 - _globals['_TAGASSIGNMENTCONFIGRESPONSE']._serialized_end=2087 - _globals['_TAGASSIGNMENTCONFIGSOMEREQUEST']._serialized_start=2089 - _globals['_TAGASSIGNMENTCONFIGSOMEREQUEST']._serialized_end=2210 - _globals['_TAGASSIGNMENTCONFIGSOMERESPONSE']._serialized_start=2213 - _globals['_TAGASSIGNMENTCONFIGSOMERESPONSE']._serialized_end=2384 - _globals['_TAGASSIGNMENTCONFIGSTREAMREQUEST']._serialized_start=2387 - _globals['_TAGASSIGNMENTCONFIGSTREAMREQUEST']._serialized_end=2523 - _globals['_TAGASSIGNMENTCONFIGSTREAMRESPONSE']._serialized_start=2526 - _globals['_TAGASSIGNMENTCONFIGSTREAMRESPONSE']._serialized_end=2701 - _globals['_TAGASSIGNMENTCONFIGSETREQUEST']._serialized_start=2703 - _globals['_TAGASSIGNMENTCONFIGSETREQUEST']._serialized_end=2785 - _globals['_TAGASSIGNMENTCONFIGSETRESPONSE']._serialized_start=2787 - _globals['_TAGASSIGNMENTCONFIGSETRESPONSE']._serialized_end=2912 - _globals['_TAGASSIGNMENTCONFIGSETSOMEREQUEST']._serialized_start=2914 - _globals['_TAGASSIGNMENTCONFIGSETSOMEREQUEST']._serialized_end=3001 - _globals['_TAGASSIGNMENTCONFIGSETSOMERESPONSE']._serialized_start=3003 - _globals['_TAGASSIGNMENTCONFIGSETSOMERESPONSE']._serialized_end=3100 - _globals['_TAGASSIGNMENTCONFIGDELETEREQUEST']._serialized_start=3102 - _globals['_TAGASSIGNMENTCONFIGDELETEREQUEST']._serialized_end=3182 - _globals['_TAGASSIGNMENTCONFIGDELETERESPONSE']._serialized_start=3184 - _globals['_TAGASSIGNMENTCONFIGDELETERESPONSE']._serialized_end=3307 - _globals['_TAGASSIGNMENTCONFIGDELETESOMEREQUEST']._serialized_start=3309 - _globals['_TAGASSIGNMENTCONFIGDELETESOMEREQUEST']._serialized_end=3394 - _globals['_TAGASSIGNMENTCONFIGDELETESOMERESPONSE']._serialized_start=3396 - _globals['_TAGASSIGNMENTCONFIGDELETESOMERESPONSE']._serialized_end=3496 - _globals['_TAGASSIGNMENTCONFIGDELETEALLREQUEST']._serialized_start=3498 - _globals['_TAGASSIGNMENTCONFIGDELETEALLREQUEST']._serialized_end=3535 - _globals['_TAGASSIGNMENTCONFIGDELETEALLRESPONSE']._serialized_start=3538 - _globals['_TAGASSIGNMENTCONFIGDELETEALLRESPONSE']._serialized_end=3741 - _globals['_TAGCONFIGREQUEST']._serialized_start=3743 - _globals['_TAGCONFIGREQUEST']._serialized_end=3839 - _globals['_TAGCONFIGRESPONSE']._serialized_start=3841 - _globals['_TAGCONFIGRESPONSE']._serialized_end=3943 - _globals['_TAGCONFIGSOMEREQUEST']._serialized_start=3945 - _globals['_TAGCONFIGSOMEREQUEST']._serialized_end=4046 - _globals['_TAGCONFIGSOMERESPONSE']._serialized_start=4049 - _globals['_TAGCONFIGSOMERESPONSE']._serialized_end=4200 - _globals['_TAGCONFIGSTREAMREQUEST']._serialized_start=4202 - _globals['_TAGCONFIGSTREAMREQUEST']._serialized_end=4318 - _globals['_TAGCONFIGSTREAMRESPONSE']._serialized_start=4321 - _globals['_TAGCONFIGSTREAMRESPONSE']._serialized_end=4476 - _globals['_TAGCONFIGSETREQUEST']._serialized_start=4478 - _globals['_TAGCONFIGSETREQUEST']._serialized_end=4540 - _globals['_TAGCONFIGSETRESPONSE']._serialized_start=4542 - _globals['_TAGCONFIGSETRESPONSE']._serialized_end=4647 - _globals['_TAGCONFIGSETSOMEREQUEST']._serialized_start=4649 - _globals['_TAGCONFIGSETSOMEREQUEST']._serialized_end=4716 - _globals['_TAGCONFIGSETSOMERESPONSE']._serialized_start=4718 - _globals['_TAGCONFIGSETSOMERESPONSE']._serialized_end=4795 - _globals['_TAGCONFIGDELETEREQUEST']._serialized_start=4797 - _globals['_TAGCONFIGDELETEREQUEST']._serialized_end=4857 - _globals['_TAGCONFIGDELETERESPONSE']._serialized_start=4859 - _globals['_TAGCONFIGDELETERESPONSE']._serialized_end=4962 - _globals['_TAGCONFIGDELETESOMEREQUEST']._serialized_start=4964 - _globals['_TAGCONFIGDELETESOMEREQUEST']._serialized_end=5029 - _globals['_TAGCONFIGDELETESOMERESPONSE']._serialized_start=5031 - _globals['_TAGCONFIGDELETESOMERESPONSE']._serialized_end=5111 - _globals['_TAGCONFIGDELETEALLREQUEST']._serialized_start=5113 - _globals['_TAGCONFIGDELETEALLREQUEST']._serialized_end=5140 - _globals['_TAGCONFIGDELETEALLRESPONSE']._serialized_start=5143 - _globals['_TAGCONFIGDELETEALLRESPONSE']._serialized_end=5326 - _globals['_TAGSERVICE']._serialized_start=5329 - _globals['_TAGSERVICE']._serialized_end=5797 - _globals['_TAGASSIGNMENTSERVICE']._serialized_start=5800 - _globals['_TAGASSIGNMENTSERVICE']._serialized_end=6378 - _globals['_TAGASSIGNMENTCONFIGSERVICE']._serialized_start=6381 - _globals['_TAGASSIGNMENTCONFIGSERVICE']._serialized_end=7591 - _globals['_TAGCONFIGSERVICE']._serialized_start=7594 - _globals['_TAGCONFIGSERVICE']._serialized_end=8594 + _globals['_TAGBATCHEDSTREAMREQUEST']._serialized_start=1053 + _globals['_TAGBATCHEDSTREAMREQUEST']._serialized_end=1216 + _globals['_TAGBATCHEDSTREAMRESPONSE']._serialized_start=1218 + _globals['_TAGBATCHEDSTREAMRESPONSE']._serialized_end=1297 + _globals['_TAGASSIGNMENTREQUEST']._serialized_start=1299 + _globals['_TAGASSIGNMENTREQUEST']._serialized_end=1409 + _globals['_TAGASSIGNMENTRESPONSE']._serialized_start=1411 + _globals['_TAGASSIGNMENTRESPONSE']._serialized_end=1521 + _globals['_TAGASSIGNMENTSOMEREQUEST']._serialized_start=1523 + _globals['_TAGASSIGNMENTSOMEREQUEST']._serialized_end=1638 + _globals['_TAGASSIGNMENTSOMERESPONSE']._serialized_start=1641 + _globals['_TAGASSIGNMENTSOMERESPONSE']._serialized_end=1800 + _globals['_TAGASSIGNMENTSTREAMREQUEST']._serialized_start=1802 + _globals['_TAGASSIGNMENTSTREAMREQUEST']._serialized_end=1926 + _globals['_TAGASSIGNMENTSTREAMRESPONSE']._serialized_start=1929 + _globals['_TAGASSIGNMENTSTREAMRESPONSE']._serialized_end=2092 + _globals['_TAGASSIGNMENTBATCHEDSTREAMREQUEST']._serialized_start=2095 + _globals['_TAGASSIGNMENTBATCHEDSTREAMREQUEST']._serialized_end=2278 + _globals['_TAGASSIGNMENTBATCHEDSTREAMRESPONSE']._serialized_start=2280 + _globals['_TAGASSIGNMENTBATCHEDSTREAMRESPONSE']._serialized_end=2379 + _globals['_TAGASSIGNMENTCONFIGREQUEST']._serialized_start=2381 + _globals['_TAGASSIGNMENTCONFIGREQUEST']._serialized_end=2497 + _globals['_TAGASSIGNMENTCONFIGRESPONSE']._serialized_start=2499 + _globals['_TAGASSIGNMENTCONFIGRESPONSE']._serialized_end=2621 + _globals['_TAGASSIGNMENTCONFIGSOMEREQUEST']._serialized_start=2623 + _globals['_TAGASSIGNMENTCONFIGSOMEREQUEST']._serialized_end=2744 + _globals['_TAGASSIGNMENTCONFIGSOMERESPONSE']._serialized_start=2747 + _globals['_TAGASSIGNMENTCONFIGSOMERESPONSE']._serialized_end=2918 + _globals['_TAGASSIGNMENTCONFIGSTREAMREQUEST']._serialized_start=2921 + _globals['_TAGASSIGNMENTCONFIGSTREAMREQUEST']._serialized_end=3057 + _globals['_TAGASSIGNMENTCONFIGSTREAMRESPONSE']._serialized_start=3060 + _globals['_TAGASSIGNMENTCONFIGSTREAMRESPONSE']._serialized_end=3235 + _globals['_TAGASSIGNMENTCONFIGBATCHEDSTREAMREQUEST']._serialized_start=3238 + _globals['_TAGASSIGNMENTCONFIGBATCHEDSTREAMREQUEST']._serialized_end=3433 + _globals['_TAGASSIGNMENTCONFIGBATCHEDSTREAMRESPONSE']._serialized_start=3435 + _globals['_TAGASSIGNMENTCONFIGBATCHEDSTREAMRESPONSE']._serialized_end=3546 + _globals['_TAGASSIGNMENTCONFIGSETREQUEST']._serialized_start=3548 + _globals['_TAGASSIGNMENTCONFIGSETREQUEST']._serialized_end=3630 + _globals['_TAGASSIGNMENTCONFIGSETRESPONSE']._serialized_start=3632 + _globals['_TAGASSIGNMENTCONFIGSETRESPONSE']._serialized_end=3757 + _globals['_TAGASSIGNMENTCONFIGSETSOMEREQUEST']._serialized_start=3759 + _globals['_TAGASSIGNMENTCONFIGSETSOMEREQUEST']._serialized_end=3846 + _globals['_TAGASSIGNMENTCONFIGSETSOMERESPONSE']._serialized_start=3848 + _globals['_TAGASSIGNMENTCONFIGSETSOMERESPONSE']._serialized_end=3945 + _globals['_TAGASSIGNMENTCONFIGDELETEREQUEST']._serialized_start=3947 + _globals['_TAGASSIGNMENTCONFIGDELETEREQUEST']._serialized_end=4027 + _globals['_TAGASSIGNMENTCONFIGDELETERESPONSE']._serialized_start=4029 + _globals['_TAGASSIGNMENTCONFIGDELETERESPONSE']._serialized_end=4152 + _globals['_TAGASSIGNMENTCONFIGDELETESOMEREQUEST']._serialized_start=4154 + _globals['_TAGASSIGNMENTCONFIGDELETESOMEREQUEST']._serialized_end=4239 + _globals['_TAGASSIGNMENTCONFIGDELETESOMERESPONSE']._serialized_start=4241 + _globals['_TAGASSIGNMENTCONFIGDELETESOMERESPONSE']._serialized_end=4341 + _globals['_TAGASSIGNMENTCONFIGDELETEALLREQUEST']._serialized_start=4343 + _globals['_TAGASSIGNMENTCONFIGDELETEALLREQUEST']._serialized_end=4443 + _globals['_TAGASSIGNMENTCONFIGDELETEALLRESPONSE']._serialized_start=4446 + _globals['_TAGASSIGNMENTCONFIGDELETEALLRESPONSE']._serialized_end=4649 + _globals['_TAGCONFIGREQUEST']._serialized_start=4651 + _globals['_TAGCONFIGREQUEST']._serialized_end=4747 + _globals['_TAGCONFIGRESPONSE']._serialized_start=4749 + _globals['_TAGCONFIGRESPONSE']._serialized_end=4851 + _globals['_TAGCONFIGSOMEREQUEST']._serialized_start=4853 + _globals['_TAGCONFIGSOMEREQUEST']._serialized_end=4954 + _globals['_TAGCONFIGSOMERESPONSE']._serialized_start=4957 + _globals['_TAGCONFIGSOMERESPONSE']._serialized_end=5108 + _globals['_TAGCONFIGSTREAMREQUEST']._serialized_start=5110 + _globals['_TAGCONFIGSTREAMREQUEST']._serialized_end=5226 + _globals['_TAGCONFIGSTREAMRESPONSE']._serialized_start=5229 + _globals['_TAGCONFIGSTREAMRESPONSE']._serialized_end=5384 + _globals['_TAGCONFIGBATCHEDSTREAMREQUEST']._serialized_start=5387 + _globals['_TAGCONFIGBATCHEDSTREAMREQUEST']._serialized_end=5562 + _globals['_TAGCONFIGBATCHEDSTREAMRESPONSE']._serialized_start=5564 + _globals['_TAGCONFIGBATCHEDSTREAMRESPONSE']._serialized_end=5655 + _globals['_TAGCONFIGSETREQUEST']._serialized_start=5657 + _globals['_TAGCONFIGSETREQUEST']._serialized_end=5719 + _globals['_TAGCONFIGSETRESPONSE']._serialized_start=5721 + _globals['_TAGCONFIGSETRESPONSE']._serialized_end=5826 + _globals['_TAGCONFIGSETSOMEREQUEST']._serialized_start=5828 + _globals['_TAGCONFIGSETSOMEREQUEST']._serialized_end=5895 + _globals['_TAGCONFIGSETSOMERESPONSE']._serialized_start=5897 + _globals['_TAGCONFIGSETSOMERESPONSE']._serialized_end=5974 + _globals['_TAGCONFIGDELETEREQUEST']._serialized_start=5976 + _globals['_TAGCONFIGDELETEREQUEST']._serialized_end=6036 + _globals['_TAGCONFIGDELETERESPONSE']._serialized_start=6038 + _globals['_TAGCONFIGDELETERESPONSE']._serialized_end=6141 + _globals['_TAGCONFIGDELETESOMEREQUEST']._serialized_start=6143 + _globals['_TAGCONFIGDELETESOMEREQUEST']._serialized_end=6208 + _globals['_TAGCONFIGDELETESOMERESPONSE']._serialized_start=6210 + _globals['_TAGCONFIGDELETESOMERESPONSE']._serialized_end=6290 + _globals['_TAGCONFIGDELETEALLREQUEST']._serialized_start=6292 + _globals['_TAGCONFIGDELETEALLREQUEST']._serialized_end=6372 + _globals['_TAGCONFIGDELETEALLRESPONSE']._serialized_start=6375 + _globals['_TAGCONFIGDELETEALLRESPONSE']._serialized_end=6558 + _globals['_TAGSERVICE']._serialized_start=6561 + _globals['_TAGSERVICE']._serialized_end=7232 + _globals['_TAGASSIGNMENTSERVICE']._serialized_start=7235 + _globals['_TAGASSIGNMENTSERVICE']._serialized_end=8056 + _globals['_TAGASSIGNMENTCONFIGSERVICE']._serialized_start=8059 + _globals['_TAGASSIGNMENTCONFIGSERVICE']._serialized_end=9538 + _globals['_TAGCONFIGSERVICE']._serialized_start=9541 + _globals['_TAGCONFIGSERVICE']._serialized_end=10768 # @@protoc_insertion_point(module_scope) diff --git a/arista/tag/v2/services/gen_pb2.pyi b/arista/tag/v2/services/gen_pb2.pyi index 47349c28..b7249f91 100644 --- a/arista/tag/v2/services/gen_pb2.pyi +++ b/arista/tag/v2/services/gen_pb2.pyi @@ -225,6 +225,74 @@ class TagStreamResponse(google.protobuf.message.Message): def ClearField(self, field_name: typing_extensions.Literal["time",b"time","type",b"type","value",b"value"]) -> None: ... global___TagStreamResponse = TagStreamResponse +class TagBatchedStreamRequest(google.protobuf.message.Message): + DESCRIPTOR: google.protobuf.descriptor.Descriptor + PARTIAL_EQ_FILTER_FIELD_NUMBER: builtins.int + TIME_FIELD_NUMBER: builtins.int + MAX_MESSAGES_FIELD_NUMBER: builtins.int + @property + def partial_eq_filter(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[arista.tag.v2.tag_pb2.Tag]: + """PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. + This requires all provided fields to be equal to the response. + + While transparent to users, this field also allows services to optimize internal + subscriptions if filter(s) are sufficiently specific. + """ + pass + @property + def time(self) -> arista.time.time_pb2.TimeBounds: + """TimeRange allows limiting response data to within a specified time window. + If this field is populated, at least one of the two time fields are required. + + For GetAll, the fields start and end can be used as follows: + + * end: Returns the state of each Tag at end. + * Each Tag response is fully-specified (all fields set). + * start: Returns the state of each Tag at start, followed by updates until now. + * Each Tag response at start is fully-specified, but updates may be partial. + * start and end: Returns the state of each Tag at start, followed by updates + until end. + * Each Tag response at start is fully-specified, but updates until end may + be partial. + + This field is not allowed in the Subscribe RPC. + """ + pass + @property + def max_messages(self) -> google.protobuf.wrappers_pb2.UInt32Value: + """MaxMessages limits the maximum number of messages that can be contained in one batch. + MaxMessages is required to be at least 1. + The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT) + INTERNAL_BATCH_LIMIT is set based on the maximum message size. + """ + pass + def __init__(self, + *, + partial_eq_filter: typing.Optional[typing.Iterable[arista.tag.v2.tag_pb2.Tag]] = ..., + time: typing.Optional[arista.time.time_pb2.TimeBounds] = ..., + max_messages: typing.Optional[google.protobuf.wrappers_pb2.UInt32Value] = ..., + ) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["max_messages",b"max_messages","time",b"time"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["max_messages",b"max_messages","partial_eq_filter",b"partial_eq_filter","time",b"time"]) -> None: ... +global___TagBatchedStreamRequest = TagBatchedStreamRequest + +class TagBatchedStreamResponse(google.protobuf.message.Message): + DESCRIPTOR: google.protobuf.descriptor.Descriptor + RESPONSES_FIELD_NUMBER: builtins.int + @property + def responses(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___TagStreamResponse]: + """Values are the values deemed relevant to the initiating request. + The length of this structure is guaranteed to be between (inclusive) 1 and + min(req.max_messages, INTERNAL_BATCH_LIMIT). + """ + pass + def __init__(self, + *, + responses: typing.Optional[typing.Iterable[global___TagStreamResponse]] = ..., + ) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["responses",b"responses"]) -> None: ... +global___TagBatchedStreamResponse = TagBatchedStreamResponse + class TagAssignmentRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor KEY_FIELD_NUMBER: builtins.int @@ -403,6 +471,74 @@ class TagAssignmentStreamResponse(google.protobuf.message.Message): def ClearField(self, field_name: typing_extensions.Literal["time",b"time","type",b"type","value",b"value"]) -> None: ... global___TagAssignmentStreamResponse = TagAssignmentStreamResponse +class TagAssignmentBatchedStreamRequest(google.protobuf.message.Message): + DESCRIPTOR: google.protobuf.descriptor.Descriptor + PARTIAL_EQ_FILTER_FIELD_NUMBER: builtins.int + TIME_FIELD_NUMBER: builtins.int + MAX_MESSAGES_FIELD_NUMBER: builtins.int + @property + def partial_eq_filter(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[arista.tag.v2.tag_pb2.TagAssignment]: + """PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. + This requires all provided fields to be equal to the response. + + While transparent to users, this field also allows services to optimize internal + subscriptions if filter(s) are sufficiently specific. + """ + pass + @property + def time(self) -> arista.time.time_pb2.TimeBounds: + """TimeRange allows limiting response data to within a specified time window. + If this field is populated, at least one of the two time fields are required. + + For GetAll, the fields start and end can be used as follows: + + * end: Returns the state of each TagAssignment at end. + * Each TagAssignment response is fully-specified (all fields set). + * start: Returns the state of each TagAssignment at start, followed by updates until now. + * Each TagAssignment response at start is fully-specified, but updates may be partial. + * start and end: Returns the state of each TagAssignment at start, followed by updates + until end. + * Each TagAssignment response at start is fully-specified, but updates until end may + be partial. + + This field is not allowed in the Subscribe RPC. + """ + pass + @property + def max_messages(self) -> google.protobuf.wrappers_pb2.UInt32Value: + """MaxMessages limits the maximum number of messages that can be contained in one batch. + MaxMessages is required to be at least 1. + The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT) + INTERNAL_BATCH_LIMIT is set based on the maximum message size. + """ + pass + def __init__(self, + *, + partial_eq_filter: typing.Optional[typing.Iterable[arista.tag.v2.tag_pb2.TagAssignment]] = ..., + time: typing.Optional[arista.time.time_pb2.TimeBounds] = ..., + max_messages: typing.Optional[google.protobuf.wrappers_pb2.UInt32Value] = ..., + ) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["max_messages",b"max_messages","time",b"time"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["max_messages",b"max_messages","partial_eq_filter",b"partial_eq_filter","time",b"time"]) -> None: ... +global___TagAssignmentBatchedStreamRequest = TagAssignmentBatchedStreamRequest + +class TagAssignmentBatchedStreamResponse(google.protobuf.message.Message): + DESCRIPTOR: google.protobuf.descriptor.Descriptor + RESPONSES_FIELD_NUMBER: builtins.int + @property + def responses(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___TagAssignmentStreamResponse]: + """Values are the values deemed relevant to the initiating request. + The length of this structure is guaranteed to be between (inclusive) 1 and + min(req.max_messages, INTERNAL_BATCH_LIMIT). + """ + pass + def __init__(self, + *, + responses: typing.Optional[typing.Iterable[global___TagAssignmentStreamResponse]] = ..., + ) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["responses",b"responses"]) -> None: ... +global___TagAssignmentBatchedStreamResponse = TagAssignmentBatchedStreamResponse + class TagAssignmentConfigRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor KEY_FIELD_NUMBER: builtins.int @@ -581,6 +717,74 @@ class TagAssignmentConfigStreamResponse(google.protobuf.message.Message): def ClearField(self, field_name: typing_extensions.Literal["time",b"time","type",b"type","value",b"value"]) -> None: ... global___TagAssignmentConfigStreamResponse = TagAssignmentConfigStreamResponse +class TagAssignmentConfigBatchedStreamRequest(google.protobuf.message.Message): + DESCRIPTOR: google.protobuf.descriptor.Descriptor + PARTIAL_EQ_FILTER_FIELD_NUMBER: builtins.int + TIME_FIELD_NUMBER: builtins.int + MAX_MESSAGES_FIELD_NUMBER: builtins.int + @property + def partial_eq_filter(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[arista.tag.v2.tag_pb2.TagAssignmentConfig]: + """PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. + This requires all provided fields to be equal to the response. + + While transparent to users, this field also allows services to optimize internal + subscriptions if filter(s) are sufficiently specific. + """ + pass + @property + def time(self) -> arista.time.time_pb2.TimeBounds: + """TimeRange allows limiting response data to within a specified time window. + If this field is populated, at least one of the two time fields are required. + + For GetAll, the fields start and end can be used as follows: + + * end: Returns the state of each TagAssignmentConfig at end. + * Each TagAssignmentConfig response is fully-specified (all fields set). + * start: Returns the state of each TagAssignmentConfig at start, followed by updates until now. + * Each TagAssignmentConfig response at start is fully-specified, but updates may be partial. + * start and end: Returns the state of each TagAssignmentConfig at start, followed by updates + until end. + * Each TagAssignmentConfig response at start is fully-specified, but updates until end may + be partial. + + This field is not allowed in the Subscribe RPC. + """ + pass + @property + def max_messages(self) -> google.protobuf.wrappers_pb2.UInt32Value: + """MaxMessages limits the maximum number of messages that can be contained in one batch. + MaxMessages is required to be at least 1. + The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT) + INTERNAL_BATCH_LIMIT is set based on the maximum message size. + """ + pass + def __init__(self, + *, + partial_eq_filter: typing.Optional[typing.Iterable[arista.tag.v2.tag_pb2.TagAssignmentConfig]] = ..., + time: typing.Optional[arista.time.time_pb2.TimeBounds] = ..., + max_messages: typing.Optional[google.protobuf.wrappers_pb2.UInt32Value] = ..., + ) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["max_messages",b"max_messages","time",b"time"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["max_messages",b"max_messages","partial_eq_filter",b"partial_eq_filter","time",b"time"]) -> None: ... +global___TagAssignmentConfigBatchedStreamRequest = TagAssignmentConfigBatchedStreamRequest + +class TagAssignmentConfigBatchedStreamResponse(google.protobuf.message.Message): + DESCRIPTOR: google.protobuf.descriptor.Descriptor + RESPONSES_FIELD_NUMBER: builtins.int + @property + def responses(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___TagAssignmentConfigStreamResponse]: + """Values are the values deemed relevant to the initiating request. + The length of this structure is guaranteed to be between (inclusive) 1 and + min(req.max_messages, INTERNAL_BATCH_LIMIT). + """ + pass + def __init__(self, + *, + responses: typing.Optional[typing.Iterable[global___TagAssignmentConfigStreamResponse]] = ..., + ) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["responses",b"responses"]) -> None: ... +global___TagAssignmentConfigBatchedStreamResponse = TagAssignmentConfigBatchedStreamResponse + class TagAssignmentConfigSetRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor VALUE_FIELD_NUMBER: builtins.int @@ -738,8 +942,19 @@ global___TagAssignmentConfigDeleteSomeResponse = TagAssignmentConfigDeleteSomeRe class TagAssignmentConfigDeleteAllRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor + PARTIAL_EQ_FILTER_FIELD_NUMBER: builtins.int + @property + def partial_eq_filter(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[arista.tag.v2.tag_pb2.TagAssignmentConfig]: + """PartialEqFilter provides a way to server-side filter a DeleteAll. + This requires all provided fields to be equal to the response. + A filtered DeleteAll will use GetAll with filter to find things to delete. + """ + pass def __init__(self, + *, + partial_eq_filter: typing.Optional[typing.Iterable[arista.tag.v2.tag_pb2.TagAssignmentConfig]] = ..., ) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["partial_eq_filter",b"partial_eq_filter"]) -> None: ... global___TagAssignmentConfigDeleteAllRequest = TagAssignmentConfigDeleteAllRequest class TagAssignmentConfigDeleteAllResponse(google.protobuf.message.Message): @@ -749,7 +964,9 @@ class TagAssignmentConfigDeleteAllResponse(google.protobuf.message.Message): KEY_FIELD_NUMBER: builtins.int TIME_FIELD_NUMBER: builtins.int type: fmp.deletes_pb2.DeleteError.ValueType - """This describes the class of delete error.""" + """This describes the class of delete error. + A DeleteAllResponse is only sent when there is an error. + """ @property def error(self) -> google.protobuf.wrappers_pb2.StringValue: @@ -952,6 +1169,74 @@ class TagConfigStreamResponse(google.protobuf.message.Message): def ClearField(self, field_name: typing_extensions.Literal["time",b"time","type",b"type","value",b"value"]) -> None: ... global___TagConfigStreamResponse = TagConfigStreamResponse +class TagConfigBatchedStreamRequest(google.protobuf.message.Message): + DESCRIPTOR: google.protobuf.descriptor.Descriptor + PARTIAL_EQ_FILTER_FIELD_NUMBER: builtins.int + TIME_FIELD_NUMBER: builtins.int + MAX_MESSAGES_FIELD_NUMBER: builtins.int + @property + def partial_eq_filter(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[arista.tag.v2.tag_pb2.TagConfig]: + """PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. + This requires all provided fields to be equal to the response. + + While transparent to users, this field also allows services to optimize internal + subscriptions if filter(s) are sufficiently specific. + """ + pass + @property + def time(self) -> arista.time.time_pb2.TimeBounds: + """TimeRange allows limiting response data to within a specified time window. + If this field is populated, at least one of the two time fields are required. + + For GetAll, the fields start and end can be used as follows: + + * end: Returns the state of each TagConfig at end. + * Each TagConfig response is fully-specified (all fields set). + * start: Returns the state of each TagConfig at start, followed by updates until now. + * Each TagConfig response at start is fully-specified, but updates may be partial. + * start and end: Returns the state of each TagConfig at start, followed by updates + until end. + * Each TagConfig response at start is fully-specified, but updates until end may + be partial. + + This field is not allowed in the Subscribe RPC. + """ + pass + @property + def max_messages(self) -> google.protobuf.wrappers_pb2.UInt32Value: + """MaxMessages limits the maximum number of messages that can be contained in one batch. + MaxMessages is required to be at least 1. + The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT) + INTERNAL_BATCH_LIMIT is set based on the maximum message size. + """ + pass + def __init__(self, + *, + partial_eq_filter: typing.Optional[typing.Iterable[arista.tag.v2.tag_pb2.TagConfig]] = ..., + time: typing.Optional[arista.time.time_pb2.TimeBounds] = ..., + max_messages: typing.Optional[google.protobuf.wrappers_pb2.UInt32Value] = ..., + ) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["max_messages",b"max_messages","time",b"time"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["max_messages",b"max_messages","partial_eq_filter",b"partial_eq_filter","time",b"time"]) -> None: ... +global___TagConfigBatchedStreamRequest = TagConfigBatchedStreamRequest + +class TagConfigBatchedStreamResponse(google.protobuf.message.Message): + DESCRIPTOR: google.protobuf.descriptor.Descriptor + RESPONSES_FIELD_NUMBER: builtins.int + @property + def responses(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___TagConfigStreamResponse]: + """Values are the values deemed relevant to the initiating request. + The length of this structure is guaranteed to be between (inclusive) 1 and + min(req.max_messages, INTERNAL_BATCH_LIMIT). + """ + pass + def __init__(self, + *, + responses: typing.Optional[typing.Iterable[global___TagConfigStreamResponse]] = ..., + ) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["responses",b"responses"]) -> None: ... +global___TagConfigBatchedStreamResponse = TagConfigBatchedStreamResponse + class TagConfigSetRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor VALUE_FIELD_NUMBER: builtins.int @@ -1109,8 +1394,19 @@ global___TagConfigDeleteSomeResponse = TagConfigDeleteSomeResponse class TagConfigDeleteAllRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor + PARTIAL_EQ_FILTER_FIELD_NUMBER: builtins.int + @property + def partial_eq_filter(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[arista.tag.v2.tag_pb2.TagConfig]: + """PartialEqFilter provides a way to server-side filter a DeleteAll. + This requires all provided fields to be equal to the response. + A filtered DeleteAll will use GetAll with filter to find things to delete. + """ + pass def __init__(self, + *, + partial_eq_filter: typing.Optional[typing.Iterable[arista.tag.v2.tag_pb2.TagConfig]] = ..., ) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["partial_eq_filter",b"partial_eq_filter"]) -> None: ... global___TagConfigDeleteAllRequest = TagConfigDeleteAllRequest class TagConfigDeleteAllResponse(google.protobuf.message.Message): @@ -1120,7 +1416,9 @@ class TagConfigDeleteAllResponse(google.protobuf.message.Message): KEY_FIELD_NUMBER: builtins.int TIME_FIELD_NUMBER: builtins.int type: fmp.deletes_pb2.DeleteError.ValueType - """This describes the class of delete error.""" + """This describes the class of delete error. + A DeleteAllResponse is only sent when there is an error. + """ @property def error(self) -> google.protobuf.wrappers_pb2.StringValue: diff --git a/arista/tag/v2/services/gen_pb2_grpc.py b/arista/tag/v2/services/gen_pb2_grpc.py index 8705976b..4d05ef9e 100644 --- a/arista/tag/v2/services/gen_pb2_grpc.py +++ b/arista/tag/v2/services/gen_pb2_grpc.py @@ -44,6 +44,16 @@ def __init__(self, channel): request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagStreamRequest.SerializeToString, response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.MetaResponse.FromString, ) + self.GetAllBatched = channel.unary_stream( + '/arista.tag.v2.TagService/GetAllBatched', + request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamRequest.SerializeToString, + response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamResponse.FromString, + ) + self.SubscribeBatched = channel.unary_stream( + '/arista.tag.v2.TagService/SubscribeBatched', + request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamRequest.SerializeToString, + response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamResponse.FromString, + ) class TagServiceServicer(object): @@ -85,6 +95,18 @@ def SubscribeMeta(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + 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!') + + 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!') + def add_TagServiceServicer_to_server(servicer, server): rpc_method_handlers = { @@ -118,6 +140,16 @@ def add_TagServiceServicer_to_server(servicer, server): request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagStreamRequest.FromString, response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.MetaResponse.SerializeToString, ), + 'GetAllBatched': grpc.unary_stream_rpc_method_handler( + servicer.GetAllBatched, + request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamRequest.FromString, + response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamResponse.SerializeToString, + ), + 'SubscribeBatched': grpc.unary_stream_rpc_method_handler( + servicer.SubscribeBatched, + request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamRequest.FromString, + response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( 'arista.tag.v2.TagService', rpc_method_handlers) @@ -230,6 +262,40 @@ def SubscribeMeta(request, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + @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.tag.v2.TagService/GetAllBatched', + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamRequest.SerializeToString, + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @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.tag.v2.TagService/SubscribeBatched', + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamRequest.SerializeToString, + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagBatchedStreamResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + class TagAssignmentServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -270,6 +336,16 @@ def __init__(self, channel): request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentStreamRequest.SerializeToString, response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.MetaResponse.FromString, ) + self.GetAllBatched = channel.unary_stream( + '/arista.tag.v2.TagAssignmentService/GetAllBatched', + request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamRequest.SerializeToString, + response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamResponse.FromString, + ) + self.SubscribeBatched = channel.unary_stream( + '/arista.tag.v2.TagAssignmentService/SubscribeBatched', + request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamRequest.SerializeToString, + response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamResponse.FromString, + ) class TagAssignmentServiceServicer(object): @@ -311,6 +387,18 @@ def SubscribeMeta(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + 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!') + + 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!') + def add_TagAssignmentServiceServicer_to_server(servicer, server): rpc_method_handlers = { @@ -344,6 +432,16 @@ def add_TagAssignmentServiceServicer_to_server(servicer, server): request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentStreamRequest.FromString, response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.MetaResponse.SerializeToString, ), + 'GetAllBatched': grpc.unary_stream_rpc_method_handler( + servicer.GetAllBatched, + request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamRequest.FromString, + response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamResponse.SerializeToString, + ), + 'SubscribeBatched': grpc.unary_stream_rpc_method_handler( + servicer.SubscribeBatched, + request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamRequest.FromString, + response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( 'arista.tag.v2.TagAssignmentService', rpc_method_handlers) @@ -456,6 +554,40 @@ def SubscribeMeta(request, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + @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.tag.v2.TagAssignmentService/GetAllBatched', + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamRequest.SerializeToString, + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @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.tag.v2.TagAssignmentService/SubscribeBatched', + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamRequest.SerializeToString, + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentBatchedStreamResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + class TagAssignmentConfigServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -521,6 +653,16 @@ def __init__(self, channel): request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigDeleteAllRequest.SerializeToString, response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigDeleteAllResponse.FromString, ) + self.GetAllBatched = channel.unary_stream( + '/arista.tag.v2.TagAssignmentConfigService/GetAllBatched', + request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamRequest.SerializeToString, + response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamResponse.FromString, + ) + self.SubscribeBatched = channel.unary_stream( + '/arista.tag.v2.TagAssignmentConfigService/SubscribeBatched', + request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamRequest.SerializeToString, + response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamResponse.FromString, + ) class TagAssignmentConfigServiceServicer(object): @@ -592,6 +734,18 @@ def DeleteAll(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + 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!') + + 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!') + def add_TagAssignmentConfigServiceServicer_to_server(servicer, server): rpc_method_handlers = { @@ -650,6 +804,16 @@ def add_TagAssignmentConfigServiceServicer_to_server(servicer, server): request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigDeleteAllRequest.FromString, response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigDeleteAllResponse.SerializeToString, ), + 'GetAllBatched': grpc.unary_stream_rpc_method_handler( + servicer.GetAllBatched, + request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamRequest.FromString, + response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamResponse.SerializeToString, + ), + 'SubscribeBatched': grpc.unary_stream_rpc_method_handler( + servicer.SubscribeBatched, + request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamRequest.FromString, + response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( 'arista.tag.v2.TagAssignmentConfigService', rpc_method_handlers) @@ -847,6 +1011,40 @@ def DeleteAll(request, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + @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.tag.v2.TagAssignmentConfigService/GetAllBatched', + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamRequest.SerializeToString, + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @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.tag.v2.TagAssignmentConfigService/SubscribeBatched', + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamRequest.SerializeToString, + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagAssignmentConfigBatchedStreamResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + class TagConfigServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -912,6 +1110,16 @@ def __init__(self, channel): request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigDeleteAllRequest.SerializeToString, response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigDeleteAllResponse.FromString, ) + self.GetAllBatched = channel.unary_stream( + '/arista.tag.v2.TagConfigService/GetAllBatched', + request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamRequest.SerializeToString, + response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamResponse.FromString, + ) + self.SubscribeBatched = channel.unary_stream( + '/arista.tag.v2.TagConfigService/SubscribeBatched', + request_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamRequest.SerializeToString, + response_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamResponse.FromString, + ) class TagConfigServiceServicer(object): @@ -983,6 +1191,18 @@ def DeleteAll(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + 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!') + + 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!') + def add_TagConfigServiceServicer_to_server(servicer, server): rpc_method_handlers = { @@ -1041,6 +1261,16 @@ def add_TagConfigServiceServicer_to_server(servicer, server): request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigDeleteAllRequest.FromString, response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigDeleteAllResponse.SerializeToString, ), + 'GetAllBatched': grpc.unary_stream_rpc_method_handler( + servicer.GetAllBatched, + request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamRequest.FromString, + response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamResponse.SerializeToString, + ), + 'SubscribeBatched': grpc.unary_stream_rpc_method_handler( + servicer.SubscribeBatched, + request_deserializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamRequest.FromString, + response_serializer=arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( 'arista.tag.v2.TagConfigService', rpc_method_handlers) @@ -1237,3 +1467,37 @@ def DeleteAll(request, arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigDeleteAllResponse.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @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.tag.v2.TagConfigService/GetAllBatched', + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamRequest.SerializeToString, + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @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.tag.v2.TagConfigService/SubscribeBatched', + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamRequest.SerializeToString, + arista_dot_tag_dot_v2_dot_services_dot_gen__pb2.TagConfigBatchedStreamResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) diff --git a/fmp/__init__.py b/fmp/__init__.py index e8655893..fac06ce7 100644 --- a/fmp/__init__.py +++ b/fmp/__init__.py @@ -1,8 +1,8 @@ # Copyright (c) 2024 Arista Networks, Inc. All rights reserved. -import fmp.wrappers_pb2 as wrappers -import fmp.extensions_pb2 as extensions import fmp.pages_pb2 as pages -import fmp.deletes_pb2 as deletes import fmp.inet_pb2 as inet +import fmp.extensions_pb2 as extensions import fmp.yang_pb2 as yang +import fmp.deletes_pb2 as deletes +import fmp.wrappers_pb2 as wrappers