1# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 2"""Client and server classes corresponding to protobuf-defined services.""" 3import grpc 4 5import route_guide_pb2 as route__guide__pb2 6 7 8class RouteGuideStub(object): 9 """Interface exported by the server. 10 """ 11 12 def __init__(self, channel): 13 """Constructor. 14 15 Args: 16 channel: A grpc.Channel. 17 """ 18 self.GetFeature = channel.unary_unary( 19 '/routeguide.RouteGuide/GetFeature', 20 request_serializer=route__guide__pb2.Point.SerializeToString, 21 response_deserializer=route__guide__pb2.Feature.FromString, 22 ) 23 self.ListFeatures = channel.unary_stream( 24 '/routeguide.RouteGuide/ListFeatures', 25 request_serializer=route__guide__pb2.Rectangle.SerializeToString, 26 response_deserializer=route__guide__pb2.Feature.FromString, 27 ) 28 self.RecordRoute = channel.stream_unary( 29 '/routeguide.RouteGuide/RecordRoute', 30 request_serializer=route__guide__pb2.Point.SerializeToString, 31 response_deserializer=route__guide__pb2.RouteSummary.FromString, 32 ) 33 self.RouteChat = channel.stream_stream( 34 '/routeguide.RouteGuide/RouteChat', 35 request_serializer=route__guide__pb2.RouteNote.SerializeToString, 36 response_deserializer=route__guide__pb2.RouteNote.FromString, 37 ) 38 39 40class RouteGuideServicer(object): 41 """Interface exported by the server. 42 """ 43 44 def GetFeature(self, request, context): 45 """A simple RPC. 46 47 Obtains the feature at a given position. 48 49 A feature with an empty name is returned if there's no feature at the given 50 position. 51 """ 52 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 53 context.set_details('Method not implemented!') 54 raise NotImplementedError('Method not implemented!') 55 56 def ListFeatures(self, request, context): 57 """A server-to-client streaming RPC. 58 59 Obtains the Features available within the given Rectangle. Results are 60 streamed rather than returned at once (e.g. in a response message with a 61 repeated field), as the rectangle may cover a large area and contain a 62 huge number of features. 63 """ 64 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 65 context.set_details('Method not implemented!') 66 raise NotImplementedError('Method not implemented!') 67 68 def RecordRoute(self, request_iterator, context): 69 """A client-to-server streaming RPC. 70 71 Accepts a stream of Points on a route being traversed, returning a 72 RouteSummary when traversal is completed. 73 """ 74 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 75 context.set_details('Method not implemented!') 76 raise NotImplementedError('Method not implemented!') 77 78 def RouteChat(self, request_iterator, context): 79 """A Bidirectional streaming RPC. 80 81 Accepts a stream of RouteNotes sent while a route is being traversed, 82 while receiving other RouteNotes (e.g. from other users). 83 """ 84 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 85 context.set_details('Method not implemented!') 86 raise NotImplementedError('Method not implemented!') 87 88 89def add_RouteGuideServicer_to_server(servicer, server): 90 rpc_method_handlers = { 91 'GetFeature': grpc.unary_unary_rpc_method_handler( 92 servicer.GetFeature, 93 request_deserializer=route__guide__pb2.Point.FromString, 94 response_serializer=route__guide__pb2.Feature.SerializeToString, 95 ), 96 'ListFeatures': grpc.unary_stream_rpc_method_handler( 97 servicer.ListFeatures, 98 request_deserializer=route__guide__pb2.Rectangle.FromString, 99 response_serializer=route__guide__pb2.Feature.SerializeToString, 100 ), 101 'RecordRoute': grpc.stream_unary_rpc_method_handler( 102 servicer.RecordRoute, 103 request_deserializer=route__guide__pb2.Point.FromString, 104 response_serializer=route__guide__pb2.RouteSummary.SerializeToString, 105 ), 106 'RouteChat': grpc.stream_stream_rpc_method_handler( 107 servicer.RouteChat, 108 request_deserializer=route__guide__pb2.RouteNote.FromString, 109 response_serializer=route__guide__pb2.RouteNote.SerializeToString, 110 ), 111 } 112 generic_handler = grpc.method_handlers_generic_handler( 113 'routeguide.RouteGuide', rpc_method_handlers) 114 server.add_generic_rpc_handlers((generic_handler,)) 115 116 117 # This class is part of an EXPERIMENTAL API. 118class RouteGuide(object): 119 """Interface exported by the server. 120 """ 121 122 @staticmethod 123 def GetFeature(request, 124 target, 125 options=(), 126 channel_credentials=None, 127 call_credentials=None, 128 insecure=False, 129 compression=None, 130 wait_for_ready=None, 131 timeout=None, 132 metadata=None): 133 return grpc.experimental.unary_unary(request, target, '/routeguide.RouteGuide/GetFeature', 134 route__guide__pb2.Point.SerializeToString, 135 route__guide__pb2.Feature.FromString, 136 options, channel_credentials, 137 insecure, call_credentials, compression, wait_for_ready, timeout, metadata) 138 139 @staticmethod 140 def ListFeatures(request, 141 target, 142 options=(), 143 channel_credentials=None, 144 call_credentials=None, 145 insecure=False, 146 compression=None, 147 wait_for_ready=None, 148 timeout=None, 149 metadata=None): 150 return grpc.experimental.unary_stream(request, target, '/routeguide.RouteGuide/ListFeatures', 151 route__guide__pb2.Rectangle.SerializeToString, 152 route__guide__pb2.Feature.FromString, 153 options, channel_credentials, 154 insecure, call_credentials, compression, wait_for_ready, timeout, metadata) 155 156 @staticmethod 157 def RecordRoute(request_iterator, 158 target, 159 options=(), 160 channel_credentials=None, 161 call_credentials=None, 162 insecure=False, 163 compression=None, 164 wait_for_ready=None, 165 timeout=None, 166 metadata=None): 167 return grpc.experimental.stream_unary(request_iterator, target, '/routeguide.RouteGuide/RecordRoute', 168 route__guide__pb2.Point.SerializeToString, 169 route__guide__pb2.RouteSummary.FromString, 170 options, channel_credentials, 171 insecure, call_credentials, compression, wait_for_ready, timeout, metadata) 172 173 @staticmethod 174 def RouteChat(request_iterator, 175 target, 176 options=(), 177 channel_credentials=None, 178 call_credentials=None, 179 insecure=False, 180 compression=None, 181 wait_for_ready=None, 182 timeout=None, 183 metadata=None): 184 return grpc.experimental.stream_stream(request_iterator, target, '/routeguide.RouteGuide/RouteChat', 185 route__guide__pb2.RouteNote.SerializeToString, 186 route__guide__pb2.RouteNote.FromString, 187 options, channel_credentials, 188 insecure, call_credentials, compression, wait_for_ready, timeout, metadata) 189