/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
D | _server.py | 70 invocation_metadata, deadline): argument 73 rpc = _rpc.Rpc(handler, invocation_metadata) 87 invocation_metadata, request, deadline): argument 90 invocation_metadata, deadline) 93 invocation_metadata, request, deadline): argument 96 invocation_metadata, deadline) 99 invocation_metadata, deadline): argument 102 invocation_metadata, deadline) 105 invocation_metadata, deadline): argument 108 invocation_metadata, deadline) [all …]
|
D | _rpc.py | 27 def __init__(self, handler, invocation_metadata): argument 30 self._invocation_metadata = invocation_metadata 141 def invocation_metadata(self): member in Rpc
|
D | _servicer_context.py | 44 def invocation_metadata(self): member in ServicerContext 45 return self._rpc.invocation_metadata()
|
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
D | _beta_features_test.py | 53 self._invocation_metadata = context.invocation_metadata() 63 self._invocation_metadata = context.invocation_metadata() 75 self._invocation_metadata = context.invocation_metadata() 88 self._invocation_metadata = context.invocation_metadata() 197 invocation_metadata = [ 203 invocation_metadata) 214 invocation_metadata = [ 220 invocation_metadata) 237 invocation_metadata = [ 243 invocation_metadata) [all …]
|
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/ |
D | _common.py | 101 def invoke_rpc(self, method_full_rpc_name, invocation_metadata, requests, argument 146 invocation_metadata, request, deadline): argument 151 invocation_metadata, request, deadline): argument 156 invocation_metadata, deadline): argument 161 invocation_metadata, deadline): argument
|
D | __init__.py | 498 def invoke_unary_unary(self, method_descriptor, invocation_metadata, argument 516 def invoke_unary_stream(self, method_descriptor, invocation_metadata, argument 534 def invoke_stream_unary(self, method_descriptor, invocation_metadata, argument 551 def invoke_stream_stream(self, method_descriptor, invocation_metadata, argument
|
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/ |
D | _client_test.py | 57 invocation_metadata, request, rpc = ( 73 invocation_metadata, request, rpc = ( 88 invocation_metadata, rpc = self._real_time_channel.take_stream_unary( 112 invocation_metadata, rpc = self._fake_time_channel.take_stream_stream( 138 invocation_metadata, rpc = ( 171 invocation_metadata, request, rpc = ( 218 invocation_metadata, rpc = self._real_time_channel.take_stream_stream( 243 invocation_metadata, request, rpc = ( 259 invocation_metadata, rpc = self._real_time_channel.take_stream_stream( 285 invocation_metadata, rpc = self._real_time_channel.take_stream_unary(
|
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
D | _rpc_state.py | 23 def __init__(self, invocation_metadata, requests, requests_closed): argument 25 self._invocation_metadata = invocation_metadata 109 invocation_metadata = self._invocation_metadata 111 return invocation_metadata 120 invocation_metadata = self._invocation_metadata 122 return invocation_metadata, self._requests.pop(0)
|
D | _channel_rpc.py | 100 invocation_metadata, request = ( 102 return invocation_metadata, request, _UnaryUnary(rpc_state) 107 invocation_metadata, request = ( 109 return invocation_metadata, request, _UnaryStream(rpc_state)
|
D | _channel_state.py | 28 def invoke_rpc(self, method_full_rpc_name, invocation_metadata, requests, argument 30 rpc_state = _rpc_state.State(invocation_metadata, requests,
|
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
D | event.pyx.pxi | 29 Call call, CallDetails call_details, tuple invocation_metadata): argument 35 self.invocation_metadata = invocation_metadata
|
D | tag.pyx.pxi | 44 cdef tuple invocation_metadata = _metadata(&self.c_invocation_metadata) 48 self.call_details, invocation_metadata)
|
D | event.pxd.pxi | 30 cdef readonly tuple invocation_metadata
|
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
D | _metadata_test.py | 91 invocation_metadata = servicer_context.invocation_metadata() 94 invocation_metadata)) 95 user_agent = _user_agent(invocation_metadata)
|
D | _metadata_code_details_test.py | 73 self._received_client_metadata = context.invocation_metadata() 90 self._received_client_metadata = context.invocation_metadata() 107 self._received_client_metadata = context.invocation_metadata() 127 self._received_client_metadata = context.invocation_metadata()
|
D | _interceptor_test.py | 87 servicer_context.invocation_metadata() 319 lambda x: ('secret', '42') in x.invocation_metadata,
|
D | _invocation_defects_test.py | 84 servicer_context.invocation_metadata()
|
D | _rpc_test.py | 91 servicer_context.invocation_metadata()
|
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/ |
D | methods.py | 38 invocation_metadata = dict(servicer_context.invocation_metadata()) 39 if _INITIAL_METADATA_KEY in invocation_metadata: 41 invocation_metadata[_INITIAL_METADATA_KEY]) 43 if _TRAILING_METADATA_KEY in invocation_metadata: 45 invocation_metadata[_TRAILING_METADATA_KEY])
|
/external/grpc-grpc/examples/python/interceptors/headers/ |
D | request_header_validator_interceptor.py | 36 self._value) in handler_call_details.invocation_metadata:
|
/external/grpc-grpc/src/python/grpcio/grpc/beta/ |
D | _server_adaptations.py | 68 def invocation_metadata(self): member in _FaceServicerContext 69 return _metadata.beta(self._servicer_context.invocation_metadata())
|
/external/grpc-grpc/src/python/grpcio/grpc/ |
D | _server.py | 243 def invocation_metadata(self): member in _Context 244 return self._rpc_event.invocation_metadata 570 rpc_event.invocation_metadata)
|
D | __init__.py | 952 def invocation_metadata(self): member in ServicerContext
|
/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/ |
D | face.py | 255 def invocation_metadata(self): member in ServicerContext
|
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
D | cygrpc_test.py | 227 request_event.invocation_metadata))
|