diff --git a/Makefile b/Makefile index 6c7fc00..9642f49 100644 --- a/Makefile +++ b/Makefile @@ -30,8 +30,8 @@ cleanup: - docker rm -f eventstore_local_noauth eventstore_docker: - docker run -d --name eventstore_local -p 2113:2113 -p 1113:1113 eventstore/eventstore - docker run -d --name eventstore_local_noauth -p 22113:2113 -p 11113:1113 eventstore/eventstore + docker run -d --name eventstore_local -p 2113:2113 -p 1113:1113 eventstore/eventstore:release-5.0.8 + docker run -d --name eventstore_local_noauth -p 22113:2113 -p 11113:1113 eventstore/eventstore:release-5.0.8 for i in {1..10}; do curl -f -i "http://127.0.0.1:2113/users" --user admin:changeit && break || sleep 1; done for i in {1..10}; do curl -f -i "http://127.0.0.1:22113/users" --user admin:changeit && break || sleep 1; done curl -f -i "http://127.0.0.1:2113/streams/%24settings" \ diff --git a/photonpump/messages_pb2.py b/photonpump/messages_pb2.py index 1a1470c..0201626 100644 --- a/photonpump/messages_pb2.py +++ b/photonpump/messages_pb2.py @@ -1,63 +1,101 @@ +# -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: messages.proto - -import sys - -_b = sys.version_info[0] < 3 and (lambda x: x) or (lambda x: x.encode("latin1")) +"""Generated protocol buffer code.""" from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import message as _message from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database -from google.protobuf import descriptor_pb2 # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() + DESCRIPTOR = _descriptor.FileDescriptor( name="messages.proto", package="EventStore.Client.Messages", syntax="proto2", - serialized_pb=_b( - '\n\x0emessages.proto\x12\x1a\x45ventStore.Client.Messages"\x8a\x01\n\x08NewEvent\x12\x10\n\x08\x65vent_id\x18\x01 \x02(\x0c\x12\x12\n\nevent_type\x18\x02 \x02(\t\x12\x19\n\x11\x64\x61ta_content_type\x18\x03 \x02(\x05\x12\x1d\n\x15metadata_content_type\x18\x04 \x02(\x05\x12\x0c\n\x04\x64\x61ta\x18\x05 \x02(\x0c\x12\x10\n\x08metadata\x18\x06 \x01(\x0c"\xe4\x01\n\x0b\x45ventRecord\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x14\n\x0c\x65vent_number\x18\x02 \x02(\x05\x12\x10\n\x08\x65vent_id\x18\x03 \x02(\x0c\x12\x12\n\nevent_type\x18\x04 \x02(\t\x12\x19\n\x11\x64\x61ta_content_type\x18\x05 \x02(\x05\x12\x1d\n\x15metadata_content_type\x18\x06 \x02(\x05\x12\x0c\n\x04\x64\x61ta\x18\x07 \x02(\x0c\x12\x10\n\x08metadata\x18\x08 \x01(\x0c\x12\x0f\n\x07\x63reated\x18\t \x01(\x03\x12\x15\n\rcreated_epoch\x18\n \x01(\x03"\x85\x01\n\x14ResolvedIndexedEvent\x12\x36\n\x05\x65vent\x18\x01 \x02(\x0b\x32\'.EventStore.Client.Messages.EventRecord\x12\x35\n\x04link\x18\x02 \x01(\x0b\x32\'.EventStore.Client.Messages.EventRecord"\xb1\x01\n\rResolvedEvent\x12\x36\n\x05\x65vent\x18\x01 \x02(\x0b\x32\'.EventStore.Client.Messages.EventRecord\x12\x35\n\x04link\x18\x02 \x01(\x0b\x32\'.EventStore.Client.Messages.EventRecord\x12\x17\n\x0f\x63ommit_position\x18\x03 \x02(\x03\x12\x18\n\x10prepare_position\x18\x04 \x02(\x03"\x8e\x01\n\x0bWriteEvents\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x18\n\x10\x65xpected_version\x18\x02 \x02(\x05\x12\x34\n\x06\x65vents\x18\x03 \x03(\x0b\x32$.EventStore.Client.Messages.NewEvent\x12\x16\n\x0erequire_master\x18\x04 \x02(\x08"\xce\x01\n\x14WriteEventsCompleted\x12;\n\x06result\x18\x01 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x1a\n\x12\x66irst_event_number\x18\x03 \x02(\x05\x12\x19\n\x11last_event_number\x18\x04 \x02(\x05\x12\x18\n\x10prepare_position\x18\x05 \x01(\x03\x12\x17\n\x0f\x63ommit_position\x18\x06 \x01(\x03"n\n\x0c\x44\x65leteStream\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x18\n\x10\x65xpected_version\x18\x02 \x02(\x05\x12\x16\n\x0erequire_master\x18\x03 \x02(\x08\x12\x13\n\x0bhard_delete\x18\x04 \x01(\x08"\x98\x01\n\x15\x44\x65leteStreamCompleted\x12;\n\x06result\x18\x01 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x18\n\x10prepare_position\x18\x03 \x01(\x03\x12\x17\n\x0f\x63ommit_position\x18\x04 \x01(\x03"]\n\x10TransactionStart\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x18\n\x10\x65xpected_version\x18\x02 \x02(\x05\x12\x16\n\x0erequire_master\x18\x03 \x02(\x08"\x81\x01\n\x19TransactionStartCompleted\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12;\n\x06result\x18\x02 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x03 \x01(\t"x\n\x10TransactionWrite\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12\x34\n\x06\x65vents\x18\x02 \x03(\x0b\x32$.EventStore.Client.Messages.NewEvent\x12\x16\n\x0erequire_master\x18\x03 \x02(\x08"\x81\x01\n\x19TransactionWriteCompleted\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12;\n\x06result\x18\x02 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x03 \x01(\t"C\n\x11TransactionCommit\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12\x16\n\x0erequire_master\x18\x02 \x02(\x08"\xec\x01\n\x1aTransactionCommitCompleted\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12;\n\x06result\x18\x02 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x03 \x01(\t\x12\x1a\n\x12\x66irst_event_number\x18\x04 \x02(\x05\x12\x19\n\x11last_event_number\x18\x05 \x02(\x05\x12\x18\n\x10prepare_position\x18\x06 \x01(\x03\x12\x17\n\x0f\x63ommit_position\x18\x07 \x01(\x03"l\n\tReadEvent\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x14\n\x0c\x65vent_number\x18\x02 \x02(\x05\x12\x18\n\x10resolve_link_tos\x18\x03 \x02(\x08\x12\x16\n\x0erequire_master\x18\x04 \x02(\x08"\xa0\x02\n\x12ReadEventCompleted\x12N\n\x06result\x18\x01 \x02(\x0e\x32>.EventStore.Client.Messages.ReadEventCompleted.ReadEventResult\x12?\n\x05\x65vent\x18\x02 \x02(\x0b\x32\x30.EventStore.Client.Messages.ResolvedIndexedEvent\x12\r\n\x05\x65rror\x18\x03 \x01(\t"j\n\x0fReadEventResult\x12\x0b\n\x07Success\x10\x00\x12\x0c\n\x08NotFound\x10\x01\x12\x0c\n\x08NoStream\x10\x02\x12\x11\n\rStreamDeleted\x10\x03\x12\t\n\x05\x45rror\x10\x04\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x05"\x8b\x01\n\x10ReadStreamEvents\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x19\n\x11\x66rom_event_number\x18\x02 \x02(\x05\x12\x11\n\tmax_count\x18\x03 \x02(\x05\x12\x18\n\x10resolve_link_tos\x18\x04 \x02(\x08\x12\x16\n\x0erequire_master\x18\x05 \x02(\x08"\xa2\x03\n\x19ReadStreamEventsCompleted\x12@\n\x06\x65vents\x18\x01 \x03(\x0b\x32\x30.EventStore.Client.Messages.ResolvedIndexedEvent\x12V\n\x06result\x18\x02 \x02(\x0e\x32\x46.EventStore.Client.Messages.ReadStreamEventsCompleted.ReadStreamResult\x12\x19\n\x11next_event_number\x18\x03 \x02(\x05\x12\x19\n\x11last_event_number\x18\x04 \x02(\x05\x12\x18\n\x10is_end_of_stream\x18\x05 \x02(\x08\x12\x1c\n\x14last_commit_position\x18\x06 \x02(\x03\x12\r\n\x05\x65rror\x18\x07 \x01(\t"n\n\x10ReadStreamResult\x12\x0b\n\x07Success\x10\x00\x12\x0c\n\x08NoStream\x10\x01\x12\x11\n\rStreamDeleted\x10\x02\x12\x0f\n\x0bNotModified\x10\x03\x12\t\n\x05\x45rror\x10\x04\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x05"\x87\x01\n\rReadAllEvents\x12\x17\n\x0f\x63ommit_position\x18\x01 \x02(\x03\x12\x18\n\x10prepare_position\x18\x02 \x02(\x03\x12\x11\n\tmax_count\x18\x03 \x02(\x05\x12\x18\n\x10resolve_link_tos\x18\x04 \x02(\x08\x12\x16\n\x0erequire_master\x18\x05 \x02(\x08"\xf9\x02\n\x16ReadAllEventsCompleted\x12\x17\n\x0f\x63ommit_position\x18\x01 \x02(\x03\x12\x18\n\x10prepare_position\x18\x02 \x02(\x03\x12\x39\n\x06\x65vents\x18\x03 \x03(\x0b\x32).EventStore.Client.Messages.ResolvedEvent\x12\x1c\n\x14next_commit_position\x18\x04 \x02(\x03\x12\x1d\n\x15next_prepare_position\x18\x05 \x02(\x03\x12Y\n\x06result\x18\x06 \x01(\x0e\x32@.EventStore.Client.Messages.ReadAllEventsCompleted.ReadAllResult:\x07Success\x12\r\n\x05\x65rror\x18\x07 \x01(\t"J\n\rReadAllResult\x12\x0b\n\x07Success\x10\x00\x12\x0f\n\x0bNotModified\x10\x01\x12\t\n\x05\x45rror\x10\x02\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x03"\xde\x03\n\x1c\x43reatePersistentSubscription\x12\x1f\n\x17subscription_group_name\x18\x01 \x02(\t\x12\x17\n\x0f\x65vent_stream_id\x18\x02 \x02(\t\x12\x18\n\x10resolve_link_tos\x18\x03 \x02(\x08\x12\x12\n\nstart_from\x18\x04 \x02(\x05\x12$\n\x1cmessage_timeout_milliseconds\x18\x05 \x02(\x05\x12\x19\n\x11record_statistics\x18\x06 \x02(\x08\x12\x18\n\x10live_buffer_size\x18\x07 \x02(\x05\x12\x17\n\x0fread_batch_size\x18\x08 \x02(\x05\x12\x13\n\x0b\x62uffer_size\x18\t \x02(\x05\x12\x17\n\x0fmax_retry_count\x18\n \x02(\x05\x12\x1a\n\x12prefer_round_robin\x18\x0b \x02(\x08\x12\x1d\n\x15\x63heckpoint_after_time\x18\x0c \x02(\x05\x12\x1c\n\x14\x63heckpoint_max_count\x18\r \x02(\x05\x12\x1c\n\x14\x63heckpoint_min_count\x18\x0e \x02(\x05\x12\x1c\n\x14subscriber_max_count\x18\x0f \x02(\x05\x12\x1f\n\x17named_consumer_strategy\x18\x10 \x01(\t"X\n\x1c\x44\x65letePersistentSubscription\x12\x1f\n\x17subscription_group_name\x18\x01 \x02(\t\x12\x17\n\x0f\x65vent_stream_id\x18\x02 \x02(\t"\xde\x03\n\x1cUpdatePersistentSubscription\x12\x1f\n\x17subscription_group_name\x18\x01 \x02(\t\x12\x17\n\x0f\x65vent_stream_id\x18\x02 \x02(\t\x12\x18\n\x10resolve_link_tos\x18\x03 \x02(\x08\x12\x12\n\nstart_from\x18\x04 \x02(\x05\x12$\n\x1cmessage_timeout_milliseconds\x18\x05 \x02(\x05\x12\x19\n\x11record_statistics\x18\x06 \x02(\x08\x12\x18\n\x10live_buffer_size\x18\x07 \x02(\x05\x12\x17\n\x0fread_batch_size\x18\x08 \x02(\x05\x12\x13\n\x0b\x62uffer_size\x18\t \x02(\x05\x12\x17\n\x0fmax_retry_count\x18\n \x02(\x05\x12\x1a\n\x12prefer_round_robin\x18\x0b \x02(\x08\x12\x1d\n\x15\x63heckpoint_after_time\x18\x0c \x02(\x05\x12\x1c\n\x14\x63heckpoint_max_count\x18\r \x02(\x05\x12\x1c\n\x14\x63heckpoint_min_count\x18\x0e \x02(\x05\x12\x1c\n\x14subscriber_max_count\x18\x0f \x02(\x05\x12\x1f\n\x17named_consumer_strategy\x18\x10 \x01(\t"\x97\x02\n%UpdatePersistentSubscriptionCompleted\x12}\n\x06result\x18\x01 \x02(\x0e\x32\x64.EventStore.Client.Messages.UpdatePersistentSubscriptionCompleted.UpdatePersistentSubscriptionResult:\x07Success\x12\x0e\n\x06reason\x18\x02 \x01(\t"_\n"UpdatePersistentSubscriptionResult\x12\x0b\n\x07Success\x10\x00\x12\x10\n\x0c\x44oesNotExist\x10\x01\x12\x08\n\x04\x46\x61il\x10\x02\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x03"\x98\x02\n%CreatePersistentSubscriptionCompleted\x12}\n\x06result\x18\x01 \x02(\x0e\x32\x64.EventStore.Client.Messages.CreatePersistentSubscriptionCompleted.CreatePersistentSubscriptionResult:\x07Success\x12\x0e\n\x06reason\x18\x02 \x01(\t"`\n"CreatePersistentSubscriptionResult\x12\x0b\n\x07Success\x10\x00\x12\x11\n\rAlreadyExists\x10\x01\x12\x08\n\x04\x46\x61il\x10\x02\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x03"\x97\x02\n%DeletePersistentSubscriptionCompleted\x12}\n\x06result\x18\x01 \x02(\x0e\x32\x64.EventStore.Client.Messages.DeletePersistentSubscriptionCompleted.DeletePersistentSubscriptionResult:\x07Success\x12\x0e\n\x06reason\x18\x02 \x01(\t"_\n"DeletePersistentSubscriptionResult\x12\x0b\n\x07Success\x10\x00\x12\x10\n\x0c\x44oesNotExist\x10\x01\x12\x08\n\x04\x46\x61il\x10\x02\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x03"w\n\x1f\x43onnectToPersistentSubscription\x12\x17\n\x0fsubscription_id\x18\x01 \x02(\t\x12\x17\n\x0f\x65vent_stream_id\x18\x02 \x02(\t\x12"\n\x1a\x61llowed_in_flight_messages\x18\x03 \x02(\x05"W\n\x1fPersistentSubscriptionAckEvents\x12\x17\n\x0fsubscription_id\x18\x01 \x02(\t\x12\x1b\n\x13processed_event_ids\x18\x02 \x03(\x0c"\x8b\x02\n\x1fPersistentSubscriptionNakEvents\x12\x17\n\x0fsubscription_id\x18\x01 \x02(\t\x12\x1b\n\x13processed_event_ids\x18\x02 \x03(\x0c\x12\x0f\n\x07message\x18\x03 \x01(\t\x12^\n\x06\x61\x63tion\x18\x04 \x02(\x0e\x32\x45.EventStore.Client.Messages.PersistentSubscriptionNakEvents.NakAction:\x07Unknown"A\n\tNakAction\x12\x0b\n\x07Unknown\x10\x00\x12\x08\n\x04Park\x10\x01\x12\t\n\x05Retry\x10\x02\x12\x08\n\x04Skip\x10\x03\x12\x08\n\x04Stop\x10\x04"v\n"PersistentSubscriptionConfirmation\x12\x1c\n\x14last_commit_position\x18\x01 \x02(\x03\x12\x17\n\x0fsubscription_id\x18\x02 \x02(\t\x12\x19\n\x11last_event_number\x18\x03 \x01(\x05"l\n)PersistentSubscriptionStreamEventAppeared\x12?\n\x05\x65vent\x18\x01 \x02(\x0b\x32\x30.EventStore.Client.Messages.ResolvedIndexedEvent"F\n\x11SubscribeToStream\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x18\n\x10resolve_link_tos\x18\x02 \x02(\x08"S\n\x18SubscriptionConfirmation\x12\x1c\n\x14last_commit_position\x18\x01 \x02(\x03\x12\x19\n\x11last_event_number\x18\x02 \x01(\x05"O\n\x13StreamEventAppeared\x12\x38\n\x05\x65vent\x18\x01 \x02(\x0b\x32).EventStore.Client.Messages.ResolvedEvent"\x17\n\x15UnsubscribeFromStream"\x06\n\x04Ping"\x06\n\x04Pong"\x8a\x02\n\x13SubscriptionDropped\x12\x64\n\x06reason\x18\x01 \x01(\x0e\x32\x46.EventStore.Client.Messages.SubscriptionDropped.SubscriptionDropReason:\x0cUnsubscribed"\x8c\x01\n\x16SubscriptionDropReason\x12\x10\n\x0cUnsubscribed\x10\x00\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x01\x12\x0c\n\x08NotFound\x10\x02\x12!\n\x1dPersistentSubscriptionDeleted\x10\x03\x12\x1d\n\x19SubscriberMaxCountReached\x10\x04"\xf6\x02\n\nNotHandled\x12G\n\x06reason\x18\x01 \x02(\x0e\x32\x37.EventStore.Client.Messages.NotHandled.NotHandledReason\x12\x17\n\x0f\x61\x64\x64itional_info\x18\x02 \x01(\x0c\x1a\xc7\x01\n\nMasterInfo\x12\x1c\n\x14\x65xternal_tcp_address\x18\x01 \x02(\t\x12\x19\n\x11\x65xternal_tcp_port\x18\x02 \x02(\x05\x12\x1d\n\x15\x65xternal_http_address\x18\x03 \x02(\t\x12\x1a\n\x12\x65xternal_http_port\x18\x04 \x02(\x05\x12#\n\x1b\x65xternal_secure_tcp_address\x18\x05 \x01(\t\x12 \n\x18\x65xternal_secure_tcp_port\x18\x06 \x01(\x05"<\n\x10NotHandledReason\x12\x0c\n\x08NotReady\x10\x00\x12\x0b\n\x07TooBusy\x10\x01\x12\r\n\tNotMaster\x10\x02"\x12\n\x10ScavengeDatabase"\xed\x01\n\x19ScavengeDatabaseCompleted\x12T\n\x06result\x18\x01 \x02(\x0e\x32\x44.EventStore.Client.Messages.ScavengeDatabaseCompleted.ScavengeResult\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x12\x15\n\rtotal_time_ms\x18\x03 \x02(\x05\x12\x19\n\x11total_space_saved\x18\x04 \x02(\x03"9\n\x0eScavengeResult\x12\x0b\n\x07Success\x10\x00\x12\x0e\n\nInProgress\x10\x01\x12\n\n\x06\x46\x61iled\x10\x02*\xb0\x01\n\x0fOperationResult\x12\x0b\n\x07Success\x10\x00\x12\x12\n\x0ePrepareTimeout\x10\x01\x12\x11\n\rCommitTimeout\x10\x02\x12\x12\n\x0e\x46orwardTimeout\x10\x03\x12\x18\n\x14WrongExpectedVersion\x10\x04\x12\x11\n\rStreamDeleted\x10\x05\x12\x16\n\x12InvalidTransaction\x10\x06\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x07' - ), + serialized_options=None, + create_key=_descriptor._internal_create_key, + serialized_pb=b'\n\x0emessages.proto\x12\x1a\x45ventStore.Client.Messages"\x8a\x01\n\x08NewEvent\x12\x10\n\x08\x65vent_id\x18\x01 \x02(\x0c\x12\x12\n\nevent_type\x18\x02 \x02(\t\x12\x19\n\x11\x64\x61ta_content_type\x18\x03 \x02(\x05\x12\x1d\n\x15metadata_content_type\x18\x04 \x02(\x05\x12\x0c\n\x04\x64\x61ta\x18\x05 \x02(\x0c\x12\x10\n\x08metadata\x18\x06 \x01(\x0c"\xe4\x01\n\x0b\x45ventRecord\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x14\n\x0c\x65vent_number\x18\x02 \x02(\x05\x12\x10\n\x08\x65vent_id\x18\x03 \x02(\x0c\x12\x12\n\nevent_type\x18\x04 \x02(\t\x12\x19\n\x11\x64\x61ta_content_type\x18\x05 \x02(\x05\x12\x1d\n\x15metadata_content_type\x18\x06 \x02(\x05\x12\x0c\n\x04\x64\x61ta\x18\x07 \x02(\x0c\x12\x10\n\x08metadata\x18\x08 \x01(\x0c\x12\x0f\n\x07\x63reated\x18\t \x01(\x03\x12\x15\n\rcreated_epoch\x18\n \x01(\x03"\x85\x01\n\x14ResolvedIndexedEvent\x12\x36\n\x05\x65vent\x18\x01 \x02(\x0b\x32\'.EventStore.Client.Messages.EventRecord\x12\x35\n\x04link\x18\x02 \x01(\x0b\x32\'.EventStore.Client.Messages.EventRecord"\xb1\x01\n\rResolvedEvent\x12\x36\n\x05\x65vent\x18\x01 \x02(\x0b\x32\'.EventStore.Client.Messages.EventRecord\x12\x35\n\x04link\x18\x02 \x01(\x0b\x32\'.EventStore.Client.Messages.EventRecord\x12\x17\n\x0f\x63ommit_position\x18\x03 \x02(\x03\x12\x18\n\x10prepare_position\x18\x04 \x02(\x03"\x8e\x01\n\x0bWriteEvents\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x18\n\x10\x65xpected_version\x18\x02 \x02(\x05\x12\x34\n\x06\x65vents\x18\x03 \x03(\x0b\x32$.EventStore.Client.Messages.NewEvent\x12\x16\n\x0erequire_master\x18\x04 \x02(\x08"\xce\x01\n\x14WriteEventsCompleted\x12;\n\x06result\x18\x01 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x1a\n\x12\x66irst_event_number\x18\x03 \x02(\x05\x12\x19\n\x11last_event_number\x18\x04 \x02(\x05\x12\x18\n\x10prepare_position\x18\x05 \x01(\x03\x12\x17\n\x0f\x63ommit_position\x18\x06 \x01(\x03"n\n\x0c\x44\x65leteStream\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x18\n\x10\x65xpected_version\x18\x02 \x02(\x05\x12\x16\n\x0erequire_master\x18\x03 \x02(\x08\x12\x13\n\x0bhard_delete\x18\x04 \x01(\x08"\x98\x01\n\x15\x44\x65leteStreamCompleted\x12;\n\x06result\x18\x01 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x18\n\x10prepare_position\x18\x03 \x01(\x03\x12\x17\n\x0f\x63ommit_position\x18\x04 \x01(\x03"]\n\x10TransactionStart\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x18\n\x10\x65xpected_version\x18\x02 \x02(\x05\x12\x16\n\x0erequire_master\x18\x03 \x02(\x08"\x81\x01\n\x19TransactionStartCompleted\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12;\n\x06result\x18\x02 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x03 \x01(\t"x\n\x10TransactionWrite\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12\x34\n\x06\x65vents\x18\x02 \x03(\x0b\x32$.EventStore.Client.Messages.NewEvent\x12\x16\n\x0erequire_master\x18\x03 \x02(\x08"\x81\x01\n\x19TransactionWriteCompleted\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12;\n\x06result\x18\x02 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x03 \x01(\t"C\n\x11TransactionCommit\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12\x16\n\x0erequire_master\x18\x02 \x02(\x08"\xec\x01\n\x1aTransactionCommitCompleted\x12\x16\n\x0etransaction_id\x18\x01 \x02(\x03\x12;\n\x06result\x18\x02 \x02(\x0e\x32+.EventStore.Client.Messages.OperationResult\x12\x0f\n\x07message\x18\x03 \x01(\t\x12\x1a\n\x12\x66irst_event_number\x18\x04 \x02(\x05\x12\x19\n\x11last_event_number\x18\x05 \x02(\x05\x12\x18\n\x10prepare_position\x18\x06 \x01(\x03\x12\x17\n\x0f\x63ommit_position\x18\x07 \x01(\x03"l\n\tReadEvent\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x14\n\x0c\x65vent_number\x18\x02 \x02(\x05\x12\x18\n\x10resolve_link_tos\x18\x03 \x02(\x08\x12\x16\n\x0erequire_master\x18\x04 \x02(\x08"\xa0\x02\n\x12ReadEventCompleted\x12N\n\x06result\x18\x01 \x02(\x0e\x32>.EventStore.Client.Messages.ReadEventCompleted.ReadEventResult\x12?\n\x05\x65vent\x18\x02 \x02(\x0b\x32\x30.EventStore.Client.Messages.ResolvedIndexedEvent\x12\r\n\x05\x65rror\x18\x03 \x01(\t"j\n\x0fReadEventResult\x12\x0b\n\x07Success\x10\x00\x12\x0c\n\x08NotFound\x10\x01\x12\x0c\n\x08NoStream\x10\x02\x12\x11\n\rStreamDeleted\x10\x03\x12\t\n\x05\x45rror\x10\x04\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x05"\x8b\x01\n\x10ReadStreamEvents\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x19\n\x11\x66rom_event_number\x18\x02 \x02(\x05\x12\x11\n\tmax_count\x18\x03 \x02(\x05\x12\x18\n\x10resolve_link_tos\x18\x04 \x02(\x08\x12\x16\n\x0erequire_master\x18\x05 \x02(\x08"\xa2\x03\n\x19ReadStreamEventsCompleted\x12@\n\x06\x65vents\x18\x01 \x03(\x0b\x32\x30.EventStore.Client.Messages.ResolvedIndexedEvent\x12V\n\x06result\x18\x02 \x02(\x0e\x32\x46.EventStore.Client.Messages.ReadStreamEventsCompleted.ReadStreamResult\x12\x19\n\x11next_event_number\x18\x03 \x02(\x05\x12\x19\n\x11last_event_number\x18\x04 \x02(\x05\x12\x18\n\x10is_end_of_stream\x18\x05 \x02(\x08\x12\x1c\n\x14last_commit_position\x18\x06 \x02(\x03\x12\r\n\x05\x65rror\x18\x07 \x01(\t"n\n\x10ReadStreamResult\x12\x0b\n\x07Success\x10\x00\x12\x0c\n\x08NoStream\x10\x01\x12\x11\n\rStreamDeleted\x10\x02\x12\x0f\n\x0bNotModified\x10\x03\x12\t\n\x05\x45rror\x10\x04\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x05"\x87\x01\n\rReadAllEvents\x12\x17\n\x0f\x63ommit_position\x18\x01 \x02(\x03\x12\x18\n\x10prepare_position\x18\x02 \x02(\x03\x12\x11\n\tmax_count\x18\x03 \x02(\x05\x12\x18\n\x10resolve_link_tos\x18\x04 \x02(\x08\x12\x16\n\x0erequire_master\x18\x05 \x02(\x08"\xf9\x02\n\x16ReadAllEventsCompleted\x12\x17\n\x0f\x63ommit_position\x18\x01 \x02(\x03\x12\x18\n\x10prepare_position\x18\x02 \x02(\x03\x12\x39\n\x06\x65vents\x18\x03 \x03(\x0b\x32).EventStore.Client.Messages.ResolvedEvent\x12\x1c\n\x14next_commit_position\x18\x04 \x02(\x03\x12\x1d\n\x15next_prepare_position\x18\x05 \x02(\x03\x12Y\n\x06result\x18\x06 \x01(\x0e\x32@.EventStore.Client.Messages.ReadAllEventsCompleted.ReadAllResult:\x07Success\x12\r\n\x05\x65rror\x18\x07 \x01(\t"J\n\rReadAllResult\x12\x0b\n\x07Success\x10\x00\x12\x0f\n\x0bNotModified\x10\x01\x12\t\n\x05\x45rror\x10\x02\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x03"\xde\x03\n\x1c\x43reatePersistentSubscription\x12\x1f\n\x17subscription_group_name\x18\x01 \x02(\t\x12\x17\n\x0f\x65vent_stream_id\x18\x02 \x02(\t\x12\x18\n\x10resolve_link_tos\x18\x03 \x02(\x08\x12\x12\n\nstart_from\x18\x04 \x02(\x05\x12$\n\x1cmessage_timeout_milliseconds\x18\x05 \x02(\x05\x12\x19\n\x11record_statistics\x18\x06 \x02(\x08\x12\x18\n\x10live_buffer_size\x18\x07 \x02(\x05\x12\x17\n\x0fread_batch_size\x18\x08 \x02(\x05\x12\x13\n\x0b\x62uffer_size\x18\t \x02(\x05\x12\x17\n\x0fmax_retry_count\x18\n \x02(\x05\x12\x1a\n\x12prefer_round_robin\x18\x0b \x02(\x08\x12\x1d\n\x15\x63heckpoint_after_time\x18\x0c \x02(\x05\x12\x1c\n\x14\x63heckpoint_max_count\x18\r \x02(\x05\x12\x1c\n\x14\x63heckpoint_min_count\x18\x0e \x02(\x05\x12\x1c\n\x14subscriber_max_count\x18\x0f \x02(\x05\x12\x1f\n\x17named_consumer_strategy\x18\x10 \x01(\t"X\n\x1c\x44\x65letePersistentSubscription\x12\x1f\n\x17subscription_group_name\x18\x01 \x02(\t\x12\x17\n\x0f\x65vent_stream_id\x18\x02 \x02(\t"\xde\x03\n\x1cUpdatePersistentSubscription\x12\x1f\n\x17subscription_group_name\x18\x01 \x02(\t\x12\x17\n\x0f\x65vent_stream_id\x18\x02 \x02(\t\x12\x18\n\x10resolve_link_tos\x18\x03 \x02(\x08\x12\x12\n\nstart_from\x18\x04 \x02(\x05\x12$\n\x1cmessage_timeout_milliseconds\x18\x05 \x02(\x05\x12\x19\n\x11record_statistics\x18\x06 \x02(\x08\x12\x18\n\x10live_buffer_size\x18\x07 \x02(\x05\x12\x17\n\x0fread_batch_size\x18\x08 \x02(\x05\x12\x13\n\x0b\x62uffer_size\x18\t \x02(\x05\x12\x17\n\x0fmax_retry_count\x18\n \x02(\x05\x12\x1a\n\x12prefer_round_robin\x18\x0b \x02(\x08\x12\x1d\n\x15\x63heckpoint_after_time\x18\x0c \x02(\x05\x12\x1c\n\x14\x63heckpoint_max_count\x18\r \x02(\x05\x12\x1c\n\x14\x63heckpoint_min_count\x18\x0e \x02(\x05\x12\x1c\n\x14subscriber_max_count\x18\x0f \x02(\x05\x12\x1f\n\x17named_consumer_strategy\x18\x10 \x01(\t"\x97\x02\n%UpdatePersistentSubscriptionCompleted\x12}\n\x06result\x18\x01 \x02(\x0e\x32\x64.EventStore.Client.Messages.UpdatePersistentSubscriptionCompleted.UpdatePersistentSubscriptionResult:\x07Success\x12\x0e\n\x06reason\x18\x02 \x01(\t"_\n"UpdatePersistentSubscriptionResult\x12\x0b\n\x07Success\x10\x00\x12\x10\n\x0c\x44oesNotExist\x10\x01\x12\x08\n\x04\x46\x61il\x10\x02\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x03"\x98\x02\n%CreatePersistentSubscriptionCompleted\x12}\n\x06result\x18\x01 \x02(\x0e\x32\x64.EventStore.Client.Messages.CreatePersistentSubscriptionCompleted.CreatePersistentSubscriptionResult:\x07Success\x12\x0e\n\x06reason\x18\x02 \x01(\t"`\n"CreatePersistentSubscriptionResult\x12\x0b\n\x07Success\x10\x00\x12\x11\n\rAlreadyExists\x10\x01\x12\x08\n\x04\x46\x61il\x10\x02\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x03"\x97\x02\n%DeletePersistentSubscriptionCompleted\x12}\n\x06result\x18\x01 \x02(\x0e\x32\x64.EventStore.Client.Messages.DeletePersistentSubscriptionCompleted.DeletePersistentSubscriptionResult:\x07Success\x12\x0e\n\x06reason\x18\x02 \x01(\t"_\n"DeletePersistentSubscriptionResult\x12\x0b\n\x07Success\x10\x00\x12\x10\n\x0c\x44oesNotExist\x10\x01\x12\x08\n\x04\x46\x61il\x10\x02\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x03"w\n\x1f\x43onnectToPersistentSubscription\x12\x17\n\x0fsubscription_id\x18\x01 \x02(\t\x12\x17\n\x0f\x65vent_stream_id\x18\x02 \x02(\t\x12"\n\x1a\x61llowed_in_flight_messages\x18\x03 \x02(\x05"W\n\x1fPersistentSubscriptionAckEvents\x12\x17\n\x0fsubscription_id\x18\x01 \x02(\t\x12\x1b\n\x13processed_event_ids\x18\x02 \x03(\x0c"\x8b\x02\n\x1fPersistentSubscriptionNakEvents\x12\x17\n\x0fsubscription_id\x18\x01 \x02(\t\x12\x1b\n\x13processed_event_ids\x18\x02 \x03(\x0c\x12\x0f\n\x07message\x18\x03 \x01(\t\x12^\n\x06\x61\x63tion\x18\x04 \x02(\x0e\x32\x45.EventStore.Client.Messages.PersistentSubscriptionNakEvents.NakAction:\x07Unknown"A\n\tNakAction\x12\x0b\n\x07Unknown\x10\x00\x12\x08\n\x04Park\x10\x01\x12\t\n\x05Retry\x10\x02\x12\x08\n\x04Skip\x10\x03\x12\x08\n\x04Stop\x10\x04"v\n"PersistentSubscriptionConfirmation\x12\x1c\n\x14last_commit_position\x18\x01 \x02(\x03\x12\x17\n\x0fsubscription_id\x18\x02 \x02(\t\x12\x19\n\x11last_event_number\x18\x03 \x01(\x05"l\n)PersistentSubscriptionStreamEventAppeared\x12?\n\x05\x65vent\x18\x01 \x02(\x0b\x32\x30.EventStore.Client.Messages.ResolvedIndexedEvent"F\n\x11SubscribeToStream\x12\x17\n\x0f\x65vent_stream_id\x18\x01 \x02(\t\x12\x18\n\x10resolve_link_tos\x18\x02 \x02(\x08"S\n\x18SubscriptionConfirmation\x12\x1c\n\x14last_commit_position\x18\x01 \x02(\x03\x12\x19\n\x11last_event_number\x18\x02 \x01(\x05"O\n\x13StreamEventAppeared\x12\x38\n\x05\x65vent\x18\x01 \x02(\x0b\x32).EventStore.Client.Messages.ResolvedEvent"\x17\n\x15UnsubscribeFromStream"\x06\n\x04Ping"\x06\n\x04Pong"\x8a\x02\n\x13SubscriptionDropped\x12\x64\n\x06reason\x18\x01 \x01(\x0e\x32\x46.EventStore.Client.Messages.SubscriptionDropped.SubscriptionDropReason:\x0cUnsubscribed"\x8c\x01\n\x16SubscriptionDropReason\x12\x10\n\x0cUnsubscribed\x10\x00\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x01\x12\x0c\n\x08NotFound\x10\x02\x12!\n\x1dPersistentSubscriptionDeleted\x10\x03\x12\x1d\n\x19SubscriberMaxCountReached\x10\x04"\xf6\x02\n\nNotHandled\x12G\n\x06reason\x18\x01 \x02(\x0e\x32\x37.EventStore.Client.Messages.NotHandled.NotHandledReason\x12\x17\n\x0f\x61\x64\x64itional_info\x18\x02 \x01(\x0c\x1a\xc7\x01\n\nMasterInfo\x12\x1c\n\x14\x65xternal_tcp_address\x18\x01 \x02(\t\x12\x19\n\x11\x65xternal_tcp_port\x18\x02 \x02(\x05\x12\x1d\n\x15\x65xternal_http_address\x18\x03 \x02(\t\x12\x1a\n\x12\x65xternal_http_port\x18\x04 \x02(\x05\x12#\n\x1b\x65xternal_secure_tcp_address\x18\x05 \x01(\t\x12 \n\x18\x65xternal_secure_tcp_port\x18\x06 \x01(\x05"<\n\x10NotHandledReason\x12\x0c\n\x08NotReady\x10\x00\x12\x0b\n\x07TooBusy\x10\x01\x12\r\n\tNotMaster\x10\x02"\x12\n\x10ScavengeDatabase"\xed\x01\n\x19ScavengeDatabaseCompleted\x12T\n\x06result\x18\x01 \x02(\x0e\x32\x44.EventStore.Client.Messages.ScavengeDatabaseCompleted.ScavengeResult\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x12\x15\n\rtotal_time_ms\x18\x03 \x02(\x05\x12\x19\n\x11total_space_saved\x18\x04 \x02(\x03"9\n\x0eScavengeResult\x12\x0b\n\x07Success\x10\x00\x12\x0e\n\nInProgress\x10\x01\x12\n\n\x06\x46\x61iled\x10\x02*\xb0\x01\n\x0fOperationResult\x12\x0b\n\x07Success\x10\x00\x12\x12\n\x0ePrepareTimeout\x10\x01\x12\x11\n\rCommitTimeout\x10\x02\x12\x12\n\x0e\x46orwardTimeout\x10\x03\x12\x18\n\x14WrongExpectedVersion\x10\x04\x12\x11\n\rStreamDeleted\x10\x05\x12\x16\n\x12InvalidTransaction\x10\x06\x12\x10\n\x0c\x41\x63\x63\x65ssDenied\x10\x07', ) -_sym_db.RegisterFileDescriptor(DESCRIPTOR) _OPERATIONRESULT = _descriptor.EnumDescriptor( name="OperationResult", full_name="EventStore.Client.Messages.OperationResult", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Success", index=0, number=0, options=None, type=None + name="Success", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="PrepareTimeout", index=1, number=1, options=None, type=None + name="PrepareTimeout", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="CommitTimeout", index=2, number=2, options=None, type=None + name="CommitTimeout", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="ForwardTimeout", index=3, number=3, options=None, type=None + name="ForwardTimeout", + index=3, + number=3, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="WrongExpectedVersion", index=4, number=4, options=None, type=None + name="WrongExpectedVersion", + index=4, + number=4, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="StreamDeleted", index=5, number=5, options=None, type=None + name="StreamDeleted", + index=5, + number=5, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="InvalidTransaction", index=6, number=6, options=None, type=None + name="InvalidTransaction", + index=6, + number=6, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AccessDenied", index=7, number=7, options=None, type=None + name="AccessDenied", + index=7, + number=7, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=7421, serialized_end=7597, ) @@ -73,33 +111,65 @@ InvalidTransaction = 6 AccessDenied = 7 + _READEVENTCOMPLETED_READEVENTRESULT = _descriptor.EnumDescriptor( name="ReadEventResult", full_name="EventStore.Client.Messages.ReadEventCompleted.ReadEventResult", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Success", index=0, number=0, options=None, type=None + name="Success", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="NotFound", index=1, number=1, options=None, type=None + name="NotFound", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="NoStream", index=2, number=2, options=None, type=None + name="NoStream", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="StreamDeleted", index=3, number=3, options=None, type=None + name="StreamDeleted", + index=3, + number=3, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Error", index=4, number=4, options=None, type=None + name="Error", + index=4, + number=4, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AccessDenied", index=5, number=5, options=None, type=None + name="AccessDenied", + index=5, + number=5, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=2437, serialized_end=2543, ) @@ -110,28 +180,59 @@ full_name="EventStore.Client.Messages.ReadStreamEventsCompleted.ReadStreamResult", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Success", index=0, number=0, options=None, type=None + name="Success", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="NoStream", index=1, number=1, options=None, type=None + name="NoStream", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="StreamDeleted", index=2, number=2, options=None, type=None + name="StreamDeleted", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="NotModified", index=3, number=3, options=None, type=None + name="NotModified", + index=3, + number=3, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Error", index=4, number=4, options=None, type=None + name="Error", + index=4, + number=4, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AccessDenied", index=5, number=5, options=None, type=None + name="AccessDenied", + index=5, + number=5, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=2996, serialized_end=3106, ) @@ -142,22 +243,43 @@ full_name="EventStore.Client.Messages.ReadAllEventsCompleted.ReadAllResult", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Success", index=0, number=0, options=None, type=None + name="Success", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="NotModified", index=1, number=1, options=None, type=None + name="NotModified", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Error", index=2, number=2, options=None, type=None + name="Error", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AccessDenied", index=3, number=3, options=None, type=None + name="AccessDenied", + index=3, + number=3, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=3550, serialized_end=3624, ) @@ -168,22 +290,43 @@ full_name="EventStore.Client.Messages.UpdatePersistentSubscriptionCompleted.UpdatePersistentSubscriptionResult", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Success", index=0, number=0, options=None, type=None + name="Success", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="DoesNotExist", index=1, number=1, options=None, type=None + name="DoesNotExist", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Fail", index=2, number=2, options=None, type=None + name="Fail", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AccessDenied", index=3, number=3, options=None, type=None + name="AccessDenied", + index=3, + number=3, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=4863, serialized_end=4958, ) @@ -196,22 +339,43 @@ full_name="EventStore.Client.Messages.CreatePersistentSubscriptionCompleted.CreatePersistentSubscriptionResult", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Success", index=0, number=0, options=None, type=None + name="Success", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AlreadyExists", index=1, number=1, options=None, type=None + name="AlreadyExists", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Fail", index=2, number=2, options=None, type=None + name="Fail", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AccessDenied", index=3, number=3, options=None, type=None + name="AccessDenied", + index=3, + number=3, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=5145, serialized_end=5241, ) @@ -224,22 +388,43 @@ full_name="EventStore.Client.Messages.DeletePersistentSubscriptionCompleted.DeletePersistentSubscriptionResult", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Success", index=0, number=0, options=None, type=None + name="Success", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="DoesNotExist", index=1, number=1, options=None, type=None + name="DoesNotExist", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Fail", index=2, number=2, options=None, type=None + name="Fail", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AccessDenied", index=3, number=3, options=None, type=None + name="AccessDenied", + index=3, + number=3, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=5428, serialized_end=5523, ) @@ -252,25 +437,51 @@ full_name="EventStore.Client.Messages.PersistentSubscriptionNakEvents.NakAction", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Unknown", index=0, number=0, options=None, type=None + name="Unknown", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Park", index=1, number=1, options=None, type=None + name="Park", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Retry", index=2, number=2, options=None, type=None + name="Retry", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Skip", index=3, number=3, options=None, type=None + name="Skip", + index=3, + number=3, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Stop", index=4, number=4, options=None, type=None + name="Stop", + index=4, + number=4, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=5938, serialized_end=6003, ) @@ -281,29 +492,51 @@ full_name="EventStore.Client.Messages.SubscriptionDropped.SubscriptionDropReason", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Unsubscribed", index=0, number=0, options=None, type=None + name="Unsubscribed", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="AccessDenied", index=1, number=1, options=None, type=None + name="AccessDenied", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="NotFound", index=2, number=2, options=None, type=None + name="NotFound", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( name="PersistentSubscriptionDeleted", index=3, number=3, - options=None, + serialized_options=None, type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="SubscriberMaxCountReached", index=4, number=4, options=None, type=None + name="SubscriberMaxCountReached", + index=4, + number=4, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=6641, serialized_end=6781, ) @@ -314,19 +547,35 @@ full_name="EventStore.Client.Messages.NotHandled.NotHandledReason", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="NotReady", index=0, number=0, options=None, type=None + name="NotReady", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="TooBusy", index=1, number=1, options=None, type=None + name="TooBusy", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="NotMaster", index=2, number=2, options=None, type=None + name="NotMaster", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=7098, serialized_end=7158, ) @@ -337,30 +586,48 @@ full_name="EventStore.Client.Messages.ScavengeDatabaseCompleted.ScavengeResult", filename=None, file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, values=[ _descriptor.EnumValueDescriptor( - name="Success", index=0, number=0, options=None, type=None + name="Success", + index=0, + number=0, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="InProgress", index=1, number=1, options=None, type=None + name="InProgress", + index=1, + number=1, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), _descriptor.EnumValueDescriptor( - name="Failed", index=2, number=2, options=None, type=None + name="Failed", + index=2, + number=2, + serialized_options=None, + type=None, + create_key=_descriptor._internal_create_key, ), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=7361, serialized_end=7418, ) _sym_db.RegisterEnumDescriptor(_SCAVENGEDATABASECOMPLETED_SCAVENGERESULT) + _NEWEVENT = _descriptor.Descriptor( name="NewEvent", full_name="EventStore.Client.Messages.NewEvent", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event_id", @@ -371,13 +638,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b(""), + default_value=b"", message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_type", @@ -388,13 +657,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="data_content_type", @@ -411,7 +682,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="metadata_content_type", @@ -428,7 +701,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="data", @@ -439,13 +714,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b(""), + default_value=b"", message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="metadata", @@ -456,19 +733,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b(""), + default_value=b"", message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -477,12 +756,14 @@ serialized_end=185, ) + _EVENTRECORD = _descriptor.Descriptor( name="EventRecord", full_name="EventStore.Client.Messages.EventRecord", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event_stream_id", @@ -493,13 +774,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_number", @@ -516,7 +799,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_id", @@ -527,13 +812,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b(""), + default_value=b"", message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_type", @@ -544,13 +831,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="data_content_type", @@ -567,7 +856,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="metadata_content_type", @@ -584,7 +875,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="data", @@ -595,13 +888,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b(""), + default_value=b"", message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="metadata", @@ -612,13 +907,15 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b(""), + default_value=b"", message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="created", @@ -635,7 +932,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="created_epoch", @@ -652,13 +951,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -667,12 +968,14 @@ serialized_end=416, ) + _RESOLVEDINDEXEDEVENT = _descriptor.Descriptor( name="ResolvedIndexedEvent", full_name="EventStore.Client.Messages.ResolvedIndexedEvent", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event", @@ -689,7 +992,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="link", @@ -706,13 +1011,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -721,12 +1028,14 @@ serialized_end=552, ) + _RESOLVEDEVENT = _descriptor.Descriptor( name="ResolvedEvent", full_name="EventStore.Client.Messages.ResolvedEvent", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event", @@ -743,7 +1052,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="link", @@ -760,7 +1071,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="commit_position", @@ -777,7 +1090,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="prepare_position", @@ -794,13 +1109,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -809,12 +1126,14 @@ serialized_end=732, ) + _WRITEEVENTS = _descriptor.Descriptor( name="WriteEvents", full_name="EventStore.Client.Messages.WriteEvents", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event_stream_id", @@ -825,13 +1144,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="expected_version", @@ -848,7 +1169,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="events", @@ -865,7 +1188,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="require_master", @@ -882,13 +1207,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -897,12 +1224,14 @@ serialized_end=877, ) + _WRITEEVENTSCOMPLETED = _descriptor.Descriptor( name="WriteEventsCompleted", full_name="EventStore.Client.Messages.WriteEventsCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="result", @@ -919,7 +1248,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="message", @@ -930,13 +1261,15 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="first_event_number", @@ -953,7 +1286,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="last_event_number", @@ -970,7 +1305,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="prepare_position", @@ -987,7 +1324,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="commit_position", @@ -1004,13 +1343,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1019,12 +1360,14 @@ serialized_end=1086, ) + _DELETESTREAM = _descriptor.Descriptor( name="DeleteStream", full_name="EventStore.Client.Messages.DeleteStream", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event_stream_id", @@ -1035,13 +1378,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="expected_version", @@ -1058,7 +1403,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="require_master", @@ -1075,7 +1422,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="hard_delete", @@ -1092,13 +1441,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1107,12 +1458,14 @@ serialized_end=1198, ) + _DELETESTREAMCOMPLETED = _descriptor.Descriptor( name="DeleteStreamCompleted", full_name="EventStore.Client.Messages.DeleteStreamCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="result", @@ -1129,7 +1482,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="message", @@ -1140,13 +1495,15 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="prepare_position", @@ -1163,7 +1520,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="commit_position", @@ -1180,13 +1539,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1195,12 +1556,14 @@ serialized_end=1353, ) + _TRANSACTIONSTART = _descriptor.Descriptor( name="TransactionStart", full_name="EventStore.Client.Messages.TransactionStart", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event_stream_id", @@ -1211,13 +1574,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="expected_version", @@ -1234,7 +1599,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="require_master", @@ -1251,13 +1618,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1266,12 +1635,14 @@ serialized_end=1448, ) + _TRANSACTIONSTARTCOMPLETED = _descriptor.Descriptor( name="TransactionStartCompleted", full_name="EventStore.Client.Messages.TransactionStartCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="transaction_id", @@ -1288,7 +1659,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="result", @@ -1305,7 +1678,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="message", @@ -1316,19 +1691,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1337,12 +1714,14 @@ serialized_end=1580, ) + _TRANSACTIONWRITE = _descriptor.Descriptor( name="TransactionWrite", full_name="EventStore.Client.Messages.TransactionWrite", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="transaction_id", @@ -1359,7 +1738,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="events", @@ -1376,7 +1757,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="require_master", @@ -1393,13 +1776,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1408,12 +1793,14 @@ serialized_end=1702, ) + _TRANSACTIONWRITECOMPLETED = _descriptor.Descriptor( name="TransactionWriteCompleted", full_name="EventStore.Client.Messages.TransactionWriteCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="transaction_id", @@ -1430,7 +1817,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="result", @@ -1447,7 +1836,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="message", @@ -1458,19 +1849,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1479,12 +1872,14 @@ serialized_end=1834, ) + _TRANSACTIONCOMMIT = _descriptor.Descriptor( name="TransactionCommit", full_name="EventStore.Client.Messages.TransactionCommit", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="transaction_id", @@ -1501,7 +1896,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="require_master", @@ -1518,13 +1915,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1533,12 +1932,14 @@ serialized_end=1903, ) + _TRANSACTIONCOMMITCOMPLETED = _descriptor.Descriptor( name="TransactionCommitCompleted", full_name="EventStore.Client.Messages.TransactionCommitCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="transaction_id", @@ -1555,7 +1956,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="result", @@ -1572,7 +1975,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="message", @@ -1583,13 +1988,15 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="first_event_number", @@ -1606,7 +2013,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="last_event_number", @@ -1623,7 +2032,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="prepare_position", @@ -1640,7 +2051,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="commit_position", @@ -1657,13 +2070,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1672,12 +2087,14 @@ serialized_end=2142, ) + _READEVENT = _descriptor.Descriptor( name="ReadEvent", full_name="EventStore.Client.Messages.ReadEvent", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event_stream_id", @@ -1688,13 +2105,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_number", @@ -1711,7 +2130,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="resolve_link_tos", @@ -1728,7 +2149,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="require_master", @@ -1745,13 +2168,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1760,12 +2185,14 @@ serialized_end=2252, ) + _READEVENTCOMPLETED = _descriptor.Descriptor( name="ReadEventCompleted", full_name="EventStore.Client.Messages.ReadEventCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="result", @@ -1782,7 +2209,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event", @@ -1799,7 +2228,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="error", @@ -1810,19 +2241,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], - enum_types=[_READEVENTCOMPLETED_READEVENTRESULT], - options=None, + enum_types=[_READEVENTCOMPLETED_READEVENTRESULT,], + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1831,12 +2264,14 @@ serialized_end=2543, ) + _READSTREAMEVENTS = _descriptor.Descriptor( name="ReadStreamEvents", full_name="EventStore.Client.Messages.ReadStreamEvents", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event_stream_id", @@ -1847,13 +2282,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="from_event_number", @@ -1870,7 +2307,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="max_count", @@ -1887,7 +2326,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="resolve_link_tos", @@ -1904,7 +2345,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="require_master", @@ -1921,13 +2364,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -1936,12 +2381,14 @@ serialized_end=2685, ) + _READSTREAMEVENTSCOMPLETED = _descriptor.Descriptor( name="ReadStreamEventsCompleted", full_name="EventStore.Client.Messages.ReadStreamEventsCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="events", @@ -1958,7 +2405,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="result", @@ -1975,7 +2424,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="next_event_number", @@ -1992,7 +2443,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="last_event_number", @@ -2009,7 +2462,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="is_end_of_stream", @@ -2026,7 +2481,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="last_commit_position", @@ -2043,7 +2500,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="error", @@ -2054,19 +2513,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], - enum_types=[_READSTREAMEVENTSCOMPLETED_READSTREAMRESULT], - options=None, + enum_types=[_READSTREAMEVENTSCOMPLETED_READSTREAMRESULT,], + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -2075,12 +2536,14 @@ serialized_end=3106, ) + _READALLEVENTS = _descriptor.Descriptor( name="ReadAllEvents", full_name="EventStore.Client.Messages.ReadAllEvents", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="commit_position", @@ -2097,7 +2560,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="prepare_position", @@ -2114,7 +2579,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="max_count", @@ -2131,7 +2598,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="resolve_link_tos", @@ -2148,7 +2617,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="require_master", @@ -2165,13 +2636,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -2180,12 +2653,14 @@ serialized_end=3244, ) + _READALLEVENTSCOMPLETED = _descriptor.Descriptor( name="ReadAllEventsCompleted", full_name="EventStore.Client.Messages.ReadAllEventsCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="commit_position", @@ -2202,7 +2677,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="prepare_position", @@ -2219,7 +2696,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="events", @@ -2236,7 +2715,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="next_commit_position", @@ -2253,7 +2734,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="next_prepare_position", @@ -2270,7 +2753,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="result", @@ -2287,7 +2772,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="error", @@ -2298,19 +2785,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], - enum_types=[_READALLEVENTSCOMPLETED_READALLRESULT], - options=None, + enum_types=[_READALLEVENTSCOMPLETED_READALLRESULT,], + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -2319,12 +2808,14 @@ serialized_end=3624, ) + _CREATEPERSISTENTSUBSCRIPTION = _descriptor.Descriptor( name="CreatePersistentSubscription", full_name="EventStore.Client.Messages.CreatePersistentSubscription", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="subscription_group_name", @@ -2335,13 +2826,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_stream_id", @@ -2352,13 +2845,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="resolve_link_tos", @@ -2375,7 +2870,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="start_from", @@ -2392,7 +2889,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="message_timeout_milliseconds", @@ -2409,7 +2908,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="record_statistics", @@ -2426,7 +2927,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="live_buffer_size", @@ -2443,7 +2946,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="read_batch_size", @@ -2460,7 +2965,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="buffer_size", @@ -2477,7 +2984,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="max_retry_count", @@ -2494,7 +3003,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="prefer_round_robin", @@ -2511,7 +3022,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="checkpoint_after_time", @@ -2528,7 +3041,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="checkpoint_max_count", @@ -2545,7 +3060,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="checkpoint_min_count", @@ -2562,7 +3079,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="subscriber_max_count", @@ -2579,7 +3098,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="named_consumer_strategy", @@ -2590,19 +3111,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -2611,12 +3134,14 @@ serialized_end=4105, ) + _DELETEPERSISTENTSUBSCRIPTION = _descriptor.Descriptor( name="DeletePersistentSubscription", full_name="EventStore.Client.Messages.DeletePersistentSubscription", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="subscription_group_name", @@ -2627,13 +3152,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_stream_id", @@ -2644,19 +3171,21 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -2665,12 +3194,14 @@ serialized_end=4195, ) + _UPDATEPERSISTENTSUBSCRIPTION = _descriptor.Descriptor( name="UpdatePersistentSubscription", full_name="EventStore.Client.Messages.UpdatePersistentSubscription", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="subscription_group_name", @@ -2681,13 +3212,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_stream_id", @@ -2698,13 +3231,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="resolve_link_tos", @@ -2721,7 +3256,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="start_from", @@ -2738,7 +3275,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="message_timeout_milliseconds", @@ -2755,7 +3294,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="record_statistics", @@ -2772,7 +3313,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="live_buffer_size", @@ -2789,7 +3332,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="read_batch_size", @@ -2806,7 +3351,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="buffer_size", @@ -2823,7 +3370,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="max_retry_count", @@ -2840,7 +3389,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="prefer_round_robin", @@ -2857,7 +3408,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="checkpoint_after_time", @@ -2874,7 +3427,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="checkpoint_max_count", @@ -2891,7 +3446,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="checkpoint_min_count", @@ -2908,7 +3465,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="subscriber_max_count", @@ -2925,7 +3484,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="named_consumer_strategy", @@ -2936,19 +3497,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -2957,12 +3520,14 @@ serialized_end=4676, ) + _UPDATEPERSISTENTSUBSCRIPTIONCOMPLETED = _descriptor.Descriptor( name="UpdatePersistentSubscriptionCompleted", full_name="EventStore.Client.Messages.UpdatePersistentSubscriptionCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="result", @@ -2979,7 +3544,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="reason", @@ -2990,21 +3557,23 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[ - _UPDATEPERSISTENTSUBSCRIPTIONCOMPLETED_UPDATEPERSISTENTSUBSCRIPTIONRESULT + _UPDATEPERSISTENTSUBSCRIPTIONCOMPLETED_UPDATEPERSISTENTSUBSCRIPTIONRESULT, ], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3013,12 +3582,14 @@ serialized_end=4958, ) + _CREATEPERSISTENTSUBSCRIPTIONCOMPLETED = _descriptor.Descriptor( name="CreatePersistentSubscriptionCompleted", full_name="EventStore.Client.Messages.CreatePersistentSubscriptionCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="result", @@ -3035,7 +3606,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="reason", @@ -3046,21 +3619,23 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[ - _CREATEPERSISTENTSUBSCRIPTIONCOMPLETED_CREATEPERSISTENTSUBSCRIPTIONRESULT + _CREATEPERSISTENTSUBSCRIPTIONCOMPLETED_CREATEPERSISTENTSUBSCRIPTIONRESULT, ], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3069,12 +3644,14 @@ serialized_end=5241, ) + _DELETEPERSISTENTSUBSCRIPTIONCOMPLETED = _descriptor.Descriptor( name="DeletePersistentSubscriptionCompleted", full_name="EventStore.Client.Messages.DeletePersistentSubscriptionCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="result", @@ -3091,7 +3668,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="reason", @@ -3102,21 +3681,23 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[ - _DELETEPERSISTENTSUBSCRIPTIONCOMPLETED_DELETEPERSISTENTSUBSCRIPTIONRESULT + _DELETEPERSISTENTSUBSCRIPTIONCOMPLETED_DELETEPERSISTENTSUBSCRIPTIONRESULT, ], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3125,12 +3706,14 @@ serialized_end=5523, ) + _CONNECTTOPERSISTENTSUBSCRIPTION = _descriptor.Descriptor( name="ConnectToPersistentSubscription", full_name="EventStore.Client.Messages.ConnectToPersistentSubscription", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="subscription_id", @@ -3141,13 +3724,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="event_stream_id", @@ -3158,13 +3743,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="allowed_in_flight_messages", @@ -3181,13 +3768,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3196,12 +3785,14 @@ serialized_end=5644, ) + _PERSISTENTSUBSCRIPTIONACKEVENTS = _descriptor.Descriptor( name="PersistentSubscriptionAckEvents", full_name="EventStore.Client.Messages.PersistentSubscriptionAckEvents", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="subscription_id", @@ -3212,13 +3803,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="processed_event_ids", @@ -3235,13 +3828,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3250,12 +3845,14 @@ serialized_end=5733, ) + _PERSISTENTSUBSCRIPTIONNAKEVENTS = _descriptor.Descriptor( name="PersistentSubscriptionNakEvents", full_name="EventStore.Client.Messages.PersistentSubscriptionNakEvents", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="subscription_id", @@ -3266,13 +3863,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="processed_event_ids", @@ -3289,7 +3888,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="message", @@ -3300,13 +3901,15 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="action", @@ -3323,13 +3926,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], - enum_types=[_PERSISTENTSUBSCRIPTIONNAKEVENTS_NAKACTION], - options=None, + enum_types=[_PERSISTENTSUBSCRIPTIONNAKEVENTS_NAKACTION,], + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3338,12 +3943,14 @@ serialized_end=6003, ) + _PERSISTENTSUBSCRIPTIONCONFIRMATION = _descriptor.Descriptor( name="PersistentSubscriptionConfirmation", full_name="EventStore.Client.Messages.PersistentSubscriptionConfirmation", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="last_commit_position", @@ -3360,7 +3967,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="subscription_id", @@ -3371,13 +3980,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="last_event_number", @@ -3394,13 +4005,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3409,12 +4022,14 @@ serialized_end=6123, ) + _PERSISTENTSUBSCRIPTIONSTREAMEVENTAPPEARED = _descriptor.Descriptor( name="PersistentSubscriptionStreamEventAppeared", full_name="EventStore.Client.Messages.PersistentSubscriptionStreamEventAppeared", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event", @@ -3431,13 +4046,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, - ) + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, + ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3446,12 +4063,14 @@ serialized_end=6233, ) + _SUBSCRIBETOSTREAM = _descriptor.Descriptor( name="SubscribeToStream", full_name="EventStore.Client.Messages.SubscribeToStream", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event_stream_id", @@ -3462,13 +4081,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="resolve_link_tos", @@ -3485,13 +4106,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3500,12 +4123,14 @@ serialized_end=6305, ) + _SUBSCRIPTIONCONFIRMATION = _descriptor.Descriptor( name="SubscriptionConfirmation", full_name="EventStore.Client.Messages.SubscriptionConfirmation", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="last_commit_position", @@ -3522,7 +4147,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="last_event_number", @@ -3539,13 +4166,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3554,12 +4183,14 @@ serialized_end=6390, ) + _STREAMEVENTAPPEARED = _descriptor.Descriptor( name="StreamEventAppeared", full_name="EventStore.Client.Messages.StreamEventAppeared", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="event", @@ -3576,13 +4207,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, - ) + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, + ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3591,17 +4224,19 @@ serialized_end=6471, ) + _UNSUBSCRIBEFROMSTREAM = _descriptor.Descriptor( name="UnsubscribeFromStream", full_name="EventStore.Client.Messages.UnsubscribeFromStream", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3610,17 +4245,19 @@ serialized_end=6496, ) + _PING = _descriptor.Descriptor( name="Ping", full_name="EventStore.Client.Messages.Ping", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3629,17 +4266,19 @@ serialized_end=6504, ) + _PONG = _descriptor.Descriptor( name="Pong", full_name="EventStore.Client.Messages.Pong", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3648,12 +4287,14 @@ serialized_end=6512, ) + _SUBSCRIPTIONDROPPED = _descriptor.Descriptor( name="SubscriptionDropped", full_name="EventStore.Client.Messages.SubscriptionDropped", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="reason", @@ -3670,13 +4311,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, - ) + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, + ), ], extensions=[], nested_types=[], - enum_types=[_SUBSCRIPTIONDROPPED_SUBSCRIPTIONDROPREASON], - options=None, + enum_types=[_SUBSCRIPTIONDROPPED_SUBSCRIPTIONDROPREASON,], + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3685,12 +4328,14 @@ serialized_end=6781, ) + _NOTHANDLED_MASTERINFO = _descriptor.Descriptor( name="MasterInfo", full_name="EventStore.Client.Messages.NotHandled.MasterInfo", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="external_tcp_address", @@ -3701,13 +4346,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="external_tcp_port", @@ -3724,7 +4371,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="external_http_address", @@ -3735,13 +4384,15 @@ cpp_type=9, label=2, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="external_http_port", @@ -3758,7 +4409,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="external_secure_tcp_address", @@ -3769,13 +4422,15 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="external_secure_tcp_port", @@ -3792,13 +4447,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3813,6 +4470,7 @@ filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="reason", @@ -3829,7 +4487,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="additional_info", @@ -3840,19 +4500,21 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b(""), + default_value=b"", message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], - nested_types=[_NOTHANDLED_MASTERINFO], - enum_types=[_NOTHANDLED_NOTHANDLEDREASON], - options=None, + nested_types=[_NOTHANDLED_MASTERINFO,], + enum_types=[_NOTHANDLED_NOTHANDLEDREASON,], + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3861,17 +4523,19 @@ serialized_end=7158, ) + _SCAVENGEDATABASE = _descriptor.Descriptor( name="ScavengeDatabase", full_name="EventStore.Client.Messages.ScavengeDatabase", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[], extensions=[], nested_types=[], enum_types=[], - options=None, + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -3880,12 +4544,14 @@ serialized_end=7178, ) + _SCAVENGEDATABASECOMPLETED = _descriptor.Descriptor( name="ScavengeDatabaseCompleted", full_name="EventStore.Client.Messages.ScavengeDatabaseCompleted", filename=None, file=DESCRIPTOR, containing_type=None, + create_key=_descriptor._internal_create_key, fields=[ _descriptor.FieldDescriptor( name="result", @@ -3902,7 +4568,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="error", @@ -3913,13 +4581,15 @@ cpp_type=9, label=1, has_default_value=False, - default_value=_b("").decode("utf-8"), + default_value=b"".decode("utf-8"), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="total_time_ms", @@ -3936,7 +4606,9 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), _descriptor.FieldDescriptor( name="total_space_saved", @@ -3953,13 +4625,15 @@ containing_type=None, is_extension=False, extension_scope=None, - options=None, + serialized_options=None, + file=DESCRIPTOR, + create_key=_descriptor._internal_create_key, ), ], extensions=[], nested_types=[], - enum_types=[_SCAVENGEDATABASECOMPLETED_SCAVENGERESULT], - options=None, + enum_types=[_SCAVENGEDATABASECOMPLETED_SCAVENGERESULT,], + serialized_options=None, is_extendable=False, syntax="proto2", extension_ranges=[], @@ -4107,442 +4781,443 @@ "ScavengeDatabaseCompleted" ] = _SCAVENGEDATABASECOMPLETED DESCRIPTOR.enum_types_by_name["OperationResult"] = _OPERATIONRESULT +_sym_db.RegisterFileDescriptor(DESCRIPTOR) NewEvent = _reflection.GeneratedProtocolMessageType( "NewEvent", (_message.Message,), - dict( - DESCRIPTOR=_NEWEVENT, - __module__="messages_pb2" + { + "DESCRIPTOR": _NEWEVENT, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.NewEvent) - ), + }, ) _sym_db.RegisterMessage(NewEvent) EventRecord = _reflection.GeneratedProtocolMessageType( "EventRecord", (_message.Message,), - dict( - DESCRIPTOR=_EVENTRECORD, - __module__="messages_pb2" + { + "DESCRIPTOR": _EVENTRECORD, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.EventRecord) - ), + }, ) _sym_db.RegisterMessage(EventRecord) ResolvedIndexedEvent = _reflection.GeneratedProtocolMessageType( "ResolvedIndexedEvent", (_message.Message,), - dict( - DESCRIPTOR=_RESOLVEDINDEXEDEVENT, - __module__="messages_pb2" + { + "DESCRIPTOR": _RESOLVEDINDEXEDEVENT, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ResolvedIndexedEvent) - ), + }, ) _sym_db.RegisterMessage(ResolvedIndexedEvent) ResolvedEvent = _reflection.GeneratedProtocolMessageType( "ResolvedEvent", (_message.Message,), - dict( - DESCRIPTOR=_RESOLVEDEVENT, - __module__="messages_pb2" + { + "DESCRIPTOR": _RESOLVEDEVENT, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ResolvedEvent) - ), + }, ) _sym_db.RegisterMessage(ResolvedEvent) WriteEvents = _reflection.GeneratedProtocolMessageType( "WriteEvents", (_message.Message,), - dict( - DESCRIPTOR=_WRITEEVENTS, - __module__="messages_pb2" + { + "DESCRIPTOR": _WRITEEVENTS, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.WriteEvents) - ), + }, ) _sym_db.RegisterMessage(WriteEvents) WriteEventsCompleted = _reflection.GeneratedProtocolMessageType( "WriteEventsCompleted", (_message.Message,), - dict( - DESCRIPTOR=_WRITEEVENTSCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _WRITEEVENTSCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.WriteEventsCompleted) - ), + }, ) _sym_db.RegisterMessage(WriteEventsCompleted) DeleteStream = _reflection.GeneratedProtocolMessageType( "DeleteStream", (_message.Message,), - dict( - DESCRIPTOR=_DELETESTREAM, - __module__="messages_pb2" + { + "DESCRIPTOR": _DELETESTREAM, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.DeleteStream) - ), + }, ) _sym_db.RegisterMessage(DeleteStream) DeleteStreamCompleted = _reflection.GeneratedProtocolMessageType( "DeleteStreamCompleted", (_message.Message,), - dict( - DESCRIPTOR=_DELETESTREAMCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _DELETESTREAMCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.DeleteStreamCompleted) - ), + }, ) _sym_db.RegisterMessage(DeleteStreamCompleted) TransactionStart = _reflection.GeneratedProtocolMessageType( "TransactionStart", (_message.Message,), - dict( - DESCRIPTOR=_TRANSACTIONSTART, - __module__="messages_pb2" + { + "DESCRIPTOR": _TRANSACTIONSTART, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.TransactionStart) - ), + }, ) _sym_db.RegisterMessage(TransactionStart) TransactionStartCompleted = _reflection.GeneratedProtocolMessageType( "TransactionStartCompleted", (_message.Message,), - dict( - DESCRIPTOR=_TRANSACTIONSTARTCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _TRANSACTIONSTARTCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.TransactionStartCompleted) - ), + }, ) _sym_db.RegisterMessage(TransactionStartCompleted) TransactionWrite = _reflection.GeneratedProtocolMessageType( "TransactionWrite", (_message.Message,), - dict( - DESCRIPTOR=_TRANSACTIONWRITE, - __module__="messages_pb2" + { + "DESCRIPTOR": _TRANSACTIONWRITE, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.TransactionWrite) - ), + }, ) _sym_db.RegisterMessage(TransactionWrite) TransactionWriteCompleted = _reflection.GeneratedProtocolMessageType( "TransactionWriteCompleted", (_message.Message,), - dict( - DESCRIPTOR=_TRANSACTIONWRITECOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _TRANSACTIONWRITECOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.TransactionWriteCompleted) - ), + }, ) _sym_db.RegisterMessage(TransactionWriteCompleted) TransactionCommit = _reflection.GeneratedProtocolMessageType( "TransactionCommit", (_message.Message,), - dict( - DESCRIPTOR=_TRANSACTIONCOMMIT, - __module__="messages_pb2" + { + "DESCRIPTOR": _TRANSACTIONCOMMIT, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.TransactionCommit) - ), + }, ) _sym_db.RegisterMessage(TransactionCommit) TransactionCommitCompleted = _reflection.GeneratedProtocolMessageType( "TransactionCommitCompleted", (_message.Message,), - dict( - DESCRIPTOR=_TRANSACTIONCOMMITCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _TRANSACTIONCOMMITCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.TransactionCommitCompleted) - ), + }, ) _sym_db.RegisterMessage(TransactionCommitCompleted) ReadEvent = _reflection.GeneratedProtocolMessageType( "ReadEvent", (_message.Message,), - dict( - DESCRIPTOR=_READEVENT, - __module__="messages_pb2" + { + "DESCRIPTOR": _READEVENT, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ReadEvent) - ), + }, ) _sym_db.RegisterMessage(ReadEvent) ReadEventCompleted = _reflection.GeneratedProtocolMessageType( "ReadEventCompleted", (_message.Message,), - dict( - DESCRIPTOR=_READEVENTCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _READEVENTCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ReadEventCompleted) - ), + }, ) _sym_db.RegisterMessage(ReadEventCompleted) ReadStreamEvents = _reflection.GeneratedProtocolMessageType( "ReadStreamEvents", (_message.Message,), - dict( - DESCRIPTOR=_READSTREAMEVENTS, - __module__="messages_pb2" + { + "DESCRIPTOR": _READSTREAMEVENTS, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ReadStreamEvents) - ), + }, ) _sym_db.RegisterMessage(ReadStreamEvents) ReadStreamEventsCompleted = _reflection.GeneratedProtocolMessageType( "ReadStreamEventsCompleted", (_message.Message,), - dict( - DESCRIPTOR=_READSTREAMEVENTSCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _READSTREAMEVENTSCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ReadStreamEventsCompleted) - ), + }, ) _sym_db.RegisterMessage(ReadStreamEventsCompleted) ReadAllEvents = _reflection.GeneratedProtocolMessageType( "ReadAllEvents", (_message.Message,), - dict( - DESCRIPTOR=_READALLEVENTS, - __module__="messages_pb2" + { + "DESCRIPTOR": _READALLEVENTS, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ReadAllEvents) - ), + }, ) _sym_db.RegisterMessage(ReadAllEvents) ReadAllEventsCompleted = _reflection.GeneratedProtocolMessageType( "ReadAllEventsCompleted", (_message.Message,), - dict( - DESCRIPTOR=_READALLEVENTSCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _READALLEVENTSCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ReadAllEventsCompleted) - ), + }, ) _sym_db.RegisterMessage(ReadAllEventsCompleted) CreatePersistentSubscription = _reflection.GeneratedProtocolMessageType( "CreatePersistentSubscription", (_message.Message,), - dict( - DESCRIPTOR=_CREATEPERSISTENTSUBSCRIPTION, - __module__="messages_pb2" + { + "DESCRIPTOR": _CREATEPERSISTENTSUBSCRIPTION, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.CreatePersistentSubscription) - ), + }, ) _sym_db.RegisterMessage(CreatePersistentSubscription) DeletePersistentSubscription = _reflection.GeneratedProtocolMessageType( "DeletePersistentSubscription", (_message.Message,), - dict( - DESCRIPTOR=_DELETEPERSISTENTSUBSCRIPTION, - __module__="messages_pb2" + { + "DESCRIPTOR": _DELETEPERSISTENTSUBSCRIPTION, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.DeletePersistentSubscription) - ), + }, ) _sym_db.RegisterMessage(DeletePersistentSubscription) UpdatePersistentSubscription = _reflection.GeneratedProtocolMessageType( "UpdatePersistentSubscription", (_message.Message,), - dict( - DESCRIPTOR=_UPDATEPERSISTENTSUBSCRIPTION, - __module__="messages_pb2" + { + "DESCRIPTOR": _UPDATEPERSISTENTSUBSCRIPTION, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.UpdatePersistentSubscription) - ), + }, ) _sym_db.RegisterMessage(UpdatePersistentSubscription) UpdatePersistentSubscriptionCompleted = _reflection.GeneratedProtocolMessageType( "UpdatePersistentSubscriptionCompleted", (_message.Message,), - dict( - DESCRIPTOR=_UPDATEPERSISTENTSUBSCRIPTIONCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _UPDATEPERSISTENTSUBSCRIPTIONCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.UpdatePersistentSubscriptionCompleted) - ), + }, ) _sym_db.RegisterMessage(UpdatePersistentSubscriptionCompleted) CreatePersistentSubscriptionCompleted = _reflection.GeneratedProtocolMessageType( "CreatePersistentSubscriptionCompleted", (_message.Message,), - dict( - DESCRIPTOR=_CREATEPERSISTENTSUBSCRIPTIONCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _CREATEPERSISTENTSUBSCRIPTIONCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.CreatePersistentSubscriptionCompleted) - ), + }, ) _sym_db.RegisterMessage(CreatePersistentSubscriptionCompleted) DeletePersistentSubscriptionCompleted = _reflection.GeneratedProtocolMessageType( "DeletePersistentSubscriptionCompleted", (_message.Message,), - dict( - DESCRIPTOR=_DELETEPERSISTENTSUBSCRIPTIONCOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _DELETEPERSISTENTSUBSCRIPTIONCOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.DeletePersistentSubscriptionCompleted) - ), + }, ) _sym_db.RegisterMessage(DeletePersistentSubscriptionCompleted) ConnectToPersistentSubscription = _reflection.GeneratedProtocolMessageType( "ConnectToPersistentSubscription", (_message.Message,), - dict( - DESCRIPTOR=_CONNECTTOPERSISTENTSUBSCRIPTION, - __module__="messages_pb2" + { + "DESCRIPTOR": _CONNECTTOPERSISTENTSUBSCRIPTION, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ConnectToPersistentSubscription) - ), + }, ) _sym_db.RegisterMessage(ConnectToPersistentSubscription) PersistentSubscriptionAckEvents = _reflection.GeneratedProtocolMessageType( "PersistentSubscriptionAckEvents", (_message.Message,), - dict( - DESCRIPTOR=_PERSISTENTSUBSCRIPTIONACKEVENTS, - __module__="messages_pb2" + { + "DESCRIPTOR": _PERSISTENTSUBSCRIPTIONACKEVENTS, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.PersistentSubscriptionAckEvents) - ), + }, ) _sym_db.RegisterMessage(PersistentSubscriptionAckEvents) PersistentSubscriptionNakEvents = _reflection.GeneratedProtocolMessageType( "PersistentSubscriptionNakEvents", (_message.Message,), - dict( - DESCRIPTOR=_PERSISTENTSUBSCRIPTIONNAKEVENTS, - __module__="messages_pb2" + { + "DESCRIPTOR": _PERSISTENTSUBSCRIPTIONNAKEVENTS, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.PersistentSubscriptionNakEvents) - ), + }, ) _sym_db.RegisterMessage(PersistentSubscriptionNakEvents) PersistentSubscriptionConfirmation = _reflection.GeneratedProtocolMessageType( "PersistentSubscriptionConfirmation", (_message.Message,), - dict( - DESCRIPTOR=_PERSISTENTSUBSCRIPTIONCONFIRMATION, - __module__="messages_pb2" + { + "DESCRIPTOR": _PERSISTENTSUBSCRIPTIONCONFIRMATION, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.PersistentSubscriptionConfirmation) - ), + }, ) _sym_db.RegisterMessage(PersistentSubscriptionConfirmation) PersistentSubscriptionStreamEventAppeared = _reflection.GeneratedProtocolMessageType( "PersistentSubscriptionStreamEventAppeared", (_message.Message,), - dict( - DESCRIPTOR=_PERSISTENTSUBSCRIPTIONSTREAMEVENTAPPEARED, - __module__="messages_pb2" + { + "DESCRIPTOR": _PERSISTENTSUBSCRIPTIONSTREAMEVENTAPPEARED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.PersistentSubscriptionStreamEventAppeared) - ), + }, ) _sym_db.RegisterMessage(PersistentSubscriptionStreamEventAppeared) SubscribeToStream = _reflection.GeneratedProtocolMessageType( "SubscribeToStream", (_message.Message,), - dict( - DESCRIPTOR=_SUBSCRIBETOSTREAM, - __module__="messages_pb2" + { + "DESCRIPTOR": _SUBSCRIBETOSTREAM, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.SubscribeToStream) - ), + }, ) _sym_db.RegisterMessage(SubscribeToStream) SubscriptionConfirmation = _reflection.GeneratedProtocolMessageType( "SubscriptionConfirmation", (_message.Message,), - dict( - DESCRIPTOR=_SUBSCRIPTIONCONFIRMATION, - __module__="messages_pb2" + { + "DESCRIPTOR": _SUBSCRIPTIONCONFIRMATION, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.SubscriptionConfirmation) - ), + }, ) _sym_db.RegisterMessage(SubscriptionConfirmation) StreamEventAppeared = _reflection.GeneratedProtocolMessageType( "StreamEventAppeared", (_message.Message,), - dict( - DESCRIPTOR=_STREAMEVENTAPPEARED, - __module__="messages_pb2" + { + "DESCRIPTOR": _STREAMEVENTAPPEARED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.StreamEventAppeared) - ), + }, ) _sym_db.RegisterMessage(StreamEventAppeared) UnsubscribeFromStream = _reflection.GeneratedProtocolMessageType( "UnsubscribeFromStream", (_message.Message,), - dict( - DESCRIPTOR=_UNSUBSCRIBEFROMSTREAM, - __module__="messages_pb2" + { + "DESCRIPTOR": _UNSUBSCRIBEFROMSTREAM, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.UnsubscribeFromStream) - ), + }, ) _sym_db.RegisterMessage(UnsubscribeFromStream) Ping = _reflection.GeneratedProtocolMessageType( "Ping", (_message.Message,), - dict( - DESCRIPTOR=_PING, - __module__="messages_pb2" + { + "DESCRIPTOR": _PING, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.Ping) - ), + }, ) _sym_db.RegisterMessage(Ping) Pong = _reflection.GeneratedProtocolMessageType( "Pong", (_message.Message,), - dict( - DESCRIPTOR=_PONG, - __module__="messages_pb2" + { + "DESCRIPTOR": _PONG, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.Pong) - ), + }, ) _sym_db.RegisterMessage(Pong) SubscriptionDropped = _reflection.GeneratedProtocolMessageType( "SubscriptionDropped", (_message.Message,), - dict( - DESCRIPTOR=_SUBSCRIPTIONDROPPED, - __module__="messages_pb2" + { + "DESCRIPTOR": _SUBSCRIPTIONDROPPED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.SubscriptionDropped) - ), + }, ) _sym_db.RegisterMessage(SubscriptionDropped) NotHandled = _reflection.GeneratedProtocolMessageType( "NotHandled", (_message.Message,), - dict( - MasterInfo=_reflection.GeneratedProtocolMessageType( + { + "MasterInfo": _reflection.GeneratedProtocolMessageType( "MasterInfo", (_message.Message,), - dict( - DESCRIPTOR=_NOTHANDLED_MASTERINFO, - __module__="messages_pb2" + { + "DESCRIPTOR": _NOTHANDLED_MASTERINFO, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.NotHandled.MasterInfo) - ), + }, ), - DESCRIPTOR=_NOTHANDLED, - __module__="messages_pb2" + "DESCRIPTOR": _NOTHANDLED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.NotHandled) - ), + }, ) _sym_db.RegisterMessage(NotHandled) _sym_db.RegisterMessage(NotHandled.MasterInfo) @@ -4550,23 +5225,24 @@ ScavengeDatabase = _reflection.GeneratedProtocolMessageType( "ScavengeDatabase", (_message.Message,), - dict( - DESCRIPTOR=_SCAVENGEDATABASE, - __module__="messages_pb2" + { + "DESCRIPTOR": _SCAVENGEDATABASE, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ScavengeDatabase) - ), + }, ) _sym_db.RegisterMessage(ScavengeDatabase) ScavengeDatabaseCompleted = _reflection.GeneratedProtocolMessageType( "ScavengeDatabaseCompleted", (_message.Message,), - dict( - DESCRIPTOR=_SCAVENGEDATABASECOMPLETED, - __module__="messages_pb2" + { + "DESCRIPTOR": _SCAVENGEDATABASECOMPLETED, + "__module__": "messages_pb2" # @@protoc_insertion_point(class_scope:EventStore.Client.Messages.ScavengeDatabaseCompleted) - ), + }, ) _sym_db.RegisterMessage(ScavengeDatabaseCompleted) + # @@protoc_insertion_point(module_scope) diff --git a/setup.py b/setup.py index 7c6ac71..4cc4021 100644 --- a/setup.py +++ b/setup.py @@ -38,7 +38,7 @@ def run_tests(self): url="http://github.com/madedotcom/photon-pump/", license="MIT", author="Bob Gregory", - install_requires=["aiodns>=1.1.1", "aiohttp>=3.1.3", "protobuf>=3.5.1"], + install_requires=["aiodns>=1.1.1", "aiohttp>=3.1.3", "protobuf>=3.12.0"], cmdclass=versioneer.get_cmdclass(), author_email="bob@made.com", description="Fast, easy to use client for EventStore",