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
↓ 9 callers
Method
execute
(Runnable runnable)
stub/src/main/java/io/grpc/stub/ClientCalls.java:854
↓ 9 callers
Method
extractPeerObject
Returns the peer extracted from a completed handshake. @return the extracted peer.
alts/src/main/java/io/grpc/alts/internal/TsiHandshaker.java:89
↓ 9 callers
Method
fail
(Status status)
binder/src/main/java/io/grpc/binder/internal/PingTracker.java:99
↓ 9 callers
Method
fakeCurrentTimeNanos
Returns the current time, for tests that rely on the clock.
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:248
↓ 9 callers
Method
filterChains
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:308
↓ 9 callers
Method
filterStateTestVhost
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:1726
↓ 9 callers
Method
fromString
Returns the {@link TestCases} matching the string {@code s}. The matching is done case insensitive.
interop-testing/src/main/java/io/grpc/testing/integration/TestCases.java:81
↓ 9 callers
Method
generateListenerUpdate
(FakeXdsClient xdsClient, EnvoyServerProtoData.DownstreamTlsContext tlsCo
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:87
↓ 9 callers
Method
getAddressesFromPick
Picks subchannel using mockArgs, gets its EAG, and then strips the Attrs to make a key.
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:325
↓ 9 callers
Method
getByteBuffer
Gets a {@link ByteBuffer} that contains some bytes of the content next to be read, or {@code null} if this buffer has been exhausted. The number of by
core/src/main/java/io/grpc/internal/ReadableBuffer.java:161
↓ 9 callers
Method
getClusterDropStats
Gets or creates the stats object for recording drops for the specified cluster with edsServiceName. The returned object is reference counted and the c
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:75
↓ 9 callers
Method
getDefaultInstance
()
alts/src/main/java/io/grpc/alts/internal/AltsInternalContext.java:41
↓ 9 callers
Method
getEffectiveInterceptors
(String computedTarget)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:744
↓ 9 callers
Method
getFallbackTimeoutMs
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbConfig.java:53
↓ 9 callers
Method
getHandshakeSession
()
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:1226
↓ 9 callers
Method
getHealthService
Gets the health check service created in the constructor.
services/src/main/java/io/grpc/services/HealthStatusManager.java:55
↓ 9 callers
Method
getId
()
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:231
↓ 9 callers
Method
getInboundUncompressedSize
Returns to sum of all sizes passed to {@link StreamTracer#inboundUncompressedSize}.
testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java:58
↓ 9 callers
Method
getLink
()
netty/src/main/java/io/grpc/netty/WriteQueue.java:231
↓ 9 callers
Method
getMetricValue
Resolves a custom metric value for `parsedMetric` Returns OptionalDouble.empty() if the metric is absent or invalid. @param report The metric report
xds/src/main/java/io/grpc/xds/internal/MetricReportUtils.java:88
↓ 9 callers
Method
getOrCreateOrcaListener
(float errorUtilizationPenalty, ImmutableList<ParsedMetricName> parsedMetricNamesForComputingUtilizati
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:332
↓ 9 callers
Method
getOutboundHeaders
Returns if {@link ClientStreamTracer#outboundHeaders} has been called.
testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java:68
↓ 9 callers
Method
getPackage
Returns the package target of the wrapped {@link Intent}, either from its package restriction or, if not present, its fully qualified {@link Component
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:138
↓ 9 callers
Method
getPingCount
()
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:248
↓ 9 callers
Method
getPort
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1473
↓ 9 callers
Method
getReportIntervalNanos
Returns the configured maximum interval of receiving out-of-band ORCA reports.
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:591
↓ 9 callers
Method
getReportTimer
()
netty/src/main/java/io/grpc/netty/TcpMetrics.java:192
↓ 9 callers
Method
getRequestCostMetrics
()
services/src/main/java/io/grpc/services/MetricReport.java:65
↓ 9 callers
Method
getResponses
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceV1Test.java:648
↓ 9 callers
Method
getResponses
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java:648
↓ 9 callers
Method
getRootChannels
Returns a {@link RootChannelList}.
api/src/main/java/io/grpc/InternalChannelz.java:145
↓ 9 callers
Method
getSampler
Get sampler for TraceConfig - when Cloud Tracing is enabled.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:47
↓ 9 callers
Method
getScheduledExecutorService
Returns an executor for scheduling provided by the transport. The service should be configured to allow cancelled scheduled runnables to be GCed. <p>
core/src/main/java/io/grpc/internal/ClientTransportFactory.java:59
↓ 9 callers
Method
getSubchannel
(EquivalentAddressGroup removedEag)
xds/src/test/java/io/grpc/xds/LeastRequestLoadBalancerTest.java:228
↓ 9 callers
Method
getToken
Returns an access token for the given identity.
s2a/src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/TokenFetcher.java:27
↓ 9 callers
Method
getTransportTracer
()
core/src/main/java/io/grpc/internal/AbstractStream.java:371
↓ 9 callers
Method
getUserInfo
Returns the percent-decoded "User Information" component of this URI, or null if not present. <p>NB: This method assumes this component was encoded a
api/src/main/java/io/grpc/Uri.java:406
↓ 9 callers
Method
getWatchers
(TrackedWatcherType<T> watcherType)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:285
↓ 9 callers
Method
grpcKeybuilders
Returns unordered specifications for constructing keys for gRPC requests. All GrpcKeyBuilders on this list must have unique "name" fields so that the
rls/src/main/java/io/grpc/rls/RlsProtoData.java:104
↓ 9 callers
Method
grpcResponseHeaders
()
netty/src/test/java/io/grpc/netty/NettyClientStreamTest.java:597
↓ 9 callers
Method
handleResolvedAddresses
(ResolvedAddresses resolvedAddresses)
util/src/main/java/io/grpc/util/ForwardingLoadBalancer.java:32
↓ 9 callers
Method
hasPendingStreams
()
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:263
↓ 9 callers
Method
headerBytes
()
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/ConfigFilterHelper.java:97
↓ 9 callers
Method
headersToRemove
()
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutations.java:33
↓ 9 callers
Method
isBefore
Is {@code this} deadline before another. Two deadlines must be created using the same {@link Ticker}.
api/src/context/java/io/grpc/Deadline.java:137
↓ 9 callers
Method
isCancelled
()
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:559
↓ 9 callers
Method
isEnableCloudMonitoring
Is Cloud Monitoring enabled.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:32
↓ 9 callers
Method
isEnabledHappyEyeballs
()
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:645
↓ 9 callers
Method
isInUse
()
netty/src/test/java/io/grpc/netty/NettyTestUtil.java:82
↓ 9 callers
Method
keyMap
Returns a map of key values extracted via key builders for the gRPC or HTTP request.
rls/src/main/java/io/grpc/rls/RlsProtoData.java:62
↓ 9 callers
Method
log
(ChannelLogLevel level, String message)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:887
↓ 9 callers
Method
lookupServiceTimeoutInNanos
Returns the timeout value for lookup service requests.
rls/src/main/java/io/grpc/rls/RlsProtoData.java:113
↓ 9 callers
Method
newBuilder
Creates a new builder.
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:586
↓ 9 callers
Method
newClientCallTracer
Creates a {@link CallAttemptsTracerFactory} for a new call.
census/src/main/java/io/grpc/census/CensusTracingModule.java:127
↓ 9 callers
Method
newServerStreamTracer
( String fullMethodName, Metadata headers)
core/src/test/java/io/grpc/internal/ServerImplTest.java:530
↓ 9 callers
Method
newThrottledRetriableStream
(Throttle throttle)
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:212
↓ 9 callers
Method
notifyShutdown
Returns {@code true} if was the first shutdown.
netty/src/main/java/io/grpc/netty/ClientTransportLifecycleManager.java:68
↓ 9 callers
Method
parseHeaderMatcher
( io.envoyproxy.envoy.config.route.v3.HeaderMatcher proto)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:386
↓ 9 callers
Method
payload
()
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:162
↓ 9 callers
Method
pickSubchannel
(PickSubchannelArgs args)
util/src/test/java/io/grpc/util/MultiChildLoadBalancerTest.java:413
↓ 9 callers
Method
pickSubchannel
(PickSubchannelArgs args)
util/src/main/java/io/grpc/util/RoundRobinLoadBalancer.java:139
↓ 9 callers
Method
pickSubchannel
(SubchannelPicker picker, String clusterName)
xds/src/test/java/io/grpc/xds/ClusterManagerLoadBalancerTest.java:315
↓ 9 callers
Method
policy
(Function<Integer, Boolean> func)
binder/src/androidTest/java/io/grpc/binder/BinderSecurityTest.java:319
↓ 9 callers
Method
recordLongHistogram
Records a value for a long valued histogram metric associated with specified metric instrument. @param metricInstrument The histogram metric instrume
api/src/main/java/io/grpc/MetricSink.java:112
↓ 9 callers
Method
recordMemoryUtilizationMetric
Records a call metric measurement for memory utilization in the range [0, 1]. Values outside the valid range are ignored. If RPC has already finished,
services/src/main/java/io/grpc/services/CallMetricRecorder.java:195
↓ 9 callers
Method
resetCounters
Reset any counters because PINGs are allowed in response to something sent. Typically called when sending HEADERS and DATA frames.
core/src/main/java/io/grpc/internal/KeepAliveEnforcer.java:78
↓ 9 callers
Method
retryableStatusCodes
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:283
↓ 9 callers
Method
returnObject
(XdsClient xdsClient)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:1054
↓ 9 callers
Method
scheduleFlush
Schedule a flush on the channel.
netty/src/main/java/io/grpc/netty/WriteQueue.java:63
↓ 9 callers
Method
selectConfig
Selects the config for an RPC.
api/src/main/java/io/grpc/InternalConfigSelector.java:39
↓ 9 callers
Method
send
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:207
↓ 9 callers
Method
setAutoCreate
Controls whether sending a call over the associated {@link io.grpc.Channel} will cause the target {@link android.app.Service} to be created and whethe
binder/src/main/java/io/grpc/binder/BindServiceFlags.java:141
↓ 9 callers
Method
setConfigurators
(List<InternalConfigurator> configurators)
api/src/main/java/io/grpc/InternalConfiguratorRegistry.java:28
↓ 9 callers
Method
setHandler
Replaces the current {@link TransactionHandler} with `handler`. <p>{@link TransactionHandler} mutations race against incoming transactions except in
binder/src/main/java/io/grpc/binder/internal/LeakSafeOneWayBinder.java:91
↓ 9 callers
Method
setIsTransparentRetry
Sets whether the stream is a transparent retry. @since 1.40.0
api/src/main/java/io/grpc/ClientStreamTracer.java:250
↓ 9 callers
Method
setMaxConcurrentStreams
(int num)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2265
↓ 9 callers
Method
setStatsEnabled
(NettyChannelBuilder builder, boolean value)
netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java:74
↓ 9 callers
Method
setTargetUser
Specifies the Android user in which the built Address' bind Intent will be evaluated. <p>Connecting to a server in a different Android user is uncomm
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:269
↓ 9 callers
Method
setText
()
opentelemetry/src/test/java/io/grpc/opentelemetry/MetadataSetterTest.java:54
↓ 9 callers
Method
setVerificationResult
(VerificationResult verificationResult)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:103
↓ 9 callers
Method
sign
Signs the input bytes by sending the request to the S2A srever. @param engine not used. @param signatureAlgorithm the {@link OpenSslPrivateKeyMethod}
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2APrivateKeyMethod.java:112
↓ 9 callers
Method
socketAddressToProto
(SocketAddress address)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:409
↓ 9 callers
Method
statusForCode
Looks up the {@link Status} from the given HTTP/2 error code. This is preferred over {@code forCode(code).status()}, to more easily conform to HTTP/2:
core/src/main/java/io/grpc/internal/GrpcUtil.java:422
↓ 9 callers
Method
subscribeToCluster
(String clusterName)
xds/src/main/java/io/grpc/xds/XdsConfig.java:257
↓ 9 callers
Method
synReply
(boolean outFinished, int streamId, List<Header> headerBlock)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameWriter.java:57
↓ 9 callers
Method
toHttp2Headers
Transform the given headers to a format where only spec-compliant ASCII characters are allowed. Binary header values are encoded by Base64 in the resu
core/src/main/java/io/grpc/internal/TransportFrameUtil.java:50
↓ 9 callers
Method
toSocket
(InternalInstrumented<SocketStats> obj)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:177
↓ 9 callers
Method
toString
()
api/src/context/java/io/grpc/Deadline.java:201
↓ 9 callers
Method
toSubchannelRef
(InternalWithLogId obj)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:101
↓ 9 callers
Method
transact
(int code, Parcel data, Parcel reply, int flags)
binder/src/testFixtures/java/io/grpc/binder/internal/FakeDeadBinder.java:58
↓ 9 callers
Method
transact
Enqueues a transaction for the wrapped {@link IBinder} with guaranteed "oneway" semantics. <p>NB: Unlike {@link IBinder#transact}, implementations of
binder/src/main/java/io/grpc/binder/internal/OneWayBinderProxy.java:96
↓ 9 callers
Method
typeName
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5387
↓ 9 callers
Method
typeName
()
xds/src/main/java/io/grpc/xds/client/XdsResourceType.java:68
↓ 9 callers
Method
updateBalancingState
(ConnectivityState state, SubchannelPicker picker)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:449
↓ 9 callers
Method
updateSpiffeTrustMap
(Map<String, List<X509Certificate>> spiffeTrustMap)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:49
↓ 9 callers
Method
verifyHttpError
( int streamId, int httpCode, Status.Code grpcCode, String errorDescription)
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1428
↓ 9 callers
Method
watch
<pre> Performs a watch for the serving status of the requested service. The server will immediately send back a message indicating the current serving
services/src/generated/main/grpc/io/grpc/health/v1/HealthGrpc.java:168
↓ 8 callers
Method
addCallback
Registers a callback on the given executor. The callback will run when SslContext becomes available or immediately if the result is already available.
xds/src/main/java/io/grpc/xds/internal/security/SslContextProvider.java:114
↓ 8 callers
Method
addDoubleCounter
Adds a value for a double-precision counter associated with specified metric instrument. @param metricInstrument The counter metric instrument identi
api/src/main/java/io/grpc/MetricSink.java:60
↓ 8 callers
Method
applicationProtocols
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:242
← previous
next →
1,701–1,800 of 22,628, ranked by callers