From c6023257e9be3d710e5c6b6675b4b0b385dadd54 Mon Sep 17 00:00:00 2001 From: Patrick Deziel <42919891+pdeziel@users.noreply.github.com> Date: Thu, 17 Aug 2023 08:57:23 -0500 Subject: [PATCH] Update protocol buffers for v0.9.0 (#60) --- pyensign/api/v1beta1/ensign_pb2.py | 44 +++++++++++++-------------- pyensign/api/v1beta1/topic_pb2.py | 48 +++++++++++++++--------------- pyensign/nack.py | 4 +-- 3 files changed, 48 insertions(+), 48 deletions(-) diff --git a/pyensign/api/v1beta1/ensign_pb2.py b/pyensign/api/v1beta1/ensign_pb2.py index 714fa5d..ef703d3 100644 --- a/pyensign/api/v1beta1/ensign_pb2.py +++ b/pyensign/api/v1beta1/ensign_pb2.py @@ -21,7 +21,7 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile( - b'\n\x18\x61pi/v1beta1/ensign.proto\x12\x0e\x65nsign.v1beta1\x1a\x17\x61pi/v1beta1/event.proto\x1a\x17\x61pi/v1beta1/topic.proto\x1a\x18\x61pi/v1beta1/groups.proto\x1a\x17\x61pi/v1beta1/query.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/duration.proto"}\n\x10PublisherRequest\x12-\n\x05\x65vent\x18\x01 \x01(\x0b\x32\x1c.ensign.v1beta1.EventWrapperH\x00\x12\x31\n\x0bopen_stream\x18\x02 \x01(\x0b\x32\x1a.ensign.v1beta1.OpenStreamH\x00\x42\x07\n\x05\x65mbed"\xc6\x01\n\x0ePublisherReply\x12"\n\x03\x61\x63k\x18\x01 \x01(\x0b\x32\x13.ensign.v1beta1.AckH\x00\x12$\n\x04nack\x18\x02 \x01(\x0b\x32\x14.ensign.v1beta1.NackH\x00\x12,\n\x05ready\x18\x03 \x01(\x0b\x32\x1b.ensign.v1beta1.StreamReadyH\x00\x12\x33\n\x0c\x63lose_stream\x18\x04 \x01(\x0b\x32\x1b.ensign.v1beta1.CloseStreamH\x00\x42\x07\n\x05\x65mbed"\x9b\x01\n\x10SubscribeRequest\x12"\n\x03\x61\x63k\x18\x01 \x01(\x0b\x32\x13.ensign.v1beta1.AckH\x00\x12$\n\x04nack\x18\x02 \x01(\x0b\x32\x14.ensign.v1beta1.NackH\x00\x12\x34\n\x0csubscription\x18\x03 \x01(\x0b\x32\x1c.ensign.v1beta1.SubscriptionH\x00\x42\x07\n\x05\x65mbed"\xab\x01\n\x0eSubscribeReply\x12-\n\x05\x65vent\x18\x01 \x01(\x0b\x32\x1c.ensign.v1beta1.EventWrapperH\x00\x12,\n\x05ready\x18\x02 \x01(\x0b\x32\x1b.ensign.v1beta1.StreamReadyH\x00\x12\x33\n\x0c\x63lose_stream\x18\x03 \x01(\x0b\x32\x1b.ensign.v1beta1.CloseStreamH\x00\x42\x07\n\x05\x65mbed"@\n\x03\x41\x63k\x12\n\n\x02id\x18\x01 \x01(\x0c\x12-\n\tcommitted\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"\x90\x03\n\x04Nack\x12\n\n\x02id\x18\x01 \x01(\x0c\x12\'\n\x04\x63ode\x18\x02 \x01(\x0e\x32\x19.ensign.v1beta1.Nack.Code\x12\r\n\x05\x65rror\x18\x03 \x01(\t"\xc3\x02\n\x04\x43ode\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x1b\n\x17MAX_EVENT_SIZE_EXCEEDED\x10\x01\x12\x10\n\x0cTOPIC_UKNOWN\x10\x02\x12\x13\n\x0fTOPIC_ARCHVIVED\x10\x03\x12\x11\n\rTOPIC_DELETED\x10\x04\x12\x15\n\x11PERMISSION_DENIED\x10\x05\x12\x15\n\x11\x43ONSENSUS_FAILURE\x10\x06\x12\x14\n\x10SHARDING_FAILURE\x10\x07\x12\x0c\n\x08REDIRECT\x10\x08\x12\x0c\n\x08INTERNAL\x10\t\x12\x0f\n\x0bUNPROCESSED\x10\x64\x12\x0b\n\x07TIMEOUT\x10\x65\x12\x16\n\x12UNHANDLED_MIMETYPE\x10\x66\x12\x10\n\x0cUNKNOWN_TYPE\x10g\x12\x15\n\x11\x44\x45LIVER_AGAIN_ANY\x10h\x12\x18\n\x14\x44\x45LIVER_AGAIN_NOT_ME\x10i"/\n\nOpenStream\x12\x11\n\tclient_id\x18\x01 \x01(\t\x12\x0e\n\x06topics\x18\x02 \x03(\t"@\n\x0b\x43loseStream\x12\x0e\n\x06\x65vents\x18\x01 \x01(\x04\x12\x0e\n\x06topics\x18\x02 \x01(\x04\x12\x11\n\tconsumers\x18\x03 \x01(\x04"\x9b\x01\n\x0bStreamReady\x12\x11\n\tclient_id\x18\x01 \x01(\t\x12\x11\n\tserver_id\x18\x02 \x01(\t\x12\x37\n\x06topics\x18\x03 \x03(\x0b\x32\'.ensign.v1beta1.StreamReady.TopicsEntry\x1a-\n\x0bTopicsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01"\x85\x01\n\x0cSubscription\x12\x11\n\tclient_id\x18\x01 \x01(\t\x12\x0e\n\x06topics\x18\x02 \x03(\t\x12$\n\x05query\x18\x03 \x01(\x0b\x32\x15.ensign.v1beta1.Query\x12,\n\x05group\x18\x04 \x01(\x0b\x32\x1d.ensign.v1beta1.ConsumerGroup"\x1d\n\x0bInfoRequest\x12\x0e\n\x06topics\x18\x01 \x03(\x0c"\xba\x01\n\x0bProjectInfo\x12\x12\n\nproject_id\x18\x01 \x01(\x0c\x12\x12\n\nnum_topics\x18\x02 \x01(\x04\x12\x1b\n\x13num_readonly_topics\x18\x03 \x01(\x04\x12\x0e\n\x06\x65vents\x18\x07 \x01(\x04\x12\x12\n\nduplicates\x18\x08 \x01(\x04\x12\x17\n\x0f\x64\x61ta_size_bytes\x18\t \x01(\x04\x12)\n\x06topics\x18\x0f \x03(\x0b\x32\x19.ensign.v1beta1.TopicInfo"T\n\x0bHealthCheck\x12\x10\n\x08\x61ttempts\x18\x01 \x01(\r\x12\x33\n\x0flast_checked_at\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"\xbb\x02\n\x0cServiceState\x12\x33\n\x06status\x18\x01 \x01(\x0e\x32#.ensign.v1beta1.ServiceState.Status\x12\x0f\n\x07version\x18\x02 \x01(\t\x12)\n\x06uptime\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\x12.\n\nnot_before\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\tnot_after\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"[\n\x06Status\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0b\n\x07HEALTHY\x10\x01\x12\r\n\tUNHEALTHY\x10\x02\x12\n\n\x06\x44\x41NGER\x10\x03\x12\x0b\n\x07OFFLINE\x10\x04\x12\x0f\n\x0bMAINTENANCE\x10\x05"6\n\x08PageInfo\x12\x11\n\tpage_size\x18\x01 \x01(\r\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t2\xeb\x06\n\x06\x45nsign\x12Q\n\x07Publish\x12 .ensign.v1beta1.PublisherRequest\x1a\x1e.ensign.v1beta1.PublisherReply"\x00(\x01\x30\x01\x12S\n\tSubscribe\x12 .ensign.v1beta1.SubscribeRequest\x1a\x1e.ensign.v1beta1.SubscribeReply"\x00(\x01\x30\x01\x12@\n\x05\x45nSQL\x12\x15.ensign.v1beta1.Query\x1a\x1c.ensign.v1beta1.EventWrapper"\x00\x30\x01\x12\x44\n\x07\x45xplain\x12\x15.ensign.v1beta1.Query\x1a .ensign.v1beta1.QueryExplanation"\x00\x12\x44\n\nListTopics\x12\x18.ensign.v1beta1.PageInfo\x1a\x1a.ensign.v1beta1.TopicsPage"\x00\x12=\n\x0b\x43reateTopic\x12\x15.ensign.v1beta1.Topic\x1a\x15.ensign.v1beta1.Topic"\x00\x12?\n\rRetrieveTopic\x12\x15.ensign.v1beta1.Topic\x1a\x15.ensign.v1beta1.Topic"\x00\x12I\n\x0b\x44\x65leteTopic\x12\x18.ensign.v1beta1.TopicMod\x1a\x1e.ensign.v1beta1.TopicTombstone"\x00\x12H\n\nTopicNames\x12\x18.ensign.v1beta1.PageInfo\x1a\x1e.ensign.v1beta1.TopicNamesPage"\x00\x12K\n\x0bTopicExists\x12\x19.ensign.v1beta1.TopicName\x1a\x1f.ensign.v1beta1.TopicExistsInfo"\x00\x12\x42\n\x04Info\x12\x1b.ensign.v1beta1.InfoRequest\x1a\x1b.ensign.v1beta1.ProjectInfo"\x00\x12\x45\n\x06Status\x12\x1b.ensign.v1beta1.HealthCheck\x1a\x1c.ensign.v1beta1.ServiceState"\x00\x62\x06proto3' + b'\n\x18\x61pi/v1beta1/ensign.proto\x12\x0e\x65nsign.v1beta1\x1a\x17\x61pi/v1beta1/event.proto\x1a\x17\x61pi/v1beta1/topic.proto\x1a\x18\x61pi/v1beta1/groups.proto\x1a\x17\x61pi/v1beta1/query.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/duration.proto"}\n\x10PublisherRequest\x12-\n\x05\x65vent\x18\x01 \x01(\x0b\x32\x1c.ensign.v1beta1.EventWrapperH\x00\x12\x31\n\x0bopen_stream\x18\x02 \x01(\x0b\x32\x1a.ensign.v1beta1.OpenStreamH\x00\x42\x07\n\x05\x65mbed"\xc6\x01\n\x0ePublisherReply\x12"\n\x03\x61\x63k\x18\x01 \x01(\x0b\x32\x13.ensign.v1beta1.AckH\x00\x12$\n\x04nack\x18\x02 \x01(\x0b\x32\x14.ensign.v1beta1.NackH\x00\x12,\n\x05ready\x18\x03 \x01(\x0b\x32\x1b.ensign.v1beta1.StreamReadyH\x00\x12\x33\n\x0c\x63lose_stream\x18\x04 \x01(\x0b\x32\x1b.ensign.v1beta1.CloseStreamH\x00\x42\x07\n\x05\x65mbed"\x9b\x01\n\x10SubscribeRequest\x12"\n\x03\x61\x63k\x18\x01 \x01(\x0b\x32\x13.ensign.v1beta1.AckH\x00\x12$\n\x04nack\x18\x02 \x01(\x0b\x32\x14.ensign.v1beta1.NackH\x00\x12\x34\n\x0csubscription\x18\x03 \x01(\x0b\x32\x1c.ensign.v1beta1.SubscriptionH\x00\x42\x07\n\x05\x65mbed"\xab\x01\n\x0eSubscribeReply\x12-\n\x05\x65vent\x18\x01 \x01(\x0b\x32\x1c.ensign.v1beta1.EventWrapperH\x00\x12,\n\x05ready\x18\x02 \x01(\x0b\x32\x1b.ensign.v1beta1.StreamReadyH\x00\x12\x33\n\x0c\x63lose_stream\x18\x03 \x01(\x0b\x32\x1b.ensign.v1beta1.CloseStreamH\x00\x42\x07\n\x05\x65mbed"@\n\x03\x41\x63k\x12\n\n\x02id\x18\x01 \x01(\x0c\x12-\n\tcommitted\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"\x90\x03\n\x04Nack\x12\n\n\x02id\x18\x01 \x01(\x0c\x12\'\n\x04\x63ode\x18\x02 \x01(\x0e\x32\x19.ensign.v1beta1.Nack.Code\x12\r\n\x05\x65rror\x18\x03 \x01(\t"\xc3\x02\n\x04\x43ode\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x1b\n\x17MAX_EVENT_SIZE_EXCEEDED\x10\x01\x12\x11\n\rTOPIC_UNKNOWN\x10\x02\x12\x12\n\x0eTOPIC_ARCHIVED\x10\x03\x12\x11\n\rTOPIC_DELETED\x10\x04\x12\x15\n\x11PERMISSION_DENIED\x10\x05\x12\x15\n\x11\x43ONSENSUS_FAILURE\x10\x06\x12\x14\n\x10SHARDING_FAILURE\x10\x07\x12\x0c\n\x08REDIRECT\x10\x08\x12\x0c\n\x08INTERNAL\x10\t\x12\x0f\n\x0bUNPROCESSED\x10\x64\x12\x0b\n\x07TIMEOUT\x10\x65\x12\x16\n\x12UNHANDLED_MIMETYPE\x10\x66\x12\x10\n\x0cUNKNOWN_TYPE\x10g\x12\x15\n\x11\x44\x45LIVER_AGAIN_ANY\x10h\x12\x18\n\x14\x44\x45LIVER_AGAIN_NOT_ME\x10i"/\n\nOpenStream\x12\x11\n\tclient_id\x18\x01 \x01(\t\x12\x0e\n\x06topics\x18\x02 \x03(\t"J\n\x0b\x43loseStream\x12\x0e\n\x06\x65vents\x18\x01 \x01(\x04\x12\x0e\n\x06topics\x18\x02 \x01(\x04\x12\x0c\n\x04\x61\x63ks\x18\x03 \x01(\x04\x12\r\n\x05nacks\x18\x04 \x01(\x04"\x9b\x01\n\x0bStreamReady\x12\x11\n\tclient_id\x18\x01 \x01(\t\x12\x11\n\tserver_id\x18\x02 \x01(\t\x12\x37\n\x06topics\x18\x03 \x03(\x0b\x32\'.ensign.v1beta1.StreamReady.TopicsEntry\x1a-\n\x0bTopicsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01"\x85\x01\n\x0cSubscription\x12\x11\n\tclient_id\x18\x01 \x01(\t\x12\x0e\n\x06topics\x18\x02 \x03(\t\x12$\n\x05query\x18\x03 \x01(\x0b\x32\x15.ensign.v1beta1.Query\x12,\n\x05group\x18\x04 \x01(\x0b\x32\x1d.ensign.v1beta1.ConsumerGroup"\x1d\n\x0bInfoRequest\x12\x0e\n\x06topics\x18\x01 \x03(\x0c"\xba\x01\n\x0bProjectInfo\x12\x12\n\nproject_id\x18\x01 \x01(\x0c\x12\x12\n\nnum_topics\x18\x02 \x01(\x04\x12\x1b\n\x13num_readonly_topics\x18\x03 \x01(\x04\x12\x0e\n\x06\x65vents\x18\x07 \x01(\x04\x12\x12\n\nduplicates\x18\x08 \x01(\x04\x12\x17\n\x0f\x64\x61ta_size_bytes\x18\t \x01(\x04\x12)\n\x06topics\x18\x0f \x03(\x0b\x32\x19.ensign.v1beta1.TopicInfo"T\n\x0bHealthCheck\x12\x10\n\x08\x61ttempts\x18\x01 \x01(\r\x12\x33\n\x0flast_checked_at\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"\xbb\x02\n\x0cServiceState\x12\x33\n\x06status\x18\x01 \x01(\x0e\x32#.ensign.v1beta1.ServiceState.Status\x12\x0f\n\x07version\x18\x02 \x01(\t\x12)\n\x06uptime\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\x12.\n\nnot_before\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\tnot_after\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"[\n\x06Status\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0b\n\x07HEALTHY\x10\x01\x12\r\n\tUNHEALTHY\x10\x02\x12\n\n\x06\x44\x41NGER\x10\x03\x12\x0b\n\x07OFFLINE\x10\x04\x12\x0f\n\x0bMAINTENANCE\x10\x05"6\n\x08PageInfo\x12\x11\n\tpage_size\x18\x01 \x01(\r\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t2\xeb\x06\n\x06\x45nsign\x12Q\n\x07Publish\x12 .ensign.v1beta1.PublisherRequest\x1a\x1e.ensign.v1beta1.PublisherReply"\x00(\x01\x30\x01\x12S\n\tSubscribe\x12 .ensign.v1beta1.SubscribeRequest\x1a\x1e.ensign.v1beta1.SubscribeReply"\x00(\x01\x30\x01\x12@\n\x05\x45nSQL\x12\x15.ensign.v1beta1.Query\x1a\x1c.ensign.v1beta1.EventWrapper"\x00\x30\x01\x12\x44\n\x07\x45xplain\x12\x15.ensign.v1beta1.Query\x1a .ensign.v1beta1.QueryExplanation"\x00\x12\x44\n\nListTopics\x12\x18.ensign.v1beta1.PageInfo\x1a\x1a.ensign.v1beta1.TopicsPage"\x00\x12=\n\x0b\x43reateTopic\x12\x15.ensign.v1beta1.Topic\x1a\x15.ensign.v1beta1.Topic"\x00\x12?\n\rRetrieveTopic\x12\x15.ensign.v1beta1.Topic\x1a\x15.ensign.v1beta1.Topic"\x00\x12I\n\x0b\x44\x65leteTopic\x12\x18.ensign.v1beta1.TopicMod\x1a\x1e.ensign.v1beta1.TopicTombstone"\x00\x12H\n\nTopicNames\x12\x18.ensign.v1beta1.PageInfo\x1a\x1e.ensign.v1beta1.TopicNamesPage"\x00\x12K\n\x0bTopicExists\x12\x19.ensign.v1beta1.TopicName\x1a\x1f.ensign.v1beta1.TopicExistsInfo"\x00\x12\x42\n\x04Info\x12\x1b.ensign.v1beta1.InfoRequest\x1a\x1b.ensign.v1beta1.ProjectInfo"\x00\x12\x45\n\x06Status\x12\x1b.ensign.v1beta1.HealthCheck\x1a\x1c.ensign.v1beta1.ServiceState"\x00\x62\x06proto3' ) _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) @@ -48,25 +48,25 @@ _OPENSTREAM._serialized_start = 1339 _OPENSTREAM._serialized_end = 1386 _CLOSESTREAM._serialized_start = 1388 - _CLOSESTREAM._serialized_end = 1452 - _STREAMREADY._serialized_start = 1455 - _STREAMREADY._serialized_end = 1610 - _STREAMREADY_TOPICSENTRY._serialized_start = 1565 - _STREAMREADY_TOPICSENTRY._serialized_end = 1610 - _SUBSCRIPTION._serialized_start = 1613 - _SUBSCRIPTION._serialized_end = 1746 - _INFOREQUEST._serialized_start = 1748 - _INFOREQUEST._serialized_end = 1777 - _PROJECTINFO._serialized_start = 1780 - _PROJECTINFO._serialized_end = 1966 - _HEALTHCHECK._serialized_start = 1968 - _HEALTHCHECK._serialized_end = 2052 - _SERVICESTATE._serialized_start = 2055 - _SERVICESTATE._serialized_end = 2370 - _SERVICESTATE_STATUS._serialized_start = 2279 - _SERVICESTATE_STATUS._serialized_end = 2370 - _PAGEINFO._serialized_start = 2372 - _PAGEINFO._serialized_end = 2426 - _ENSIGN._serialized_start = 2429 - _ENSIGN._serialized_end = 3304 + _CLOSESTREAM._serialized_end = 1462 + _STREAMREADY._serialized_start = 1465 + _STREAMREADY._serialized_end = 1620 + _STREAMREADY_TOPICSENTRY._serialized_start = 1575 + _STREAMREADY_TOPICSENTRY._serialized_end = 1620 + _SUBSCRIPTION._serialized_start = 1623 + _SUBSCRIPTION._serialized_end = 1756 + _INFOREQUEST._serialized_start = 1758 + _INFOREQUEST._serialized_end = 1787 + _PROJECTINFO._serialized_start = 1790 + _PROJECTINFO._serialized_end = 1976 + _HEALTHCHECK._serialized_start = 1978 + _HEALTHCHECK._serialized_end = 2062 + _SERVICESTATE._serialized_start = 2065 + _SERVICESTATE._serialized_end = 2380 + _SERVICESTATE_STATUS._serialized_start = 2289 + _SERVICESTATE_STATUS._serialized_end = 2380 + _PAGEINFO._serialized_start = 2382 + _PAGEINFO._serialized_end = 2436 + _ENSIGN._serialized_start = 2439 + _ENSIGN._serialized_end = 3314 # @@protoc_insertion_point(module_scope) diff --git a/pyensign/api/v1beta1/topic_pb2.py b/pyensign/api/v1beta1/topic_pb2.py index 610e69f..6949262 100644 --- a/pyensign/api/v1beta1/topic_pb2.py +++ b/pyensign/api/v1beta1/topic_pb2.py @@ -21,7 +21,7 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile( - b'\n\x17\x61pi/v1beta1/topic.proto\x12\x0e\x65nsign.v1beta1\x1a\x17\x61pi/v1beta1/event.proto\x1a\x1bregion/v1beta1/region.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1fmimetype/v1beta1/mimetype.proto"\x96\x02\n\x05Topic\x12\n\n\x02id\x18\x01 \x01(\x0c\x12\x12\n\nproject_id\x18\x02 \x01(\x0c\x12\x0c\n\x04name\x18\x03 \x01(\t\x12\x10\n\x08readonly\x18\x04 \x01(\x08\x12\x0e\n\x06offset\x18\x05 \x01(\x04\x12\x0e\n\x06shards\x18\x06 \x01(\r\x12-\n\nplacements\x18\x0c \x03(\x0b\x32\x19.ensign.v1beta1.Placement\x12#\n\x05types\x18\r \x03(\x0b\x32\x14.ensign.v1beta1.Type\x12+\n\x07\x63reated\x18\x0e \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12,\n\x08modified\x18\x0f \x01(\x0b\x32\x1a.google.protobuf.Timestamp"?\n\tTopicName\x12\x10\n\x08topic_id\x18\x01 \x01(\t\x12\x12\n\nproject_id\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t"\xca\x01\n\tTopicInfo\x12\x10\n\x08topic_id\x18\x01 \x01(\x0c\x12\x12\n\nproject_id\x18\x02 \x01(\x0c\x12\x0e\n\x06\x65vents\x18\x03 \x01(\x04\x12\x12\n\nduplicates\x18\x04 \x01(\x04\x12\x17\n\x0f\x64\x61ta_size_bytes\x18\x05 \x01(\x04\x12,\n\x05types\x18\x0e \x03(\x0b\x32\x1d.ensign.v1beta1.EventTypeInfo\x12,\n\x08modified\x18\x0f \x01(\x0b\x32\x1a.google.protobuf.Timestamp"L\n\nTopicsPage\x12%\n\x06topics\x18\x01 \x03(\x0b\x32\x15.ensign.v1beta1.Topic\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t"Y\n\x0eTopicNamesPage\x12.\n\x0btopic_names\x18\x01 \x03(\x0b\x32\x19.ensign.v1beta1.TopicName\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t"~\n\x08TopicMod\x12\n\n\x02id\x18\x01 \x01(\t\x12\x35\n\toperation\x18\x02 \x01(\x0e\x32".ensign.v1beta1.TopicMod.Operation"/\n\tOperation\x12\x08\n\x04NOOP\x10\x00\x12\x0b\n\x07\x41RCHIVE\x10\x01\x12\x0b\n\x07\x44\x45STROY\x10\x02"\x85\x01\n\x0eTopicTombstone\x12\n\n\x02id\x18\x01 \x01(\t\x12\x34\n\x05state\x18\x02 \x01(\x0e\x32%.ensign.v1beta1.TopicTombstone.Status"1\n\x06Status\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0c\n\x08READONLY\x10\x01\x12\x0c\n\x08\x44\x45LETING\x10\x02"0\n\x0fTopicExistsInfo\x12\r\n\x05query\x18\x01 \x01(\t\x12\x0e\n\x06\x65xists\x18\x02 \x01(\x08"\x9c\x01\n\tPlacement\x12\r\n\x05\x65poch\x18\x01 \x01(\x04\x12\x32\n\x08sharding\x18\x02 \x01(\x0e\x32 .ensign.v1beta1.ShardingStrategy\x12\'\n\x07regions\x18\x03 \x03(\x0e\x32\x16.region.v1beta1.Region\x12#\n\x05nodes\x18\x04 \x03(\x0b\x32\x14.ensign.v1beta1.Node"x\n\x04Node\x12\n\n\x02id\x18\x01 \x01(\t\x12\x10\n\x08hostname\x18\x02 \x01(\t\x12\x0e\n\x06quorum\x18\x03 \x01(\x04\x12\r\n\x05shard\x18\x04 \x01(\x04\x12&\n\x06region\x18\x05 \x01(\x0e\x32\x16.region.v1beta1.Region\x12\x0b\n\x03url\x18\x06 \x01(\t"\xc8\x01\n\rEventTypeInfo\x12"\n\x04type\x18\x01 \x01(\x0b\x32\x14.ensign.v1beta1.Type\x12(\n\x08mimetype\x18\x02 \x01(\x0e\x32\x16.mimetype.v1beta1.MIME\x12\x0e\n\x06\x65vents\x18\n \x01(\x04\x12\x12\n\nduplicates\x18\x0b \x01(\x04\x12\x17\n\x0f\x64\x61ta_size_bytes\x18\x0c \x01(\x04\x12,\n\x08modified\x18\x0f \x01(\x0b\x32\x1a.google.protobuf.Timestamp*m\n\x10ShardingStrategy\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0f\n\x0bNO_SHARDING\x10\x01\x12\x17\n\x13\x43ONSISTENT_KEY_HASH\x10\x02\x12\n\n\x06RANDOM\x10\x03\x12\x16\n\x12PUBLISHER_ORDERING\x10\x04\x62\x06proto3' + b'\n\x17\x61pi/v1beta1/topic.proto\x12\x0e\x65nsign.v1beta1\x1a\x17\x61pi/v1beta1/event.proto\x1a\x1bregion/v1beta1/region.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1fmimetype/v1beta1/mimetype.proto"\x96\x02\n\x05Topic\x12\n\n\x02id\x18\x01 \x01(\x0c\x12\x12\n\nproject_id\x18\x02 \x01(\x0c\x12\x0c\n\x04name\x18\x03 \x01(\t\x12\x10\n\x08readonly\x18\x04 \x01(\x08\x12\x0e\n\x06offset\x18\x05 \x01(\x04\x12\x0e\n\x06shards\x18\x06 \x01(\r\x12-\n\nplacements\x18\x0c \x03(\x0b\x32\x19.ensign.v1beta1.Placement\x12#\n\x05types\x18\r \x03(\x0b\x32\x14.ensign.v1beta1.Type\x12+\n\x07\x63reated\x18\x0e \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12,\n\x08modified\x18\x0f \x01(\x0b\x32\x1a.google.protobuf.Timestamp"?\n\tTopicName\x12\x10\n\x08topic_id\x18\x01 \x01(\t\x12\x12\n\nproject_id\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t"\xe3\x01\n\tTopicInfo\x12\x10\n\x08topic_id\x18\x01 \x01(\x0c\x12\x12\n\nproject_id\x18\x02 \x01(\x0c\x12\x17\n\x0f\x65vent_offset_id\x18\x03 \x01(\x0c\x12\x0e\n\x06\x65vents\x18\x07 \x01(\x04\x12\x12\n\nduplicates\x18\x08 \x01(\x04\x12\x17\n\x0f\x64\x61ta_size_bytes\x18\t \x01(\x04\x12,\n\x05types\x18\x0e \x03(\x0b\x32\x1d.ensign.v1beta1.EventTypeInfo\x12,\n\x08modified\x18\x0f \x01(\x0b\x32\x1a.google.protobuf.Timestamp"L\n\nTopicsPage\x12%\n\x06topics\x18\x01 \x03(\x0b\x32\x15.ensign.v1beta1.Topic\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t"Y\n\x0eTopicNamesPage\x12.\n\x0btopic_names\x18\x01 \x03(\x0b\x32\x19.ensign.v1beta1.TopicName\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t"~\n\x08TopicMod\x12\n\n\x02id\x18\x01 \x01(\t\x12\x35\n\toperation\x18\x02 \x01(\x0e\x32".ensign.v1beta1.TopicMod.Operation"/\n\tOperation\x12\x08\n\x04NOOP\x10\x00\x12\x0b\n\x07\x41RCHIVE\x10\x01\x12\x0b\n\x07\x44\x45STROY\x10\x02"\x85\x01\n\x0eTopicTombstone\x12\n\n\x02id\x18\x01 \x01(\t\x12\x34\n\x05state\x18\x02 \x01(\x0e\x32%.ensign.v1beta1.TopicTombstone.Status"1\n\x06Status\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0c\n\x08READONLY\x10\x01\x12\x0c\n\x08\x44\x45LETING\x10\x02"0\n\x0fTopicExistsInfo\x12\r\n\x05query\x18\x01 \x01(\t\x12\x0e\n\x06\x65xists\x18\x02 \x01(\x08"\x9c\x01\n\tPlacement\x12\r\n\x05\x65poch\x18\x01 \x01(\x04\x12\x32\n\x08sharding\x18\x02 \x01(\x0e\x32 .ensign.v1beta1.ShardingStrategy\x12\'\n\x07regions\x18\x03 \x03(\x0e\x32\x16.region.v1beta1.Region\x12#\n\x05nodes\x18\x04 \x03(\x0b\x32\x14.ensign.v1beta1.Node"x\n\x04Node\x12\n\n\x02id\x18\x01 \x01(\t\x12\x10\n\x08hostname\x18\x02 \x01(\t\x12\x0e\n\x06quorum\x18\x03 \x01(\x04\x12\r\n\x05shard\x18\x04 \x01(\x04\x12&\n\x06region\x18\x05 \x01(\x0e\x32\x16.region.v1beta1.Region\x12\x0b\n\x03url\x18\x06 \x01(\t"\xc8\x01\n\rEventTypeInfo\x12"\n\x04type\x18\x01 \x01(\x0b\x32\x14.ensign.v1beta1.Type\x12(\n\x08mimetype\x18\x02 \x01(\x0e\x32\x16.mimetype.v1beta1.MIME\x12\x0e\n\x06\x65vents\x18\n \x01(\x04\x12\x12\n\nduplicates\x18\x0b \x01(\x04\x12\x17\n\x0f\x64\x61ta_size_bytes\x18\x0c \x01(\x04\x12,\n\x08modified\x18\x0f \x01(\x0b\x32\x1a.google.protobuf.Timestamp*m\n\x10ShardingStrategy\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0f\n\x0bNO_SHARDING\x10\x01\x12\x17\n\x13\x43ONSISTENT_KEY_HASH\x10\x02\x12\n\n\x06RANDOM\x10\x03\x12\x16\n\x12PUBLISHER_ORDERING\x10\x04\x62\x06proto3' ) _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) @@ -29,32 +29,32 @@ if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None - _SHARDINGSTRATEGY._serialized_start = 1681 - _SHARDINGSTRATEGY._serialized_end = 1790 + _SHARDINGSTRATEGY._serialized_start = 1706 + _SHARDINGSTRATEGY._serialized_end = 1815 _TOPIC._serialized_start = 164 _TOPIC._serialized_end = 442 _TOPICNAME._serialized_start = 444 _TOPICNAME._serialized_end = 507 _TOPICINFO._serialized_start = 510 - _TOPICINFO._serialized_end = 712 - _TOPICSPAGE._serialized_start = 714 - _TOPICSPAGE._serialized_end = 790 - _TOPICNAMESPAGE._serialized_start = 792 - _TOPICNAMESPAGE._serialized_end = 881 - _TOPICMOD._serialized_start = 883 - _TOPICMOD._serialized_end = 1009 - _TOPICMOD_OPERATION._serialized_start = 962 - _TOPICMOD_OPERATION._serialized_end = 1009 - _TOPICTOMBSTONE._serialized_start = 1012 - _TOPICTOMBSTONE._serialized_end = 1145 - _TOPICTOMBSTONE_STATUS._serialized_start = 1096 - _TOPICTOMBSTONE_STATUS._serialized_end = 1145 - _TOPICEXISTSINFO._serialized_start = 1147 - _TOPICEXISTSINFO._serialized_end = 1195 - _PLACEMENT._serialized_start = 1198 - _PLACEMENT._serialized_end = 1354 - _NODE._serialized_start = 1356 - _NODE._serialized_end = 1476 - _EVENTTYPEINFO._serialized_start = 1479 - _EVENTTYPEINFO._serialized_end = 1679 + _TOPICINFO._serialized_end = 737 + _TOPICSPAGE._serialized_start = 739 + _TOPICSPAGE._serialized_end = 815 + _TOPICNAMESPAGE._serialized_start = 817 + _TOPICNAMESPAGE._serialized_end = 906 + _TOPICMOD._serialized_start = 908 + _TOPICMOD._serialized_end = 1034 + _TOPICMOD_OPERATION._serialized_start = 987 + _TOPICMOD_OPERATION._serialized_end = 1034 + _TOPICTOMBSTONE._serialized_start = 1037 + _TOPICTOMBSTONE._serialized_end = 1170 + _TOPICTOMBSTONE_STATUS._serialized_start = 1121 + _TOPICTOMBSTONE_STATUS._serialized_end = 1170 + _TOPICEXISTSINFO._serialized_start = 1172 + _TOPICEXISTSINFO._serialized_end = 1220 + _PLACEMENT._serialized_start = 1223 + _PLACEMENT._serialized_end = 1379 + _NODE._serialized_start = 1381 + _NODE._serialized_end = 1501 + _EVENTTYPEINFO._serialized_start = 1504 + _EVENTTYPEINFO._serialized_end = 1704 # @@protoc_insertion_point(module_scope) diff --git a/pyensign/nack.py b/pyensign/nack.py index 928853d..0da4d9f 100644 --- a/pyensign/nack.py +++ b/pyensign/nack.py @@ -15,8 +15,8 @@ # should inspect the error code in a Nack returned by the Ensign service to determine # why the event was not published. MaxEventSizeExceeded = Nack.Code.MAX_EVENT_SIZE_EXCEEDED -TopicUnknown = Nack.Code.TOPIC_UKNOWN -TopicArchived = Nack.Code.TOPIC_ARCHVIVED +TopicUnknown = Nack.Code.TOPIC_UNKNOWN +TopicArchived = Nack.Code.TOPIC_ARCHIVED TopicDeleted = Nack.Code.TOPIC_DELETED PermissionDenied = Nack.Code.PERMISSION_DENIED ConsensusFailure = Nack.Code.CONSENSUS_FAILURE