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
↓ 2 callers
Method
buildTransportFactory
()
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:606
↓ 2 callers
Method
buildTrustManagerAndGetSslParameters
()
xds/src/test/java/io/grpc/xds/internal/security/trust/XdsX509TrustManagerTest.java:778
↓ 2 callers
Method
bytes
(CharSequence seq)
netty/src/main/java/io/grpc/netty/Utils.java:269
↓ 2 callers
Method
bytes
(AsciiString str)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:249
↓ 2 callers
Method
cacheAndClean
(RouteLookupRequestKey key, CacheEntry value)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:985
↓ 2 callers
Method
calcStringSize
(String target)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:750
↓ 2 callers
Method
calculateMaxBackoff
()
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:157
↓ 2 callers
Method
call
Discuss waiting strategy between calls. Sleeping seems to be very inaccurate (see below). On the other hand calling System.nanoTime() a lot (especiall
benchmarks/src/main/java/io/grpc/benchmarks/qps/OpenLoopClient.java:159
↓ 2 callers
Method
callPerformCallback
( Callback callback, final AbstractMap.SimpleImmutableEntry<SslContext,X509TrustManager> s
xds/src/main/java/io/grpc/xds/internal/security/DynamicSslContextProvider.java:102
↓ 2 callers
Method
callTracer0
(Status status)
core/src/test/java/io/grpc/internal/ServerCallImplTest.java:113
↓ 2 callers
Method
cancel
Tears down the stream, typically in the event of a timeout. This method may be called multiple times and from any thread.
core/src/main/java/io/grpc/internal/ServerStream.java:60
↓ 2 callers
Method
cancel
(@Nullable String message, @Nullable Throwable cause)
core/src/main/java/io/grpc/internal/ClientCallImpl.java:451
↓ 2 callers
Method
cancel
(@Nullable final String message, @Nullable final Throwable cause)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:223
↓ 2 callers
Method
cancel
Cancel the task if it's still {@link #isPending pending}.
api/src/main/java/io/grpc/SynchronizationContext.java:252
↓ 2 callers
Method
cancel
(Status status)
servlet/src/main/java/io/grpc/servlet/ServletServerStream.java:292
↓ 2 callers
Method
cancelLbRpcRetryTimer
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:453
↓ 2 callers
Method
cancelReconnectTask
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:523
↓ 2 callers
Method
cancelled
Notifies that a context was cancelled. @param context the newly cancelled context.
api/src/context/java/io/grpc/Context.java:941
↓ 2 callers
Method
cartesianProductParams
(List<?>... lists)
netty/src/test/java/io/grpc/netty/NettyAdaptiveCumulatorTest.java:59
↓ 2 callers
Method
caseSensitive
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:124
↓ 2 callers
Method
certificateChainToDerChain
(X509Certificate[] chain)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2ATrustManager.java:151
↓ 2 callers
Method
channelCredentials
()
xds/src/main/java/io/grpc/xds/client/ConfiguredChannelCredentials.java:29
↓ 2 callers
Method
channelFactory
Specifies the {@link ChannelFactory} to create {@link Channel} instances. This method is usually only used if the specific {@code Channel} requires co
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:301
↓ 2 callers
Method
channelsAndSubchannels_instrumented0
(boolean success)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:3296
↓ 2 callers
Method
channelsPerServer
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:726
↓ 2 callers
Method
checkAuthorization
Decides whether the given Android UID is authorized. (Validity is implementation dependent). <p><b>IMPORTANT</b>: This method may block for extended
binder/src/main/java/io/grpc/binder/SecurityPolicy.java:55
↓ 2 callers
Method
checkAuthorization
Get whether we're authorized to make this call.
binder/src/main/java/io/grpc/binder/internal/BinderTransportSecurity.java:182
↓ 2 callers
Method
checkCensus
Check information recorded by Census.
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1936
↓ 2 callers
Method
checkDueTasks
()
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:317
↓ 2 callers
Method
checkFeature
Gets the feature at the given point. @param location the location to check. @return The feature object at the point. Note that an empty name indicate
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideServer.java:265
↓ 2 callers
Method
checkForNull
(T value, String fieldName)
xds/src/main/java/io/grpc/xds/client/BootstrapperImpl.java:316
↓ 2 callers
Method
checkForceXds
(QueryParams params)
googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:405
↓ 2 callers
Method
checkKeys
(Set<String> keys, String key, String keyType)
rls/src/main/java/io/grpc/rls/RlsProtoConverters.java:201
↓ 2 callers
Method
checkListHasNoNulls
(List<?> list, String msg)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:568
↓ 2 callers
Method
checkLowercase
An HTTP/2 response cannot contain uppercase header characters and must be treated as malformed.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:630
↓ 2 callers
Method
checkMapEntryTypes
(@Nullable Map<?, ?> map)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:563
↓ 2 callers
Method
checkObjectList
(Object o)
core/src/test/java/io/grpc/internal/ServiceConfigUtilTest.java:117
↓ 2 callers
Method
checkPackageSignature
Checks if the signature of {@code packageName} matches one of the given signatures. @param packageName the package to be checked @param signatureChec
binder/src/main/java/io/grpc/binder/SecurityPolicies.java:288
↓ 2 callers
Method
checkPeerTrusted
(X509Certificate[] chain, boolean isCheckingClientCertificateChain)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2ATrustManager.java:100
↓ 2 callers
Method
checkServerAuthorization
(int remoteUid)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:353
↓ 2 callers
Method
checkServerAuthorizationAsync
(int remoteUid)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:372
↓ 2 callers
Method
checkTracers
Check information recorded by tracers.
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1901
↓ 2 callers
Method
chooseEngineClientAlias
(String[] keyType, Principal[] issuers, SSLEngine engine)
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:104
↓ 2 callers
Method
cleanQueue
()
xds/src/main/java/io/grpc/xds/SharedCallCounterMap.java:77
↓ 2 callers
Method
cleanStatus
Returns a new status with the same code and description. If includeCauseWithStatus is true, cause is also included. <p>For InProcess transport to beh
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:960
↓ 2 callers
Method
cleanUp
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:847
↓ 2 callers
Method
cleanUp
()
xds/src/main/java/io/grpc/xds/client/LoadReportClient.java:319
↓ 2 callers
Method
cleanUpResourceTimers
(ControlPlaneClient cpcForThisStream)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:458
↓ 2 callers
Method
cleanUpRouteDiscoveryStates
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:746
↓ 2 callers
Method
clearApplicationUtilizationMetric
Clear the application specific utilization metrics data.
services/src/main/java/io/grpc/services/MetricRecorder.java:100
↓ 2 callers
Method
clearDynamicTable
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:180
↓ 2 callers
Method
clearDynamicTable
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:548
↓ 2 callers
Method
clearEpsMetric
Clear the EPS metrics data.
services/src/main/java/io/grpc/services/MetricRecorder.java:152
↓ 2 callers
Method
clearInternal
()
core/src/main/java/io/grpc/internal/ManagedChannelOrphanWrapper.java:142
↓ 2 callers
Method
clearKeyManagers
()
api/src/main/java/io/grpc/TlsServerCredentials.java:330
↓ 2 callers
Method
clearKeyManagers
()
api/src/main/java/io/grpc/TlsChannelCredentials.java:311
↓ 2 callers
Method
clearOnReadyThreshold
Resets to the default number of bytes that must be queued before the call will leave the <a href="https://github.com/grpc/grpc/blob/master/doc/wait-fo
api/src/main/java/io/grpc/CallOptions.java:237
↓ 2 callers
Method
clearQpsMetric
Clear the QPS metrics data.
services/src/main/java/io/grpc/services/MetricRecorder.java:135
↓ 2 callers
Method
clearSafely
Safe to call concurrently.
core/src/main/java/io/grpc/internal/ManagedChannelOrphanWrapper.java:135
↓ 2 callers
Method
clearTrustManagers
()
api/src/main/java/io/grpc/TlsServerCredentials.java:387
↓ 2 callers
Method
clearTrustManagers
()
api/src/main/java/io/grpc/TlsChannelCredentials.java:358
↓ 2 callers
Method
clearValues
()
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:144
↓ 2 callers
Method
clientChannelBuilder
( Server server, ChannelCredentials creds)
okhttp/src/test/java/io/grpc/okhttp/TlsTest.java:752
↓ 2 callers
Method
clientCompressedStreaming
Tests client per-message compression for streaming calls. The Java API does not support inspecting a message's compression level, so this is primarily
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:630
↓ 2 callers
Method
clientCompressedUnary
Tests client per-message compression for unary calls. The Java API does not support inspecting a message's compression level, so this is primarily int
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:460
↓ 2 callers
Method
clientHandler
(Blackhole bh, Http2Headers headers)
netty/src/jmh/java/io/grpc/netty/InboundHeadersBenchmark.java:140
↓ 2 callers
Method
cloneCustomArgs
( @Nullable IdentityHashMap<Args.Key<?>, Object> customArgs)
api/src/main/java/io/grpc/NameResolver.java:1035
↓ 2 callers
Method
clonePendingCallbacksAndClear
()
xds/src/main/java/io/grpc/xds/internal/security/DynamicSslContextProvider.java:149
↓ 2 callers
Method
close
Closes the connection.
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerClient.java:245
↓ 2 callers
Method
close
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:625
↓ 2 callers
Method
closeListener
Closes the listener if not previously closed. @throws IllegalStateException if the call has not yet been started.
core/src/main/java/io/grpc/internal/AbstractClientStream.java:456
↓ 2 callers
Method
closeStreamWhenDone
(ChannelPromise promise, Http2Stream stream)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:753
↓ 2 callers
Method
closeWithSleepTime
Method to close along with sleep time explicitly. @param sleepTime sleepTime
gcp-observability/src/main/java/io/grpc/gcp/observability/GcpObservability.java:138
↓ 2 callers
Method
combineInterceptors
(final List<ClientInterceptor> interceptors)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:622
↓ 2 callers
Method
commandLineFlag
(Param param)
benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java:208
↓ 2 callers
Method
compareNanos
Positive when time1 is greater; negative when time2 is greater; 0 when equal. It is important to use something like this instead of directly comparing
core/src/main/java/io/grpc/internal/KeepAliveEnforcer.java:98
↓ 2 callers
Method
complete
(V result)
binder/src/testFixtures/java/io/grpc/binder/internal/MainThreadScheduledExecutorService.java:186
↓ 2 callers
Method
compressedIndex
(int indexBit)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:280
↓ 2 callers
Method
concatLengthPrefixed
Returns the concatenation of 8-bit, length prefixed protocol names. http://tools.ietf.org/html/draft-agl-tls-nextprotoneg-04#page-4
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java:578
↓ 2 callers
Method
config
()
xds/src/main/java/io/grpc/xds/ClusterSpecifierPlugin.java:44
↓ 2 callers
Method
config
()
xds/src/main/java/io/grpc/xds/RouteLookupServiceClusterSpecifierPlugin.java:86
↓ 2 callers
Method
configureChannelBuilder
(ManagedChannelBuilder<?> channelBuilder)
api/src/main/java/io/grpc/InternalConfiguratorRegistry.java:36
↓ 2 callers
Method
configureNetty
( NettyChannelBuilder builder, Transport transport, int flowControlWindow)
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:125
↓ 2 callers
Method
connectionSpec
For secure connection, provides a ConnectionSpec to specify Cipher suite and TLS versions. <p>By default a modern, HTTP/2-compatible spec will be use
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:428
↓ 2 callers
Method
constantKeys
()
rls/src/main/java/io/grpc/rls/RlsProtoData.java:207
↓ 2 callers
Method
contains
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:225
↓ 2 callers
Method
containsServer
(InternalLogId serverRef)
api/src/main/java/io/grpc/InternalChannelz.java:224
↓ 2 callers
Method
convert
Converts {@link CertificateProviderPluginInstance} to {@link CommonTlsContext.CertificateProviderInstance}.
xds/src/main/java/io/grpc/xds/internal/security/CommonTlsContextUtil.java:62
↓ 2 callers
Method
convertCustomConfig
Converts a custom TypedStruct LB config to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:343
↓ 2 callers
Method
convertHeaders
(List<Header> http2Headers)
okhttp/src/main/java/io/grpc/okhttp/Utils.java:48
↓ 2 callers
Method
convertHeadersToArray
(List<Header> http2Headers)
okhttp/src/main/java/io/grpc/okhttp/Utils.java:56
↓ 2 callers
Method
convertHeadersToArray
(Http2Headers http2Headers)
netty/src/main/java/io/grpc/netty/Utils.java:256
↓ 2 callers
Method
convertRlsServerStatus
Convert the status to UNAVAILABLE and enhance the error message. @param status status as provided by server @param serverName Used for error descripti
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:310
↓ 2 callers
Method
convertToServiceConfig
Converts a {@link LoadBalancingPolicy} object to a service config JSON object.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:217
↓ 2 callers
Method
copy
Copy as much as possible to dst from src. Unlike {@link ByteBuffer#put(ByteBuffer)}, this stops early if there is no room left in dst.
alts/src/main/java/io/grpc/alts/internal/AltsFraming.java:352
↓ 2 callers
Method
corruptedCiphertextTest
Test corrupted ciphertext.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:294
↓ 2 callers
Method
corruptedCounterTest
Test corrupted counter.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:253
↓ 2 callers
Method
corruptedTagTest
Test corrupted tag.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:333
↓ 2 callers
Method
countRstStream
Returns non-{@code null} when the connection should be killed by the caller.
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:1244
↓ 2 callers
Method
create
Creates a {@code SingleTokenFetcher} from {@code ENVIRONMENT_VARIABLE}, and returns an empty {@code Optional} instance if the token could not be fetch
s2a/src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/SingleTokenFetcher.java:35
← previous
next →
4,301–4,400 of 22,628, ranked by callers