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
↓ 5 callers
Method
awaitTermination
()
core/src/test/java/io/grpc/internal/ForwardingManagedChannelTest.java:80
↓ 5 callers
Method
blockingClientStreamingCall
Initiates a server streaming call and sends the specified request to the server. It returns an object which can be used in a blocking manner to retri
stub/src/main/java/io/grpc/stub/ClientCalls.java:286
↓ 5 callers
Method
bootstrapInfo
()
xds/src/main/java/io/grpc/xds/Filter.java:137
↓ 5 callers
Method
build
Returns a new {@link CsmObservability} built with the configuration of this {@link Builder}.
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/CsmObservability.java:156
↓ 5 callers
Method
buildListenerWithApiListenerInvalid
(String name)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5298
↓ 5 callers
Method
buildRecursiveMessage
(int depth)
protobuf-lite/src/test/java/io/grpc/protobuf/lite/ProtoLiteUtilsTest.java:304
↓ 5 callers
Method
buildStaticValidationContext
( String... verifySans)
xds/src/test/java/io/grpc/xds/internal/security/trust/XdsTrustManagerFactoryTest.java:311
↓ 5 callers
Method
buildTransportFactory
()
inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:244
↓ 5 callers
Method
buildTransportServers
( List<? extends ServerStreamTracer.Factory> streamTracerFactories, MetricRecorder metricRecorder)
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:709
↓ 5 callers
Method
buildTrustManagerAndGetSslEngine
()
xds/src/test/java/io/grpc/xds/internal/security/trust/XdsX509TrustManagerTest.java:757
↓ 5 callers
Method
buildUpdate
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:219
↓ 5 callers
Method
buildUpstreamTlsContext
(String instanceName, String certName)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5341
↓ 5 callers
Method
buildWrappedResource
(Any originalResource)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5283
↓ 5 callers
Method
bytebuf
()
netty/src/main/java/io/grpc/netty/NettyWritableBuffer.java:58
↓ 5 callers
Method
callUpdateSslContext
(SslContextProviderSupplier sslContextProviderSupplier)
xds/src/test/java/io/grpc/xds/XdsClientWrapperForServerSdsTestMisc.java:305
↓ 5 callers
Method
cancel
Cancel this context and optionally provide a cause (can be {@code null}) for the cancellation. This will trigger notification of listeners. It is safe
api/src/context/java/io/grpc/Context.java:813
↓ 5 callers
Method
cancelFallbackTimer
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:447
↓ 5 callers
Method
cancellableAncestor
Returns {@code parent} if it is a {@link CancellableContext}, otherwise returns the parent's {@link #cancellableAncestor}.
api/src/context/java/io/grpc/Context.java:1095
↓ 5 callers
Method
channelCredentials
()
xds/src/test/java/io/grpc/xds/internal/TlsXdsCredentialsProviderTest.java:52
↓ 5 callers
Method
checkAuthorizationForServiceAsync
Returns whether the given Android UID is authorized to access a particular service. <p>This method never throws an exception. If the execution of the
binder/src/main/java/io/grpc/binder/internal/BinderTransportSecurity.java:246
↓ 5 callers
Method
checkContext
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1279
↓ 5 callers
Method
checkNotDone
()
api/src/test/java/io/grpc/ClientInterceptorsTest.java:469
↓ 5 callers
Method
checkProductNameOnLinux
(BufferedReader reader)
alts/src/main/java/io/grpc/alts/InternalCheckGcpEnvironment.java:56
↓ 5 callers
Method
checkServerTrusted
(X509Certificate[] chain, String authType, SSLEngine engine)
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:92
↓ 5 callers
Method
clientAttemptCountCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:32
↓ 5 callers
Method
closeWithException
(StatusRuntimeException t)
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:107
↓ 5 callers
Method
closed
(Status status)
core/src/main/java/io/grpc/internal/ServerCallImpl.java:360
↓ 5 callers
Method
compareTo
{@inheritDoc} <p>Both deadlines must be created with the same {@link Ticker}.
api/src/context/java/io/grpc/Deadline.java:227
↓ 5 callers
Method
containsSubchannel
(InternalLogId subchannelRef)
api/src/main/java/io/grpc/InternalChannelz.java:229
↓ 5 callers
Method
convertHeaders
(Http2Headers http2Headers)
netty/src/main/java/io/grpc/netty/Utils.java:193
↓ 5 callers
Method
convertToJson
(Struct struct)
xds/src/main/java/io/grpc/xds/internal/ProtobufJsonConverter.java:33
↓ 5 callers
Method
create
(Channel channel)
stub/src/test/java/io/grpc/stub/BaseAbstractStubTest.java:44
↓ 5 callers
Method
create
Creates a {@link ChannelCredentials} that will use the provided {@code negotiator}.
netty/src/main/java/io/grpc/netty/InternalNettyChannelCredentials.java:31
↓ 5 callers
Method
create
(String category, int dropsPerMillion)
xds/src/main/java/io/grpc/xds/Endpoints.java:98
↓ 5 callers
Method
create
(@Nullable String exact, @Nullable String prefix, @Nullable String suffix, @Nullable Pattern regEx, @N
xds/src/main/java/io/grpc/xds/internal/Matchers.java:289
↓ 5 callers
Method
create
(Matchers.CidrMatcher delegate)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:182
↓ 5 callers
Method
createBinaryLog
Returns a binlog with the correct header and message limits or {@code null} if the input is malformed. The input should be a string that is in one of
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:720
↓ 5 callers
Method
createForTest
A convenient method to allow creating a {@link XdsNameResolverProvider} with custom scheme and bootstrap.
xds/src/main/java/io/grpc/xds/XdsNameResolverProvider.java:75
↓ 5 callers
Method
createKeyManager
(byte[] certChain, byte[] privateKey)
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:687
↓ 5 callers
Method
createMatchSrcIp
(String srcCidr)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1986
↓ 5 callers
Method
createMetricReport
(double cpu, double app, double mem, double qps, double eps, Map<String, Double> namedMetrics)
xds/src/test/java/io/grpc/xds/internal/MetricReportUtilsTest.java:110
↓ 5 callers
Method
createNewChannel
()
interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:195
↓ 5 callers
Method
createProtocolNegotiatorByType
( NegotiationType negotiationType, SslContext sslContext, ObjectPool<? extends Executor> exe
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:644
↓ 5 callers
Method
createRandomSubsettingLbConfig
( int subsetSize, LoadBalancerProvider childLbProvider, Object childConfig)
util/src/test/java/io/grpc/util/RandomSubsettingLoadBalancerTest.java:99
↓ 5 callers
Method
createSocket
(Socket s, String host, int port, boolean autoClose)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:545
↓ 5 callers
Method
createSubchannel
(CreateSubchannelArgs args)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:720
↓ 5 callers
Method
createXdsClient
(List<String> serverUris, XdsTransportFactory xdsTransportFactor
xds/src/test/java/io/grpc/xds/client/CommonBootstrapperTestUtils.java:169
↓ 5 callers
Method
deadline
()
api/src/testFixtures/java/io/grpc/testing/DeadlineSubject.java:39
↓ 5 callers
Method
deframeFailed
(Throwable cause)
core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java:422
↓ 5 callers
Method
delayOrExecute
(Runnable runnable)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:277
↓ 5 callers
Method
delegate
()
core/src/main/java/io/grpc/internal/ForwardingClientStreamListener.java:25
↓ 5 callers
Method
delegate
Returns the delegated {@code ServerCall.Listener}.
api/src/main/java/io/grpc/PartialForwardingServerCallListener.java:31
↓ 5 callers
Method
deliverAddresses
(WrrLocalityConfig config, List<EquivalentAddressGroup> addresses)
xds/src/test/java/io/grpc/xds/WrrLocalityLoadBalancerTest.java:215
↓ 5 callers
Method
deliverSubchannelState
(LoadBalancer.Subchannel subchannel, ConnectivityStateInfo newState)
util/src/test/java/io/grpc/util/MultiChildLoadBalancerTest.java:363
↓ 5 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 {@link #regist
api/src/main/java/io/grpc/NameResolverRegistry.java:97
↓ 5 callers
Method
detach
(Context toAttach)
api/src/context/java/io/grpc/Context.java:717
↓ 5 callers
Method
disableRetry
()
core/src/test/java/io/grpc/internal/ManagedChannelImplBuilderTest.java:702
↓ 5 callers
Method
disableServiceConfigLookUp
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:640
↓ 5 callers
Method
disallowedHeaders
Specifies which request headers are not sent to the authorization service. This overrides {@link #allowedHeaders()}. @see ExtAuthz#getDisallowedHeade
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:112
↓ 5 callers
Method
doUnaryRpc
(ManagedChannel channel)
s2a/src/test/java/io/grpc/s2a/IntegrationTest.java:196
↓ 5 callers
Method
droppedCount
()
xds/src/main/java/io/grpc/xds/client/Stats.java:89
↓ 5 callers
Method
edsServiceName
(String edsServiceName)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:755
↓ 5 callers
Method
emptyBuilder
()
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:177
↓ 5 callers
Method
enableButtons
(boolean enable)
android-interop-testing/src/main/java/io/grpc/android/integrationtest/TesterActivity.java:114
↓ 5 callers
Method
enableRetry
Enables the retry and hedging subsystem which will use <a href="https://github.com/grpc/proposal/blob/master/A6-client-retries.md#integration-with-ser
api/src/main/java/io/grpc/ManagedChannelBuilder.java:524
↓ 5 callers
Method
error
(String error)
api/src/main/java/io/grpc/ManagedChannelProvider.java:102
↓ 5 callers
Method
error
(String error)
api/src/main/java/io/grpc/ServerProvider.java:90
↓ 5 callers
Method
error
(String error)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:307
↓ 5 callers
Method
estimatedMaxSizeBytes
()
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:105
↓ 5 callers
Method
execute
(Runnable action)
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:278
↓ 5 callers
Method
exists
Indicates whether the given feature exists (i.e. has a valid name).
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideUtil.java:77
↓ 5 callers
Method
extractChannelData
(InternalChannelz.ChannelStats stats)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:354
↓ 5 callers
Method
failWrites
Propagate failures to all buffered writes.
netty/src/main/java/io/grpc/netty/WriteBufferingAndExceptionHandler.java:234
↓ 5 callers
Method
finalizeAndDump2
(CallMetricRecorder recorder)
services/src/main/java/io/grpc/services/InternalCallMetricRecorder.java:44
↓ 5 callers
Method
findClusterStats
( List<ClusterStats> statsList, String cluster, @Nullable String edsServiceName)
xds/src/test/java/io/grpc/xds/client/LoadStatsManager2Test.java:359
↓ 5 callers
Method
findOrCreateClientSslContextProvider
( UpstreamTlsContext upstreamTlsContext)
xds/src/main/java/io/grpc/xds/internal/security/TlsContextManagerImpl.java:70
↓ 5 callers
Method
findOrCreateServerSslContextProvider
( DownstreamTlsContext downstreamTlsContext)
xds/src/main/java/io/grpc/xds/internal/security/TlsContextManagerImpl.java:59
↓ 5 callers
Method
fireOnEviction
(K key, SizedValue value, EvictionType cause)
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:286
↓ 5 callers
Method
forAddress
Creates a channel builder that will bind to a remote Android service. <p>The underlying Android binding will be torn down when the channel becomes id
binder/src/main/java/io/grpc/binder/BinderChannelBuilder.java:60
↓ 5 callers
Method
forContext
Creates an address for the given {@link android.app.Service} instance with the default binding {@link Intent}.
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:73
↓ 5 callers
Method
forDefault
Creates the default BinderChannelCredentials. @return a BinderChannelCredentials
binder/src/main/java/io/grpc/binder/BinderChannelCredentials.java:34
↓ 5 callers
Method
forHeader
(boolean isTerminal, String headerName, @Nullable Pattern regEx, @Nullable String regExSubstitutio
xds/src/main/java/io/grpc/xds/VirtualHost.java:258
↓ 5 callers
Method
forRange
The request header value should be within the range.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:94
↓ 5 callers
Method
forWeightedClusters
( List<ClusterWeight> weightedClusters, List<HashPolicy> hashPolicies, @Nullable Long time
xds/src/main/java/io/grpc/xds/VirtualHost.java:179
↓ 5 callers
Method
get
(K key, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:72
↓ 5 callers
Method
get
(K key, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:295
↓ 5 callers
Method
get
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpProtocolNegotiator.java:61
↓ 5 callers
Method
getActiveCpc
(String authority)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:169
↓ 5 callers
Method
getAdvertisedMessageEncodings
Provides a list of all message encodings that have decompressors available and should be advertised. <p>The specification doesn't say anything about
api/src/main/java/io/grpc/DecompressorRegistry.java:115
↓ 5 callers
Method
getAllGauges
<pre> Returns the values of all the gauges that are currently being maintained by the service </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/MetricsServiceGrpc.java:146
↓ 5 callers
Method
getAltsMaxConcurrentHandshakes
(String altsMaxConcurrentHandshakes)
alts/src/main/java/io/grpc/alts/internal/AltsProtocolNegotiator.java:426
↓ 5 callers
Method
getAppListener
()
core/src/main/java/io/grpc/internal/ApplicationThreadDeframer.java:136
↓ 5 callers
Method
getChannelLogger
()
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:802
↓ 5 callers
Method
getClientInterceptor
Returns a {@link ClientInterceptor} with default stats implementation.
census/src/main/java/io/grpc/census/InternalCensusStatsAccessor.java:49
↓ 5 callers
Method
getConfig
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplDataTest.java:1270
↓ 5 callers
Method
getCurrentAddress
()
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:716
↓ 5 callers
Method
getDeadline
Returns the deadline or {@code null} if the deadline is not set.
api/src/main/java/io/grpc/CallOptions.java:189
↓ 5 callers
Method
getDelegate
Returns the wrapped {@link IBinder} for the purpose of calling methods other than {@link IBinder#transact(int, Parcel, Parcel, int)}.
binder/src/main/java/io/grpc/binder/internal/OneWayBinderProxy.java:102
↓ 5 callers
Method
getDetails
()
api/src/main/java/io/grpc/InternalLogId.java:79
↓ 5 callers
Method
getErrorState
The metadata capturing the error details of the last rejected update of the resource.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:249
← previous
next →
2,601–2,700 of 22,628, ranked by callers