From a33f3e33b2392e445be9b7e6e75fbab96f12b068 Mon Sep 17 00:00:00 2001 From: Scott Lewis Date: Wed, 4 Sep 2024 15:19:32 -0700 Subject: [PATCH 1/2] Generated protos using protobuf 5.27.2 --- .project | 17 + .pydevproject | 12 + .settings/org.eclipse.core.resources.prefs | 4 + etcd3/etcdrpc/auth_pb2.py | 67 +- etcd3/etcdrpc/auth_pb2_grpc.py | 24 + etcd3/etcdrpc/kv_pb2.py | 55 +- etcd3/etcdrpc/kv_pb2_grpc.py | 24 + etcd3/etcdrpc/rpc_pb2.py | 1093 ++++---------------- etcd3/etcdrpc/rpc_pb2_grpc.py | 710 ++++++++++--- 9 files changed, 899 insertions(+), 1107 deletions(-) create mode 100644 .project create mode 100644 .pydevproject create mode 100644 .settings/org.eclipse.core.resources.prefs create mode 100644 etcd3/etcdrpc/auth_pb2_grpc.py create mode 100644 etcd3/etcdrpc/kv_pb2_grpc.py diff --git a/.project b/.project new file mode 100644 index 00000000..1814f6af --- /dev/null +++ b/.project @@ -0,0 +1,17 @@ + + + python-etcd3 + + + + + + org.python.pydev.PyDevBuilder + + + + + + org.python.pydev.pythonNature + + diff --git a/.pydevproject b/.pydevproject new file mode 100644 index 00000000..8b58396d --- /dev/null +++ b/.pydevproject @@ -0,0 +1,12 @@ + + + + Default + + python interpreter + + + /${PROJECT_DIR_NAME} + + + diff --git a/.settings/org.eclipse.core.resources.prefs b/.settings/org.eclipse.core.resources.prefs new file mode 100644 index 00000000..283e2478 --- /dev/null +++ b/.settings/org.eclipse.core.resources.prefs @@ -0,0 +1,4 @@ +eclipse.preferences.version=1 +encoding//etcd3/etcdrpc/auth_pb2.py=utf-8 +encoding//etcd3/etcdrpc/kv_pb2.py=utf-8 +encoding//etcd3/etcdrpc/rpc_pb2.py=utf-8 diff --git a/etcd3/etcdrpc/auth_pb2.py b/etcd3/etcdrpc/auth_pb2.py index b8abc39e..b3546ee3 100644 --- a/etcd3/etcdrpc/auth_pb2.py +++ b/etcd3/etcdrpc/auth_pb2.py @@ -1,12 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: auth.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import message as _message -from google.protobuf import reflection as _reflection +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database +from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'auth.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -16,43 +26,18 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nauth.proto\x12\x06\x61uthpb\"5\n\x04User\x12\x0c\n\x04name\x18\x01 \x01(\x0c\x12\x10\n\x08password\x18\x02 \x01(\x0c\x12\r\n\x05roles\x18\x03 \x03(\t\"\x83\x01\n\nPermission\x12)\n\x08permType\x18\x01 \x01(\x0e\x32\x17.authpb.Permission.Type\x12\x0b\n\x03key\x18\x02 \x01(\x0c\x12\x11\n\trange_end\x18\x03 \x01(\x0c\"*\n\x04Type\x12\x08\n\x04READ\x10\x00\x12\t\n\x05WRITE\x10\x01\x12\r\n\tREADWRITE\x10\x02\"?\n\x04Role\x12\x0c\n\x04name\x18\x01 \x01(\x0c\x12)\n\rkeyPermission\x18\x02 \x03(\x0b\x32\x12.authpb.PermissionB\x15\n\x11io.etcd.jetcd.apiP\x01\x62\x06proto3') - - -_USER = DESCRIPTOR.message_types_by_name['User'] -_PERMISSION = DESCRIPTOR.message_types_by_name['Permission'] -_ROLE = DESCRIPTOR.message_types_by_name['Role'] -_PERMISSION_TYPE = _PERMISSION.enum_types_by_name['Type'] -User = _reflection.GeneratedProtocolMessageType('User', (_message.Message,), { - 'DESCRIPTOR' : _USER, - '__module__' : 'auth_pb2' - # @@protoc_insertion_point(class_scope:authpb.User) - }) -_sym_db.RegisterMessage(User) - -Permission = _reflection.GeneratedProtocolMessageType('Permission', (_message.Message,), { - 'DESCRIPTOR' : _PERMISSION, - '__module__' : 'auth_pb2' - # @@protoc_insertion_point(class_scope:authpb.Permission) - }) -_sym_db.RegisterMessage(Permission) - -Role = _reflection.GeneratedProtocolMessageType('Role', (_message.Message,), { - 'DESCRIPTOR' : _ROLE, - '__module__' : 'auth_pb2' - # @@protoc_insertion_point(class_scope:authpb.Role) - }) -_sym_db.RegisterMessage(Role) - -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'\n\021io.etcd.jetcd.apiP\001' - _USER._serialized_start=22 - _USER._serialized_end=75 - _PERMISSION._serialized_start=78 - _PERMISSION._serialized_end=209 - _PERMISSION_TYPE._serialized_start=167 - _PERMISSION_TYPE._serialized_end=209 - _ROLE._serialized_start=211 - _ROLE._serialized_end=274 +_globals = globals() +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'auth_pb2', _globals) +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'\n\021io.etcd.jetcd.apiP\001' + _globals['_USER']._serialized_start=22 + _globals['_USER']._serialized_end=75 + _globals['_PERMISSION']._serialized_start=78 + _globals['_PERMISSION']._serialized_end=209 + _globals['_PERMISSION_TYPE']._serialized_start=167 + _globals['_PERMISSION_TYPE']._serialized_end=209 + _globals['_ROLE']._serialized_start=211 + _globals['_ROLE']._serialized_end=274 # @@protoc_insertion_point(module_scope) diff --git a/etcd3/etcdrpc/auth_pb2_grpc.py b/etcd3/etcdrpc/auth_pb2_grpc.py new file mode 100644 index 00000000..f53a51b7 --- /dev/null +++ b/etcd3/etcdrpc/auth_pb2_grpc.py @@ -0,0 +1,24 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc +import warnings + + +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in auth_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + ) diff --git a/etcd3/etcdrpc/kv_pb2.py b/etcd3/etcdrpc/kv_pb2.py index ea354832..6736911c 100644 --- a/etcd3/etcdrpc/kv_pb2.py +++ b/etcd3/etcdrpc/kv_pb2.py @@ -1,12 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: kv.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import message as _message -from google.protobuf import reflection as _reflection +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database +from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'kv.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -16,33 +26,16 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x08kv.proto\x12\x06mvccpb\"u\n\x08KeyValue\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x12\x17\n\x0f\x63reate_revision\x18\x02 \x01(\x03\x12\x14\n\x0cmod_revision\x18\x03 \x01(\x03\x12\x0f\n\x07version\x18\x04 \x01(\x03\x12\r\n\x05value\x18\x05 \x01(\x0c\x12\r\n\x05lease\x18\x06 \x01(\x03\"\x91\x01\n\x05\x45vent\x12%\n\x04type\x18\x01 \x01(\x0e\x32\x17.mvccpb.Event.EventType\x12\x1c\n\x02kv\x18\x02 \x01(\x0b\x32\x10.mvccpb.KeyValue\x12!\n\x07prev_kv\x18\x03 \x01(\x0b\x32\x10.mvccpb.KeyValue\" \n\tEventType\x12\x07\n\x03PUT\x10\x00\x12\n\n\x06\x44\x45LETE\x10\x01\x42\x15\n\x11io.etcd.jetcd.apiP\x01\x62\x06proto3') - - -_KEYVALUE = DESCRIPTOR.message_types_by_name['KeyValue'] -_EVENT = DESCRIPTOR.message_types_by_name['Event'] -_EVENT_EVENTTYPE = _EVENT.enum_types_by_name['EventType'] -KeyValue = _reflection.GeneratedProtocolMessageType('KeyValue', (_message.Message,), { - 'DESCRIPTOR' : _KEYVALUE, - '__module__' : 'kv_pb2' - # @@protoc_insertion_point(class_scope:mvccpb.KeyValue) - }) -_sym_db.RegisterMessage(KeyValue) - -Event = _reflection.GeneratedProtocolMessageType('Event', (_message.Message,), { - 'DESCRIPTOR' : _EVENT, - '__module__' : 'kv_pb2' - # @@protoc_insertion_point(class_scope:mvccpb.Event) - }) -_sym_db.RegisterMessage(Event) - -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'\n\021io.etcd.jetcd.apiP\001' - _KEYVALUE._serialized_start=20 - _KEYVALUE._serialized_end=137 - _EVENT._serialized_start=140 - _EVENT._serialized_end=285 - _EVENT_EVENTTYPE._serialized_start=253 - _EVENT_EVENTTYPE._serialized_end=285 +_globals = globals() +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'kv_pb2', _globals) +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'\n\021io.etcd.jetcd.apiP\001' + _globals['_KEYVALUE']._serialized_start=20 + _globals['_KEYVALUE']._serialized_end=137 + _globals['_EVENT']._serialized_start=140 + _globals['_EVENT']._serialized_end=285 + _globals['_EVENT_EVENTTYPE']._serialized_start=253 + _globals['_EVENT_EVENTTYPE']._serialized_end=285 # @@protoc_insertion_point(module_scope) diff --git a/etcd3/etcdrpc/kv_pb2_grpc.py b/etcd3/etcdrpc/kv_pb2_grpc.py new file mode 100644 index 00000000..66ed2bcb --- /dev/null +++ b/etcd3/etcdrpc/kv_pb2_grpc.py @@ -0,0 +1,24 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc +import warnings + + +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in kv_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + ) diff --git a/etcd3/etcdrpc/rpc_pb2.py b/etcd3/etcdrpc/rpc_pb2.py index 7eb99440..15d552cd 100644 --- a/etcd3/etcdrpc/rpc_pb2.py +++ b/etcd3/etcdrpc/rpc_pb2.py @@ -1,900 +1,227 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: rpc.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" -from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import message as _message -from google.protobuf import reflection as _reflection +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database +from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'rpc.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() - from etcd3.etcdrpc import kv_pb2 as kv__pb2 from etcd3.etcdrpc import auth_pb2 as auth__pb2 - DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\trpc.proto\x12\x0c\x65tcdserverpb\x1a\x08kv.proto\x1a\nauth.proto\"\\\n\x0eResponseHeader\x12\x12\n\ncluster_id\x18\x01 \x01(\x04\x12\x11\n\tmember_id\x18\x02 \x01(\x04\x12\x10\n\x08revision\x18\x03 \x01(\x03\x12\x11\n\traft_term\x18\x04 \x01(\x04\"\xe4\x03\n\x0cRangeRequest\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x12\x11\n\trange_end\x18\x02 \x01(\x0c\x12\r\n\x05limit\x18\x03 \x01(\x03\x12\x10\n\x08revision\x18\x04 \x01(\x03\x12\x38\n\nsort_order\x18\x05 \x01(\x0e\x32$.etcdserverpb.RangeRequest.SortOrder\x12:\n\x0bsort_target\x18\x06 \x01(\x0e\x32%.etcdserverpb.RangeRequest.SortTarget\x12\x14\n\x0cserializable\x18\x07 \x01(\x08\x12\x11\n\tkeys_only\x18\x08 \x01(\x08\x12\x12\n\ncount_only\x18\t \x01(\x08\x12\x18\n\x10min_mod_revision\x18\n \x01(\x03\x12\x18\n\x10max_mod_revision\x18\x0b \x01(\x03\x12\x1b\n\x13min_create_revision\x18\x0c \x01(\x03\x12\x1b\n\x13max_create_revision\x18\r \x01(\x03\".\n\tSortOrder\x12\x08\n\x04NONE\x10\x00\x12\n\n\x06\x41SCEND\x10\x01\x12\x0b\n\x07\x44\x45SCEND\x10\x02\"B\n\nSortTarget\x12\x07\n\x03KEY\x10\x00\x12\x0b\n\x07VERSION\x10\x01\x12\n\n\x06\x43REATE\x10\x02\x12\x07\n\x03MOD\x10\x03\x12\t\n\x05VALUE\x10\x04\"y\n\rRangeResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\x1d\n\x03kvs\x18\x02 \x03(\x0b\x32\x10.mvccpb.KeyValue\x12\x0c\n\x04more\x18\x03 \x01(\x08\x12\r\n\x05\x63ount\x18\x04 \x01(\x03\"t\n\nPutRequest\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x12\r\n\x05value\x18\x02 \x01(\x0c\x12\r\n\x05lease\x18\x03 \x01(\x03\x12\x0f\n\x07prev_kv\x18\x04 \x01(\x08\x12\x14\n\x0cignore_value\x18\x05 \x01(\x08\x12\x14\n\x0cignore_lease\x18\x06 \x01(\x08\"^\n\x0bPutResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12!\n\x07prev_kv\x18\x02 \x01(\x0b\x32\x10.mvccpb.KeyValue\"E\n\x12\x44\x65leteRangeRequest\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x12\x11\n\trange_end\x18\x02 \x01(\x0c\x12\x0f\n\x07prev_kv\x18\x03 \x01(\x08\"x\n\x13\x44\x65leteRangeResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\x0f\n\x07\x64\x65leted\x18\x02 \x01(\x03\x12\"\n\x08prev_kvs\x18\x03 \x03(\x0b\x32\x10.mvccpb.KeyValue\"\xef\x01\n\tRequestOp\x12\x33\n\rrequest_range\x18\x01 \x01(\x0b\x32\x1a.etcdserverpb.RangeRequestH\x00\x12/\n\x0brequest_put\x18\x02 \x01(\x0b\x32\x18.etcdserverpb.PutRequestH\x00\x12@\n\x14request_delete_range\x18\x03 \x01(\x0b\x32 .etcdserverpb.DeleteRangeRequestH\x00\x12/\n\x0brequest_txn\x18\x04 \x01(\x0b\x32\x18.etcdserverpb.TxnRequestH\x00\x42\t\n\x07request\"\xf9\x01\n\nResponseOp\x12\x35\n\x0eresponse_range\x18\x01 \x01(\x0b\x32\x1b.etcdserverpb.RangeResponseH\x00\x12\x31\n\x0cresponse_put\x18\x02 \x01(\x0b\x32\x19.etcdserverpb.PutResponseH\x00\x12\x42\n\x15response_delete_range\x18\x03 \x01(\x0b\x32!.etcdserverpb.DeleteRangeResponseH\x00\x12\x31\n\x0cresponse_txn\x18\x04 \x01(\x0b\x32\x19.etcdserverpb.TxnResponseH\x00\x42\n\n\x08response\"\x96\x03\n\x07\x43ompare\x12\x33\n\x06result\x18\x01 \x01(\x0e\x32#.etcdserverpb.Compare.CompareResult\x12\x33\n\x06target\x18\x02 \x01(\x0e\x32#.etcdserverpb.Compare.CompareTarget\x12\x0b\n\x03key\x18\x03 \x01(\x0c\x12\x11\n\x07version\x18\x04 \x01(\x03H\x00\x12\x19\n\x0f\x63reate_revision\x18\x05 \x01(\x03H\x00\x12\x16\n\x0cmod_revision\x18\x06 \x01(\x03H\x00\x12\x0f\n\x05value\x18\x07 \x01(\x0cH\x00\x12\x0f\n\x05lease\x18\x08 \x01(\x03H\x00\x12\x11\n\trange_end\x18@ \x01(\x0c\"@\n\rCompareResult\x12\t\n\x05\x45QUAL\x10\x00\x12\x0b\n\x07GREATER\x10\x01\x12\x08\n\x04LESS\x10\x02\x12\r\n\tNOT_EQUAL\x10\x03\"G\n\rCompareTarget\x12\x0b\n\x07VERSION\x10\x00\x12\n\n\x06\x43REATE\x10\x01\x12\x07\n\x03MOD\x10\x02\x12\t\n\x05VALUE\x10\x03\x12\t\n\x05LEASE\x10\x04\x42\x0e\n\x0ctarget_union\"\x88\x01\n\nTxnRequest\x12&\n\x07\x63ompare\x18\x01 \x03(\x0b\x32\x15.etcdserverpb.Compare\x12(\n\x07success\x18\x02 \x03(\x0b\x32\x17.etcdserverpb.RequestOp\x12(\n\x07\x66\x61ilure\x18\x03 \x03(\x0b\x32\x17.etcdserverpb.RequestOp\"{\n\x0bTxnResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\x11\n\tsucceeded\x18\x02 \x01(\x08\x12+\n\tresponses\x18\x03 \x03(\x0b\x32\x18.etcdserverpb.ResponseOp\"7\n\x11\x43ompactionRequest\x12\x10\n\x08revision\x18\x01 \x01(\x03\x12\x10\n\x08physical\x18\x02 \x01(\x08\"B\n\x12\x43ompactionResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"\r\n\x0bHashRequest\"J\n\x0cHashResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\x0c\n\x04hash\x18\x02 \x01(\r\"!\n\rHashKVRequest\x12\x10\n\x08revision\x18\x01 \x01(\x03\"f\n\x0eHashKVResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\x0c\n\x04hash\x18\x02 \x01(\r\x12\x18\n\x10\x63ompact_revision\x18\x03 \x01(\x03\"\x11\n\x0fSnapshotRequest\"g\n\x10SnapshotResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\x17\n\x0fremaining_bytes\x18\x02 \x01(\x04\x12\x0c\n\x04\x62lob\x18\x03 \x01(\x0c\"\xd7\x01\n\x0cWatchRequest\x12:\n\x0e\x63reate_request\x18\x01 \x01(\x0b\x32 .etcdserverpb.WatchCreateRequestH\x00\x12:\n\x0e\x63\x61ncel_request\x18\x02 \x01(\x0b\x32 .etcdserverpb.WatchCancelRequestH\x00\x12>\n\x10progress_request\x18\x03 \x01(\x0b\x32\".etcdserverpb.WatchProgressRequestH\x00\x42\x0f\n\rrequest_union\"\xdb\x01\n\x12WatchCreateRequest\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x12\x11\n\trange_end\x18\x02 \x01(\x0c\x12\x16\n\x0estart_revision\x18\x03 \x01(\x03\x12\x17\n\x0fprogress_notify\x18\x04 \x01(\x08\x12<\n\x07\x66ilters\x18\x05 \x03(\x0e\x32+.etcdserverpb.WatchCreateRequest.FilterType\x12\x0f\n\x07prev_kv\x18\x06 \x01(\x08\"%\n\nFilterType\x12\t\n\x05NOPUT\x10\x00\x12\x0c\n\x08NODELETE\x10\x01\"&\n\x12WatchCancelRequest\x12\x10\n\x08watch_id\x18\x01 \x01(\x03\"\x16\n\x14WatchProgressRequest\"\xc2\x01\n\rWatchResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\x10\n\x08watch_id\x18\x02 \x01(\x03\x12\x0f\n\x07\x63reated\x18\x03 \x01(\x08\x12\x10\n\x08\x63\x61nceled\x18\x04 \x01(\x08\x12\x18\n\x10\x63ompact_revision\x18\x05 \x01(\x03\x12\x15\n\rcancel_reason\x18\x06 \x01(\t\x12\x1d\n\x06\x65vents\x18\x0b \x03(\x0b\x32\r.mvccpb.Event\",\n\x11LeaseGrantRequest\x12\x0b\n\x03TTL\x18\x01 \x01(\x03\x12\n\n\x02ID\x18\x02 \x01(\x03\"j\n\x12LeaseGrantResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\n\n\x02ID\x18\x02 \x01(\x03\x12\x0b\n\x03TTL\x18\x03 \x01(\x03\x12\r\n\x05\x65rror\x18\x04 \x01(\t\" \n\x12LeaseRevokeRequest\x12\n\n\x02ID\x18\x01 \x01(\x03\"C\n\x13LeaseRevokeResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"#\n\x15LeaseKeepAliveRequest\x12\n\n\x02ID\x18\x01 \x01(\x03\"_\n\x16LeaseKeepAliveResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\n\n\x02ID\x18\x02 \x01(\x03\x12\x0b\n\x03TTL\x18\x03 \x01(\x03\"2\n\x16LeaseTimeToLiveRequest\x12\n\n\x02ID\x18\x01 \x01(\x03\x12\x0c\n\x04keys\x18\x02 \x01(\x08\"\x82\x01\n\x17LeaseTimeToLiveResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\n\n\x02ID\x18\x02 \x01(\x03\x12\x0b\n\x03TTL\x18\x03 \x01(\x03\x12\x12\n\ngrantedTTL\x18\x04 \x01(\x03\x12\x0c\n\x04keys\x18\x05 \x03(\x0c\"H\n\x06Member\x12\n\n\x02ID\x18\x01 \x01(\x04\x12\x0c\n\x04name\x18\x02 \x01(\t\x12\x10\n\x08peerURLs\x18\x03 \x03(\t\x12\x12\n\nclientURLs\x18\x04 \x03(\t\"$\n\x10MemberAddRequest\x12\x10\n\x08peerURLs\x18\x01 \x03(\t\"\x8e\x01\n\x11MemberAddResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12$\n\x06member\x18\x02 \x01(\x0b\x32\x14.etcdserverpb.Member\x12%\n\x07members\x18\x03 \x03(\x0b\x32\x14.etcdserverpb.Member\"!\n\x13MemberRemoveRequest\x12\n\n\x02ID\x18\x01 \x01(\x04\"k\n\x14MemberRemoveResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12%\n\x07members\x18\x02 \x03(\x0b\x32\x14.etcdserverpb.Member\"3\n\x13MemberUpdateRequest\x12\n\n\x02ID\x18\x01 \x01(\x04\x12\x10\n\x08peerURLs\x18\x02 \x03(\t\"k\n\x14MemberUpdateResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12%\n\x07members\x18\x02 \x03(\x0b\x32\x14.etcdserverpb.Member\"\x13\n\x11MemberListRequest\"i\n\x12MemberListResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12%\n\x07members\x18\x02 \x03(\x0b\x32\x14.etcdserverpb.Member\"\x13\n\x11\x44\x65\x66ragmentRequest\"B\n\x12\x44\x65\x66ragmentResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"%\n\x11MoveLeaderRequest\x12\x10\n\x08targetID\x18\x01 \x01(\x04\"B\n\x12MoveLeaderResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"\xb6\x01\n\x0c\x41larmRequest\x12\x36\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32&.etcdserverpb.AlarmRequest.AlarmAction\x12\x10\n\x08memberID\x18\x02 \x01(\x04\x12&\n\x05\x61larm\x18\x03 \x01(\x0e\x32\x17.etcdserverpb.AlarmType\"4\n\x0b\x41larmAction\x12\x07\n\x03GET\x10\x00\x12\x0c\n\x08\x41\x43TIVATE\x10\x01\x12\x0e\n\nDEACTIVATE\x10\x02\"G\n\x0b\x41larmMember\x12\x10\n\x08memberID\x18\x01 \x01(\x04\x12&\n\x05\x61larm\x18\x02 \x01(\x0e\x32\x17.etcdserverpb.AlarmType\"h\n\rAlarmResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12)\n\x06\x61larms\x18\x02 \x03(\x0b\x32\x19.etcdserverpb.AlarmMember\"\x0f\n\rStatusRequest\"\x94\x01\n\x0eStatusResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\x0f\n\x07version\x18\x02 \x01(\t\x12\x0e\n\x06\x64\x62Size\x18\x03 \x01(\x03\x12\x0e\n\x06leader\x18\x04 \x01(\x04\x12\x11\n\traftIndex\x18\x05 \x01(\x04\x12\x10\n\x08raftTerm\x18\x06 \x01(\x04\"\x13\n\x11\x41uthEnableRequest\"\x14\n\x12\x41uthDisableRequest\"5\n\x13\x41uthenticateRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\"4\n\x12\x41uthUserAddRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\"\"\n\x12\x41uthUserGetRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"%\n\x15\x41uthUserDeleteRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"?\n\x1d\x41uthUserChangePasswordRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\"6\n\x18\x41uthUserGrantRoleRequest\x12\x0c\n\x04user\x18\x01 \x01(\t\x12\x0c\n\x04role\x18\x02 \x01(\t\"7\n\x19\x41uthUserRevokeRoleRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0c\n\x04role\x18\x02 \x01(\t\"\"\n\x12\x41uthRoleAddRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"\"\n\x12\x41uthRoleGetRequest\x12\x0c\n\x04role\x18\x01 \x01(\t\"\x15\n\x13\x41uthUserListRequest\"\x15\n\x13\x41uthRoleListRequest\"%\n\x15\x41uthRoleDeleteRequest\x12\x0c\n\x04role\x18\x01 \x01(\t\"P\n\x1e\x41uthRoleGrantPermissionRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12 \n\x04perm\x18\x02 \x01(\x0b\x32\x12.authpb.Permission\"O\n\x1f\x41uthRoleRevokePermissionRequest\x12\x0c\n\x04role\x18\x01 \x01(\t\x12\x0b\n\x03key\x18\x02 \x01(\t\x12\x11\n\trange_end\x18\x03 \x01(\t\"B\n\x12\x41uthEnableResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"C\n\x13\x41uthDisableResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"S\n\x14\x41uthenticateResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\r\n\x05token\x18\x02 \x01(\t\"C\n\x13\x41uthUserAddResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"R\n\x13\x41uthUserGetResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\r\n\x05roles\x18\x02 \x03(\t\"F\n\x16\x41uthUserDeleteResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"N\n\x1e\x41uthUserChangePasswordResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"I\n\x19\x41uthUserGrantRoleResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"J\n\x1a\x41uthUserRevokeRoleResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"C\n\x13\x41uthRoleAddResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"e\n\x13\x41uthRoleGetResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12 \n\x04perm\x18\x02 \x03(\x0b\x32\x12.authpb.Permission\"S\n\x14\x41uthRoleListResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\r\n\x05roles\x18\x02 \x03(\t\"S\n\x14\x41uthUserListResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\x12\r\n\x05users\x18\x02 \x03(\t\"F\n\x16\x41uthRoleDeleteResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"O\n\x1f\x41uthRoleGrantPermissionResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader\"P\n AuthRoleRevokePermissionResponse\x12,\n\x06header\x18\x01 \x01(\x0b\x32\x1c.etcdserverpb.ResponseHeader*\"\n\tAlarmType\x12\x08\n\x04NONE\x10\x00\x12\x0b\n\x07NOSPACE\x10\x01\x32\xea\x02\n\x02KV\x12\x42\n\x05Range\x12\x1a.etcdserverpb.RangeRequest\x1a\x1b.etcdserverpb.RangeResponse\"\x00\x12<\n\x03Put\x12\x18.etcdserverpb.PutRequest\x1a\x19.etcdserverpb.PutResponse\"\x00\x12T\n\x0b\x44\x65leteRange\x12 .etcdserverpb.DeleteRangeRequest\x1a!.etcdserverpb.DeleteRangeResponse\"\x00\x12<\n\x03Txn\x12\x18.etcdserverpb.TxnRequest\x1a\x19.etcdserverpb.TxnResponse\"\x00\x12N\n\x07\x43ompact\x12\x1f.etcdserverpb.CompactionRequest\x1a .etcdserverpb.CompactionResponse\"\x00\x32\x9e\x01\n\x05Watch\x12M\n\x08Progress\x12\".etcdserverpb.WatchProgressRequest\x1a\x1b.etcdserverpb.WatchResponse\"\x00\x12\x46\n\x05Watch\x12\x1a.etcdserverpb.WatchRequest\x1a\x1b.etcdserverpb.WatchResponse\"\x00(\x01\x30\x01\x32\xf5\x02\n\x05Lease\x12Q\n\nLeaseGrant\x12\x1f.etcdserverpb.LeaseGrantRequest\x1a .etcdserverpb.LeaseGrantResponse\"\x00\x12T\n\x0bLeaseRevoke\x12 .etcdserverpb.LeaseRevokeRequest\x1a!.etcdserverpb.LeaseRevokeResponse\"\x00\x12\x61\n\x0eLeaseKeepAlive\x12#.etcdserverpb.LeaseKeepAliveRequest\x1a$.etcdserverpb.LeaseKeepAliveResponse\"\x00(\x01\x30\x01\x12`\n\x0fLeaseTimeToLive\x12$.etcdserverpb.LeaseTimeToLiveRequest\x1a%.etcdserverpb.LeaseTimeToLiveResponse\"\x00\x32\xde\x02\n\x07\x43luster\x12N\n\tMemberAdd\x12\x1e.etcdserverpb.MemberAddRequest\x1a\x1f.etcdserverpb.MemberAddResponse\"\x00\x12W\n\x0cMemberRemove\x12!.etcdserverpb.MemberRemoveRequest\x1a\".etcdserverpb.MemberRemoveResponse\"\x00\x12W\n\x0cMemberUpdate\x12!.etcdserverpb.MemberUpdateRequest\x1a\".etcdserverpb.MemberUpdateResponse\"\x00\x12Q\n\nMemberList\x12\x1f.etcdserverpb.MemberListRequest\x1a .etcdserverpb.MemberListResponse\"\x00\x32\x95\x04\n\x0bMaintenance\x12\x42\n\x05\x41larm\x12\x1a.etcdserverpb.AlarmRequest\x1a\x1b.etcdserverpb.AlarmResponse\"\x00\x12\x45\n\x06Status\x12\x1b.etcdserverpb.StatusRequest\x1a\x1c.etcdserverpb.StatusResponse\"\x00\x12Q\n\nDefragment\x12\x1f.etcdserverpb.DefragmentRequest\x1a .etcdserverpb.DefragmentResponse\"\x00\x12?\n\x04Hash\x12\x19.etcdserverpb.HashRequest\x1a\x1a.etcdserverpb.HashResponse\"\x00\x12\x45\n\x06HashKV\x12\x1b.etcdserverpb.HashKVRequest\x1a\x1c.etcdserverpb.HashKVResponse\"\x00\x12M\n\x08Snapshot\x12\x1d.etcdserverpb.SnapshotRequest\x1a\x1e.etcdserverpb.SnapshotResponse\"\x00\x30\x01\x12Q\n\nMoveLeader\x12\x1f.etcdserverpb.MoveLeaderRequest\x1a .etcdserverpb.MoveLeaderResponse\"\x00\x32\xdd\x0b\n\x04\x41uth\x12Q\n\nAuthEnable\x12\x1f.etcdserverpb.AuthEnableRequest\x1a .etcdserverpb.AuthEnableResponse\"\x00\x12T\n\x0b\x41uthDisable\x12 .etcdserverpb.AuthDisableRequest\x1a!.etcdserverpb.AuthDisableResponse\"\x00\x12W\n\x0c\x41uthenticate\x12!.etcdserverpb.AuthenticateRequest\x1a\".etcdserverpb.AuthenticateResponse\"\x00\x12P\n\x07UserAdd\x12 .etcdserverpb.AuthUserAddRequest\x1a!.etcdserverpb.AuthUserAddResponse\"\x00\x12P\n\x07UserGet\x12 .etcdserverpb.AuthUserGetRequest\x1a!.etcdserverpb.AuthUserGetResponse\"\x00\x12S\n\x08UserList\x12!.etcdserverpb.AuthUserListRequest\x1a\".etcdserverpb.AuthUserListResponse\"\x00\x12Y\n\nUserDelete\x12#.etcdserverpb.AuthUserDeleteRequest\x1a$.etcdserverpb.AuthUserDeleteResponse\"\x00\x12q\n\x12UserChangePassword\x12+.etcdserverpb.AuthUserChangePasswordRequest\x1a,.etcdserverpb.AuthUserChangePasswordResponse\"\x00\x12\x62\n\rUserGrantRole\x12&.etcdserverpb.AuthUserGrantRoleRequest\x1a\'.etcdserverpb.AuthUserGrantRoleResponse\"\x00\x12\x65\n\x0eUserRevokeRole\x12\'.etcdserverpb.AuthUserRevokeRoleRequest\x1a(.etcdserverpb.AuthUserRevokeRoleResponse\"\x00\x12P\n\x07RoleAdd\x12 .etcdserverpb.AuthRoleAddRequest\x1a!.etcdserverpb.AuthRoleAddResponse\"\x00\x12P\n\x07RoleGet\x12 .etcdserverpb.AuthRoleGetRequest\x1a!.etcdserverpb.AuthRoleGetResponse\"\x00\x12S\n\x08RoleList\x12!.etcdserverpb.AuthRoleListRequest\x1a\".etcdserverpb.AuthRoleListResponse\"\x00\x12Y\n\nRoleDelete\x12#.etcdserverpb.AuthRoleDeleteRequest\x1a$.etcdserverpb.AuthRoleDeleteResponse\"\x00\x12t\n\x13RoleGrantPermission\x12,.etcdserverpb.AuthRoleGrantPermissionRequest\x1a-.etcdserverpb.AuthRoleGrantPermissionResponse\"\x00\x12w\n\x14RoleRevokePermission\x12-.etcdserverpb.AuthRoleRevokePermissionRequest\x1a..etcdserverpb.AuthRoleRevokePermissionResponse\"\x00\x42)\n\x11io.etcd.jetcd.apiB\nJetcdProtoP\x01\xa2\x02\x05Jetcdb\x06proto3') -_ALARMTYPE = DESCRIPTOR.enum_types_by_name['AlarmType'] -AlarmType = enum_type_wrapper.EnumTypeWrapper(_ALARMTYPE) -NONE = 0 -NOSPACE = 1 - - -_RESPONSEHEADER = DESCRIPTOR.message_types_by_name['ResponseHeader'] -_RANGEREQUEST = DESCRIPTOR.message_types_by_name['RangeRequest'] -_RANGERESPONSE = DESCRIPTOR.message_types_by_name['RangeResponse'] -_PUTREQUEST = DESCRIPTOR.message_types_by_name['PutRequest'] -_PUTRESPONSE = DESCRIPTOR.message_types_by_name['PutResponse'] -_DELETERANGEREQUEST = DESCRIPTOR.message_types_by_name['DeleteRangeRequest'] -_DELETERANGERESPONSE = DESCRIPTOR.message_types_by_name['DeleteRangeResponse'] -_REQUESTOP = DESCRIPTOR.message_types_by_name['RequestOp'] -_RESPONSEOP = DESCRIPTOR.message_types_by_name['ResponseOp'] -_COMPARE = DESCRIPTOR.message_types_by_name['Compare'] -_TXNREQUEST = DESCRIPTOR.message_types_by_name['TxnRequest'] -_TXNRESPONSE = DESCRIPTOR.message_types_by_name['TxnResponse'] -_COMPACTIONREQUEST = DESCRIPTOR.message_types_by_name['CompactionRequest'] -_COMPACTIONRESPONSE = DESCRIPTOR.message_types_by_name['CompactionResponse'] -_HASHREQUEST = DESCRIPTOR.message_types_by_name['HashRequest'] -_HASHRESPONSE = DESCRIPTOR.message_types_by_name['HashResponse'] -_HASHKVREQUEST = DESCRIPTOR.message_types_by_name['HashKVRequest'] -_HASHKVRESPONSE = DESCRIPTOR.message_types_by_name['HashKVResponse'] -_SNAPSHOTREQUEST = DESCRIPTOR.message_types_by_name['SnapshotRequest'] -_SNAPSHOTRESPONSE = DESCRIPTOR.message_types_by_name['SnapshotResponse'] -_WATCHREQUEST = DESCRIPTOR.message_types_by_name['WatchRequest'] -_WATCHCREATEREQUEST = DESCRIPTOR.message_types_by_name['WatchCreateRequest'] -_WATCHCANCELREQUEST = DESCRIPTOR.message_types_by_name['WatchCancelRequest'] -_WATCHPROGRESSREQUEST = DESCRIPTOR.message_types_by_name['WatchProgressRequest'] -_WATCHRESPONSE = DESCRIPTOR.message_types_by_name['WatchResponse'] -_LEASEGRANTREQUEST = DESCRIPTOR.message_types_by_name['LeaseGrantRequest'] -_LEASEGRANTRESPONSE = DESCRIPTOR.message_types_by_name['LeaseGrantResponse'] -_LEASEREVOKEREQUEST = DESCRIPTOR.message_types_by_name['LeaseRevokeRequest'] -_LEASEREVOKERESPONSE = DESCRIPTOR.message_types_by_name['LeaseRevokeResponse'] -_LEASEKEEPALIVEREQUEST = DESCRIPTOR.message_types_by_name['LeaseKeepAliveRequest'] -_LEASEKEEPALIVERESPONSE = DESCRIPTOR.message_types_by_name['LeaseKeepAliveResponse'] -_LEASETIMETOLIVEREQUEST = DESCRIPTOR.message_types_by_name['LeaseTimeToLiveRequest'] -_LEASETIMETOLIVERESPONSE = DESCRIPTOR.message_types_by_name['LeaseTimeToLiveResponse'] -_MEMBER = DESCRIPTOR.message_types_by_name['Member'] -_MEMBERADDREQUEST = DESCRIPTOR.message_types_by_name['MemberAddRequest'] -_MEMBERADDRESPONSE = DESCRIPTOR.message_types_by_name['MemberAddResponse'] -_MEMBERREMOVEREQUEST = DESCRIPTOR.message_types_by_name['MemberRemoveRequest'] -_MEMBERREMOVERESPONSE = DESCRIPTOR.message_types_by_name['MemberRemoveResponse'] -_MEMBERUPDATEREQUEST = DESCRIPTOR.message_types_by_name['MemberUpdateRequest'] -_MEMBERUPDATERESPONSE = DESCRIPTOR.message_types_by_name['MemberUpdateResponse'] -_MEMBERLISTREQUEST = DESCRIPTOR.message_types_by_name['MemberListRequest'] -_MEMBERLISTRESPONSE = DESCRIPTOR.message_types_by_name['MemberListResponse'] -_DEFRAGMENTREQUEST = DESCRIPTOR.message_types_by_name['DefragmentRequest'] -_DEFRAGMENTRESPONSE = DESCRIPTOR.message_types_by_name['DefragmentResponse'] -_MOVELEADERREQUEST = DESCRIPTOR.message_types_by_name['MoveLeaderRequest'] -_MOVELEADERRESPONSE = DESCRIPTOR.message_types_by_name['MoveLeaderResponse'] -_ALARMREQUEST = DESCRIPTOR.message_types_by_name['AlarmRequest'] -_ALARMMEMBER = DESCRIPTOR.message_types_by_name['AlarmMember'] -_ALARMRESPONSE = DESCRIPTOR.message_types_by_name['AlarmResponse'] -_STATUSREQUEST = DESCRIPTOR.message_types_by_name['StatusRequest'] -_STATUSRESPONSE = DESCRIPTOR.message_types_by_name['StatusResponse'] -_AUTHENABLEREQUEST = DESCRIPTOR.message_types_by_name['AuthEnableRequest'] -_AUTHDISABLEREQUEST = DESCRIPTOR.message_types_by_name['AuthDisableRequest'] -_AUTHENTICATEREQUEST = DESCRIPTOR.message_types_by_name['AuthenticateRequest'] -_AUTHUSERADDREQUEST = DESCRIPTOR.message_types_by_name['AuthUserAddRequest'] -_AUTHUSERGETREQUEST = DESCRIPTOR.message_types_by_name['AuthUserGetRequest'] -_AUTHUSERDELETEREQUEST = DESCRIPTOR.message_types_by_name['AuthUserDeleteRequest'] -_AUTHUSERCHANGEPASSWORDREQUEST = DESCRIPTOR.message_types_by_name['AuthUserChangePasswordRequest'] -_AUTHUSERGRANTROLEREQUEST = DESCRIPTOR.message_types_by_name['AuthUserGrantRoleRequest'] -_AUTHUSERREVOKEROLEREQUEST = DESCRIPTOR.message_types_by_name['AuthUserRevokeRoleRequest'] -_AUTHROLEADDREQUEST = DESCRIPTOR.message_types_by_name['AuthRoleAddRequest'] -_AUTHROLEGETREQUEST = DESCRIPTOR.message_types_by_name['AuthRoleGetRequest'] -_AUTHUSERLISTREQUEST = DESCRIPTOR.message_types_by_name['AuthUserListRequest'] -_AUTHROLELISTREQUEST = DESCRIPTOR.message_types_by_name['AuthRoleListRequest'] -_AUTHROLEDELETEREQUEST = DESCRIPTOR.message_types_by_name['AuthRoleDeleteRequest'] -_AUTHROLEGRANTPERMISSIONREQUEST = DESCRIPTOR.message_types_by_name['AuthRoleGrantPermissionRequest'] -_AUTHROLEREVOKEPERMISSIONREQUEST = DESCRIPTOR.message_types_by_name['AuthRoleRevokePermissionRequest'] -_AUTHENABLERESPONSE = DESCRIPTOR.message_types_by_name['AuthEnableResponse'] -_AUTHDISABLERESPONSE = DESCRIPTOR.message_types_by_name['AuthDisableResponse'] -_AUTHENTICATERESPONSE = DESCRIPTOR.message_types_by_name['AuthenticateResponse'] -_AUTHUSERADDRESPONSE = DESCRIPTOR.message_types_by_name['AuthUserAddResponse'] -_AUTHUSERGETRESPONSE = DESCRIPTOR.message_types_by_name['AuthUserGetResponse'] -_AUTHUSERDELETERESPONSE = DESCRIPTOR.message_types_by_name['AuthUserDeleteResponse'] -_AUTHUSERCHANGEPASSWORDRESPONSE = DESCRIPTOR.message_types_by_name['AuthUserChangePasswordResponse'] -_AUTHUSERGRANTROLERESPONSE = DESCRIPTOR.message_types_by_name['AuthUserGrantRoleResponse'] -_AUTHUSERREVOKEROLERESPONSE = DESCRIPTOR.message_types_by_name['AuthUserRevokeRoleResponse'] -_AUTHROLEADDRESPONSE = DESCRIPTOR.message_types_by_name['AuthRoleAddResponse'] -_AUTHROLEGETRESPONSE = DESCRIPTOR.message_types_by_name['AuthRoleGetResponse'] -_AUTHROLELISTRESPONSE = DESCRIPTOR.message_types_by_name['AuthRoleListResponse'] -_AUTHUSERLISTRESPONSE = DESCRIPTOR.message_types_by_name['AuthUserListResponse'] -_AUTHROLEDELETERESPONSE = DESCRIPTOR.message_types_by_name['AuthRoleDeleteResponse'] -_AUTHROLEGRANTPERMISSIONRESPONSE = DESCRIPTOR.message_types_by_name['AuthRoleGrantPermissionResponse'] -_AUTHROLEREVOKEPERMISSIONRESPONSE = DESCRIPTOR.message_types_by_name['AuthRoleRevokePermissionResponse'] -_RANGEREQUEST_SORTORDER = _RANGEREQUEST.enum_types_by_name['SortOrder'] -_RANGEREQUEST_SORTTARGET = _RANGEREQUEST.enum_types_by_name['SortTarget'] -_COMPARE_COMPARERESULT = _COMPARE.enum_types_by_name['CompareResult'] -_COMPARE_COMPARETARGET = _COMPARE.enum_types_by_name['CompareTarget'] -_WATCHCREATEREQUEST_FILTERTYPE = _WATCHCREATEREQUEST.enum_types_by_name['FilterType'] -_ALARMREQUEST_ALARMACTION = _ALARMREQUEST.enum_types_by_name['AlarmAction'] -ResponseHeader = _reflection.GeneratedProtocolMessageType('ResponseHeader', (_message.Message,), { - 'DESCRIPTOR' : _RESPONSEHEADER, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.ResponseHeader) - }) -_sym_db.RegisterMessage(ResponseHeader) - -RangeRequest = _reflection.GeneratedProtocolMessageType('RangeRequest', (_message.Message,), { - 'DESCRIPTOR' : _RANGEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.RangeRequest) - }) -_sym_db.RegisterMessage(RangeRequest) - -RangeResponse = _reflection.GeneratedProtocolMessageType('RangeResponse', (_message.Message,), { - 'DESCRIPTOR' : _RANGERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.RangeResponse) - }) -_sym_db.RegisterMessage(RangeResponse) - -PutRequest = _reflection.GeneratedProtocolMessageType('PutRequest', (_message.Message,), { - 'DESCRIPTOR' : _PUTREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.PutRequest) - }) -_sym_db.RegisterMessage(PutRequest) - -PutResponse = _reflection.GeneratedProtocolMessageType('PutResponse', (_message.Message,), { - 'DESCRIPTOR' : _PUTRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.PutResponse) - }) -_sym_db.RegisterMessage(PutResponse) - -DeleteRangeRequest = _reflection.GeneratedProtocolMessageType('DeleteRangeRequest', (_message.Message,), { - 'DESCRIPTOR' : _DELETERANGEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.DeleteRangeRequest) - }) -_sym_db.RegisterMessage(DeleteRangeRequest) - -DeleteRangeResponse = _reflection.GeneratedProtocolMessageType('DeleteRangeResponse', (_message.Message,), { - 'DESCRIPTOR' : _DELETERANGERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.DeleteRangeResponse) - }) -_sym_db.RegisterMessage(DeleteRangeResponse) - -RequestOp = _reflection.GeneratedProtocolMessageType('RequestOp', (_message.Message,), { - 'DESCRIPTOR' : _REQUESTOP, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.RequestOp) - }) -_sym_db.RegisterMessage(RequestOp) - -ResponseOp = _reflection.GeneratedProtocolMessageType('ResponseOp', (_message.Message,), { - 'DESCRIPTOR' : _RESPONSEOP, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.ResponseOp) - }) -_sym_db.RegisterMessage(ResponseOp) - -Compare = _reflection.GeneratedProtocolMessageType('Compare', (_message.Message,), { - 'DESCRIPTOR' : _COMPARE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.Compare) - }) -_sym_db.RegisterMessage(Compare) - -TxnRequest = _reflection.GeneratedProtocolMessageType('TxnRequest', (_message.Message,), { - 'DESCRIPTOR' : _TXNREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.TxnRequest) - }) -_sym_db.RegisterMessage(TxnRequest) - -TxnResponse = _reflection.GeneratedProtocolMessageType('TxnResponse', (_message.Message,), { - 'DESCRIPTOR' : _TXNRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.TxnResponse) - }) -_sym_db.RegisterMessage(TxnResponse) - -CompactionRequest = _reflection.GeneratedProtocolMessageType('CompactionRequest', (_message.Message,), { - 'DESCRIPTOR' : _COMPACTIONREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.CompactionRequest) - }) -_sym_db.RegisterMessage(CompactionRequest) - -CompactionResponse = _reflection.GeneratedProtocolMessageType('CompactionResponse', (_message.Message,), { - 'DESCRIPTOR' : _COMPACTIONRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.CompactionResponse) - }) -_sym_db.RegisterMessage(CompactionResponse) - -HashRequest = _reflection.GeneratedProtocolMessageType('HashRequest', (_message.Message,), { - 'DESCRIPTOR' : _HASHREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.HashRequest) - }) -_sym_db.RegisterMessage(HashRequest) - -HashResponse = _reflection.GeneratedProtocolMessageType('HashResponse', (_message.Message,), { - 'DESCRIPTOR' : _HASHRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.HashResponse) - }) -_sym_db.RegisterMessage(HashResponse) - -HashKVRequest = _reflection.GeneratedProtocolMessageType('HashKVRequest', (_message.Message,), { - 'DESCRIPTOR' : _HASHKVREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.HashKVRequest) - }) -_sym_db.RegisterMessage(HashKVRequest) - -HashKVResponse = _reflection.GeneratedProtocolMessageType('HashKVResponse', (_message.Message,), { - 'DESCRIPTOR' : _HASHKVRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.HashKVResponse) - }) -_sym_db.RegisterMessage(HashKVResponse) - -SnapshotRequest = _reflection.GeneratedProtocolMessageType('SnapshotRequest', (_message.Message,), { - 'DESCRIPTOR' : _SNAPSHOTREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.SnapshotRequest) - }) -_sym_db.RegisterMessage(SnapshotRequest) - -SnapshotResponse = _reflection.GeneratedProtocolMessageType('SnapshotResponse', (_message.Message,), { - 'DESCRIPTOR' : _SNAPSHOTRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.SnapshotResponse) - }) -_sym_db.RegisterMessage(SnapshotResponse) - -WatchRequest = _reflection.GeneratedProtocolMessageType('WatchRequest', (_message.Message,), { - 'DESCRIPTOR' : _WATCHREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.WatchRequest) - }) -_sym_db.RegisterMessage(WatchRequest) - -WatchCreateRequest = _reflection.GeneratedProtocolMessageType('WatchCreateRequest', (_message.Message,), { - 'DESCRIPTOR' : _WATCHCREATEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.WatchCreateRequest) - }) -_sym_db.RegisterMessage(WatchCreateRequest) - -WatchCancelRequest = _reflection.GeneratedProtocolMessageType('WatchCancelRequest', (_message.Message,), { - 'DESCRIPTOR' : _WATCHCANCELREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.WatchCancelRequest) - }) -_sym_db.RegisterMessage(WatchCancelRequest) - -WatchProgressRequest = _reflection.GeneratedProtocolMessageType('WatchProgressRequest', (_message.Message,), { - 'DESCRIPTOR' : _WATCHPROGRESSREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.WatchProgressRequest) - }) -_sym_db.RegisterMessage(WatchProgressRequest) - -WatchResponse = _reflection.GeneratedProtocolMessageType('WatchResponse', (_message.Message,), { - 'DESCRIPTOR' : _WATCHRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.WatchResponse) - }) -_sym_db.RegisterMessage(WatchResponse) - -LeaseGrantRequest = _reflection.GeneratedProtocolMessageType('LeaseGrantRequest', (_message.Message,), { - 'DESCRIPTOR' : _LEASEGRANTREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.LeaseGrantRequest) - }) -_sym_db.RegisterMessage(LeaseGrantRequest) - -LeaseGrantResponse = _reflection.GeneratedProtocolMessageType('LeaseGrantResponse', (_message.Message,), { - 'DESCRIPTOR' : _LEASEGRANTRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.LeaseGrantResponse) - }) -_sym_db.RegisterMessage(LeaseGrantResponse) - -LeaseRevokeRequest = _reflection.GeneratedProtocolMessageType('LeaseRevokeRequest', (_message.Message,), { - 'DESCRIPTOR' : _LEASEREVOKEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.LeaseRevokeRequest) - }) -_sym_db.RegisterMessage(LeaseRevokeRequest) - -LeaseRevokeResponse = _reflection.GeneratedProtocolMessageType('LeaseRevokeResponse', (_message.Message,), { - 'DESCRIPTOR' : _LEASEREVOKERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.LeaseRevokeResponse) - }) -_sym_db.RegisterMessage(LeaseRevokeResponse) - -LeaseKeepAliveRequest = _reflection.GeneratedProtocolMessageType('LeaseKeepAliveRequest', (_message.Message,), { - 'DESCRIPTOR' : _LEASEKEEPALIVEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.LeaseKeepAliveRequest) - }) -_sym_db.RegisterMessage(LeaseKeepAliveRequest) - -LeaseKeepAliveResponse = _reflection.GeneratedProtocolMessageType('LeaseKeepAliveResponse', (_message.Message,), { - 'DESCRIPTOR' : _LEASEKEEPALIVERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.LeaseKeepAliveResponse) - }) -_sym_db.RegisterMessage(LeaseKeepAliveResponse) - -LeaseTimeToLiveRequest = _reflection.GeneratedProtocolMessageType('LeaseTimeToLiveRequest', (_message.Message,), { - 'DESCRIPTOR' : _LEASETIMETOLIVEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.LeaseTimeToLiveRequest) - }) -_sym_db.RegisterMessage(LeaseTimeToLiveRequest) - -LeaseTimeToLiveResponse = _reflection.GeneratedProtocolMessageType('LeaseTimeToLiveResponse', (_message.Message,), { - 'DESCRIPTOR' : _LEASETIMETOLIVERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.LeaseTimeToLiveResponse) - }) -_sym_db.RegisterMessage(LeaseTimeToLiveResponse) - -Member = _reflection.GeneratedProtocolMessageType('Member', (_message.Message,), { - 'DESCRIPTOR' : _MEMBER, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.Member) - }) -_sym_db.RegisterMessage(Member) - -MemberAddRequest = _reflection.GeneratedProtocolMessageType('MemberAddRequest', (_message.Message,), { - 'DESCRIPTOR' : _MEMBERADDREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MemberAddRequest) - }) -_sym_db.RegisterMessage(MemberAddRequest) - -MemberAddResponse = _reflection.GeneratedProtocolMessageType('MemberAddResponse', (_message.Message,), { - 'DESCRIPTOR' : _MEMBERADDRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MemberAddResponse) - }) -_sym_db.RegisterMessage(MemberAddResponse) - -MemberRemoveRequest = _reflection.GeneratedProtocolMessageType('MemberRemoveRequest', (_message.Message,), { - 'DESCRIPTOR' : _MEMBERREMOVEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MemberRemoveRequest) - }) -_sym_db.RegisterMessage(MemberRemoveRequest) - -MemberRemoveResponse = _reflection.GeneratedProtocolMessageType('MemberRemoveResponse', (_message.Message,), { - 'DESCRIPTOR' : _MEMBERREMOVERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MemberRemoveResponse) - }) -_sym_db.RegisterMessage(MemberRemoveResponse) - -MemberUpdateRequest = _reflection.GeneratedProtocolMessageType('MemberUpdateRequest', (_message.Message,), { - 'DESCRIPTOR' : _MEMBERUPDATEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MemberUpdateRequest) - }) -_sym_db.RegisterMessage(MemberUpdateRequest) - -MemberUpdateResponse = _reflection.GeneratedProtocolMessageType('MemberUpdateResponse', (_message.Message,), { - 'DESCRIPTOR' : _MEMBERUPDATERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MemberUpdateResponse) - }) -_sym_db.RegisterMessage(MemberUpdateResponse) - -MemberListRequest = _reflection.GeneratedProtocolMessageType('MemberListRequest', (_message.Message,), { - 'DESCRIPTOR' : _MEMBERLISTREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MemberListRequest) - }) -_sym_db.RegisterMessage(MemberListRequest) - -MemberListResponse = _reflection.GeneratedProtocolMessageType('MemberListResponse', (_message.Message,), { - 'DESCRIPTOR' : _MEMBERLISTRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MemberListResponse) - }) -_sym_db.RegisterMessage(MemberListResponse) - -DefragmentRequest = _reflection.GeneratedProtocolMessageType('DefragmentRequest', (_message.Message,), { - 'DESCRIPTOR' : _DEFRAGMENTREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.DefragmentRequest) - }) -_sym_db.RegisterMessage(DefragmentRequest) - -DefragmentResponse = _reflection.GeneratedProtocolMessageType('DefragmentResponse', (_message.Message,), { - 'DESCRIPTOR' : _DEFRAGMENTRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.DefragmentResponse) - }) -_sym_db.RegisterMessage(DefragmentResponse) - -MoveLeaderRequest = _reflection.GeneratedProtocolMessageType('MoveLeaderRequest', (_message.Message,), { - 'DESCRIPTOR' : _MOVELEADERREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MoveLeaderRequest) - }) -_sym_db.RegisterMessage(MoveLeaderRequest) - -MoveLeaderResponse = _reflection.GeneratedProtocolMessageType('MoveLeaderResponse', (_message.Message,), { - 'DESCRIPTOR' : _MOVELEADERRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.MoveLeaderResponse) - }) -_sym_db.RegisterMessage(MoveLeaderResponse) - -AlarmRequest = _reflection.GeneratedProtocolMessageType('AlarmRequest', (_message.Message,), { - 'DESCRIPTOR' : _ALARMREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AlarmRequest) - }) -_sym_db.RegisterMessage(AlarmRequest) - -AlarmMember = _reflection.GeneratedProtocolMessageType('AlarmMember', (_message.Message,), { - 'DESCRIPTOR' : _ALARMMEMBER, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AlarmMember) - }) -_sym_db.RegisterMessage(AlarmMember) - -AlarmResponse = _reflection.GeneratedProtocolMessageType('AlarmResponse', (_message.Message,), { - 'DESCRIPTOR' : _ALARMRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AlarmResponse) - }) -_sym_db.RegisterMessage(AlarmResponse) - -StatusRequest = _reflection.GeneratedProtocolMessageType('StatusRequest', (_message.Message,), { - 'DESCRIPTOR' : _STATUSREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.StatusRequest) - }) -_sym_db.RegisterMessage(StatusRequest) - -StatusResponse = _reflection.GeneratedProtocolMessageType('StatusResponse', (_message.Message,), { - 'DESCRIPTOR' : _STATUSRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.StatusResponse) - }) -_sym_db.RegisterMessage(StatusResponse) - -AuthEnableRequest = _reflection.GeneratedProtocolMessageType('AuthEnableRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHENABLEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthEnableRequest) - }) -_sym_db.RegisterMessage(AuthEnableRequest) - -AuthDisableRequest = _reflection.GeneratedProtocolMessageType('AuthDisableRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHDISABLEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthDisableRequest) - }) -_sym_db.RegisterMessage(AuthDisableRequest) - -AuthenticateRequest = _reflection.GeneratedProtocolMessageType('AuthenticateRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHENTICATEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthenticateRequest) - }) -_sym_db.RegisterMessage(AuthenticateRequest) - -AuthUserAddRequest = _reflection.GeneratedProtocolMessageType('AuthUserAddRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERADDREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserAddRequest) - }) -_sym_db.RegisterMessage(AuthUserAddRequest) - -AuthUserGetRequest = _reflection.GeneratedProtocolMessageType('AuthUserGetRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERGETREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserGetRequest) - }) -_sym_db.RegisterMessage(AuthUserGetRequest) - -AuthUserDeleteRequest = _reflection.GeneratedProtocolMessageType('AuthUserDeleteRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERDELETEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserDeleteRequest) - }) -_sym_db.RegisterMessage(AuthUserDeleteRequest) - -AuthUserChangePasswordRequest = _reflection.GeneratedProtocolMessageType('AuthUserChangePasswordRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERCHANGEPASSWORDREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserChangePasswordRequest) - }) -_sym_db.RegisterMessage(AuthUserChangePasswordRequest) - -AuthUserGrantRoleRequest = _reflection.GeneratedProtocolMessageType('AuthUserGrantRoleRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERGRANTROLEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserGrantRoleRequest) - }) -_sym_db.RegisterMessage(AuthUserGrantRoleRequest) - -AuthUserRevokeRoleRequest = _reflection.GeneratedProtocolMessageType('AuthUserRevokeRoleRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERREVOKEROLEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserRevokeRoleRequest) - }) -_sym_db.RegisterMessage(AuthUserRevokeRoleRequest) - -AuthRoleAddRequest = _reflection.GeneratedProtocolMessageType('AuthRoleAddRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEADDREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleAddRequest) - }) -_sym_db.RegisterMessage(AuthRoleAddRequest) - -AuthRoleGetRequest = _reflection.GeneratedProtocolMessageType('AuthRoleGetRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEGETREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleGetRequest) - }) -_sym_db.RegisterMessage(AuthRoleGetRequest) - -AuthUserListRequest = _reflection.GeneratedProtocolMessageType('AuthUserListRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERLISTREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserListRequest) - }) -_sym_db.RegisterMessage(AuthUserListRequest) - -AuthRoleListRequest = _reflection.GeneratedProtocolMessageType('AuthRoleListRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLELISTREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleListRequest) - }) -_sym_db.RegisterMessage(AuthRoleListRequest) - -AuthRoleDeleteRequest = _reflection.GeneratedProtocolMessageType('AuthRoleDeleteRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEDELETEREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleDeleteRequest) - }) -_sym_db.RegisterMessage(AuthRoleDeleteRequest) - -AuthRoleGrantPermissionRequest = _reflection.GeneratedProtocolMessageType('AuthRoleGrantPermissionRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEGRANTPERMISSIONREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleGrantPermissionRequest) - }) -_sym_db.RegisterMessage(AuthRoleGrantPermissionRequest) - -AuthRoleRevokePermissionRequest = _reflection.GeneratedProtocolMessageType('AuthRoleRevokePermissionRequest', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEREVOKEPERMISSIONREQUEST, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleRevokePermissionRequest) - }) -_sym_db.RegisterMessage(AuthRoleRevokePermissionRequest) - -AuthEnableResponse = _reflection.GeneratedProtocolMessageType('AuthEnableResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHENABLERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthEnableResponse) - }) -_sym_db.RegisterMessage(AuthEnableResponse) - -AuthDisableResponse = _reflection.GeneratedProtocolMessageType('AuthDisableResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHDISABLERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthDisableResponse) - }) -_sym_db.RegisterMessage(AuthDisableResponse) - -AuthenticateResponse = _reflection.GeneratedProtocolMessageType('AuthenticateResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHENTICATERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthenticateResponse) - }) -_sym_db.RegisterMessage(AuthenticateResponse) - -AuthUserAddResponse = _reflection.GeneratedProtocolMessageType('AuthUserAddResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERADDRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserAddResponse) - }) -_sym_db.RegisterMessage(AuthUserAddResponse) - -AuthUserGetResponse = _reflection.GeneratedProtocolMessageType('AuthUserGetResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERGETRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserGetResponse) - }) -_sym_db.RegisterMessage(AuthUserGetResponse) - -AuthUserDeleteResponse = _reflection.GeneratedProtocolMessageType('AuthUserDeleteResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERDELETERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserDeleteResponse) - }) -_sym_db.RegisterMessage(AuthUserDeleteResponse) - -AuthUserChangePasswordResponse = _reflection.GeneratedProtocolMessageType('AuthUserChangePasswordResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERCHANGEPASSWORDRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserChangePasswordResponse) - }) -_sym_db.RegisterMessage(AuthUserChangePasswordResponse) - -AuthUserGrantRoleResponse = _reflection.GeneratedProtocolMessageType('AuthUserGrantRoleResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERGRANTROLERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserGrantRoleResponse) - }) -_sym_db.RegisterMessage(AuthUserGrantRoleResponse) - -AuthUserRevokeRoleResponse = _reflection.GeneratedProtocolMessageType('AuthUserRevokeRoleResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERREVOKEROLERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserRevokeRoleResponse) - }) -_sym_db.RegisterMessage(AuthUserRevokeRoleResponse) - -AuthRoleAddResponse = _reflection.GeneratedProtocolMessageType('AuthRoleAddResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEADDRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleAddResponse) - }) -_sym_db.RegisterMessage(AuthRoleAddResponse) - -AuthRoleGetResponse = _reflection.GeneratedProtocolMessageType('AuthRoleGetResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEGETRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleGetResponse) - }) -_sym_db.RegisterMessage(AuthRoleGetResponse) - -AuthRoleListResponse = _reflection.GeneratedProtocolMessageType('AuthRoleListResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLELISTRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleListResponse) - }) -_sym_db.RegisterMessage(AuthRoleListResponse) - -AuthUserListResponse = _reflection.GeneratedProtocolMessageType('AuthUserListResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHUSERLISTRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthUserListResponse) - }) -_sym_db.RegisterMessage(AuthUserListResponse) - -AuthRoleDeleteResponse = _reflection.GeneratedProtocolMessageType('AuthRoleDeleteResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEDELETERESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleDeleteResponse) - }) -_sym_db.RegisterMessage(AuthRoleDeleteResponse) - -AuthRoleGrantPermissionResponse = _reflection.GeneratedProtocolMessageType('AuthRoleGrantPermissionResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEGRANTPERMISSIONRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleGrantPermissionResponse) - }) -_sym_db.RegisterMessage(AuthRoleGrantPermissionResponse) - -AuthRoleRevokePermissionResponse = _reflection.GeneratedProtocolMessageType('AuthRoleRevokePermissionResponse', (_message.Message,), { - 'DESCRIPTOR' : _AUTHROLEREVOKEPERMISSIONRESPONSE, - '__module__' : 'rpc_pb2' - # @@protoc_insertion_point(class_scope:etcdserverpb.AuthRoleRevokePermissionResponse) - }) -_sym_db.RegisterMessage(AuthRoleRevokePermissionResponse) - -_KV = DESCRIPTOR.services_by_name['KV'] -_WATCH = DESCRIPTOR.services_by_name['Watch'] -_LEASE = DESCRIPTOR.services_by_name['Lease'] -_CLUSTER = DESCRIPTOR.services_by_name['Cluster'] -_MAINTENANCE = DESCRIPTOR.services_by_name['Maintenance'] -_AUTH = DESCRIPTOR.services_by_name['Auth'] -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'\n\021io.etcd.jetcd.apiB\nJetcdProtoP\001\242\002\005Jetcd' - _ALARMTYPE._serialized_start=7482 - _ALARMTYPE._serialized_end=7516 - _RESPONSEHEADER._serialized_start=49 - _RESPONSEHEADER._serialized_end=141 - _RANGEREQUEST._serialized_start=144 - _RANGEREQUEST._serialized_end=628 - _RANGEREQUEST_SORTORDER._serialized_start=514 - _RANGEREQUEST_SORTORDER._serialized_end=560 - _RANGEREQUEST_SORTTARGET._serialized_start=562 - _RANGEREQUEST_SORTTARGET._serialized_end=628 - _RANGERESPONSE._serialized_start=630 - _RANGERESPONSE._serialized_end=751 - _PUTREQUEST._serialized_start=753 - _PUTREQUEST._serialized_end=869 - _PUTRESPONSE._serialized_start=871 - _PUTRESPONSE._serialized_end=965 - _DELETERANGEREQUEST._serialized_start=967 - _DELETERANGEREQUEST._serialized_end=1036 - _DELETERANGERESPONSE._serialized_start=1038 - _DELETERANGERESPONSE._serialized_end=1158 - _REQUESTOP._serialized_start=1161 - _REQUESTOP._serialized_end=1400 - _RESPONSEOP._serialized_start=1403 - _RESPONSEOP._serialized_end=1652 - _COMPARE._serialized_start=1655 - _COMPARE._serialized_end=2061 - _COMPARE_COMPARERESULT._serialized_start=1908 - _COMPARE_COMPARERESULT._serialized_end=1972 - _COMPARE_COMPARETARGET._serialized_start=1974 - _COMPARE_COMPARETARGET._serialized_end=2045 - _TXNREQUEST._serialized_start=2064 - _TXNREQUEST._serialized_end=2200 - _TXNRESPONSE._serialized_start=2202 - _TXNRESPONSE._serialized_end=2325 - _COMPACTIONREQUEST._serialized_start=2327 - _COMPACTIONREQUEST._serialized_end=2382 - _COMPACTIONRESPONSE._serialized_start=2384 - _COMPACTIONRESPONSE._serialized_end=2450 - _HASHREQUEST._serialized_start=2452 - _HASHREQUEST._serialized_end=2465 - _HASHRESPONSE._serialized_start=2467 - _HASHRESPONSE._serialized_end=2541 - _HASHKVREQUEST._serialized_start=2543 - _HASHKVREQUEST._serialized_end=2576 - _HASHKVRESPONSE._serialized_start=2578 - _HASHKVRESPONSE._serialized_end=2680 - _SNAPSHOTREQUEST._serialized_start=2682 - _SNAPSHOTREQUEST._serialized_end=2699 - _SNAPSHOTRESPONSE._serialized_start=2701 - _SNAPSHOTRESPONSE._serialized_end=2804 - _WATCHREQUEST._serialized_start=2807 - _WATCHREQUEST._serialized_end=3022 - _WATCHCREATEREQUEST._serialized_start=3025 - _WATCHCREATEREQUEST._serialized_end=3244 - _WATCHCREATEREQUEST_FILTERTYPE._serialized_start=3207 - _WATCHCREATEREQUEST_FILTERTYPE._serialized_end=3244 - _WATCHCANCELREQUEST._serialized_start=3246 - _WATCHCANCELREQUEST._serialized_end=3284 - _WATCHPROGRESSREQUEST._serialized_start=3286 - _WATCHPROGRESSREQUEST._serialized_end=3308 - _WATCHRESPONSE._serialized_start=3311 - _WATCHRESPONSE._serialized_end=3505 - _LEASEGRANTREQUEST._serialized_start=3507 - _LEASEGRANTREQUEST._serialized_end=3551 - _LEASEGRANTRESPONSE._serialized_start=3553 - _LEASEGRANTRESPONSE._serialized_end=3659 - _LEASEREVOKEREQUEST._serialized_start=3661 - _LEASEREVOKEREQUEST._serialized_end=3693 - _LEASEREVOKERESPONSE._serialized_start=3695 - _LEASEREVOKERESPONSE._serialized_end=3762 - _LEASEKEEPALIVEREQUEST._serialized_start=3764 - _LEASEKEEPALIVEREQUEST._serialized_end=3799 - _LEASEKEEPALIVERESPONSE._serialized_start=3801 - _LEASEKEEPALIVERESPONSE._serialized_end=3896 - _LEASETIMETOLIVEREQUEST._serialized_start=3898 - _LEASETIMETOLIVEREQUEST._serialized_end=3948 - _LEASETIMETOLIVERESPONSE._serialized_start=3951 - _LEASETIMETOLIVERESPONSE._serialized_end=4081 - _MEMBER._serialized_start=4083 - _MEMBER._serialized_end=4155 - _MEMBERADDREQUEST._serialized_start=4157 - _MEMBERADDREQUEST._serialized_end=4193 - _MEMBERADDRESPONSE._serialized_start=4196 - _MEMBERADDRESPONSE._serialized_end=4338 - _MEMBERREMOVEREQUEST._serialized_start=4340 - _MEMBERREMOVEREQUEST._serialized_end=4373 - _MEMBERREMOVERESPONSE._serialized_start=4375 - _MEMBERREMOVERESPONSE._serialized_end=4482 - _MEMBERUPDATEREQUEST._serialized_start=4484 - _MEMBERUPDATEREQUEST._serialized_end=4535 - _MEMBERUPDATERESPONSE._serialized_start=4537 - _MEMBERUPDATERESPONSE._serialized_end=4644 - _MEMBERLISTREQUEST._serialized_start=4646 - _MEMBERLISTREQUEST._serialized_end=4665 - _MEMBERLISTRESPONSE._serialized_start=4667 - _MEMBERLISTRESPONSE._serialized_end=4772 - _DEFRAGMENTREQUEST._serialized_start=4774 - _DEFRAGMENTREQUEST._serialized_end=4793 - _DEFRAGMENTRESPONSE._serialized_start=4795 - _DEFRAGMENTRESPONSE._serialized_end=4861 - _MOVELEADERREQUEST._serialized_start=4863 - _MOVELEADERREQUEST._serialized_end=4900 - _MOVELEADERRESPONSE._serialized_start=4902 - _MOVELEADERRESPONSE._serialized_end=4968 - _ALARMREQUEST._serialized_start=4971 - _ALARMREQUEST._serialized_end=5153 - _ALARMREQUEST_ALARMACTION._serialized_start=5101 - _ALARMREQUEST_ALARMACTION._serialized_end=5153 - _ALARMMEMBER._serialized_start=5155 - _ALARMMEMBER._serialized_end=5226 - _ALARMRESPONSE._serialized_start=5228 - _ALARMRESPONSE._serialized_end=5332 - _STATUSREQUEST._serialized_start=5334 - _STATUSREQUEST._serialized_end=5349 - _STATUSRESPONSE._serialized_start=5352 - _STATUSRESPONSE._serialized_end=5500 - _AUTHENABLEREQUEST._serialized_start=5502 - _AUTHENABLEREQUEST._serialized_end=5521 - _AUTHDISABLEREQUEST._serialized_start=5523 - _AUTHDISABLEREQUEST._serialized_end=5543 - _AUTHENTICATEREQUEST._serialized_start=5545 - _AUTHENTICATEREQUEST._serialized_end=5598 - _AUTHUSERADDREQUEST._serialized_start=5600 - _AUTHUSERADDREQUEST._serialized_end=5652 - _AUTHUSERGETREQUEST._serialized_start=5654 - _AUTHUSERGETREQUEST._serialized_end=5688 - _AUTHUSERDELETEREQUEST._serialized_start=5690 - _AUTHUSERDELETEREQUEST._serialized_end=5727 - _AUTHUSERCHANGEPASSWORDREQUEST._serialized_start=5729 - _AUTHUSERCHANGEPASSWORDREQUEST._serialized_end=5792 - _AUTHUSERGRANTROLEREQUEST._serialized_start=5794 - _AUTHUSERGRANTROLEREQUEST._serialized_end=5848 - _AUTHUSERREVOKEROLEREQUEST._serialized_start=5850 - _AUTHUSERREVOKEROLEREQUEST._serialized_end=5905 - _AUTHROLEADDREQUEST._serialized_start=5907 - _AUTHROLEADDREQUEST._serialized_end=5941 - _AUTHROLEGETREQUEST._serialized_start=5943 - _AUTHROLEGETREQUEST._serialized_end=5977 - _AUTHUSERLISTREQUEST._serialized_start=5979 - _AUTHUSERLISTREQUEST._serialized_end=6000 - _AUTHROLELISTREQUEST._serialized_start=6002 - _AUTHROLELISTREQUEST._serialized_end=6023 - _AUTHROLEDELETEREQUEST._serialized_start=6025 - _AUTHROLEDELETEREQUEST._serialized_end=6062 - _AUTHROLEGRANTPERMISSIONREQUEST._serialized_start=6064 - _AUTHROLEGRANTPERMISSIONREQUEST._serialized_end=6144 - _AUTHROLEREVOKEPERMISSIONREQUEST._serialized_start=6146 - _AUTHROLEREVOKEPERMISSIONREQUEST._serialized_end=6225 - _AUTHENABLERESPONSE._serialized_start=6227 - _AUTHENABLERESPONSE._serialized_end=6293 - _AUTHDISABLERESPONSE._serialized_start=6295 - _AUTHDISABLERESPONSE._serialized_end=6362 - _AUTHENTICATERESPONSE._serialized_start=6364 - _AUTHENTICATERESPONSE._serialized_end=6447 - _AUTHUSERADDRESPONSE._serialized_start=6449 - _AUTHUSERADDRESPONSE._serialized_end=6516 - _AUTHUSERGETRESPONSE._serialized_start=6518 - _AUTHUSERGETRESPONSE._serialized_end=6600 - _AUTHUSERDELETERESPONSE._serialized_start=6602 - _AUTHUSERDELETERESPONSE._serialized_end=6672 - _AUTHUSERCHANGEPASSWORDRESPONSE._serialized_start=6674 - _AUTHUSERCHANGEPASSWORDRESPONSE._serialized_end=6752 - _AUTHUSERGRANTROLERESPONSE._serialized_start=6754 - _AUTHUSERGRANTROLERESPONSE._serialized_end=6827 - _AUTHUSERREVOKEROLERESPONSE._serialized_start=6829 - _AUTHUSERREVOKEROLERESPONSE._serialized_end=6903 - _AUTHROLEADDRESPONSE._serialized_start=6905 - _AUTHROLEADDRESPONSE._serialized_end=6972 - _AUTHROLEGETRESPONSE._serialized_start=6974 - _AUTHROLEGETRESPONSE._serialized_end=7075 - _AUTHROLELISTRESPONSE._serialized_start=7077 - _AUTHROLELISTRESPONSE._serialized_end=7160 - _AUTHUSERLISTRESPONSE._serialized_start=7162 - _AUTHUSERLISTRESPONSE._serialized_end=7245 - _AUTHROLEDELETERESPONSE._serialized_start=7247 - _AUTHROLEDELETERESPONSE._serialized_end=7317 - _AUTHROLEGRANTPERMISSIONRESPONSE._serialized_start=7319 - _AUTHROLEGRANTPERMISSIONRESPONSE._serialized_end=7398 - _AUTHROLEREVOKEPERMISSIONRESPONSE._serialized_start=7400 - _AUTHROLEREVOKEPERMISSIONRESPONSE._serialized_end=7480 - _KV._serialized_start=7519 - _KV._serialized_end=7881 - _WATCH._serialized_start=7884 - _WATCH._serialized_end=8042 - _LEASE._serialized_start=8045 - _LEASE._serialized_end=8418 - _CLUSTER._serialized_start=8421 - _CLUSTER._serialized_end=8771 - _MAINTENANCE._serialized_start=8774 - _MAINTENANCE._serialized_end=9307 - _AUTH._serialized_start=9310 - _AUTH._serialized_end=10811 +_globals = globals() +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'rpc_pb2', _globals) +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'\n\021io.etcd.jetcd.apiB\nJetcdProtoP\001\242\002\005Jetcd' + _globals['_ALARMTYPE']._serialized_start = 7482 + _globals['_ALARMTYPE']._serialized_end = 7516 + _globals['_RESPONSEHEADER']._serialized_start = 49 + _globals['_RESPONSEHEADER']._serialized_end = 141 + _globals['_RANGEREQUEST']._serialized_start = 144 + _globals['_RANGEREQUEST']._serialized_end = 628 + _globals['_RANGEREQUEST_SORTORDER']._serialized_start = 514 + _globals['_RANGEREQUEST_SORTORDER']._serialized_end = 560 + _globals['_RANGEREQUEST_SORTTARGET']._serialized_start = 562 + _globals['_RANGEREQUEST_SORTTARGET']._serialized_end = 628 + _globals['_RANGERESPONSE']._serialized_start = 630 + _globals['_RANGERESPONSE']._serialized_end = 751 + _globals['_PUTREQUEST']._serialized_start = 753 + _globals['_PUTREQUEST']._serialized_end = 869 + _globals['_PUTRESPONSE']._serialized_start = 871 + _globals['_PUTRESPONSE']._serialized_end = 965 + _globals['_DELETERANGEREQUEST']._serialized_start = 967 + _globals['_DELETERANGEREQUEST']._serialized_end = 1036 + _globals['_DELETERANGERESPONSE']._serialized_start = 1038 + _globals['_DELETERANGERESPONSE']._serialized_end = 1158 + _globals['_REQUESTOP']._serialized_start = 1161 + _globals['_REQUESTOP']._serialized_end = 1400 + _globals['_RESPONSEOP']._serialized_start = 1403 + _globals['_RESPONSEOP']._serialized_end = 1652 + _globals['_COMPARE']._serialized_start = 1655 + _globals['_COMPARE']._serialized_end = 2061 + _globals['_COMPARE_COMPARERESULT']._serialized_start = 1908 + _globals['_COMPARE_COMPARERESULT']._serialized_end = 1972 + _globals['_COMPARE_COMPARETARGET']._serialized_start = 1974 + _globals['_COMPARE_COMPARETARGET']._serialized_end = 2045 + _globals['_TXNREQUEST']._serialized_start = 2064 + _globals['_TXNREQUEST']._serialized_end = 2200 + _globals['_TXNRESPONSE']._serialized_start = 2202 + _globals['_TXNRESPONSE']._serialized_end = 2325 + _globals['_COMPACTIONREQUEST']._serialized_start = 2327 + _globals['_COMPACTIONREQUEST']._serialized_end = 2382 + _globals['_COMPACTIONRESPONSE']._serialized_start = 2384 + _globals['_COMPACTIONRESPONSE']._serialized_end = 2450 + _globals['_HASHREQUEST']._serialized_start = 2452 + _globals['_HASHREQUEST']._serialized_end = 2465 + _globals['_HASHRESPONSE']._serialized_start = 2467 + _globals['_HASHRESPONSE']._serialized_end = 2541 + _globals['_HASHKVREQUEST']._serialized_start = 2543 + _globals['_HASHKVREQUEST']._serialized_end = 2576 + _globals['_HASHKVRESPONSE']._serialized_start = 2578 + _globals['_HASHKVRESPONSE']._serialized_end = 2680 + _globals['_SNAPSHOTREQUEST']._serialized_start = 2682 + _globals['_SNAPSHOTREQUEST']._serialized_end = 2699 + _globals['_SNAPSHOTRESPONSE']._serialized_start = 2701 + _globals['_SNAPSHOTRESPONSE']._serialized_end = 2804 + _globals['_WATCHREQUEST']._serialized_start = 2807 + _globals['_WATCHREQUEST']._serialized_end = 3022 + _globals['_WATCHCREATEREQUEST']._serialized_start = 3025 + _globals['_WATCHCREATEREQUEST']._serialized_end = 3244 + _globals['_WATCHCREATEREQUEST_FILTERTYPE']._serialized_start = 3207 + _globals['_WATCHCREATEREQUEST_FILTERTYPE']._serialized_end = 3244 + _globals['_WATCHCANCELREQUEST']._serialized_start = 3246 + _globals['_WATCHCANCELREQUEST']._serialized_end = 3284 + _globals['_WATCHPROGRESSREQUEST']._serialized_start = 3286 + _globals['_WATCHPROGRESSREQUEST']._serialized_end = 3308 + _globals['_WATCHRESPONSE']._serialized_start = 3311 + _globals['_WATCHRESPONSE']._serialized_end = 3505 + _globals['_LEASEGRANTREQUEST']._serialized_start = 3507 + _globals['_LEASEGRANTREQUEST']._serialized_end = 3551 + _globals['_LEASEGRANTRESPONSE']._serialized_start = 3553 + _globals['_LEASEGRANTRESPONSE']._serialized_end = 3659 + _globals['_LEASEREVOKEREQUEST']._serialized_start = 3661 + _globals['_LEASEREVOKEREQUEST']._serialized_end = 3693 + _globals['_LEASEREVOKERESPONSE']._serialized_start = 3695 + _globals['_LEASEREVOKERESPONSE']._serialized_end = 3762 + _globals['_LEASEKEEPALIVEREQUEST']._serialized_start = 3764 + _globals['_LEASEKEEPALIVEREQUEST']._serialized_end = 3799 + _globals['_LEASEKEEPALIVERESPONSE']._serialized_start = 3801 + _globals['_LEASEKEEPALIVERESPONSE']._serialized_end = 3896 + _globals['_LEASETIMETOLIVEREQUEST']._serialized_start = 3898 + _globals['_LEASETIMETOLIVEREQUEST']._serialized_end = 3948 + _globals['_LEASETIMETOLIVERESPONSE']._serialized_start = 3951 + _globals['_LEASETIMETOLIVERESPONSE']._serialized_end = 4081 + _globals['_MEMBER']._serialized_start = 4083 + _globals['_MEMBER']._serialized_end = 4155 + _globals['_MEMBERADDREQUEST']._serialized_start = 4157 + _globals['_MEMBERADDREQUEST']._serialized_end = 4193 + _globals['_MEMBERADDRESPONSE']._serialized_start = 4196 + _globals['_MEMBERADDRESPONSE']._serialized_end = 4338 + _globals['_MEMBERREMOVEREQUEST']._serialized_start = 4340 + _globals['_MEMBERREMOVEREQUEST']._serialized_end = 4373 + _globals['_MEMBERREMOVERESPONSE']._serialized_start = 4375 + _globals['_MEMBERREMOVERESPONSE']._serialized_end = 4482 + _globals['_MEMBERUPDATEREQUEST']._serialized_start = 4484 + _globals['_MEMBERUPDATEREQUEST']._serialized_end = 4535 + _globals['_MEMBERUPDATERESPONSE']._serialized_start = 4537 + _globals['_MEMBERUPDATERESPONSE']._serialized_end = 4644 + _globals['_MEMBERLISTREQUEST']._serialized_start = 4646 + _globals['_MEMBERLISTREQUEST']._serialized_end = 4665 + _globals['_MEMBERLISTRESPONSE']._serialized_start = 4667 + _globals['_MEMBERLISTRESPONSE']._serialized_end = 4772 + _globals['_DEFRAGMENTREQUEST']._serialized_start = 4774 + _globals['_DEFRAGMENTREQUEST']._serialized_end = 4793 + _globals['_DEFRAGMENTRESPONSE']._serialized_start = 4795 + _globals['_DEFRAGMENTRESPONSE']._serialized_end = 4861 + _globals['_MOVELEADERREQUEST']._serialized_start = 4863 + _globals['_MOVELEADERREQUEST']._serialized_end = 4900 + _globals['_MOVELEADERRESPONSE']._serialized_start = 4902 + _globals['_MOVELEADERRESPONSE']._serialized_end = 4968 + _globals['_ALARMREQUEST']._serialized_start = 4971 + _globals['_ALARMREQUEST']._serialized_end = 5153 + _globals['_ALARMREQUEST_ALARMACTION']._serialized_start = 5101 + _globals['_ALARMREQUEST_ALARMACTION']._serialized_end = 5153 + _globals['_ALARMMEMBER']._serialized_start = 5155 + _globals['_ALARMMEMBER']._serialized_end = 5226 + _globals['_ALARMRESPONSE']._serialized_start = 5228 + _globals['_ALARMRESPONSE']._serialized_end = 5332 + _globals['_STATUSREQUEST']._serialized_start = 5334 + _globals['_STATUSREQUEST']._serialized_end = 5349 + _globals['_STATUSRESPONSE']._serialized_start = 5352 + _globals['_STATUSRESPONSE']._serialized_end = 5500 + _globals['_AUTHENABLEREQUEST']._serialized_start = 5502 + _globals['_AUTHENABLEREQUEST']._serialized_end = 5521 + _globals['_AUTHDISABLEREQUEST']._serialized_start = 5523 + _globals['_AUTHDISABLEREQUEST']._serialized_end = 5543 + _globals['_AUTHENTICATEREQUEST']._serialized_start = 5545 + _globals['_AUTHENTICATEREQUEST']._serialized_end = 5598 + _globals['_AUTHUSERADDREQUEST']._serialized_start = 5600 + _globals['_AUTHUSERADDREQUEST']._serialized_end = 5652 + _globals['_AUTHUSERGETREQUEST']._serialized_start = 5654 + _globals['_AUTHUSERGETREQUEST']._serialized_end = 5688 + _globals['_AUTHUSERDELETEREQUEST']._serialized_start = 5690 + _globals['_AUTHUSERDELETEREQUEST']._serialized_end = 5727 + _globals['_AUTHUSERCHANGEPASSWORDREQUEST']._serialized_start = 5729 + _globals['_AUTHUSERCHANGEPASSWORDREQUEST']._serialized_end = 5792 + _globals['_AUTHUSERGRANTROLEREQUEST']._serialized_start = 5794 + _globals['_AUTHUSERGRANTROLEREQUEST']._serialized_end = 5848 + _globals['_AUTHUSERREVOKEROLEREQUEST']._serialized_start = 5850 + _globals['_AUTHUSERREVOKEROLEREQUEST']._serialized_end = 5905 + _globals['_AUTHROLEADDREQUEST']._serialized_start = 5907 + _globals['_AUTHROLEADDREQUEST']._serialized_end = 5941 + _globals['_AUTHROLEGETREQUEST']._serialized_start = 5943 + _globals['_AUTHROLEGETREQUEST']._serialized_end = 5977 + _globals['_AUTHUSERLISTREQUEST']._serialized_start = 5979 + _globals['_AUTHUSERLISTREQUEST']._serialized_end = 6000 + _globals['_AUTHROLELISTREQUEST']._serialized_start = 6002 + _globals['_AUTHROLELISTREQUEST']._serialized_end = 6023 + _globals['_AUTHROLEDELETEREQUEST']._serialized_start = 6025 + _globals['_AUTHROLEDELETEREQUEST']._serialized_end = 6062 + _globals['_AUTHROLEGRANTPERMISSIONREQUEST']._serialized_start = 6064 + _globals['_AUTHROLEGRANTPERMISSIONREQUEST']._serialized_end = 6144 + _globals['_AUTHROLEREVOKEPERMISSIONREQUEST']._serialized_start = 6146 + _globals['_AUTHROLEREVOKEPERMISSIONREQUEST']._serialized_end = 6225 + _globals['_AUTHENABLERESPONSE']._serialized_start = 6227 + _globals['_AUTHENABLERESPONSE']._serialized_end = 6293 + _globals['_AUTHDISABLERESPONSE']._serialized_start = 6295 + _globals['_AUTHDISABLERESPONSE']._serialized_end = 6362 + _globals['_AUTHENTICATERESPONSE']._serialized_start = 6364 + _globals['_AUTHENTICATERESPONSE']._serialized_end = 6447 + _globals['_AUTHUSERADDRESPONSE']._serialized_start = 6449 + _globals['_AUTHUSERADDRESPONSE']._serialized_end = 6516 + _globals['_AUTHUSERGETRESPONSE']._serialized_start = 6518 + _globals['_AUTHUSERGETRESPONSE']._serialized_end = 6600 + _globals['_AUTHUSERDELETERESPONSE']._serialized_start = 6602 + _globals['_AUTHUSERDELETERESPONSE']._serialized_end = 6672 + _globals['_AUTHUSERCHANGEPASSWORDRESPONSE']._serialized_start = 6674 + _globals['_AUTHUSERCHANGEPASSWORDRESPONSE']._serialized_end = 6752 + _globals['_AUTHUSERGRANTROLERESPONSE']._serialized_start = 6754 + _globals['_AUTHUSERGRANTROLERESPONSE']._serialized_end = 6827 + _globals['_AUTHUSERREVOKEROLERESPONSE']._serialized_start = 6829 + _globals['_AUTHUSERREVOKEROLERESPONSE']._serialized_end = 6903 + _globals['_AUTHROLEADDRESPONSE']._serialized_start = 6905 + _globals['_AUTHROLEADDRESPONSE']._serialized_end = 6972 + _globals['_AUTHROLEGETRESPONSE']._serialized_start = 6974 + _globals['_AUTHROLEGETRESPONSE']._serialized_end = 7075 + _globals['_AUTHROLELISTRESPONSE']._serialized_start = 7077 + _globals['_AUTHROLELISTRESPONSE']._serialized_end = 7160 + _globals['_AUTHUSERLISTRESPONSE']._serialized_start = 7162 + _globals['_AUTHUSERLISTRESPONSE']._serialized_end = 7245 + _globals['_AUTHROLEDELETERESPONSE']._serialized_start = 7247 + _globals['_AUTHROLEDELETERESPONSE']._serialized_end = 7317 + _globals['_AUTHROLEGRANTPERMISSIONRESPONSE']._serialized_start = 7319 + _globals['_AUTHROLEGRANTPERMISSIONRESPONSE']._serialized_end = 7398 + _globals['_AUTHROLEREVOKEPERMISSIONRESPONSE']._serialized_start = 7400 + _globals['_AUTHROLEREVOKEPERMISSIONRESPONSE']._serialized_end = 7480 + _globals['_KV']._serialized_start = 7519 + _globals['_KV']._serialized_end = 7881 + _globals['_WATCH']._serialized_start = 7884 + _globals['_WATCH']._serialized_end = 8042 + _globals['_LEASE']._serialized_start = 8045 + _globals['_LEASE']._serialized_end = 8418 + _globals['_CLUSTER']._serialized_start = 8421 + _globals['_CLUSTER']._serialized_end = 8771 + _globals['_MAINTENANCE']._serialized_start = 8774 + _globals['_MAINTENANCE']._serialized_end = 9307 + _globals['_AUTH']._serialized_start = 9310 + _globals['_AUTH']._serialized_end = 10811 # @@protoc_insertion_point(module_scope) diff --git a/etcd3/etcdrpc/rpc_pb2_grpc.py b/etcd3/etcdrpc/rpc_pb2_grpc.py index 7921151d..e6e0fc1d 100644 --- a/etcd3/etcdrpc/rpc_pb2_grpc.py +++ b/etcd3/etcdrpc/rpc_pb2_grpc.py @@ -1,9 +1,29 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from etcd3.etcdrpc import rpc_pb2 as rpc__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + +f' but the generated code in rpc_pb2_grpc.py depends on' + +f' grpcio>={GRPC_GENERATED_VERSION}.' + +f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + +f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + ) + class KVStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,27 +38,27 @@ def __init__(self, channel): '/etcdserverpb.KV/Range', request_serializer=rpc__pb2.RangeRequest.SerializeToString, response_deserializer=rpc__pb2.RangeResponse.FromString, - ) + _registered_method=True) self.Put = channel.unary_unary( '/etcdserverpb.KV/Put', request_serializer=rpc__pb2.PutRequest.SerializeToString, response_deserializer=rpc__pb2.PutResponse.FromString, - ) + _registered_method=True) self.DeleteRange = channel.unary_unary( '/etcdserverpb.KV/DeleteRange', request_serializer=rpc__pb2.DeleteRangeRequest.SerializeToString, response_deserializer=rpc__pb2.DeleteRangeResponse.FromString, - ) + _registered_method=True) self.Txn = channel.unary_unary( '/etcdserverpb.KV/Txn', request_serializer=rpc__pb2.TxnRequest.SerializeToString, response_deserializer=rpc__pb2.TxnResponse.FromString, - ) + _registered_method=True) self.Compact = channel.unary_unary( '/etcdserverpb.KV/Compact', request_serializer=rpc__pb2.CompactionRequest.SerializeToString, response_deserializer=rpc__pb2.CompactionResponse.FromString, - ) + _registered_method=True) class KVServicer(object): @@ -120,6 +140,7 @@ def add_KVServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'etcdserverpb.KV', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('etcdserverpb.KV', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -137,11 +158,21 @@ def Range(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.KV/Range', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.KV/Range', rpc__pb2.RangeRequest.SerializeToString, rpc__pb2.RangeResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Put(request, @@ -154,11 +185,21 @@ def Put(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.KV/Put', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.KV/Put', rpc__pb2.PutRequest.SerializeToString, rpc__pb2.PutResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def DeleteRange(request, @@ -171,11 +212,21 @@ def DeleteRange(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.KV/DeleteRange', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.KV/DeleteRange', rpc__pb2.DeleteRangeRequest.SerializeToString, rpc__pb2.DeleteRangeResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Txn(request, @@ -188,11 +239,21 @@ def Txn(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.KV/Txn', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.KV/Txn', rpc__pb2.TxnRequest.SerializeToString, rpc__pb2.TxnResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Compact(request, @@ -205,11 +266,21 @@ def Compact(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.KV/Compact', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.KV/Compact', rpc__pb2.CompactionRequest.SerializeToString, rpc__pb2.CompactionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class WatchStub(object): @@ -225,12 +296,12 @@ def __init__(self, channel): '/etcdserverpb.Watch/Progress', request_serializer=rpc__pb2.WatchProgressRequest.SerializeToString, response_deserializer=rpc__pb2.WatchResponse.FromString, - ) + _registered_method=True) self.Watch = channel.stream_stream( '/etcdserverpb.Watch/Watch', request_serializer=rpc__pb2.WatchRequest.SerializeToString, response_deserializer=rpc__pb2.WatchResponse.FromString, - ) + _registered_method=True) class WatchServicer(object): @@ -275,6 +346,7 @@ def add_WatchServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'etcdserverpb.Watch', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('etcdserverpb.Watch', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -292,11 +364,21 @@ def Progress(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Watch/Progress', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Watch/Progress', rpc__pb2.WatchProgressRequest.SerializeToString, rpc__pb2.WatchResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Watch(request_iterator, @@ -309,11 +391,21 @@ def Watch(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_stream(request_iterator, target, '/etcdserverpb.Watch/Watch', + return grpc.experimental.stream_stream( + request_iterator, + target, + '/etcdserverpb.Watch/Watch', rpc__pb2.WatchRequest.SerializeToString, rpc__pb2.WatchResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class LeaseStub(object): @@ -329,22 +421,22 @@ def __init__(self, channel): '/etcdserverpb.Lease/LeaseGrant', request_serializer=rpc__pb2.LeaseGrantRequest.SerializeToString, response_deserializer=rpc__pb2.LeaseGrantResponse.FromString, - ) + _registered_method=True) self.LeaseRevoke = channel.unary_unary( '/etcdserverpb.Lease/LeaseRevoke', request_serializer=rpc__pb2.LeaseRevokeRequest.SerializeToString, response_deserializer=rpc__pb2.LeaseRevokeResponse.FromString, - ) + _registered_method=True) self.LeaseKeepAlive = channel.stream_stream( '/etcdserverpb.Lease/LeaseKeepAlive', request_serializer=rpc__pb2.LeaseKeepAliveRequest.SerializeToString, response_deserializer=rpc__pb2.LeaseKeepAliveResponse.FromString, - ) + _registered_method=True) self.LeaseTimeToLive = channel.unary_unary( '/etcdserverpb.Lease/LeaseTimeToLive', request_serializer=rpc__pb2.LeaseTimeToLiveRequest.SerializeToString, response_deserializer=rpc__pb2.LeaseTimeToLiveResponse.FromString, - ) + _registered_method=True) class LeaseServicer(object): @@ -408,6 +500,7 @@ def add_LeaseServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'etcdserverpb.Lease', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('etcdserverpb.Lease', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -425,11 +518,21 @@ def LeaseGrant(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Lease/LeaseGrant', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Lease/LeaseGrant', rpc__pb2.LeaseGrantRequest.SerializeToString, rpc__pb2.LeaseGrantResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def LeaseRevoke(request, @@ -442,11 +545,21 @@ def LeaseRevoke(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Lease/LeaseRevoke', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Lease/LeaseRevoke', rpc__pb2.LeaseRevokeRequest.SerializeToString, rpc__pb2.LeaseRevokeResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def LeaseKeepAlive(request_iterator, @@ -459,11 +572,21 @@ def LeaseKeepAlive(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_stream(request_iterator, target, '/etcdserverpb.Lease/LeaseKeepAlive', + return grpc.experimental.stream_stream( + request_iterator, + target, + '/etcdserverpb.Lease/LeaseKeepAlive', rpc__pb2.LeaseKeepAliveRequest.SerializeToString, rpc__pb2.LeaseKeepAliveResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def LeaseTimeToLive(request, @@ -476,11 +599,21 @@ def LeaseTimeToLive(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Lease/LeaseTimeToLive', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Lease/LeaseTimeToLive', rpc__pb2.LeaseTimeToLiveRequest.SerializeToString, rpc__pb2.LeaseTimeToLiveResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class ClusterStub(object): @@ -496,22 +629,22 @@ def __init__(self, channel): '/etcdserverpb.Cluster/MemberAdd', request_serializer=rpc__pb2.MemberAddRequest.SerializeToString, response_deserializer=rpc__pb2.MemberAddResponse.FromString, - ) + _registered_method=True) self.MemberRemove = channel.unary_unary( '/etcdserverpb.Cluster/MemberRemove', request_serializer=rpc__pb2.MemberRemoveRequest.SerializeToString, response_deserializer=rpc__pb2.MemberRemoveResponse.FromString, - ) + _registered_method=True) self.MemberUpdate = channel.unary_unary( '/etcdserverpb.Cluster/MemberUpdate', request_serializer=rpc__pb2.MemberUpdateRequest.SerializeToString, response_deserializer=rpc__pb2.MemberUpdateResponse.FromString, - ) + _registered_method=True) self.MemberList = channel.unary_unary( '/etcdserverpb.Cluster/MemberList', request_serializer=rpc__pb2.MemberListRequest.SerializeToString, response_deserializer=rpc__pb2.MemberListResponse.FromString, - ) + _registered_method=True) class ClusterServicer(object): @@ -572,6 +705,7 @@ def add_ClusterServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'etcdserverpb.Cluster', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('etcdserverpb.Cluster', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -589,11 +723,21 @@ def MemberAdd(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Cluster/MemberAdd', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Cluster/MemberAdd', rpc__pb2.MemberAddRequest.SerializeToString, rpc__pb2.MemberAddResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def MemberRemove(request, @@ -606,11 +750,21 @@ def MemberRemove(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Cluster/MemberRemove', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Cluster/MemberRemove', rpc__pb2.MemberRemoveRequest.SerializeToString, rpc__pb2.MemberRemoveResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def MemberUpdate(request, @@ -623,11 +777,21 @@ def MemberUpdate(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Cluster/MemberUpdate', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Cluster/MemberUpdate', rpc__pb2.MemberUpdateRequest.SerializeToString, rpc__pb2.MemberUpdateResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def MemberList(request, @@ -640,11 +804,21 @@ def MemberList(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Cluster/MemberList', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Cluster/MemberList', rpc__pb2.MemberListRequest.SerializeToString, rpc__pb2.MemberListResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class MaintenanceStub(object): @@ -660,37 +834,37 @@ def __init__(self, channel): '/etcdserverpb.Maintenance/Alarm', request_serializer=rpc__pb2.AlarmRequest.SerializeToString, response_deserializer=rpc__pb2.AlarmResponse.FromString, - ) + _registered_method=True) self.Status = channel.unary_unary( '/etcdserverpb.Maintenance/Status', request_serializer=rpc__pb2.StatusRequest.SerializeToString, response_deserializer=rpc__pb2.StatusResponse.FromString, - ) + _registered_method=True) self.Defragment = channel.unary_unary( '/etcdserverpb.Maintenance/Defragment', request_serializer=rpc__pb2.DefragmentRequest.SerializeToString, response_deserializer=rpc__pb2.DefragmentResponse.FromString, - ) + _registered_method=True) self.Hash = channel.unary_unary( '/etcdserverpb.Maintenance/Hash', request_serializer=rpc__pb2.HashRequest.SerializeToString, response_deserializer=rpc__pb2.HashResponse.FromString, - ) + _registered_method=True) self.HashKV = channel.unary_unary( '/etcdserverpb.Maintenance/HashKV', request_serializer=rpc__pb2.HashKVRequest.SerializeToString, response_deserializer=rpc__pb2.HashKVResponse.FromString, - ) + _registered_method=True) self.Snapshot = channel.unary_stream( '/etcdserverpb.Maintenance/Snapshot', request_serializer=rpc__pb2.SnapshotRequest.SerializeToString, response_deserializer=rpc__pb2.SnapshotResponse.FromString, - ) + _registered_method=True) self.MoveLeader = channel.unary_unary( '/etcdserverpb.Maintenance/MoveLeader', request_serializer=rpc__pb2.MoveLeaderRequest.SerializeToString, response_deserializer=rpc__pb2.MoveLeaderResponse.FromString, - ) + _registered_method=True) class MaintenanceServicer(object): @@ -789,6 +963,7 @@ def add_MaintenanceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'etcdserverpb.Maintenance', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('etcdserverpb.Maintenance', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -806,11 +981,21 @@ def Alarm(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Maintenance/Alarm', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Maintenance/Alarm', rpc__pb2.AlarmRequest.SerializeToString, rpc__pb2.AlarmResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Status(request, @@ -823,11 +1008,21 @@ def Status(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Maintenance/Status', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Maintenance/Status', rpc__pb2.StatusRequest.SerializeToString, rpc__pb2.StatusResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Defragment(request, @@ -840,11 +1035,21 @@ def Defragment(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Maintenance/Defragment', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Maintenance/Defragment', rpc__pb2.DefragmentRequest.SerializeToString, rpc__pb2.DefragmentResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Hash(request, @@ -857,11 +1062,21 @@ def Hash(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Maintenance/Hash', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Maintenance/Hash', rpc__pb2.HashRequest.SerializeToString, rpc__pb2.HashResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def HashKV(request, @@ -874,11 +1089,21 @@ def HashKV(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Maintenance/HashKV', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Maintenance/HashKV', rpc__pb2.HashKVRequest.SerializeToString, rpc__pb2.HashKVResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Snapshot(request, @@ -891,11 +1116,21 @@ def Snapshot(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream(request, target, '/etcdserverpb.Maintenance/Snapshot', + return grpc.experimental.unary_stream( + request, + target, + '/etcdserverpb.Maintenance/Snapshot', rpc__pb2.SnapshotRequest.SerializeToString, rpc__pb2.SnapshotResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def MoveLeader(request, @@ -908,11 +1143,21 @@ def MoveLeader(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Maintenance/MoveLeader', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Maintenance/MoveLeader', rpc__pb2.MoveLeaderRequest.SerializeToString, rpc__pb2.MoveLeaderResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class AuthStub(object): @@ -928,82 +1173,82 @@ def __init__(self, channel): '/etcdserverpb.Auth/AuthEnable', request_serializer=rpc__pb2.AuthEnableRequest.SerializeToString, response_deserializer=rpc__pb2.AuthEnableResponse.FromString, - ) + _registered_method=True) self.AuthDisable = channel.unary_unary( '/etcdserverpb.Auth/AuthDisable', request_serializer=rpc__pb2.AuthDisableRequest.SerializeToString, response_deserializer=rpc__pb2.AuthDisableResponse.FromString, - ) + _registered_method=True) self.Authenticate = channel.unary_unary( '/etcdserverpb.Auth/Authenticate', request_serializer=rpc__pb2.AuthenticateRequest.SerializeToString, response_deserializer=rpc__pb2.AuthenticateResponse.FromString, - ) + _registered_method=True) self.UserAdd = channel.unary_unary( '/etcdserverpb.Auth/UserAdd', request_serializer=rpc__pb2.AuthUserAddRequest.SerializeToString, response_deserializer=rpc__pb2.AuthUserAddResponse.FromString, - ) + _registered_method=True) self.UserGet = channel.unary_unary( '/etcdserverpb.Auth/UserGet', request_serializer=rpc__pb2.AuthUserGetRequest.SerializeToString, response_deserializer=rpc__pb2.AuthUserGetResponse.FromString, - ) + _registered_method=True) self.UserList = channel.unary_unary( '/etcdserverpb.Auth/UserList', request_serializer=rpc__pb2.AuthUserListRequest.SerializeToString, response_deserializer=rpc__pb2.AuthUserListResponse.FromString, - ) + _registered_method=True) self.UserDelete = channel.unary_unary( '/etcdserverpb.Auth/UserDelete', request_serializer=rpc__pb2.AuthUserDeleteRequest.SerializeToString, response_deserializer=rpc__pb2.AuthUserDeleteResponse.FromString, - ) + _registered_method=True) self.UserChangePassword = channel.unary_unary( '/etcdserverpb.Auth/UserChangePassword', request_serializer=rpc__pb2.AuthUserChangePasswordRequest.SerializeToString, response_deserializer=rpc__pb2.AuthUserChangePasswordResponse.FromString, - ) + _registered_method=True) self.UserGrantRole = channel.unary_unary( '/etcdserverpb.Auth/UserGrantRole', request_serializer=rpc__pb2.AuthUserGrantRoleRequest.SerializeToString, response_deserializer=rpc__pb2.AuthUserGrantRoleResponse.FromString, - ) + _registered_method=True) self.UserRevokeRole = channel.unary_unary( '/etcdserverpb.Auth/UserRevokeRole', request_serializer=rpc__pb2.AuthUserRevokeRoleRequest.SerializeToString, response_deserializer=rpc__pb2.AuthUserRevokeRoleResponse.FromString, - ) + _registered_method=True) self.RoleAdd = channel.unary_unary( '/etcdserverpb.Auth/RoleAdd', request_serializer=rpc__pb2.AuthRoleAddRequest.SerializeToString, response_deserializer=rpc__pb2.AuthRoleAddResponse.FromString, - ) + _registered_method=True) self.RoleGet = channel.unary_unary( '/etcdserverpb.Auth/RoleGet', request_serializer=rpc__pb2.AuthRoleGetRequest.SerializeToString, response_deserializer=rpc__pb2.AuthRoleGetResponse.FromString, - ) + _registered_method=True) self.RoleList = channel.unary_unary( '/etcdserverpb.Auth/RoleList', request_serializer=rpc__pb2.AuthRoleListRequest.SerializeToString, response_deserializer=rpc__pb2.AuthRoleListResponse.FromString, - ) + _registered_method=True) self.RoleDelete = channel.unary_unary( '/etcdserverpb.Auth/RoleDelete', request_serializer=rpc__pb2.AuthRoleDeleteRequest.SerializeToString, response_deserializer=rpc__pb2.AuthRoleDeleteResponse.FromString, - ) + _registered_method=True) self.RoleGrantPermission = channel.unary_unary( '/etcdserverpb.Auth/RoleGrantPermission', request_serializer=rpc__pb2.AuthRoleGrantPermissionRequest.SerializeToString, response_deserializer=rpc__pb2.AuthRoleGrantPermissionResponse.FromString, - ) + _registered_method=True) self.RoleRevokePermission = channel.unary_unary( '/etcdserverpb.Auth/RoleRevokePermission', request_serializer=rpc__pb2.AuthRoleRevokePermissionRequest.SerializeToString, response_deserializer=rpc__pb2.AuthRoleRevokePermissionResponse.FromString, - ) + _registered_method=True) class AuthServicer(object): @@ -1208,6 +1453,7 @@ def add_AuthServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'etcdserverpb.Auth', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('etcdserverpb.Auth', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -1225,11 +1471,21 @@ def AuthEnable(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/AuthEnable', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/AuthEnable', rpc__pb2.AuthEnableRequest.SerializeToString, rpc__pb2.AuthEnableResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def AuthDisable(request, @@ -1242,11 +1498,21 @@ def AuthDisable(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/AuthDisable', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/AuthDisable', rpc__pb2.AuthDisableRequest.SerializeToString, rpc__pb2.AuthDisableResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Authenticate(request, @@ -1259,11 +1525,21 @@ def Authenticate(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/Authenticate', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/Authenticate', rpc__pb2.AuthenticateRequest.SerializeToString, rpc__pb2.AuthenticateResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UserAdd(request, @@ -1276,11 +1552,21 @@ def UserAdd(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/UserAdd', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/UserAdd', rpc__pb2.AuthUserAddRequest.SerializeToString, rpc__pb2.AuthUserAddResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UserGet(request, @@ -1293,11 +1579,21 @@ def UserGet(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/UserGet', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/UserGet', rpc__pb2.AuthUserGetRequest.SerializeToString, rpc__pb2.AuthUserGetResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UserList(request, @@ -1310,11 +1606,21 @@ def UserList(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/UserList', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/UserList', rpc__pb2.AuthUserListRequest.SerializeToString, rpc__pb2.AuthUserListResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UserDelete(request, @@ -1327,11 +1633,21 @@ def UserDelete(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/UserDelete', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/UserDelete', rpc__pb2.AuthUserDeleteRequest.SerializeToString, rpc__pb2.AuthUserDeleteResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UserChangePassword(request, @@ -1344,11 +1660,21 @@ def UserChangePassword(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/UserChangePassword', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/UserChangePassword', rpc__pb2.AuthUserChangePasswordRequest.SerializeToString, rpc__pb2.AuthUserChangePasswordResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UserGrantRole(request, @@ -1361,11 +1687,21 @@ def UserGrantRole(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/UserGrantRole', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/UserGrantRole', rpc__pb2.AuthUserGrantRoleRequest.SerializeToString, rpc__pb2.AuthUserGrantRoleResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UserRevokeRole(request, @@ -1378,11 +1714,21 @@ def UserRevokeRole(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/UserRevokeRole', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/UserRevokeRole', rpc__pb2.AuthUserRevokeRoleRequest.SerializeToString, rpc__pb2.AuthUserRevokeRoleResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def RoleAdd(request, @@ -1395,11 +1741,21 @@ def RoleAdd(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/RoleAdd', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/RoleAdd', rpc__pb2.AuthRoleAddRequest.SerializeToString, rpc__pb2.AuthRoleAddResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def RoleGet(request, @@ -1412,11 +1768,21 @@ def RoleGet(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/RoleGet', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/RoleGet', rpc__pb2.AuthRoleGetRequest.SerializeToString, rpc__pb2.AuthRoleGetResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def RoleList(request, @@ -1429,11 +1795,21 @@ def RoleList(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/RoleList', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/RoleList', rpc__pb2.AuthRoleListRequest.SerializeToString, rpc__pb2.AuthRoleListResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def RoleDelete(request, @@ -1446,11 +1822,21 @@ def RoleDelete(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/RoleDelete', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/RoleDelete', rpc__pb2.AuthRoleDeleteRequest.SerializeToString, rpc__pb2.AuthRoleDeleteResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def RoleGrantPermission(request, @@ -1463,11 +1849,21 @@ def RoleGrantPermission(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/RoleGrantPermission', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/RoleGrantPermission', rpc__pb2.AuthRoleGrantPermissionRequest.SerializeToString, rpc__pb2.AuthRoleGrantPermissionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def RoleRevokePermission(request, @@ -1480,8 +1876,18 @@ def RoleRevokePermission(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/etcdserverpb.Auth/RoleRevokePermission', + return grpc.experimental.unary_unary( + request, + target, + '/etcdserverpb.Auth/RoleRevokePermission', rpc__pb2.AuthRoleRevokePermissionRequest.SerializeToString, rpc__pb2.AuthRoleRevokePermissionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) From fca73b5e9afd076ad1600af0f5a23e10d1d809b0 Mon Sep 17 00:00:00 2001 From: Scott Lewis Date: Wed, 4 Sep 2024 15:44:29 -0700 Subject: [PATCH 2/2] Update version from 0.12.0 to 0.13.0 --- .settings/org.eclipse.core.resources.prefs | 1 + etcd3/__init__.py | 2 +- setup.cfg | 2 +- setup.py | 2 +- 4 files changed, 4 insertions(+), 3 deletions(-) diff --git a/.settings/org.eclipse.core.resources.prefs b/.settings/org.eclipse.core.resources.prefs index 283e2478..c290201d 100644 --- a/.settings/org.eclipse.core.resources.prefs +++ b/.settings/org.eclipse.core.resources.prefs @@ -2,3 +2,4 @@ eclipse.preferences.version=1 encoding//etcd3/etcdrpc/auth_pb2.py=utf-8 encoding//etcd3/etcdrpc/kv_pb2.py=utf-8 encoding//etcd3/etcdrpc/rpc_pb2.py=utf-8 +encoding/setup.py=utf-8 diff --git a/etcd3/__init__.py b/etcd3/__init__.py index abbc3cc8..5661ecf2 100644 --- a/etcd3/__init__.py +++ b/etcd3/__init__.py @@ -13,7 +13,7 @@ __author__ = 'Louis Taylor' __email__ = 'louis@kragniz.eu' -__version__ = '0.12.0' +__version__ = '0.13.0' __all__ = ( 'etcdrpc', diff --git a/setup.cfg b/setup.cfg index 0e49001b..3f311d25 100644 --- a/setup.cfg +++ b/setup.cfg @@ -1,5 +1,5 @@ [bumpversion] -current_version = 0.12.0 +current_version = 0.13.0 commit = True tag = True message = Release: {current_version} -> {new_version} diff --git a/setup.py b/setup.py index 361f8fa6..226ac42f 100644 --- a/setup.py +++ b/setup.py @@ -25,7 +25,7 @@ def load_reqs(filename): setup( name='etcd3', - version='0.12.0', + version='0.13.0', description="Python client for the etcd3 API", long_description=readme + '\n\n' + history, author="Louis Taylor",