Home
last modified time | relevance | path

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

12

/third_party/grpc/src/python/grpcio_testing/grpc_testing/_server/
D_server.py70 invocation_metadata, deadline): argument
73 rpc = _rpc.Rpc(handler, invocation_metadata)
86 invocation_metadata, request, deadline): argument
88 invocation_metadata, deadline)
91 invocation_metadata, request, deadline): argument
93 invocation_metadata, deadline)
96 invocation_metadata, deadline): argument
98 invocation_metadata, deadline)
101 invocation_metadata, deadline): argument
103 handler, 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()
/third_party/grpc/src/python/grpcio_tests/tests/interop/
Dservice.py31 invocation_metadata = dict(servicer_context.invocation_metadata())
32 if _INITIAL_METADATA_KEY in invocation_metadata:
34 invocation_metadata[_INITIAL_METADATA_KEY])
36 if _TRAILING_METADATA_KEY in invocation_metadata:
38 invocation_metadata[_TRAILING_METADATA_KEY])
/third_party/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()
200 invocation_metadata = [
206 invocation_metadata)
217 invocation_metadata = [
223 invocation_metadata)
240 invocation_metadata = [
246 invocation_metadata)
[all …]
/third_party/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
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
D_test_server.py31 invocation_metadata = dict(servicer_context.invocation_metadata())
32 if _INITIAL_METADATA_KEY in invocation_metadata:
34 invocation_metadata[_INITIAL_METADATA_KEY])
36 if _TRAILING_METADATA_KEY in invocation_metadata:
38 invocation_metadata[_TRAILING_METADATA_KEY])
Dmetadata_test.py104 context.invocation_metadata())
124 context.invocation_metadata())
133 context.invocation_metadata())
146 context.invocation_metadata())
169 handler_call_details.invocation_metadata)
/third_party/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(
/third_party/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
110 invocation_metadata = self._invocation_metadata
112 return invocation_metadata
121 invocation_metadata = self._invocation_metadata
123 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,
/third_party/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
/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_metadata_test.py92 invocation_metadata = servicer_context.invocation_metadata()
95 invocation_metadata))
96 user_agent = _user_agent(invocation_metadata)
D_metadata_code_details_test.py74 self._received_client_metadata = context.invocation_metadata()
91 self._received_client_metadata = context.invocation_metadata()
108 self._received_client_metadata = context.invocation_metadata()
128 self._received_client_metadata = context.invocation_metadata()
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/
Dserver.pxd.pxi17 cdef readonly tuple invocation_metadata
38 cdef tuple invocation_metadata(self) member in RPCState
Dserver.pyx.pxi36 def __cinit__(self, str method, tuple invocation_metadata): argument
38 self.invocation_metadata = invocation_metadata
66 cdef tuple invocation_metadata(self): member in RPCState
200 def invocation_metadata(self): member in _ServicerContext
201 return self._rpc_state.invocation_metadata()
284 def invocation_metadata(self): member in _SyncServicerContext
285 return self._context.invocation_metadata()
727 rpc_state.invocation_metadata(),
/third_party/grpc/examples/python/interceptors/headers/
Drequest_header_validator_interceptor.py36 self._value) in handler_call_details.invocation_metadata:
/third_party/grpc/examples/python/metadata/
Dmetadata_server.py29 for key, value in context.invocation_metadata():
/third_party/grpc/examples/python/auth/
Dcustomized_auth_server.py53 if expected_metadata in handler_call_details.invocation_metadata:
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_base_server.py204 def invocation_metadata(self) -> Optional[Metadata]: member in ServicerContext
/third_party/grpc/src/python/grpcio/grpc/aio/
D_base_server.py207 def invocation_metadata(self) -> Optional[Metadata]: member in ServicerContext

12