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
↓ 2 callersMethodsendPing
Send a ping to the remote endpoint. We expect a subsequent call to {@link #onPingResponse} with the same ID (assuming the ping succeeds).
binder/src/main/java/io/grpc/binder/internal/PingTracker.java:38
↓ 2 callersMethodsendShutdownTransportTransactionAsUid
(ClientTransport client, int sendingUid)
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:385
↓ 2 callersMethodsendTransaction
(int callId, ParcelHolder parcel)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:415
↓ 2 callersMethodsendUnexpectedResponse
()
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:132
↓ 2 callersMethodserializeHeaders
(Metadata metadata, BiConsumer<String, String> consumer)
servlet/src/main/java/io/grpc/servlet/ServletServerStream.java:129
↓ 2 callersMethodserializesToStreams
Returns whether this key will be serialized to bytes lazily.
api/src/main/java/io/grpc/Metadata.java:839
↓ 2 callersMethodserverHandler
(Blackhole bh, Http2Headers headers)
netty/src/jmh/java/io/grpc/netty/InboundHeadersBenchmark.java:124
↓ 2 callersMethodserverSendsOne_okFailsOnMissingResponse
( MethodDescriptor<Long, Long> method)
core/src/test/java/io/grpc/internal/ServerCallImplTest.java:311
↓ 2 callersMethodset
(int id, int idFlags, int value)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Settings.java:92
↓ 2 callersMethodsetAcceptParcelableMetadataValues
Sets whether the policy should accept parcelable metadata values.
binder/src/main/java/io/grpc/binder/InboundParcelablePolicy.java:78
↓ 2 callersMethodsetAddressAcceptanceStatus
(Status addressAcceptanceStatus)
core/src/test/java/io/grpc/internal/ServiceConfigErrorHandlingTest.java:675
↓ 2 callersMethodsetAddresses
Sets the addresses. This field is required. @return this.
api/src/main/java/io/grpc/LoadBalancer.java:302
↓ 2 callersMethodsetAdsConfig
(ControlPlaneRule controlPlane, String serverName)
xds/src/test/java/io/grpc/xds/XdsClientFallbackTest.java:199
↓ 2 callersMethodsetAndValidateGeneric
(Channel channel)
netty/src/test/java/io/grpc/netty/UtilsTest.java:177
↓ 2 callersMethodsetAttributes
Sets the attributes. This field is optional; if not called, {@link Attributes#EMPTY} will be used. @return this.
api/src/main/java/io/grpc/LoadBalancer.java:313
↓ 2 callersMethodsetBaseEjectionTimeNanos
The base time an address is ejected for.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:994
↓ 2 callersMethodsetChannelCredentials
( BinderChannelCredentials channelCredentials)
binder/src/test/java/io/grpc/binder/internal/ServiceBindingTest.java:529
↓ 2 callersMethodsetClientBinderDecorator
Sets the {@link OneWayBinderProxy.Decorator} to be applied to this server's "client Binders". <p>Tests can use this to capture post-setup transaction
binder/src/main/java/io/grpc/binder/internal/BinderServer.java:311
↓ 2 callersMethodsetDataSizeAndSincePing
(int dataSize)
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:268
↓ 2 callersMethodsetDelegate
(LoadBalancer lb)
core/src/main/java/io/grpc/internal/AutoConfiguredLoadBalancerFactory.java:151
↓ 2 callersMethodsetEvents
(List<Event> events)
api/src/main/java/io/grpc/InternalChannelz.java:513
↓ 2 callersMethodsetExchange
(Metadata metadata)
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:255
↓ 2 callersMethodsetExecutorServicePool
( ObjectPool<ScheduledExecutorService> executorServicePool)
binder/src/test/java/io/grpc/binder/internal/BinderServerTransportTest.java:141
↓ 2 callersMethodsetExecutorServicePool
Sets the executor to be used for scheduling channel timers. <p>Optional. A process-wide default executor will be used if unset.
binder/src/main/java/io/grpc/binder/internal/BinderServer.java:275
↓ 2 callersMethodsetExpectedRdsCount
(int count)
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:274
↓ 2 callersMethodsetExtensionRegistry
Sets the global registry for proto marshalling shared across all servers and clients. <p>Warning: This API will likely change over time. It is not
protobuf-lite/src/main/java/io/grpc/protobuf/lite/ProtoLiteUtils.java:76
↓ 2 callersMethodsetFailDuplicateCallbacks
Sets whether to fail on unexpected duplicate calls to callback methods.
testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java:73
↓ 2 callersMethodsetFailureReason
(String failureReason)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:109
↓ 2 callersMethodsetHealthCheckedService
(@Nullable String service)
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:136
↓ 2 callersMethodsetHistorySeconds
(int historySeconds)
rls/src/main/java/io/grpc/rls/AdaptiveThrottler.java:160
↓ 2 callersMethodsetInUse
(OkHttpClientStream stream)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:1233
↓ 2 callersMethodsetInboundParcelablePolicy
Sets the {@link InboundParcelablePolicy} to be used for built servers. <p>Optional, {@link InboundParcelablePolicy#DEFAULT} is the default.
binder/src/main/java/io/grpc/binder/internal/BinderServer.java:296
↓ 2 callersMethodsetListener
(LdsUpdate listener)
xds/src/main/java/io/grpc/xds/XdsConfig.java:226
↓ 2 callersMethodsetLocalHostname
Sets the local identity of the client in the form of a hostname. The client may set at most 1 local identity. If no local identity is specified, then
s2a/src/main/java/io/grpc/s2a/S2AChannelCredentials.java:89
↓ 2 callersMethodsetMaxEjectionTimeNanos
The longest time an address can be ejected.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:1000
↓ 2 callersMethodsetMetricRecorder
(MetricRecorder metricRecorder)
core/src/main/java/io/grpc/internal/ClientTransportFactory.java:111
↓ 2 callersMethodsetNameResolverArg
(NameResolver.Args.Key<X> key, X value)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:622
↓ 2 callersMethodsetNeedClientAuth
(boolean need)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2556
↓ 2 callersMethodsetOptions
(ClientTransportOptions options)
binder/src/testFixtures/java/io/grpc/binder/internal/BinderClientTransportBuilder.java:47
↓ 2 callersMethodsetOutgoingBinder
Sets the binder to use for sending subsequent transactions to our peer. <p>Subclasses should call this as early as possible but not from a constructo
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:289
↓ 2 callersMethodsetPinging
(boolean pingOut)
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:232
↓ 2 callersMethodsetPreviousAttempts
Set the number of preceding attempts of the RPC. @since 1.40.0
api/src/main/java/io/grpc/ClientStreamTracer.java:240
↓ 2 callersMethodsetProtocolNegotiatorFactory
Sets the {@link ProtocolNegotiatorFactory} to be used. Overrides any specified negotiation type and {@code SslContext}.
netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java:52
↓ 2 callersMethodsetPseudoHeader
(AsciiString name, AsciiString value)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:400
↓ 2 callersMethodsetRandom
Only used for unit test, as we do not want to introduce randomness in unit test.
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideClient.java:306
↓ 2 callersMethodsetRatioForAccepts
(float ratioForAccepts)
rls/src/main/java/io/grpc/rls/AdaptiveThrottler.java:155
↓ 2 callersMethodsetRawMethodName
(MethodDescriptor<?, ?> descriptor, Object o)
api/src/main/java/io/grpc/InternalMethodDescriptor.java:38
↓ 2 callersMethodsetRawScheme
(String scheme)
api/src/main/java/io/grpc/Uri.java:716
↓ 2 callersMethodsetRealCall
(ClientCall<ReqT, RespT> realCall)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:336
↓ 2 callersMethodsetRealStream
(ClientStream realStream)
core/src/main/java/io/grpc/internal/DelayedStream.java:346
↓ 2 callersMethodsetRemoteException
Causes all future invocations of transact to throw `remoteException`. <p>Users are responsible for ensuring their calls "happen-before" the relevant
binder/src/testFixtures/java/io/grpc/binder/internal/OneWayBinderProxies.java:91
↓ 2 callersMethodsetRequestsPadding
(int requestsPadding)
rls/src/main/java/io/grpc/rls/AdaptiveThrottler.java:165
↓ 2 callersMethodsetReuseAddress
(boolean on)
android/src/main/java/io/grpc/android/UdsSocket.java:257
↓ 2 callersMethodsetRpcVersions
()
alts/src/test/java/io/grpc/alts/internal/AltsHandshakerClientTest.java:253
↓ 2 callersMethodsetSecurityAttrs
(Attributes attributes, int uid)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:537
↓ 2 callersMethodsetServer
()
inprocess/src/test/java/io/grpc/inprocess/AnonymousInProcessSocketAddressTest.java:40
↓ 2 callersMethodsetServerAddress
(SocketAddress serverAddress)
binder/src/testFixtures/java/io/grpc/binder/internal/BinderClientTransportBuilder.java:37
↓ 2 callersMethodsetStatsEnabled
(OkHttpChannelBuilder builder, boolean value)
okhttp/src/main/java/io/grpc/okhttp/InternalOkHttpChannelBuilder.java:28
↓ 2 callersMethodsetStatsRecordFinishedRpcs
Disable or enable stats recording for RPC completions. Effective only if {@link #setStatsEnabled} is set to true. Enabled by default.
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:230
↓ 2 callersMethodsetStatsRecordStartedRpcs
Disable or enable stats recording for RPC upstarts. Effective only if {@link #setStatsEnabled} is set to true. Enabled by default.
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:222
↓ 2 callersMethodsetStatus
(String service, ServingStatus status)
services/src/main/java/io/grpc/protobuf/services/HealthServiceImpl.java:126
↓ 2 callersMethodsetStatusInternal
(String service, ServingStatus status)
services/src/main/java/io/grpc/protobuf/services/HealthServiceImpl.java:136
↓ 2 callersMethodsetStreamTracerFactories
Sets the source for {@link ServerStreamTracer}s that will be installed on all new streams. <p>Required.
binder/src/main/java/io/grpc/binder/internal/BinderServer.java:254
↓ 2 callersMethodsetSubsetSize
(long subsetSize)
util/src/main/java/io/grpc/util/RandomSubsettingLoadBalancer.java:141
↓ 2 callersMethodsetTcpInfo
(TcpInfo tcpInfo)
api/src/main/java/io/grpc/InternalChannelz.java:1025
↓ 2 callersMethodsetTicker
Sets a specified time source for monitoring cleanup timeout. @return this
testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java:102
↓ 2 callersMethodsetTransportTracerFactory
(OkHttpServerBuilder builder, TransportTracer.Factory transportTracerFactory)
okhttp/src/main/java/io/grpc/okhttp/InternalOkHttpServerBuilder.java:36
↓ 2 callersMethodsetUp
()
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:308
↓ 2 callersMethodsetWeightExpirationPeriodNanos
(long weightExpirationPeriodNanos)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:850
↓ 2 callersMethodsetupBackends
(int backendCount)
util/src/test/java/io/grpc/util/RandomSubsettingLoadBalancerTest.java:107
↓ 2 callersMethodsetupPingTest
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:515
↓ 2 callersMethodshortName
()
api/src/main/java/io/grpc/InternalLogId.java:109
↓ 2 callersMethodshouldBeCountedForInUse
()
netty/src/main/java/io/grpc/netty/CreateStreamCommand.java:50
↓ 2 callersMethodshouldEscape
(char c)
core/src/main/java/io/grpc/internal/GrpcUtil.java:912
↓ 2 callersMethodshouldInvalidateEldestEntry
Determines if the eldest entry should be kept or not when the cache size limit is reached. Note that LruCache is access level and the eldest is determ
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:88
↓ 2 callersMethodshouldRejectOnMetadataSizeSoftLimitExceeded
( int h2HeadersSize, int softLimitHeaderListSize, int maxHeaderListSize)
netty/src/main/java/io/grpc/netty/Utils.java:245
↓ 2 callersMethodshutDown
Stop listening and release resources.
android-interop-testing/src/main/java/io/grpc/android/integrationtest/UdsTcpEndpointConnector.java:101
↓ 2 callersMethodshutdown
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:294
↓ 2 callersMethodshutdown
(ManagedChannel mc)
netty/src/test/java/io/grpc/netty/NettyChannelBuilderTest.java:52
↓ 2 callersMethodshutdown
()
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:877
↓ 2 callersMethodshutdownActiveFilters
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:591
↓ 2 callersMethodshutdownAndTerminate
(ExecutorService executorService)
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:199
↓ 2 callersMethodshutdownLbComm
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:388
↓ 2 callersMethodshutdownLoadBalancer
()
xds/src/test/java/io/grpc/xds/CdsLoadBalancer2Test.java:215
↓ 2 callersMethodshutdownNow
Initiates a forceful shutdown in which preexisting and new calls are closed. Existing calls should be closed with the provided {@code reason} and {@co
core/src/main/java/io/grpc/internal/KeepAliveManager.java:278
↓ 2 callersMethodshutdownNow
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:266
↓ 2 callersMethodshutdownRemovedAddresses
Compute the difference between the flattened new addresses and the old addresses that had been made into subchannels and then shutdown the matching su
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:192
↓ 2 callersMethodsize
()
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:201
↓ 2 callersMethodsplitAndAdd
(String value)
core/src/test/java/io/grpc/internal/CompositeReadableBufferTest.java:280
↓ 2 callersMethodsplitAtFirstDelimiter
(String s)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:392
↓ 2 callersMethodsslContext
SSL/TLS context to use instead of the system default. It must have been configured with {@link GrpcSslContexts}, but options could have been overridde
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:380
↓ 2 callersMethodstandardDeviation
Calculates the standard deviation for the given values and their mean.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:864
↓ 2 callersMethodstart
(ClientStreamListener listener)
core/src/main/java/io/grpc/internal/FailingClientStream.java:54
↓ 2 callersMethodstart
Starts transport. Implementations must not call {@code listener} until after {@code start()} returns. The method only returns after it has done the eq
core/src/main/java/io/grpc/internal/InternalServer.java:41
↓ 2 callersMethodstart
Starts transport. This method may only be called once. <p>This method and the returned {@code Runnable} should not throw any exceptions. @param list
core/src/main/java/io/grpc/internal/ManagedClientTransport.java:48
↓ 2 callersMethodstart
()
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestServer.java:196
↓ 2 callersMethodstart
()
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceServer.java:149
↓ 2 callersMethodstartCall
( ClientCall<ReqT, RespT> call, StartableListener<RespT> responseListener)
stub/src/main/java/io/grpc/stub/ClientCalls.java:432
↓ 2 callersMethodstartChainingServer
Create a chain of client to server calls which can be cancelled top down. @return a Future that completes when call chain is created
interop-testing/src/test/java/io/grpc/testing/integration/CascadingTest.java:230
↓ 2 callersMethodstartDelegateServer
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:337
← previousnext →5,201–5,300 of 22,628, ranked by callers