Home
last modified time | relevance | path

Searched refs:invocation_metadata (Results 1 – 25 of 25) sorted by relevance

/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_server.py70 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.py27 def __init__(self, handler, invocation_metadata): argument
30 self._invocation_metadata = invocation_metadata
141 def invocation_metadata(self): member in Rpc
D_servicer_context.py44 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.py53 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.py101 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__.py498 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.py57 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.py23 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.py100 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.py28 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/
Devent.pyx.pxi29 Call call, CallDetails call_details, tuple invocation_metadata): argument
35 self.invocation_metadata = invocation_metadata
Dtag.pyx.pxi44 cdef tuple invocation_metadata = _metadata(&self.c_invocation_metadata)
48 self.call_details, invocation_metadata)
Devent.pxd.pxi30 cdef readonly tuple invocation_metadata
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_metadata_test.py91 invocation_metadata = servicer_context.invocation_metadata()
94 invocation_metadata))
95 user_agent = _user_agent(invocation_metadata)
D_metadata_code_details_test.py73 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.py87 servicer_context.invocation_metadata()
319 lambda x: ('secret', '42') in x.invocation_metadata,
D_invocation_defects_test.py84 servicer_context.invocation_metadata()
D_rpc_test.py91 servicer_context.invocation_metadata()
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/
Dmethods.py38 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/
Drequest_header_validator_interceptor.py36 self._value) in handler_call_details.invocation_metadata:
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_server_adaptations.py68 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.py243 def invocation_metadata(self): member in _Context
244 return self._rpc_event.invocation_metadata
570 rpc_event.invocation_metadata)
D__init__.py952 def invocation_metadata(self): member in ServicerContext
/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/
Dface.py255 def invocation_metadata(self): member in ServicerContext
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
Dcygrpc_test.py227 request_event.invocation_metadata))