MCPcopy Create free account

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

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

⨍ Functions 22,628◇ Types & classes 3,835
↓ 4 callersMethodpayload
Returns the expected ping payload for this outstanding operation. @return the expected payload for this outstanding ping
core/src/main/java/io/grpc/internal/Http2Ping.java:113
↓ 4 callersMethodperformSoakTest
Runs large unary RPCs in a loop with configurable failure thresholds and channel creation behavior.
interop-testing/src/main/java/io/grpc/testing/integration/SoakClient.java:119
↓ 4 callersMethodpickSubchannel
(PickSubchannelArgs args)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:1005
↓ 4 callersMethodpluginName
()
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:95
↓ 4 callersMethodprefixedClusterName
(String name)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:657
↓ 4 callersMethodpresent
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:55
↓ 4 callersMethodrange
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:51
↓ 4 callersMethodreadAsString
Reads the entire {@link ReadableBuffer} to a new {@link String} with the given charset.
core/src/main/java/io/grpc/internal/ReadableBuffers.java:88
↓ 4 callersMethodreadableNioBuffers
Called to get access to the underlying NIO buffers for a {@link ByteBuf} that will be used for reading.
alts/src/main/java/io/grpc/alts/internal/BufUnwrapper.java:54
↓ 4 callersMethodrecordAnnotation
( Span span, MessageEvent.Type type, int seqNo, boolean isCompressed, long size)
census/src/main/java/io/grpc/census/CensusTracingModule.java:232
↓ 4 callersMethodregion
()
xds/src/main/java/io/grpc/xds/client/Locality.java:26
↓ 4 callersMethodregister
Allow tests to register a provider using test clock.
xds/src/test/java/io/grpc/xds/internal/security/certprovider/CommonCertProviderTestUtils.java:48
↓ 4 callersMethodregister0
()
xds/src/test/java/io/grpc/xds/internal/security/certprovider/CommonCertProviderTestUtils.java:62
↓ 4 callersMethodregisterParser
(MetadataValueParser parser)
xds/src/main/java/io/grpc/xds/MetadataRegistry.java:55
↓ 4 callersMethodreleaseBlock
Release a now-unused block.
binder/src/main/java/io/grpc/binder/internal/BlockPool.java:74
↓ 4 callersMethodremoteAddress
()
xds/src/test/java/io/grpc/xds/XdsClientWrapperForServerSdsTestMisc.java:147
↓ 4 callersMethodremoveClientSocket
(InternalInstrumented<SocketStats> socket)
api/src/main/java/io/grpc/InternalChannelz.java:128
↓ 4 callersMethodremoveRootChannel
(InternalInstrumented<ChannelStats> channel)
api/src/main/java/io/grpc/InternalChannelz.java:124
↓ 4 callersMethodremoveServer
Removes a server.
api/src/main/java/io/grpc/InternalChannelz.java:113
↓ 4 callersMethodreplaceInappropriateControlPlaneStatus
Some status codes from the control plane are not appropritate to use in the data plane. If one is given it will be replaced with INTERNAL, indicating
core/src/main/java/io/grpc/internal/GrpcUtil.java:822
↓ 4 callersMethodreportCallEnded
(boolean success)
core/src/main/java/io/grpc/internal/CallTracer.java:43
↓ 4 callersMethodreportCallbackMetrics
(BatchRecorder recorder, XdsClient xdsClient)
xds/src/main/java/io/grpc/xds/XdsClientMetricReporterImpl.java:135
↓ 4 callersMethodreportEqual
(MetricReport a, MetricReport b)
xds/src/test/java/io/grpc/xds/orca/OrcaPerRequestUtilTest.java:119
↓ 4 callersMethodreportKeepAliveSent
Reports that a keep alive message was sent.
core/src/main/java/io/grpc/internal/TransportTracer.java:127
↓ 4 callersMethodreportMessageSent
Reports that some messages were successfully sent. {@code numMessages} must be at least 0.
core/src/main/java/io/grpc/internal/TransportTracer.java:108
↓ 4 callersMethodrequest
(final int numMessages)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:378
↓ 4 callersMethodrequestConnection
Asks the Subchannel to create a connection (aka transport), if there isn't an active one. <p>It should be called from the Synchronization Context. C
api/src/main/java/io/grpc/LoadBalancer.java:1391
↓ 4 callersMethodrequestMessages
(int num)
binder/src/main/java/io/grpc/binder/internal/Inbound.java:330
↓ 4 callersMethodreset
Repositions this buffer to the position at the time {@link #mark} was last called on this buffer.
core/src/main/java/io/grpc/internal/ReadableBuffer.java:142
↓ 4 callersMethodresolveDefaultValue
(boolean isAndroid)
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:447
↓ 4 callersMethodrewriteAuthorizationPolicy
(String newPolicy)
authz/src/test/java/io/grpc/authz/AuthorizationEnd2EndTest.java:97
↓ 4 callersMethodrunPendingRunnables
()
auth/src/test/java/io/grpc/auth/GoogleAuthLibraryCallCredentialsTest.java:438
↓ 4 callersMethodrunServers
(String hostname, Collection<Integer> grpcPorts, Collection<Integer> xdsPorts, Collection<Integer> tlsPo
istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:209
↓ 4 callersMethodrunStoredProducer
()
core/src/test/java/io/grpc/internal/ApplicationThreadDeframerTest.java:140
↓ 4 callersMethodrunTask
()
core/src/test/java/io/grpc/internal/SharedResourceHolderTest.java:282
↓ 4 callersMethodsafeCloseMasterListener
(Status status, RpcProgress progress, Metadata metadata)
core/src/main/java/io/grpc/internal/RetriableStream.java:839
↓ 4 callersMethodsayHello
(HelloRequest request, StreamObserver<HelloReply> responseObserver)
examples/src/test/java/io/grpc/examples/header/HeaderServerInterceptorTest.java:72
↓ 4 callersMethodsayHello
(HelloRequest request, StreamObserver<HelloReply> responseObserver)
examples/src/main/java/io/grpc/examples/errorhandling/ErrorHandlingClient.java:61
↓ 4 callersMethodsayHello
(HelloRequest request, StreamObserver<HelloReply> responseObserver)
examples/src/main/java/io/grpc/examples/errordetails/ErrorDetailsExample.java:83
↓ 4 callersMethodscheduleAtFixedRate
( Runnable cmd, long initialDelay, long period, TimeUnit unit)
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:154
↓ 4 callersMethodscheduleWithFixedDelay
Schedules a task to be added and run via {@link #execute} after an initial delay and then repeated after the delay until cancelled. @param task the t
api/src/main/java/io/grpc/SynchronizationContext.java:185
↓ 4 callersMethodsendHeaders
(Metadata headers)
binder/src/androidTest/java/io/grpc/binder/BinderChannelSmokeTest.java:389
↓ 4 callersMethodserialize
(Metadata md)
api/src/main/java/io/grpc/InternalMetadata.java:77
↓ 4 callersMethodservice
()
rls/src/main/java/io/grpc/rls/RlsProtoData.java:244
↓ 4 callersMethodserviceParamsBuilder
Create a new {@link ServiceParams} builder.
binder/src/androidTest/java/io/grpc/binder/HostServices.java:111
↓ 4 callersMethodsetBindIntent
Sets the binding {@link Intent} to one having the "filter matching" fields of 'intent'. <p>'intent' must be "explicit", i.e. having either a target c
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:239
↓ 4 callersMethodsetBinderDecorator
( OneWayBinderProxy.Decorator binderDecorator)
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:164
↓ 4 callersMethodsetBuildVersion
(String buildVersion)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:182
↓ 4 callersMethodsetConfigurators
()
api/src/test/java/io/grpc/ConfiguratorRegistryTest.java:36
↓ 4 callersMethodsetEnableNewPickFirst
(boolean enableNewPickFirst)
core/src/testFixtures/java/io/grpc/internal/PickFirstLoadBalancerProviderAccessor.java:25
↓ 4 callersMethodsetEnableXdsFallback
(boolean target)
xds/src/test/java/io/grpc/xds/client/CommonBootstrapperTestUtils.java:163
↓ 4 callersMethodsetFlowControlWindowReader
Registers a {@link FlowControlReader} that can be used to read the local and remote flow control window sizes.
core/src/main/java/io/grpc/internal/TransportTracer.java:135
↓ 4 callersMethodsetFullStreamDecompressor
Sets the decompressor used for full-stream decompression. Full-stream decompression disables any per-message decompressor set by {@link #setDecompress
core/src/main/java/io/grpc/internal/Deframer.java:41
↓ 4 callersMethodsetFuture
(Future<?> future)
core/src/main/java/io/grpc/internal/RetriableStream.java:1593
↓ 4 callersMethodsetHandshakerAddressForTesting
Sets a new handshaker service address for testing.
alts/src/main/java/io/grpc/alts/AltsServerBuilder.java:67
↓ 4 callersMethodsetHelper
(Helper helper)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:866
↓ 4 callersMethodsetHttp2Stream
Sets the underlying Netty {@link Http2Stream} for this stream. This must be called in the context of the transport thread.
netty/src/main/java/io/grpc/netty/NettyClientStream.java:269
↓ 4 callersMethodsetHttpConnectProxiedSocketAddress
( @Nullable HttpConnectProxiedSocketAddress connectProxiedSocketAddr)
core/src/main/java/io/grpc/internal/ClientTransportFactory.java:152
↓ 4 callersMethodsetInterceptor
Sets the interceptor. This field is optional. @return this
api/src/main/java/io/grpc/InternalConfigSelector.java:111
↓ 4 callersMethodsetIsHedging
Sets whether the stream is hedging. @since 1.74.0
api/src/main/java/io/grpc/ClientStreamTracer.java:260
↓ 4 callersMethodsetLbPolicyConfig
(LbPolicyConfiguration lbPolicyConfig)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:871
↓ 4 callersMethodsetMetricRecorder
See {@link Args#getMetricRecorder()}. This is an optional field.
api/src/main/java/io/grpc/NameResolver.java:682
↓ 4 callersMethodsetMode
(String mode)
interop-testing/src/test/java/io/grpc/testing/integration/ProxyTest.java:191
↓ 4 callersMethodsetOffloadExecutorPool
(ObjectPool<? extends Executor> offloadExecutorPool)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransportFactory.java:147
↓ 4 callersMethodsetPreAuthorizeServers
Whether to check server addresses against the SecurityPolicy before binding to them.
binder/src/main/java/io/grpc/binder/internal/BinderClientTransportFactory.java:221
↓ 4 callersMethodsetRdsConfig
(RouteConfiguration routeConfiguration)
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:212
↓ 4 callersMethodsetReader
(StreamObserver<SessionResp> reader)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:91
↓ 4 callersMethodsetResolvedAddressesFactory
Sets a factory to create {@link ResolvedAddresses} for child load balancer.
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:884
↓ 4 callersMethodsetResolvingAddresses
This should ONLY be used by tests.
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:143
↓ 4 callersMethodsetScheduledExecutorPool
( ObjectPool<ScheduledExecutorService> scheduledExecutorPool)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransportFactory.java:162
↓ 4 callersMethodsetServerHostName
(String serverHostName)
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:99
↓ 4 callersMethodsetServiceStatus
(Status status)
alts/src/test/java/io/grpc/alts/internal/AltsHandshakerStubTest.java:138
↓ 4 callersMethodsetSocketOptionTimeoutMillis
The value of {@link java.net.Socket#getSoTimeout()}.
api/src/main/java/io/grpc/InternalChannelz.java:1012
↓ 4 callersMethodsetSourceContext
(Context sourceContext)
binder/src/test/java/io/grpc/binder/internal/ServiceBindingTest.java:499
↓ 4 callersMethodsetTargetServiceAccounts
(ImmutableList<String> targetServiceAccounts)
alts/src/main/java/io/grpc/alts/internal/AltsClientOptions.java:63
↓ 4 callersMethodsetTcpNoDelay
(boolean on)
android/src/main/java/io/grpc/android/UdsSocket.java:285
↓ 4 callersMethodsetUpSession
(StreamObserver<SessionResp> responseObserver)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeS2AServer.java:39
↓ 4 callersMethodshouldAccept
Inspect the Runnable and returns true if it should be accepted.
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:419
↓ 4 callersMethodshouldCompose
(CompositeByteBuf composite, ByteBuf in, int composeMinSize)
netty/src/main/java/io/grpc/netty/NettyAdaptiveCumulator.java:120
↓ 4 callersMethodshouldHeadersBeFlushed
(boolean shouldBeFlushed)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:1500
↓ 4 callersMethodshutdown
Initiates an orderly shutdown of the transport. Existing streams continue, but the transport will not own any new streams. New streams will either f
core/src/main/java/io/grpc/internal/ManagedClientTransport.java:58
↓ 4 callersMethodshutdown
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:250
↓ 4 callersMethodshutdownNow
Initiates a forceful shutdown in which preexisting and new calls are rejected. Although forceful, the shutdown process is still not instantaneous; {@l
api/src/main/java/io/grpc/Server.java:141
↓ 4 callersMethodshutdownUponDestruction
Arranges for {@link ManagedChannel#shutdownNow()} to be called on {@code channel} just before {@code lifecycle} is destroyed, or immediately if {@code
binder/src/main/java/io/grpc/binder/LifecycleOnDestroyHelper.java:44
↓ 4 callersMethodsleepAtLeast
(long millis)
examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java:521
↓ 4 callersMethodsnapshot
()
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:302
↓ 4 callersMethodstartClient
(Control.ClientArgs clientArgs)
benchmarks/src/test/java/io/grpc/benchmarks/driver/LoadWorkerTest.java:218
↓ 4 callersMethodstartServer
(Control.ServerArgs serverArgs)
benchmarks/src/test/java/io/grpc/benchmarks/driver/LoadWorkerTest.java:249
↓ 4 callersMethodstartTask
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:446
↓ 4 callersMethodstatusFromRemoteException
(RemoteException e)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:610
↓ 4 callersMethodstopIfNecessary
When the transport is in goAway state, we should stop it once all active streams finish.
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:1184
↓ 4 callersMethodstopServers
()
istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:244
↓ 4 callersMethodstorage
()
api/src/context/java/io/grpc/Context.java:105
↓ 4 callersMethodsubtestFailRpcFromBalancer
(boolean waitForReady, boolean drop, boolean shouldFail)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:1446
↓ 4 callersMethodsubtestGrpclbFallbackTimeout
(boolean timerExpires, long timeout)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:1199
↓ 4 callersMethodsubtestPanic
(ConnectivityState initialState)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:2439
↓ 4 callersMethodsubtestStatsHeadersPropagateTags
(boolean propagate, boolean recordStats)
census/src/test/java/io/grpc/census/CensusModulesTest.java:918
↓ 4 callersMethodtestStreamClose_setup
( final AtomicReference<ServerCall<String, Integer>> callReference, final AtomicReference<Context>
core/src/test/java/io/grpc/internal/ServerImplTest.java:1322
↓ 4 callersMethodtimeoutNano
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:154
↓ 4 callersMethodtoString
()
rls/src/main/java/io/grpc/rls/RlsRequestFactory.java:113
← previousnext →3,301–3,400 of 22,628, ranked by callers