MCPcopy Create free account

hub / github.com/grpc/grpc-java / functions

Functions22,628 in github.com/grpc/grpc-java

MethodonHeaders
(Metadata headers)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:935
MethodonHeaders
(Metadata headers)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:373
MethodonHeaders
(Metadata headers)
examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptor.java:188
MethodonHeaders
(Metadata headers)
examples/src/main/java/io/grpc/examples/header/HeaderClientInterceptor.java:51
MethodonHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/ClientCalls.java:556
MethodonHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/ClientCalls.java:613
MethodonHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/ClientCalls.java:765
MethodonHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/MetadataUtils.java:137
MethodonHeaders
(Metadata headers)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:515
MethodonHeaders
(Metadata headers)
xds/src/main/java/io/grpc/xds/GrpcXdsTransportFactory.java:213
MethodonHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:441
MethodonHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency,
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:962
MethodonHeadersRead
(int streamId, Http2Headers headers, boolean endStream)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:419
MethodonHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency,
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1078
MethodonInUse
(InternalSubchannel is)
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:142
MethodonInUse
(InternalSubchannel is)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1816
MethodonLoadReport
(MetricReport orcaLoadReport)
interop-testing/src/main/java/io/grpc/testing/integration/CustomBackendMetricsLoadBalancerProvider.java:89
MethodonLoadReport
(MetricReport callMetricReport)
interop-testing/src/main/java/io/grpc/testing/integration/CustomBackendMetricsLoadBalancerProvider.java:135
MethodonLoadReport
(MetricReport orcaLoadReport)
examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:89
MethodonLoadReport
(MetricReport orcaLoadReport)
examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:129
MethodonLoadReport
Copies ORCA metrics from {@link MetricReport} to {@link ClusterLocalityStats} such that they are included in the snapshot for the LRS report sent to t
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:536
MethodonLoadReport
(MetricReport report)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:374
MethodonMessage
(Integer msg)
core/src/test/java/io/grpc/internal/DelayedClientCallTest.java:238
MethodonMessage
(String message)
core/src/test/java/io/grpc/internal/ServerImplTest.java:1256
MethodonMessage
(Void message)
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:650
MethodonMessage
(final RespT message)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:510
MethodonMessage
(ReqT message)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingServerInterceptor.java:203
MethodonMessage
(RespT message)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptor.java:143
MethodonMessage
(Integer message)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:150
MethodonMessage
(RespT message)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:315
MethodonMessage
(ReqT message)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:368
MethodonMessage
(final HealthCheckResponse response)
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:421
MethodonMessage
(RespT message)
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:424
MethodonMessage
(Holder message)
api/src/test/java/io/grpc/ServerInterceptorsTest.java:328
MethodonMessage
(Object messageIn)
api/src/test/java/io/grpc/ContextsTest.java:60
MethodonMessage
()
api/src/test/java/io/grpc/ForwardingServerCallListenerTest.java:55
MethodonMessage
(RespT message)
api/src/main/java/io/grpc/ForwardingClientCallListener.java:31
MethodonMessage
(WRespT wMessage)
api/src/main/java/io/grpc/ClientInterceptors.java:114
MethodonMessage
(ReqT message)
api/src/main/java/io/grpc/Contexts.java:72
MethodonMessage
A request message has been received. For streaming calls, there may be zero or more request messages. @param message a received request message.
api/src/main/java/io/grpc/ServerCall.java:66
MethodonMessage
(ReqT message)
api/src/main/java/io/grpc/ForwardingServerCallListener.java:31
MethodonMessage
A response message has been received. May be called zero or more times depending on whether the call response is empty, a single message or a stream o
api/src/main/java/io/grpc/ClientCall.java:132
MethodonMessage
(WReqT message)
api/src/main/java/io/grpc/ServerInterceptors.java:321
MethodonMessage
(final ReqT message)
interop-testing/src/test/java/io/grpc/testing/integration/CascadingTest.java:292
MethodonMessage
(ReqT request)
interop-testing/src/test/java/io/grpc/testing/integration/OpenTelemetryContextPropagationTest.java:101
MethodonMessage
(final StreamingOutputCallResponse message)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:938
MethodonMessage
(RespT message)
examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptor.java:227
MethodonMessage
(ReqT message)
examples/src/main/java/io/grpc/examples/grpcproxy/GrpcProxy.java:104
MethodonMessage
(RespT message)
examples/src/main/java/io/grpc/examples/grpcproxy/GrpcProxy.java:148
MethodonMessage
(ReqT message)
binder/src/main/java/io/grpc/binder/internal/PendingAuthListener.java:79
MethodonMessage
(ByteBuf message)
benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java:284
MethodonMessage
(ByteBuf message)
benchmarks/src/main/java/io/grpc/benchmarks/driver/LoadServer.java:205
MethodonMessage
(ByteBuf message)
benchmarks/src/main/java/io/grpc/benchmarks/driver/LoadClient.java:514
MethodonMessage
(Void message)
util/src/test/java/io/grpc/util/UtilServerInterceptorsTest.java:83
MethodonMessage
(ReqT message)
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:62
MethodonMessage
(Integer message)
opentelemetry/src/test/java/io/grpc/opentelemetry/OpenTelemetryTracingModuleTest.java:694
MethodonMessage
(ReqT message)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:365
MethodonMessage
(Integer message)
stub/src/test/java/io/grpc/stub/ServerCallsTest.java:629
MethodonMessage
(RespT value)
stub/src/main/java/io/grpc/stub/BlockingClientCall.java:329
MethodonMessage
(RespT message)
stub/src/main/java/io/grpc/stub/ClientCalls.java:560
MethodonMessage
(RespT value)
stub/src/main/java/io/grpc/stub/ClientCalls.java:617
MethodonMessage
(T value)
stub/src/main/java/io/grpc/stub/ClientCalls.java:769
MethodonMessage
(ReqT request)
stub/src/main/java/io/grpc/stub/ServerCalls.java:153
MethodonMessage
(ReqT request)
stub/src/main/java/io/grpc/stub/ServerCalls.java:260
MethodonMessage
(T message)
xds/src/main/java/io/grpc/xds/GrpcXdsTransportFactory.java:216
MethodonMessage
(final OrcaLoadReport response)
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:459
MethodonNext
(SessionReq req)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/S2AProtocolNegotiatorFactoryTest.java:218
MethodonNext
(SessionReq req)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/S2AStubTest.java:269
MethodonNext
(SessionResp resp)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeS2AServerTest.java:98
MethodonNext
(SessionReq sessionReq)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:180
MethodonNext
(SessionReq req)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeS2AServer.java:42
MethodonNext
Places a {@code SessionResp} message in the {@code responses} queue, or an {@code IOException} if reading is complete. @param resp the {@code Session
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AStub.java:183
MethodonNext
(io.grpc.lookup.v1.RouteLookupResponse value)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:346
MethodonNext
(final LoadBalanceResponse response)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:661
MethodonNext
Mock writer onNext. Will respond based on the server status.
alts/src/test/java/io/grpc/alts/internal/AltsHandshakerStubTest.java:148
MethodonNext
Receive a handshaker response from the server.
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerStub.java:105
MethodonNext
(HealthCheckResponse value)
services/src/test/java/io/grpc/protobuf/services/HealthStatusManagerTest.java:317
MethodonNext
(ServerReflectionResponse value)
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceV1Test.java:633
MethodonNext
(ServerReflectionResponse value)
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java:633
MethodonNext
(ServerReflectionRequest request)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:163
MethodonNext
(StreamingOutputCallResponse value)
interop-testing/src/test/java/io/grpc/testing/integration/NettyFlowControlTest.java:204
MethodonNext
(StreamingInputCallRequest value)
interop-testing/src/test/java/io/grpc/testing/integration/MoreInProcessTest.java:90
MethodonNext
(Messages.SimpleResponse value)
interop-testing/src/test/java/io/grpc/testing/integration/CascadingTest.java:311
MethodonNext
(StreamingOutputCallResponse response)
interop-testing/src/test/java/io/grpc/testing/integration/ConcurrencyTest.java:87
MethodonNext
(SimpleResponse value)
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:284
MethodonNext
(StreamingInputCallRequest message)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:182
MethodonNext
(StreamingOutputCallResponse response)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:756
MethodonNext
(HandshakerReq value)
interop-testing/src/main/java/io/grpc/testing/integration/AltsHandshakerTestService.java:53
MethodonNext
(EmptyProtos.Empty response)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:400
MethodonNext
(StreamingOutputCallResponse value)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:987
MethodonNext
(RouteSummary summary)
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:284
MethodonNext
(RouteNote note)
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:372
MethodonNext
(Feature value)
examples/src/test/java/io/grpc/examples/routeguide/RouteGuideServerTest.java:142
MethodonNext
(Point value)
examples/src/test/java/io/grpc/examples/routeguide/RouteGuideClientTest.java:269
MethodonNext
(EchoRequest request)
examples/src/main/java/io/grpc/examples/multiplex/EchoService.java:62
MethodonNext
(EchoResponse response)
examples/src/main/java/io/grpc/examples/multiplex/SharingClient.java:100
MethodonNext
(HelloRequest request)
examples/src/main/java/io/grpc/examples/manualflowcontrol/ManualFlowControlServer.java:76
MethodonNext
(HelloReply value)
examples/src/main/java/io/grpc/examples/manualflowcontrol/ManualFlowControlClient.java:93
MethodonNext
(HelloReply value)
examples/src/main/java/io/grpc/examples/errorhandling/DetailErrorSample.java:173
MethodonNext
(HelloReply value)
examples/src/main/java/io/grpc/examples/errorhandling/ErrorHandlingClient.java:151
← previousnext →16,901–17,000 of 22,628, ranked by callers