Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/grpc/grpc-java
/ functions
Functions
22,628 in github.com/grpc/grpc-java
⨍
Functions
22,628
◇
Types & classes
3,835
↓ 1 callers
Method
detectProxy
()
core/src/main/java/io/grpc/internal/DnsNameResolver.java:250
↓ 1 callers
Method
detectProxy
(InetSocketAddress targetAddr)
core/src/main/java/io/grpc/internal/ProxyDetectorImpl.java:182
↓ 1 callers
Method
determineFaultAbortStatus
(FaultAbort faultAbort, Metadata headers)
xds/src/main/java/io/grpc/xds/FaultFilter.java:348
↓ 1 callers
Method
determineFaultDelayNanos
(FaultDelay faultDelay, Metadata headers)
xds/src/main/java/io/grpc/xds/FaultFilter.java:320
↓ 1 callers
Method
determineHostname
()
istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:144
↓ 1 callers
Method
determineHostname
()
examples/example-hostname/src/main/java/io/grpc/examples/hostname/HostnameGreeter.java:51
↓ 1 callers
Method
determineHostname
()
examples/example-xds/src/main/java/io/grpc/examples/helloworldxds/HostnameGreeter.java:51
↓ 1 callers
Method
determineHostname
()
examples/example-debug/src/main/java/io/grpc/examples/debug/HostnameGreeter.java:64
↓ 1 callers
Method
directExecutor
{@inheritDoc}
alts/src/main/java/io/grpc/alts/AltsServerBuilder.java:85
↓ 1 callers
Method
disable
Turn this recorder into a no-op one.
services/src/main/java/io/grpc/services/CallMetricRecorder.java:283
↓ 1 callers
Method
disableAutoRequest
()
stub/src/main/java/io/grpc/stub/ServerCalls.java:439
↓ 1 callers
Method
disableAutoRequestWithInitial
(int request)
stub/src/main/java/io/grpc/stub/ClientCalls.java:502
↓ 1 callers
Method
disableRetry
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:525
↓ 1 callers
Method
disableRetry
Disables the retry and hedging subsystem provided by the gRPC library. This is designed for the case when users have their own retry implementation an
api/src/main/java/io/grpc/ManagedChannelBuilder.java:510
↓ 1 callers
Method
disallowIsError
()
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationFilter.java:111
↓ 1 callers
Method
dispatchChunk
Dispatches the current response chunk to the client. This is only called by the executor. At any time, a given dispatch task should only be registered
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:384
↓ 1 callers
Method
dnsToEdsUpdate
( StatusOr<List<EquivalentAddressGroup>> dnsData, String dnsHostName)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:393
↓ 1 callers
Method
doAttach
Implements {@link io.grpc.Context#attach}. <p>Caution: {@link Context#attach()} interprets a return value of {@code null} to mean the same thing as {
api/src/context/java/io/grpc/Context.java:1015
↓ 1 callers
Method
doGetHelper
(HttpServletResponse resp)
gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/NettyClientInteropServlet.java:91
↓ 1 callers
Method
doInitialUriValidation
(String uri)
core/src/main/java/io/grpc/internal/SpiffeUtil.java:92
↓ 1 callers
Method
doParse
(Args args, Message unpackedMessage)
xds/src/main/java/io/grpc/xds/client/XdsResourceType.java:203
↓ 1 callers
Method
doPost
Call this method inside {@link javax.servlet.http.HttpServlet#doPost(HttpServletRequest, HttpServletResponse)} to serve gRPC POST request. <p>Do not
servlet/src/main/java/io/grpc/servlet/ServletAdapter.java:120
↓ 1 callers
Method
doResolve
Main logic of name resolution.
core/src/main/java/io/grpc/internal/DnsNameResolver.java:264
↓ 1 callers
Method
doRpcs
(Channel channel, SimpleRequest request, long endTime)
benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java:138
↓ 1 callers
Method
doRun
()
okhttp/src/main/java/io/grpc/okhttp/AsyncSink.java:238
↓ 1 callers
Method
doStreamingCalls
(Channel channel, final SimpleRequest request, final long endTime
benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java:185
↓ 1 callers
Method
doUnaryCalls
(Channel channel, final SimpleRequest request, final long endTime)
benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java:149
↓ 1 callers
Method
domainToAscii
Performs IDN ToASCII encoding and canonicalize the result to lowercase. e.g. This converts {@code ☃.net} to {@code xn--n3h.net}, and {@code WwW.GoOgLe
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:324
↓ 1 callers
Method
doneAllocatingPromises
Signify that no more {@link #newPromise()} allocations will be made. The aggregation can not be successful until this method is called. @return {@cod
alts/src/main/java/io/grpc/alts/internal/ProtectedPromise.java:77
↓ 1 callers
Method
drain
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1890
↓ 1 callers
Method
drainGraceTime
Sets the grace time when draining connections with outdated configuration. When an xDS config update changes connection configuration, pre-existing co
xds/src/main/java/io/grpc/xds/XdsServerBuilder.java:91
↓ 1 callers
Method
drainMessages
Discards any messages available on the stream without reading them. Does not block.
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:628
↓ 1 callers
Method
drainNow
Executes enqueued work directly on the current thread. This can be used to trigger writes before performing additional reads. Must be called from the
netty/src/main/java/io/grpc/netty/WriteQueue.java:110
↓ 1 callers
Method
drainPendingCallbacks
()
core/src/main/java/io/grpc/internal/DelayedStream.java:525
↓ 1 callers
Method
drainPendingCallbacks
()
core/src/main/java/io/grpc/internal/DelayedClientCall.java:586
↓ 1 callers
Method
dropAllTransactions
Causes all future invocations of transact to be silently dropped. <p>Users are responsible for ensuring their calls "happen-before" the relevant call
binder/src/testFixtures/java/io/grpc/binder/internal/OneWayBinderProxies.java:123
↓ 1 callers
Method
droppedRequestsListBuilder
()
xds/src/main/java/io/grpc/xds/client/Stats.java:67
↓ 1 callers
Method
dropsPerMillion
()
xds/src/main/java/io/grpc/xds/Endpoints.java:96
↓ 1 callers
Method
durationIsValid
Returns true if the given number of seconds and nanos is a valid {@code Duration}. The {@code seconds} value must be in the range [-315,576,000,000, +
core/src/main/java/io/grpc/internal/JsonUtil.java:400
↓ 1 callers
Method
eagAttributes
Sets the EAG attributes available to protocol negotiators.
netty/src/main/java/io/grpc/netty/InternalNettyServerBuilder.java:65
↓ 1 callers
Method
eagToWeight
(EquivalentAddressGroup eag, Random random)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:248
↓ 1 callers
Method
echoCallMetricsFromPayload
(TestOrcaReport report)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:140
↓ 1 callers
Method
echoFuture
Say hello to the server, but using future API.
examples/src/main/java/io/grpc/examples/cancellation/CancellationClient.java:127
↓ 1 callers
Method
echoMetricsFromPayload
(TestOrcaReport report)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:152
↓ 1 callers
Method
echoRequestHeadersInterceptor
Echo a request header from a client into response headers and trailers. Useful for testing end-to-end metadata propagation.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:515
↓ 1 callers
Method
echoRequestMetadataInHeaders
Echoes request headers with the specified key from a client into response headers only.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:546
↓ 1 callers
Method
echoRequestMetadataInTrailers
Echoes request headers with the specified key from a client into response trailers only.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:571
↓ 1 callers
Method
edsClustersWithRingHashEndpointLbPolicy
()
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:276
↓ 1 callers
Method
edsUpdateToResult
( String clusterName, CdsUpdate discovery, Object lbConfig, StatusOr<EdsUpdate
xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:293
↓ 1 callers
Method
ejectOutliers
Eject any outlier addresses.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:770
↓ 1 callers
Method
emptyStream
()
servlet/src/tomcatTest/java/io/grpc/servlet/TomcatInteropTest.java:131
↓ 1 callers
Method
enableCheckAuthority
(OkHttpChannelBuilder builder)
okhttp/src/main/java/io/grpc/okhttp/InternalOkHttpChannelBuilder.java:36
↓ 1 callers
Method
enableCheckAuthority
(NettyChannelBuilder builder)
netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java:39
↓ 1 callers
Method
enableEviction
()
rls/src/test/java/io/grpc/rls/LinkedHashLruCacheTest.java:354
↓ 1 callers
Method
enableKeepAlive
Enable keepalive with custom delay and timeout.
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:429
↓ 1 callers
Method
enablePluginForChannel
Limited ability to disable the plugin based on the target. This only has an effect for per-call metrics. <p>Ideally this method wouldn't exist and it
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryPlugin.java:36
↓ 1 callers
Method
encrypt
(ByteBuffer ciphertext, ByteBuffer plaintext, byte[] nonce)
alts/src/main/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypter.java:57
↓ 1 callers
Method
end
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:252
↓ 1 callers
Method
endpointMetadata
()
xds/src/main/java/io/grpc/xds/Endpoints.java:70
↓ 1 callers
Method
enqueue
(Runnable r)
core/src/main/java/io/grpc/internal/SerializeReentrantCallsDirectExecutor.java:75
↓ 1 callers
Method
enqueueBuffer
(ReadableBuffer buffer)
core/src/main/java/io/grpc/internal/CompositeReadableBuffer.java:64
↓ 1 callers
Method
enqueueData
(Buffer buffer, int size, boolean endOfStream)
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:335
↓ 1 callers
Method
enqueuePendingData
(PendingData data)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:347
↓ 1 callers
Method
enqueueTransactionData
(int index, TransactionData data)
binder/src/main/java/io/grpc/binder/internal/Inbound.java:432
↓ 1 callers
Method
enterIdle
Invoking this method moves the channel into the IDLE state and triggers tear-down of the channel's name resolver and load balancer, while still allowi
api/src/main/java/io/grpc/ManagedChannel.java:144
↓ 1 callers
Method
epollChannelType
()
netty/src/main/java/io/grpc/netty/Utils.java:395
↓ 1 callers
Method
epollDomainSocketChannelType
()
netty/src/main/java/io/grpc/netty/Utils.java:406
↓ 1 callers
Method
epollEventLoopGroupConstructor
()
netty/src/main/java/io/grpc/netty/Utils.java:417
↓ 1 callers
Method
epollServerChannelType
()
netty/src/main/java/io/grpc/netty/Utils.java:430
↓ 1 callers
Method
equals
(Object o)
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3109
↓ 1 callers
Method
equals
(Object obj)
core/src/main/java/io/grpc/internal/DnsNameResolver.java:536
↓ 1 callers
Method
equals
(Object o)
core/src/main/java/io/grpc/internal/ManagedChannelServiceConfig.java:212
↓ 1 callers
Method
equals
(Object other)
core/src/main/java/io/grpc/internal/UriWrapper.java:123
↓ 1 callers
Method
equals
(final Object object)
api/src/context/java/io/grpc/Deadline.java:238
↓ 1 callers
Method
equals
(Object other)
api/src/main/java/io/grpc/ConnectivityStateInfo.java:71
↓ 1 callers
Method
equals
(Object o)
util/src/testFixtures/java/io/grpc/util/AbstractTestHelper.java:283
↓ 1 callers
Method
equals
(Object o)
util/src/main/java/io/grpc/util/RoundRobinLoadBalancer.java:166
↓ 1 callers
Method
equals
(Object o)
xds/src/main/java/io/grpc/xds/WrrLocalityLoadBalancer.java:144
↓ 1 callers
Method
equals
(Object o)
xds/src/main/java/io/grpc/xds/WeightedTargetLoadBalancerProvider.java:163
↓ 1 callers
Method
escapedAV
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/DistinguishedNameParser.java:191
↓ 1 callers
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:99
↓ 1 callers
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
netty/src/main/java/io/grpc/netty/WriteBufferingAndExceptionHandler.java:84
↓ 1 callers
Method
execute
(Runnable runnable)
benchmarks/src/jmh/java/io/grpc/benchmarks/ThreadlessExecutor.java:41
↓ 1 callers
Method
executeCloseObserverInContext
( final Listener<RespT> observer, final Status status)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1125
↓ 1 callers
Method
executeSoakTestInThread
( int soakIterationsPerThread, long startNs, int minTimeMsBetweenRpcs, int soakRequest
interop-testing/src/main/java/io/grpc/testing/integration/SoakClient.java:212
↓ 1 callers
Method
executor
(Executor executor)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:374
↓ 1 callers
Method
executor
{@inheritDoc}
alts/src/main/java/io/grpc/alts/AltsServerBuilder.java:106
↓ 1 callers
Method
exhaust
Reads {@code in} until end of stream.
core/src/main/java/io/grpc/internal/GrpcUtil.java:812
↓ 1 callers
Method
exists
Indicates whether the given feature exists (i.e. has a valid name).
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideUtil.java:35
↓ 1 callers
Method
expandHeadersAndValues
()
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:277
↓ 1 callers
Method
expandOnApplicationProtocols
( Collection<FilterChainMatch> set)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:363
↓ 1 callers
Method
expandOnPrefixRange
(FilterChainMatch filterChainMatch)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:344
↓ 1 callers
Method
expandOnServerNames
(Collection<FilterChainMatch> set)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:428
↓ 1 callers
Method
expandOnSourcePorts
(Collection<FilterChainMatch> set)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:407
↓ 1 callers
Method
expandOnSourcePrefixRange
( Collection<FilterChainMatch> set)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:385
↓ 1 callers
Method
expandPercentS
(String template, String replacement)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:256
↓ 1 callers
Method
expectFailedHandshake
( ChannelCredentials channelCreds, ServerCredentials serverCreds)
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:378
↓ 1 callers
Method
extractBareMethodName
Extract the method name out of a fully qualified method name. May return {@code null} if the input is malformed, but you cannot rely on it for the val
api/src/main/java/io/grpc/MethodDescriptor.java:416
↓ 1 callers
Method
extractCallCredentials
(List<Any> callCredentialPlugins)
xds/src/main/java/io/grpc/xds/GrpcServiceConfigParser.java:268
↓ 1 callers
Method
extractCert
(List<Map<String, ?>> keysNode, String trustDomainName)
core/src/main/java/io/grpc/internal/SpiffeUtil.java:228
← previous
next →
6,001–6,100 of 22,628, ranked by callers