MCPcopy Create free account

hub / github.com/grpc/grpc-java / functions

Functions22,628 in github.com/grpc/grpc-java

↓ 9 callersMethodexecute
(Runnable runnable)
stub/src/main/java/io/grpc/stub/ClientCalls.java:854
↓ 9 callersMethodextractPeerObject
Returns the peer extracted from a completed handshake. @return the extracted peer.
alts/src/main/java/io/grpc/alts/internal/TsiHandshaker.java:89
↓ 9 callersMethodfail
(Status status)
binder/src/main/java/io/grpc/binder/internal/PingTracker.java:99
↓ 9 callersMethodfakeCurrentTimeNanos
Returns the current time, for tests that rely on the clock.
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:248
↓ 9 callersMethodfilterChains
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:308
↓ 9 callersMethodfilterStateTestVhost
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:1726
↓ 9 callersMethodfromString
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 callersMethodgenerateListenerUpdate
(FakeXdsClient xdsClient, EnvoyServerProtoData.DownstreamTlsContext tlsCo
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:87
↓ 9 callersMethodgetAddressesFromPick
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 callersMethodgetByteBuffer
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 callersMethodgetClusterDropStats
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 callersMethodgetDefaultInstance
()
alts/src/main/java/io/grpc/alts/internal/AltsInternalContext.java:41
↓ 9 callersMethodgetEffectiveInterceptors
(String computedTarget)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:744
↓ 9 callersMethodgetFallbackTimeoutMs
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbConfig.java:53
↓ 9 callersMethodgetHandshakeSession
()
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:1226
↓ 9 callersMethodgetHealthService
Gets the health check service created in the constructor.
services/src/main/java/io/grpc/services/HealthStatusManager.java:55
↓ 9 callersMethodgetId
()
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:231
↓ 9 callersMethodgetInboundUncompressedSize
Returns to sum of all sizes passed to {@link StreamTracer#inboundUncompressedSize}.
testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java:58
↓ 9 callersMethodgetLink
()
netty/src/main/java/io/grpc/netty/WriteQueue.java:231
↓ 9 callersMethodgetMetricValue
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 callersMethodgetOrCreateOrcaListener
(float errorUtilizationPenalty, ImmutableList<ParsedMetricName> parsedMetricNamesForComputingUtilizati
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:332
↓ 9 callersMethodgetOutboundHeaders
Returns if {@link ClientStreamTracer#outboundHeaders} has been called.
testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java:68
↓ 9 callersMethodgetPackage
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 callersMethodgetPingCount
()
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:248
↓ 9 callersMethodgetPort
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1473
↓ 9 callersMethodgetReportIntervalNanos
Returns the configured maximum interval of receiving out-of-band ORCA reports.
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:591
↓ 9 callersMethodgetReportTimer
()
netty/src/main/java/io/grpc/netty/TcpMetrics.java:192
↓ 9 callersMethodgetRequestCostMetrics
()
services/src/main/java/io/grpc/services/MetricReport.java:65
↓ 9 callersMethodgetResponses
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceV1Test.java:648
↓ 9 callersMethodgetResponses
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java:648
↓ 9 callersMethodgetRootChannels
Returns a {@link RootChannelList}.
api/src/main/java/io/grpc/InternalChannelz.java:145
↓ 9 callersMethodgetSampler
Get sampler for TraceConfig - when Cloud Tracing is enabled.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:47
↓ 9 callersMethodgetScheduledExecutorService
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 callersMethodgetSubchannel
(EquivalentAddressGroup removedEag)
xds/src/test/java/io/grpc/xds/LeastRequestLoadBalancerTest.java:228
↓ 9 callersMethodgetToken
Returns an access token for the given identity.
s2a/src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/TokenFetcher.java:27
↓ 9 callersMethodgetTransportTracer
()
core/src/main/java/io/grpc/internal/AbstractStream.java:371
↓ 9 callersMethodgetUserInfo
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 callersMethodgetWatchers
(TrackedWatcherType<T> watcherType)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:285
↓ 9 callersMethodgrpcKeybuilders
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 callersMethodgrpcResponseHeaders
()
netty/src/test/java/io/grpc/netty/NettyClientStreamTest.java:597
↓ 9 callersMethodhandleResolvedAddresses
(ResolvedAddresses resolvedAddresses)
util/src/main/java/io/grpc/util/ForwardingLoadBalancer.java:32
↓ 9 callersMethodhasPendingStreams
()
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:263
↓ 9 callersMethodheaderBytes
()
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/ConfigFilterHelper.java:97
↓ 9 callersMethodheadersToRemove
()
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutations.java:33
↓ 9 callersMethodisBefore
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 callersMethodisCancelled
()
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:559
↓ 9 callersMethodisEnableCloudMonitoring
Is Cloud Monitoring enabled.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:32
↓ 9 callersMethodisEnabledHappyEyeballs
()
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:645
↓ 9 callersMethodisInUse
()
netty/src/test/java/io/grpc/netty/NettyTestUtil.java:82
↓ 9 callersMethodkeyMap
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 callersMethodlog
(ChannelLogLevel level, String message)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:887
↓ 9 callersMethodlookupServiceTimeoutInNanos
Returns the timeout value for lookup service requests.
rls/src/main/java/io/grpc/rls/RlsProtoData.java:113
↓ 9 callersMethodnewBuilder
Creates a new builder.
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:586
↓ 9 callersMethodnewClientCallTracer
Creates a {@link CallAttemptsTracerFactory} for a new call.
census/src/main/java/io/grpc/census/CensusTracingModule.java:127
↓ 9 callersMethodnewServerStreamTracer
( String fullMethodName, Metadata headers)
core/src/test/java/io/grpc/internal/ServerImplTest.java:530
↓ 9 callersMethodnewThrottledRetriableStream
(Throttle throttle)
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:212
↓ 9 callersMethodnotifyShutdown
Returns {@code true} if was the first shutdown.
netty/src/main/java/io/grpc/netty/ClientTransportLifecycleManager.java:68
↓ 9 callersMethodparseHeaderMatcher
( io.envoyproxy.envoy.config.route.v3.HeaderMatcher proto)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:386
↓ 9 callersMethodpayload
()
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:162
↓ 9 callersMethodpickSubchannel
(PickSubchannelArgs args)
util/src/test/java/io/grpc/util/MultiChildLoadBalancerTest.java:413
↓ 9 callersMethodpickSubchannel
(PickSubchannelArgs args)
util/src/main/java/io/grpc/util/RoundRobinLoadBalancer.java:139
↓ 9 callersMethodpickSubchannel
(SubchannelPicker picker, String clusterName)
xds/src/test/java/io/grpc/xds/ClusterManagerLoadBalancerTest.java:315
↓ 9 callersMethodpolicy
(Function<Integer, Boolean> func)
binder/src/androidTest/java/io/grpc/binder/BinderSecurityTest.java:319
↓ 9 callersMethodrecordLongHistogram
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 callersMethodrecordMemoryUtilizationMetric
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 callersMethodresetCounters
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 callersMethodretryableStatusCodes
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:283
↓ 9 callersMethodreturnObject
(XdsClient xdsClient)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:1054
↓ 9 callersMethodscheduleFlush
Schedule a flush on the channel.
netty/src/main/java/io/grpc/netty/WriteQueue.java:63
↓ 9 callersMethodselectConfig
Selects the config for an RPC.
api/src/main/java/io/grpc/InternalConfigSelector.java:39
↓ 9 callersMethodsend
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:207
↓ 9 callersMethodsetAutoCreate
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 callersMethodsetConfigurators
(List<InternalConfigurator> configurators)
api/src/main/java/io/grpc/InternalConfiguratorRegistry.java:28
↓ 9 callersMethodsetHandler
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 callersMethodsetIsTransparentRetry
Sets whether the stream is a transparent retry. @since 1.40.0
api/src/main/java/io/grpc/ClientStreamTracer.java:250
↓ 9 callersMethodsetMaxConcurrentStreams
(int num)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2265
↓ 9 callersMethodsetStatsEnabled
(NettyChannelBuilder builder, boolean value)
netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java:74
↓ 9 callersMethodsetTargetUser
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 callersMethodsetText
()
opentelemetry/src/test/java/io/grpc/opentelemetry/MetadataSetterTest.java:54
↓ 9 callersMethodsetVerificationResult
(VerificationResult verificationResult)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:103
↓ 9 callersMethodsign
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 callersMethodsocketAddressToProto
(SocketAddress address)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:409
↓ 9 callersMethodstatusForCode
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 callersMethodsubscribeToCluster
(String clusterName)
xds/src/main/java/io/grpc/xds/XdsConfig.java:257
↓ 9 callersMethodsynReply
(boolean outFinished, int streamId, List<Header> headerBlock)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameWriter.java:57
↓ 9 callersMethodtoHttp2Headers
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 callersMethodtoSocket
(InternalInstrumented<SocketStats> obj)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:177
↓ 9 callersMethodtoString
()
api/src/context/java/io/grpc/Deadline.java:201
↓ 9 callersMethodtoSubchannelRef
(InternalWithLogId obj)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:101
↓ 9 callersMethodtransact
(int code, Parcel data, Parcel reply, int flags)
binder/src/testFixtures/java/io/grpc/binder/internal/FakeDeadBinder.java:58
↓ 9 callersMethodtransact
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 callersMethodtypeName
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5387
↓ 9 callersMethodtypeName
()
xds/src/main/java/io/grpc/xds/client/XdsResourceType.java:68
↓ 9 callersMethodupdateBalancingState
(ConnectivityState state, SubchannelPicker picker)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:449
↓ 9 callersMethodupdateSpiffeTrustMap
(Map<String, List<X509Certificate>> spiffeTrustMap)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:49
↓ 9 callersMethodverifyHttpError
( int streamId, int httpCode, Status.Code grpcCode, String errorDescription)
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1428
↓ 9 callersMethodwatch
<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 callersMethodaddCallback
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 callersMethodaddDoubleCounter
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 callersMethodapplicationProtocols
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:242
← previousnext →1,701–1,800 of 22,628, ranked by callers