| /third_party/flatbuffers/tests/FlatBuffers.Test.Swift/Tests/FlatBuffers.Test.SwiftTests/ |
| D | monster_test.grpc.swift | 31 var interceptors: MyGame_Example_MonsterStorageClientInterceptorFactoryProtocol? { get } variable
67 interceptors: self.interceptors?.makeStoreInterceptors() ?? []
80 interceptors: self.interceptors?.makeRetrieveInterceptors() ?? [],
91 interceptors: self.interceptors?.makeGetMaxHitPointInterceptors() ?? []
102 interceptors: self.interceptors?.makeGetMinMaxHitPointsInterceptors() ?? [],
126 public var interceptors: MyGame_Example_MonsterStorageClientInterceptorFactoryProtocol? in makeStoreInterceptors() variable
131 interceptors: MyGame_Example_MonsterStorageClientInterceptorFactoryProtocol? = nil in makeStoreInterceptors()
135 self.interceptors = interceptors in makeStoreInterceptors()
140 var interceptors: MyGame_Example_MonsterStorageServerInterceptorFactoryProtocol? { get } variable
158 interceptors: self.interceptors?.makeStoreInterceptors() ?? [], in Store()
[all …]
|
| /third_party/flatbuffers/grpc/examples/swift/Greeter/Sources/Model/ |
| D | greeter.grpc.swift | 31 var interceptors: models_GreeterClientInterceptorFactoryProtocol? { get } variable
58 interceptors: self.interceptors?.makeSayHelloInterceptors() ?? []
71 interceptors: self.interceptors?.makeSayManyHellosInterceptors() ?? [],
89 public var interceptors: models_GreeterClientInterceptorFactoryProtocol? in makeSayHelloInterceptors() variable
94 interceptors: models_GreeterClientInterceptorFactoryProtocol? = nil in makeSayHelloInterceptors()
98 self.interceptors = interceptors in makeSayHelloInterceptors()
103 var interceptors: models_GreeterServerInterceptorFactoryProtocol? { get } variable
119 interceptors: self.interceptors?.makeSayHelloInterceptors() ?? [], in SayHello()
127 interceptors: self.interceptors?.makeSayManyHellosInterceptors() ?? [], in SayHello()
|
| /third_party/grpc/src/php/lib/Grpc/ |
| D | Interceptor.php | 76 * @param Interceptor|Interceptor[] $interceptors interceptors to be added
80 public static function intercept($channel, $interceptors) argument
82 if (is_array($interceptors)) {
83 for ($i = count($interceptors) - 1; $i >= 0; $i--) {
84 $channel = new Internal\InterceptorChannel($channel, $interceptors[$i]);
87 $channel = new Internal\InterceptorChannel($channel, $interceptors);
|
| /third_party/grpc/src/python/grpcio/grpc/experimental/aio/ |
| D | _interceptor.py | 558 def __init__(self, interceptors: Sequence[UnaryUnaryClientInterceptor],
569 self._invoke(interceptors, method, timeout, metadata, credentials,
575 async def _invoke(self, interceptors: Sequence[UnaryUnaryClientInterceptor],
586 interceptors: Iterator[UnaryUnaryClientInterceptor],
590 interceptor = next(interceptors, None)
593 continuation = functools.partial(_run_interceptor, interceptors)
614 return await _run_interceptor(iter(interceptors), client_call_details,
630 def __init__(self, interceptors: Sequence[UnaryStreamClientInterceptor],
643 self._invoke(interceptors, method, timeout, metadata, credentials,
649 async def _invoke(self, interceptors: Sequence[UnaryUnaryClientInterceptor],
[all …]
|
| D | _server.py | 39 interceptors: Optional[Sequence[Any]],
44 if interceptors:
46 interceptor for interceptor in interceptors
54 self._loop, thread_pool, generic_handlers, interceptors,
174 interceptors: Optional[Sequence[Any]] = None,
204 () if interceptors is None else interceptors,
|
| D | _channel.py | 81 interceptors: Optional[Sequence[ClientInterceptor]],
89 self._interceptors = interceptors
237 interceptors: Optional[Sequence[ClientInterceptor]]):
254 if interceptors is not None:
255 for interceptor in interceptors:
429 interceptors: Optional[Sequence[ClientInterceptor]] = None):
445 compression, interceptors)
452 interceptors: Optional[Sequence[ClientInterceptor]] = None):
469 credentials._credentials, compression, interceptors)
|
| /third_party/grpc/src/python/grpcio/grpc/aio/ |
| D | _interceptor.py | 557 def __init__(self, interceptors: Sequence[UnaryUnaryClientInterceptor],
568 self._invoke(interceptors, method, timeout, metadata, credentials,
575 self, interceptors: Sequence[UnaryUnaryClientInterceptor],
585 interceptors: Iterator[UnaryUnaryClientInterceptor],
589 interceptor = next(interceptors, None)
592 continuation = functools.partial(_run_interceptor, interceptors)
613 return await _run_interceptor(iter(interceptors), client_call_details,
629 def __init__(self, interceptors: Sequence[UnaryStreamClientInterceptor],
642 self._invoke(interceptors, method, timeout, metadata, credentials,
649 self, interceptors: Sequence[UnaryUnaryClientInterceptor],
[all …]
|
| D | _server.py | 39 interceptors: Optional[Sequence[Any]],
44 if interceptors:
46 interceptor for interceptor in interceptors
54 self._loop, thread_pool, generic_handlers, interceptors,
177 interceptors: Optional[Sequence[Any]] = None,
207 () if interceptors is None else interceptors,
|
| D | _channel.py | 81 interceptors: Optional[Sequence[ClientInterceptor]],
89 self._interceptors = interceptors
241 interceptors: Optional[Sequence[ClientInterceptor]]):
258 if interceptors is not None:
259 for interceptor in interceptors:
433 interceptors: Optional[Sequence[ClientInterceptor]] = None):
449 compression, interceptors)
456 interceptors: Optional[Sequence[ClientInterceptor]] = None):
473 credentials._credentials, compression, interceptors)
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | client_unary_unary_interceptor_test.py | 49 aio.insecure_channel("", interceptors=[InvalidInterceptor()])
64 interceptors = [Interceptor() for i in range(2)]
67 interceptors=interceptors) as channel:
77 self.assertSequenceEqual(interceptors_executed, interceptors)
113 interceptors=[interceptor]) as channel:
143 interceptors=[interceptor]) as channel:
203 interceptors=[interceptor]) as channel:
247 interceptors=[interceptor, interceptor_response]) as channel:
290 interceptors=[Interceptor()
319 interceptors=[Interceptor()
[all …]
|
| D | client_unary_stream_interceptor_test.py | 83 interceptors=[interceptor])
124 interceptors=[interceptor])
150 interceptors=[interceptor])
172 interceptors=[interceptor])
203 interceptors = [interceptor_class(), interceptor_class()]
206 interceptors=interceptors)
236 UNREACHABLE_TARGET, interceptors=[interceptor_class()])
265 interceptors=[Interceptor()])
301 interceptors=[Interceptor()])
331 interceptors=[_UnaryStreamInterceptorWithResponseIterator()])
[all …]
|
| D | client_stream_unary_interceptor_test.py | 76 interceptors=[interceptor])
114 interceptors=[interceptor])
154 interceptors=[interceptor])
184 interceptors=[interceptor])
212 interceptors = [interceptor_class(), interceptor_class()]
214 interceptors=interceptors)
241 for interceptor in interceptors:
252 UNREACHABLE_TARGET, interceptors=[interceptor_class()])
284 UNREACHABLE_TARGET, interceptors=[interceptor_class()])
323 interceptors=[Interceptor()])
[all …]
|
| D | client_stream_stream_interceptor_test.py | 74 interceptors=[interceptor])
121 interceptors=[interceptor])
162 interceptors = [interceptor_class(), interceptor_class()]
164 interceptors=interceptors)
194 for interceptor in interceptors:
|
| D | server_interceptor_test.py | 123 *interceptors: aio.ServerInterceptor
129 server_target, server = await start_test_server(interceptors=interceptors)
143 interceptors=(InvalidInterceptor(),))
147 server_target, _ = await start_test_server(interceptors=(
171 interceptors=(_LoggingInterceptor('log1', record),))
191 server_target, _ = await start_test_server(interceptors=(
|
| D | _test_server.py | 129 interceptors=None): argument
131 interceptors=interceptors)
|
| /third_party/grpc/src/csharp/Grpc.Core/Interceptors/ |
| D | ServerServiceDefinitionExtensions.cs | 69 … Intercept(this ServerServiceDefinition serverServiceDefinition, params Interceptor[] interceptors) in Intercept() argument
72 GrpcPreconditions.CheckNotNull(interceptors, nameof(interceptors)); in Intercept()
74 foreach (var interceptor in interceptors.Reverse()) in Intercept()
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/Interceptors/ |
| D | CallInvokerExtensions.cs | 64 … public static CallInvoker Intercept(this CallInvoker invoker, params Interceptor[] interceptors) in Intercept() argument
67 GrpcPreconditions.CheckNotNull(interceptors, nameof(interceptors)); in Intercept()
69 foreach (var interceptor in interceptors.Reverse()) in Intercept()
|
| D | ChannelExtensions.cs | 62 … public static CallInvoker Intercept(this ChannelBase channel, params Interceptor[] interceptors) in Intercept() argument
64 return channel.CreateCallInvoker().Intercept(interceptors); in Intercept()
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 24 def __init__(self, interceptors): argument
25 self.interceptors = tuple(interceptors)
31 if index < len(self.interceptors):
32 interceptor = self.interceptors[index]
42 def service_pipeline(interceptors): argument
43 return _ServicePipeline(interceptors) if interceptors else None
550 def intercept_channel(channel, *interceptors): argument
551 for interceptor in reversed(list(interceptors)):
|
| D | __init__.py | 1989 def intercept_channel(channel, *interceptors): argument
2014 return _interceptor.intercept_channel(channel, *interceptors)
2019 interceptors=None, argument
2053 () if interceptors is None else interceptors,
|
| /third_party/grpc/doc/ |
| D | server_side_auth.md | 43 Auth interceptors are gRPC components that populate contents of the auth context based on gRPC's in…
44 gRPC comes with some basic "interceptors" already built-in.
47 …interceptors but you should keep in mind that as auth interceptors essentially decide which RPCs a…
49 #### Available auth interceptors
|
| /third_party/grpc/src/ruby/lib/grpc/generic/ |
| D | interceptor_registry.rb | 33 def initialize(interceptors = []) argument
35 interceptors.each do |i|
|
| D | interceptors.rb | 158 def initialize(interceptors = []) argument
159 @interceptors = interceptors.dup
|
| D | client_stub.rb | 101 interceptors: []) argument
108 @interceptors = InterceptorRegistry.new(interceptors)
|
| /third_party/flatbuffers/grpc/src/compiler/ |
| D | swift_generator.cc | 262 grpc::string interceptors = in GenerateServerExtensionBody() local
271 interceptors + in GenerateServerExtensionBody()
280 interceptors + in GenerateServerExtensionBody()
289 interceptors + in GenerateServerExtensionBody()
298 interceptors + in GenerateServerExtensionBody()
|