diff --git a/examples/grpc-bridge/client/kv_pb2.py b/examples/grpc-bridge/client/kv_pb2.py index c644220be100..3441998f76ac 100644 --- a/examples/grpc-bridge/client/kv_pb2.py +++ b/examples/grpc-bridge/client/kv_pb2.py @@ -21,7 +21,6 @@ syntax='proto3', serialized_pb=_b('\n\x08kv.proto\x12\x02kv\"\x19\n\nGetRequest\x12\x0b\n\x03key\x18\x01 \x01(\t\"\x1c\n\x0bGetResponse\x12\r\n\x05value\x18\x01 \x01(\t\"(\n\nSetRequest\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"\x19\n\x0bSetResponse\x12\n\n\x02ok\x18\x01 \x01(\x08\x32T\n\x02KV\x12&\n\x03Get\x12\x0e.kv.GetRequest\x1a\x0f.kv.GetResponse\x12&\n\x03Set\x12\x0e.kv.SetRequest\x1a\x0f.kv.SetResponseb\x06proto3') ) -_sym_db.RegisterFileDescriptor(DESCRIPTOR) @@ -39,7 +38,7 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -70,7 +69,7 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -101,14 +100,14 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='value', full_name='kv.SetRequest.value', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -139,7 +138,7 @@ has_default_value=False, default_value=False, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -160,6 +159,7 @@ DESCRIPTOR.message_types_by_name['GetResponse'] = _GETRESPONSE DESCRIPTOR.message_types_by_name['SetRequest'] = _SETREQUEST DESCRIPTOR.message_types_by_name['SetResponse'] = _SETRESPONSE +_sym_db.RegisterFileDescriptor(DESCRIPTOR) GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), dict( DESCRIPTOR = _GETREQUEST, @@ -190,110 +190,37 @@ _sym_db.RegisterMessage(SetResponse) -import grpc -from grpc.beta import implementations as beta_implementations -from grpc.beta import interfaces as beta_interfaces -from grpc.framework.common import cardinality -from grpc.framework.interfaces.face import utilities as face_utilities - - -class KVStub(object): - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.Get = channel.unary_unary( - '/kv.KV/Get', - request_serializer=GetRequest.SerializeToString, - response_deserializer=GetResponse.FromString, - ) - self.Set = channel.unary_unary( - '/kv.KV/Set', - request_serializer=SetRequest.SerializeToString, - response_deserializer=SetResponse.FromString, - ) - - -class KVServicer(object): - - def Get(self, request, context): - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Set(self, request, context): - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - -def add_KVServicer_to_server(servicer, server): - rpc_method_handlers = { - 'Get': grpc.unary_unary_rpc_method_handler( - servicer.Get, - request_deserializer=GetRequest.FromString, - response_serializer=GetResponse.SerializeToString, - ), - 'Set': grpc.unary_unary_rpc_method_handler( - servicer.Set, - request_deserializer=SetRequest.FromString, - response_serializer=SetResponse.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'kv.KV', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - - -class BetaKVServicer(object): - def Get(self, request, context): - context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) - def Set(self, request, context): - context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) - - -class BetaKVStub(object): - def Get(self, request, timeout, metadata=None, with_call=False, protocol_options=None): - raise NotImplementedError() - Get.future = None - def Set(self, request, timeout, metadata=None, with_call=False, protocol_options=None): - raise NotImplementedError() - Set.future = None - - -def beta_create_KV_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None): - request_deserializers = { - ('kv.KV', 'Get'): GetRequest.FromString, - ('kv.KV', 'Set'): SetRequest.FromString, - } - response_serializers = { - ('kv.KV', 'Get'): GetResponse.SerializeToString, - ('kv.KV', 'Set'): SetResponse.SerializeToString, - } - method_implementations = { - ('kv.KV', 'Get'): face_utilities.unary_unary_inline(servicer.Get), - ('kv.KV', 'Set'): face_utilities.unary_unary_inline(servicer.Set), - } - server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout) - return beta_implementations.server(method_implementations, options=server_options) +_KV = _descriptor.ServiceDescriptor( + name='KV', + full_name='kv.KV', + file=DESCRIPTOR, + index=0, + options=None, + serialized_start=142, + serialized_end=226, + methods=[ + _descriptor.MethodDescriptor( + name='Get', + full_name='kv.KV.Get', + index=0, + containing_service=None, + input_type=_GETREQUEST, + output_type=_GETRESPONSE, + options=None, + ), + _descriptor.MethodDescriptor( + name='Set', + full_name='kv.KV.Set', + index=1, + containing_service=None, + input_type=_SETREQUEST, + output_type=_SETRESPONSE, + options=None, + ), +]) +_sym_db.RegisterServiceDescriptor(_KV) + +DESCRIPTOR.services_by_name['KV'] = _KV -def beta_create_KV_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None): - request_serializers = { - ('kv.KV', 'Get'): GetRequest.SerializeToString, - ('kv.KV', 'Set'): SetRequest.SerializeToString, - } - response_deserializers = { - ('kv.KV', 'Get'): GetResponse.FromString, - ('kv.KV', 'Set'): SetResponse.FromString, - } - cardinalities = { - 'Get': cardinality.Cardinality.UNARY_UNARY, - 'Set': cardinality.Cardinality.UNARY_UNARY, - } - stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size) - return beta_implementations.dynamic_stub(channel, 'kv.KV', cardinalities, options=stub_options) # @@protoc_insertion_point(module_scope) diff --git a/examples/grpc-bridge/service/envoy-gen/kv_pb2.py b/examples/grpc-bridge/service/envoy-gen/kv_pb2.py index c644220be100..3441998f76ac 100644 --- a/examples/grpc-bridge/service/envoy-gen/kv_pb2.py +++ b/examples/grpc-bridge/service/envoy-gen/kv_pb2.py @@ -21,7 +21,6 @@ syntax='proto3', serialized_pb=_b('\n\x08kv.proto\x12\x02kv\"\x19\n\nGetRequest\x12\x0b\n\x03key\x18\x01 \x01(\t\"\x1c\n\x0bGetResponse\x12\r\n\x05value\x18\x01 \x01(\t\"(\n\nSetRequest\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"\x19\n\x0bSetResponse\x12\n\n\x02ok\x18\x01 \x01(\x08\x32T\n\x02KV\x12&\n\x03Get\x12\x0e.kv.GetRequest\x1a\x0f.kv.GetResponse\x12&\n\x03Set\x12\x0e.kv.SetRequest\x1a\x0f.kv.SetResponseb\x06proto3') ) -_sym_db.RegisterFileDescriptor(DESCRIPTOR) @@ -39,7 +38,7 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -70,7 +69,7 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -101,14 +100,14 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='value', full_name='kv.SetRequest.value', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -139,7 +138,7 @@ has_default_value=False, default_value=False, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -160,6 +159,7 @@ DESCRIPTOR.message_types_by_name['GetResponse'] = _GETRESPONSE DESCRIPTOR.message_types_by_name['SetRequest'] = _SETREQUEST DESCRIPTOR.message_types_by_name['SetResponse'] = _SETRESPONSE +_sym_db.RegisterFileDescriptor(DESCRIPTOR) GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), dict( DESCRIPTOR = _GETREQUEST, @@ -190,110 +190,37 @@ _sym_db.RegisterMessage(SetResponse) -import grpc -from grpc.beta import implementations as beta_implementations -from grpc.beta import interfaces as beta_interfaces -from grpc.framework.common import cardinality -from grpc.framework.interfaces.face import utilities as face_utilities - - -class KVStub(object): - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.Get = channel.unary_unary( - '/kv.KV/Get', - request_serializer=GetRequest.SerializeToString, - response_deserializer=GetResponse.FromString, - ) - self.Set = channel.unary_unary( - '/kv.KV/Set', - request_serializer=SetRequest.SerializeToString, - response_deserializer=SetResponse.FromString, - ) - - -class KVServicer(object): - - def Get(self, request, context): - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Set(self, request, context): - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - -def add_KVServicer_to_server(servicer, server): - rpc_method_handlers = { - 'Get': grpc.unary_unary_rpc_method_handler( - servicer.Get, - request_deserializer=GetRequest.FromString, - response_serializer=GetResponse.SerializeToString, - ), - 'Set': grpc.unary_unary_rpc_method_handler( - servicer.Set, - request_deserializer=SetRequest.FromString, - response_serializer=SetResponse.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'kv.KV', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - - -class BetaKVServicer(object): - def Get(self, request, context): - context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) - def Set(self, request, context): - context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) - - -class BetaKVStub(object): - def Get(self, request, timeout, metadata=None, with_call=False, protocol_options=None): - raise NotImplementedError() - Get.future = None - def Set(self, request, timeout, metadata=None, with_call=False, protocol_options=None): - raise NotImplementedError() - Set.future = None - - -def beta_create_KV_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None): - request_deserializers = { - ('kv.KV', 'Get'): GetRequest.FromString, - ('kv.KV', 'Set'): SetRequest.FromString, - } - response_serializers = { - ('kv.KV', 'Get'): GetResponse.SerializeToString, - ('kv.KV', 'Set'): SetResponse.SerializeToString, - } - method_implementations = { - ('kv.KV', 'Get'): face_utilities.unary_unary_inline(servicer.Get), - ('kv.KV', 'Set'): face_utilities.unary_unary_inline(servicer.Set), - } - server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout) - return beta_implementations.server(method_implementations, options=server_options) +_KV = _descriptor.ServiceDescriptor( + name='KV', + full_name='kv.KV', + file=DESCRIPTOR, + index=0, + options=None, + serialized_start=142, + serialized_end=226, + methods=[ + _descriptor.MethodDescriptor( + name='Get', + full_name='kv.KV.Get', + index=0, + containing_service=None, + input_type=_GETREQUEST, + output_type=_GETRESPONSE, + options=None, + ), + _descriptor.MethodDescriptor( + name='Set', + full_name='kv.KV.Set', + index=1, + containing_service=None, + input_type=_SETREQUEST, + output_type=_SETRESPONSE, + options=None, + ), +]) +_sym_db.RegisterServiceDescriptor(_KV) + +DESCRIPTOR.services_by_name['KV'] = _KV -def beta_create_KV_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None): - request_serializers = { - ('kv.KV', 'Get'): GetRequest.SerializeToString, - ('kv.KV', 'Set'): SetRequest.SerializeToString, - } - response_deserializers = { - ('kv.KV', 'Get'): GetResponse.FromString, - ('kv.KV', 'Set'): SetResponse.FromString, - } - cardinalities = { - 'Get': cardinality.Cardinality.UNARY_UNARY, - 'Set': cardinality.Cardinality.UNARY_UNARY, - } - stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size) - return beta_implementations.dynamic_stub(channel, 'kv.KV', cardinalities, options=stub_options) # @@protoc_insertion_point(module_scope) diff --git a/examples/grpc-bridge/service/gen/kv.pb.go b/examples/grpc-bridge/service/gen/kv.pb.go index 18ef2e92cc46..5ff0074cbd68 100644 --- a/examples/grpc-bridge/service/gen/kv.pb.go +++ b/examples/grpc-bridge/service/gen/kv.pb.go @@ -1,6 +1,5 @@ -// Code generated by protoc-gen-go. +// Code generated by protoc-gen-go. DO NOT EDIT. // source: kv.proto -// DO NOT EDIT! /* Package kv is a generated protocol buffer package. @@ -224,7 +223,7 @@ func init() { proto.RegisterFile("kv.proto", fileDescriptor0) } var fileDescriptor0 = []byte{ // 167 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xe2, 0xe2, 0xc8, 0x2e, 0xd3, 0x2b, + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0xc8, 0x2e, 0xd3, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0xca, 0x2e, 0x53, 0x92, 0xe3, 0xe2, 0x72, 0x4f, 0x2d, 0x09, 0x4a, 0x2d, 0x2c, 0x4d, 0x2d, 0x2e, 0x11, 0x12, 0xe0, 0x62, 0xce, 0x4e, 0xad, 0x94, 0x60, 0x54, 0x60, 0xd4, 0xe0, 0x0c, 0x02, 0x31, 0x95, 0x94, 0xb9, 0xb8, 0xc1, 0xf2, 0xc5, 0x05, 0xf9, 0x79, diff --git a/examples/grpc-bridge/service/gen/kv_pb2.py b/examples/grpc-bridge/service/gen/kv_pb2.py index c644220be100..3441998f76ac 100644 --- a/examples/grpc-bridge/service/gen/kv_pb2.py +++ b/examples/grpc-bridge/service/gen/kv_pb2.py @@ -21,7 +21,6 @@ syntax='proto3', serialized_pb=_b('\n\x08kv.proto\x12\x02kv\"\x19\n\nGetRequest\x12\x0b\n\x03key\x18\x01 \x01(\t\"\x1c\n\x0bGetResponse\x12\r\n\x05value\x18\x01 \x01(\t\"(\n\nSetRequest\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"\x19\n\x0bSetResponse\x12\n\n\x02ok\x18\x01 \x01(\x08\x32T\n\x02KV\x12&\n\x03Get\x12\x0e.kv.GetRequest\x1a\x0f.kv.GetResponse\x12&\n\x03Set\x12\x0e.kv.SetRequest\x1a\x0f.kv.SetResponseb\x06proto3') ) -_sym_db.RegisterFileDescriptor(DESCRIPTOR) @@ -39,7 +38,7 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -70,7 +69,7 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -101,14 +100,14 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='value', full_name='kv.SetRequest.value', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -139,7 +138,7 @@ has_default_value=False, default_value=False, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None), + options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -160,6 +159,7 @@ DESCRIPTOR.message_types_by_name['GetResponse'] = _GETRESPONSE DESCRIPTOR.message_types_by_name['SetRequest'] = _SETREQUEST DESCRIPTOR.message_types_by_name['SetResponse'] = _SETRESPONSE +_sym_db.RegisterFileDescriptor(DESCRIPTOR) GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), dict( DESCRIPTOR = _GETREQUEST, @@ -190,110 +190,37 @@ _sym_db.RegisterMessage(SetResponse) -import grpc -from grpc.beta import implementations as beta_implementations -from grpc.beta import interfaces as beta_interfaces -from grpc.framework.common import cardinality -from grpc.framework.interfaces.face import utilities as face_utilities - - -class KVStub(object): - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.Get = channel.unary_unary( - '/kv.KV/Get', - request_serializer=GetRequest.SerializeToString, - response_deserializer=GetResponse.FromString, - ) - self.Set = channel.unary_unary( - '/kv.KV/Set', - request_serializer=SetRequest.SerializeToString, - response_deserializer=SetResponse.FromString, - ) - - -class KVServicer(object): - - def Get(self, request, context): - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Set(self, request, context): - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - -def add_KVServicer_to_server(servicer, server): - rpc_method_handlers = { - 'Get': grpc.unary_unary_rpc_method_handler( - servicer.Get, - request_deserializer=GetRequest.FromString, - response_serializer=GetResponse.SerializeToString, - ), - 'Set': grpc.unary_unary_rpc_method_handler( - servicer.Set, - request_deserializer=SetRequest.FromString, - response_serializer=SetResponse.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'kv.KV', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - - -class BetaKVServicer(object): - def Get(self, request, context): - context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) - def Set(self, request, context): - context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) - - -class BetaKVStub(object): - def Get(self, request, timeout, metadata=None, with_call=False, protocol_options=None): - raise NotImplementedError() - Get.future = None - def Set(self, request, timeout, metadata=None, with_call=False, protocol_options=None): - raise NotImplementedError() - Set.future = None - - -def beta_create_KV_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None): - request_deserializers = { - ('kv.KV', 'Get'): GetRequest.FromString, - ('kv.KV', 'Set'): SetRequest.FromString, - } - response_serializers = { - ('kv.KV', 'Get'): GetResponse.SerializeToString, - ('kv.KV', 'Set'): SetResponse.SerializeToString, - } - method_implementations = { - ('kv.KV', 'Get'): face_utilities.unary_unary_inline(servicer.Get), - ('kv.KV', 'Set'): face_utilities.unary_unary_inline(servicer.Set), - } - server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout) - return beta_implementations.server(method_implementations, options=server_options) +_KV = _descriptor.ServiceDescriptor( + name='KV', + full_name='kv.KV', + file=DESCRIPTOR, + index=0, + options=None, + serialized_start=142, + serialized_end=226, + methods=[ + _descriptor.MethodDescriptor( + name='Get', + full_name='kv.KV.Get', + index=0, + containing_service=None, + input_type=_GETREQUEST, + output_type=_GETRESPONSE, + options=None, + ), + _descriptor.MethodDescriptor( + name='Set', + full_name='kv.KV.Set', + index=1, + containing_service=None, + input_type=_SETREQUEST, + output_type=_SETRESPONSE, + options=None, + ), +]) +_sym_db.RegisterServiceDescriptor(_KV) + +DESCRIPTOR.services_by_name['KV'] = _KV -def beta_create_KV_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None): - request_serializers = { - ('kv.KV', 'Get'): GetRequest.SerializeToString, - ('kv.KV', 'Set'): SetRequest.SerializeToString, - } - response_deserializers = { - ('kv.KV', 'Get'): GetResponse.FromString, - ('kv.KV', 'Set'): SetResponse.FromString, - } - cardinalities = { - 'Get': cardinality.Cardinality.UNARY_UNARY, - 'Set': cardinality.Cardinality.UNARY_UNARY, - } - stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size) - return beta_implementations.dynamic_stub(channel, 'kv.KV', cardinalities, options=stub_options) # @@protoc_insertion_point(module_scope) diff --git a/examples/grpc-bridge/service/gen/kv_pb2_grpc.py b/examples/grpc-bridge/service/gen/kv_pb2_grpc.py new file mode 100644 index 000000000000..927eaf541856 --- /dev/null +++ b/examples/grpc-bridge/service/gen/kv_pb2_grpc.py @@ -0,0 +1,63 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +import grpc + +import kv_pb2 as kv__pb2 + + +class KVStub(object): + # missing associated documentation comment in .proto file + pass + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.Get = channel.unary_unary( + '/kv.KV/Get', + request_serializer=kv__pb2.GetRequest.SerializeToString, + response_deserializer=kv__pb2.GetResponse.FromString, + ) + self.Set = channel.unary_unary( + '/kv.KV/Set', + request_serializer=kv__pb2.SetRequest.SerializeToString, + response_deserializer=kv__pb2.SetResponse.FromString, + ) + + +class KVServicer(object): + # missing associated documentation comment in .proto file + pass + + def Get(self, request, context): + # missing associated documentation comment in .proto file + pass + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def Set(self, request, context): + # missing associated documentation comment in .proto file + pass + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + +def add_KVServicer_to_server(servicer, server): + rpc_method_handlers = { + 'Get': grpc.unary_unary_rpc_method_handler( + servicer.Get, + request_deserializer=kv__pb2.GetRequest.FromString, + response_serializer=kv__pb2.GetResponse.SerializeToString, + ), + 'Set': grpc.unary_unary_rpc_method_handler( + servicer.Set, + request_deserializer=kv__pb2.SetRequest.FromString, + response_serializer=kv__pb2.SetResponse.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'kv.KV', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,))