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
↓ 3 callers
Method
delegate
()
xds/src/main/java/io/grpc/xds/FaultFilter.java:223
↓ 3 callers
Method
deliver
()
api/src/context/java/io/grpc/Context.java:1055
↓ 3 callers
Method
deliver
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:200
↓ 3 callers
Method
deliverError
(final Status error)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2877
↓ 3 callers
Method
deliverSubchannelState
(final Subchannel subchannel, ConnectivityState state)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1190
↓ 3 callers
Method
denyAtDisable
Specifies whether to deny requests when the filter is disabled. Defaults to {@code false}. @see ExtAuthz#getDenyAtDisable()
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:88
↓ 3 callers
Method
deregister
Deregisters a provider. No-op if the provider is not in the registry. If there are more than one providers with the same policy name as the deregist
api/src/main/java/io/grpc/LoadBalancerRegistry.java:81
↓ 3 callers
Method
deregister
Deregisters a provider. No-op if the provider is not in the registry. @param provider the provider that was added to the register via
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:83
↓ 3 callers
Method
description
Returns a description of the test case.
interop-testing/src/main/java/io/grpc/testing/integration/TestCases.java:73
↓ 3 callers
Method
determineCustomLabel
(PickSubchannelArgs args)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:1083
↓ 3 callers
Method
dnsHostName
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:604
↓ 3 callers
Method
doExecute
Executes the given runnable. This prevents exceptions from propagating so that an exception thrown by one callback won't prevent subsequent callbacks
core/src/main/java/io/grpc/internal/Http2Ping.java:179
↓ 3 callers
Method
doRpc
(Channel channel)
alts/src/test/java/io/grpc/alts/HandshakerServiceChannelTest.java:115
↓ 3 callers
Method
doTest
Main testing method. Streams 2 MB of data from a server and records the final window and average bandwidth usage.
interop-testing/src/test/java/io/grpc/testing/integration/NettyFlowControlTest.java:128
↓ 3 callers
Method
drain
Executes all queued Runnables and if there were any wakes up any waiting threads.
stub/src/main/java/io/grpc/stub/ClientCalls.java:939
↓ 3 callers
Method
drainTo
(OutputStream output)
binder/src/main/java/io/grpc/binder/internal/BlockInputStream.java:128
↓ 3 callers
Method
eag
()
xds/src/main/java/io/grpc/xds/Endpoints.java:60
↓ 3 callers
Method
echo
(io.istio.test.Echo.EchoRequest request, io.grpc.stub.StreamObserver<io.istio.test.Echo.EchoResponse>
istio-interop-testing/src/generated/main/grpc/io/istio/test/EchoTestServiceGrpc.java:142
↓ 3 callers
Method
echoAsync
Say hello to the server, but using async API and cancelling.
examples/src/main/java/io/grpc/examples/cancellation/CancellationClient.java:146
↓ 3 callers
Method
eject
()
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:373
↓ 3 callers
Method
elapseBackoff
(long time, TimeUnit unit)
interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:217
↓ 3 callers
Method
emptyGrpcFrame
(int streamId, boolean endStream)
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:1403
↓ 3 callers
Method
emptyUnary
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:425
↓ 3 callers
Method
encode
(byte[] data, OutputStream out)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Huffman.java:93
↓ 3 callers
Method
endOfMessages
Closes the underlying framer. Should be called when the outgoing stream is gracefully closed (half closure on client; closure on server).
core/src/main/java/io/grpc/internal/AbstractStream.java:101
↓ 3 callers
Method
endSpanWithStatus
(Span span, io.grpc.Status status)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:483
↓ 3 callers
Method
endStream
()
netty/src/main/java/io/grpc/netty/SendGrpcFrameCommand.java:53
↓ 3 callers
Method
endpoints
()
xds/src/main/java/io/grpc/xds/Endpoints.java:38
↓ 3 callers
Method
enforcementPercentage
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:427
↓ 3 callers
Method
enforcementPercentage
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:452
↓ 3 callers
Method
enqueue
Adds the given chunks to the response stream and schedules the next chunk to be delivered if needed.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:345
↓ 3 callers
Method
enterIdle
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:303
↓ 3 callers
Method
enterTerminalState
enterTerminalState causes the health status manager to mark all services as not serving, and prevents future updates to services. This method is mean
services/src/main/java/io/grpc/services/HealthStatusManager.java:87
↓ 3 callers
Method
eqMetricInstrumentName
(String name)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:703
↓ 3 callers
Method
equals
(Object other)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:986
↓ 3 callers
Method
equals
Returns true if the two objects are both Keys, and their names match (case insensitive).
api/src/main/java/io/grpc/Metadata.java:797
↓ 3 callers
Method
equals
Returns true if the {@link Subchannel}, {@link Status}, and {@link ClientStreamTracer.Factory} all match.
api/src/main/java/io/grpc/LoadBalancer.java:802
↓ 3 callers
Method
equals
(Object o)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:110
↓ 3 callers
Method
equals
(Object o)
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:56
↓ 3 callers
Method
errorPrefix
()
xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:227
↓ 3 callers
Method
exact
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:209
↓ 3 callers
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:764
↓ 3 callers
Method
exceptionThrown
Cancels call and schedules onClose() notification. May only be called from the application thread.
core/src/main/java/io/grpc/internal/ClientCallImpl.java:589
↓ 3 callers
Method
exceptionThrown
Cancels call and schedules onClose() notification. May only be called from within a DelayedListener callback dispatch (either queued drain or passThro
core/src/main/java/io/grpc/internal/DelayedClientCall.java:467
↓ 3 callers
Method
execute
(Runnable command)
api/src/context/java/io/grpc/Context.java:1080
↓ 3 callers
Method
execute
Adds a task and run it in this synchronization context as soon as possible. The task may run inline. If there are tasks that are previously queued b
api/src/main/java/io/grpc/SynchronizationContext.java:125
↓ 3 callers
Method
executeNoThrow
(NoThrowReadOperation<T> op, int length, T dest, int value)
core/src/main/java/io/grpc/internal/CompositeReadableBuffer.java:287
↓ 3 callers
Method
expand
(int newCapacity)
api/src/main/java/io/grpc/Metadata.java:362
↓ 3 callers
Method
factory
(HandshakerSocketFactory factory)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:516
↓ 3 callers
Method
failed
Completes this operation exceptionally. Registered callbacks are invoked and provided the given throwable as the cause of failure. @param failureCaus
core/src/main/java/io/grpc/internal/Http2Ping.java:148
↓ 3 callers
Method
failureModeAllow
Changes the filter's behavior on errors from the authorization service. If {@code true}, the filter will accept the request even if the authorization
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:58
↓ 3 callers
Method
failureModeAllowHeaderAdd
Determines if the {@code x-envoy-auth-failure-mode-allowed} header is added to the request when {@link #failureModeAllow()} is true. @see ExtAuthz#ge
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:66
↓ 3 callers
Method
filterMetadata
(ImmutableMap<String, Struct> filterMetadata)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:776
↓ 3 callers
Method
finalizeAndDump
(CallMetricRecorder recorder)
services/src/main/java/io/grpc/services/InternalCallMetricRecorder.java:40
↓ 3 callers
Method
flush
()
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:137
↓ 3 callers
Method
forChannelId
(boolean isTerminal)
xds/src/main/java/io/grpc/xds/VirtualHost.java:264
↓ 3 callers
Method
forDevicePolicyAdmin
Creates a BinderChannelCredentials to be used with DevicePolicyManager API. @param devicePolicyAdminComponentName the admin component to be specified
binder/src/main/java/io/grpc/binder/BinderChannelCredentials.java:45
↓ 3 callers
Method
forImmutableInstance
Create a stream for a Parcelable object, treating the object as immutable.
binder/src/main/java/io/grpc/binder/internal/ParcelableInputStream.java:95
↓ 3 callers
Method
forLocalComponent
Creates an address referencing a {@link android.app.Service} hosted by this application and using the default binding {@link Intent}.
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:81
↓ 3 callers
Method
forNonForwardingAction
(RouteMatch routeMatch, Map<String, FilterConfig> filterConfigOverrides)
xds/src/main/java/io/grpc/xds/VirtualHost.java:73
↓ 3 callers
Method
forPort
Always throws, to shadow {@code ServerBuilder.forPort()}. @deprecated Use {@link #forPort(int, ServerCredentials)} instead
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:92
↓ 3 callers
Method
forPrefix
The input string should have the prefix.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:239
↓ 3 callers
Method
forTarget
(String target)
rls/src/main/java/io/grpc/rls/ChildLoadBalancerHelper.java:84
↓ 3 callers
Method
forcefulClose
(final ChannelHandlerContext ctx, final ForcefulCloseCommand msg, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:872
↓ 3 callers
Method
formatDeadlineExceededStatus
()
core/src/main/java/io/grpc/internal/ClientCallImpl.java:396
↓ 3 callers
Method
formatHeader
(boolean inbound, int streamId, int length, byte type, byte flags)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:685
↓ 3 callers
Method
forwardTimeByBackoffDelay
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3134
↓ 3 callers
Method
frameWriter
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:232
↓ 3 callers
Method
freezeHedging
()
core/src/main/java/io/grpc/internal/RetriableStream.java:823
↓ 3 callers
Method
fromRegEx
(Pattern regEx)
xds/src/main/java/io/grpc/xds/VirtualHost.java:136
↓ 3 callers
Method
generatePerRouteInterceptors
( @Nullable List<NamedFilterConfig> filterConfigs, List<VirtualHost> virtualHosts, Map
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:657
↓ 3 callers
Method
getAccessToken
()
s2a/src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/SingleTokenFetcher.java:44
↓ 3 callers
Method
getActiveRequests
()
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:317
↓ 3 callers
Method
getAttributeOrDefault
(Attributes attributes, Attributes.Key<String> key)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:711
↓ 3 callers
Method
getAuthMechanism
Retrieves the authentication mechanism for a given local identity. @param localIdentity the identity for which to fetch a token. @param tokenManager
s2a/src/main/java/io/grpc/s2a/internal/handshaker/GetAuthenticationMechanisms.java:37
↓ 3 callers
Method
getAuthority
Returns the Authority which is the package name of the target app. <p>See {@link android.content.ComponentName} and {@link Intent#getPackage()}.
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:130
↓ 3 callers
Method
getAutoHostSni
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:115
↓ 3 callers
Method
getBackendServiceOrDefault
(Attributes attributes)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:716
↓ 3 callers
Method
getByte
(CharSequence name)
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:88
↓ 3 callers
Method
getCacheSize
()
xds/src/main/java/io/grpc/xds/GcpAuthenticationFilter.java:223
↓ 3 callers
Method
getCallCredentials
()
api/src/main/java/io/grpc/CompositeChannelCredentials.java:45
↓ 3 callers
Method
getCallOptions
Returns the effective CallOptions of the call.
api/src/main/java/io/grpc/ClientStreamTracer.java:149
↓ 3 callers
Method
getCertificateChain
The certificate chain for the server's identity, as a new byte array. Generally should be PEM-encoded. If {@code null}, some feature is providing key
api/src/main/java/io/grpc/TlsServerCredentials.java:87
↓ 3 callers
Method
getChildPickers
()
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:218
↓ 3 callers
Method
getClientAccumulatedStats
<pre> Gets the accumulated stats for RPCs sent by a test client. </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/LoadBalancerStatsServiceGrpc.java:161
↓ 3 callers
Method
getClientAliases
(String keyType, Principal[] issuers)
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:93
↓ 3 callers
Method
getClientConfigForXdsClient
(XdsClient xdsClient, String target)
xds/src/main/java/io/grpc/xds/CsdsService.java:188
↓ 3 callers
Method
getClientInterceptor
Returns the client interceptor that facilitates Census-based stats reporting.
census/src/main/java/io/grpc/census/CensusStatsModule.java:162
↓ 3 callers
Method
getClientInterceptor
Returns the client interceptor that facilitates otel tracing reporting.
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:132
↓ 3 callers
Method
getClientStats
<pre> Gets the backend distribution for RPCs sent by a test client. </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/LoadBalancerStatsServiceGrpc.java:151
↓ 3 callers
Method
getCompressor
Returns the compressor's name.
api/src/main/java/io/grpc/CallOptions.java:260
↓ 3 callers
Method
getConditionalInterceptor
(ClientInterceptor interceptor)
gcp-observability/src/main/java/io/grpc/gcp/observability/GcpObservability.java:216
↓ 3 callers
Method
getConfigurators
Returns a list of the configurators in this registry.
api/src/main/java/io/grpc/ConfiguratorRegistry.java:69
↓ 3 callers
Method
getConfiguratorsCallCountBeforeSet
()
api/src/main/java/io/grpc/InternalConfiguratorRegistry.java:52
↓ 3 callers
Method
getCredentialsList
Non-empty list of credentials, in preference order.
api/src/main/java/io/grpc/ChoiceServerCredentials.java:53
↓ 3 callers
Method
getCurrentRecordSink
()
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:160
↓ 3 callers
Method
getDefaultPickSubchannelArgsForServer
(int serverid)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:621
↓ 3 callers
Method
getDefaultRegistry
Returns the default registry that loads providers via the Java service loader mechanism.
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:109
↓ 3 callers
Method
getDefaultRoutingConfig
()
xds/src/main/java/io/grpc/xds/FilterChainMatchingProtocolNegotiators.java:163
↓ 3 callers
Method
getDefaultScheme
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:965
← previous
next →
3,601–3,700 of 22,628, ranked by callers