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 callersMethodhandleReflectionRequest
()
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:170
↓ 2 callersMethodhandleRequest
( ClientStatusRequest request, StreamObserver<ClientStatusResponse> responseObserver)
xds/src/main/java/io/grpc/xds/CsdsService.java:120
↓ 2 callersMethodhandleResolvedAddresses
(ResolvedAddresses resolvedAddresses)
interop-testing/src/main/java/io/grpc/testing/integration/RpcBehaviorLoadBalancerProvider.java:113
↓ 2 callersMethodhandleRpcCompleted
(long requestId, RpcType rpcType, String hostname, Set<XdsStatsWatcher> watchers)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:453
↓ 2 callersMethodhandleRpcError
(long requestId, RpcType rpcType, Status status, Set<XdsStatsWatcher> watchers)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:459
↓ 2 callersMethodhandleStreamClosed
(Status error)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:799
↓ 2 callersMethodhandleStreamClosed
(Status status)
xds/src/main/java/io/grpc/xds/client/LoadReportClient.java:279
↓ 2 callersMethodhandleTermination
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:484
↓ 2 callersMethodhandleTransportInUseState
( final ConnectionClientTransport transport, final boolean inUse)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:494
↓ 2 callersMethodhandlerAdded
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:441
↓ 2 callersMethodhandshakeSmallBufferTest
(Handshakers handshakers)
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:113
↓ 2 callersMethodhandshakeTest
(Handshakers handshakers)
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:109
↓ 2 callersMethodhandshakerSocketFactoryFrom
(ServerCredentials creds)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:408
↓ 2 callersMethodhasCertProviderInstance
(CommonTlsContext commonTlsContext)
xds/src/main/java/io/grpc/xds/internal/security/CommonTlsContextUtil.java:27
↓ 2 callersMethodhasDataValue
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:620
↓ 2 callersMethodhasPendingDeliveries
()
core/src/main/java/io/grpc/internal/MessageDeframer.java:208
↓ 2 callersMethodhasReceivedEndOfStream
Must be holding 'lock' when calling.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:1160
↓ 2 callersMethodhasResult
()
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:824
↓ 2 callersMethodhasThrottle
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:699
↓ 2 callersMethodhasWritten
()
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:202
↓ 2 callersMethodhashByte
(byte input)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:88
↓ 2 callersMethodhashChar
(char input)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:84
↓ 2 callersMethodhashCode
()
inprocess/src/main/java/io/grpc/inprocess/InProcessSocketAddress.java:60
↓ 2 callersMethodhashCode
()
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:118
↓ 2 callersMethodhashCode
Returns a hash code for the attributes. <p>Note that if a stored values are mutable, it is possible for two objects to be considered equal at one poi
api/src/main/java/io/grpc/Attributes.java:205
↓ 2 callersMethodhashCode
()
api/src/main/java/io/grpc/LoadBalancer.java:793
↓ 2 callersMethodhashCode
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5440
↓ 2 callersMethodhashCode
()
xds/src/main/java/io/grpc/xds/GrpcServiceConfigParser.java:331
↓ 2 callersMethodhashCode
()
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:223
↓ 2 callersMethodhashPolicies
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:152
↓ 2 callersMethodheaderAbort
()
xds/src/main/java/io/grpc/xds/FaultConfig.java:79
↓ 2 callersMethodheaderGetRequiredSingle
Assumes that caller requires this field, so duplicates are treated as missing.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:511
↓ 2 callersMethodheaderName
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:245
↓ 2 callersMethodheaderTableSizeSetting
Called by the reader when the peer sent {@link Settings#HEADER_TABLE_SIZE}. While this establishes the maximum dynamic table size, the {@link #maxDyna
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:164
↓ 2 callersMethodheaders
(int streamId, List<Header> headerBlock)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:432
↓ 2 callersMethodhttp2ProcessingFailed
(Status status, boolean stopDelivery, Metadata trailers)
netty/src/main/java/io/grpc/netty/NettyClientStream.java:294
↓ 2 callersMethodimmutableList
Returns an immutable list containing {@code elements}.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Util.java:45
↓ 2 callersMethodinboundDataReceived
Must be called with holding the transport lock.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java:210
↓ 2 callersMethodinboundParcelablePolicy
Sets the policy for inbound parcelable objects.
binder/src/main/java/io/grpc/binder/BinderServerBuilder.java:131
↓ 2 callersMethodinboundUncompressedSize
See {@link StreamTracer#inboundUncompressedSize}. <p>Called from {@link io.grpc.internal.MessageDeframer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:255
↓ 2 callersMethodinboundWireSize
See {@link StreamTracer#inboundWireSize}. <p>Called from {@link io.grpc.internal.MessageDeframer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:266
↓ 2 callersMethodincomprehensible
Returns an empty set if this credential can be adequately understood via the features listed, otherwise returns a hint of features that are lacking to
api/src/main/java/io/grpc/TlsServerCredentials.java:175
↓ 2 callersMethodincomprehensible
Returns an empty set if this credential can be adequately understood via the features listed, otherwise returns a hint of features that are lacking to
api/src/main/java/io/grpc/TlsChannelCredentials.java:151
↓ 2 callersMethodincrementBytes
(int delta)
interop-testing/src/test/java/io/grpc/testing/integration/TrafficControlProxy.java:229
↓ 2 callersMethodincrementCallCount
(boolean success)
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:555
↓ 2 callersMethodincrementInCounter
Increments the input counter, returning the previous (unincremented) value.
alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:145
↓ 2 callersMethodincrementOutCounter
Increments the output counter, returning the previous (unincremented) value.
alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:151
↓ 2 callersMethodinit
()
core/src/main/java/io/grpc/internal/ServerImpl.java:419
↓ 2 callersMethodinitClusterBuilder
(String clusterName, String lbPolicy, @Nullable Message ringHashLbConfig, @Nullable Message leastReque
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplV3Test.java:555
↓ 2 callersMethodinitStub
()
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbFallbackTestClient.java:170
↓ 2 callersMethodinitialOutboundWindowSize
Adjusts outbound window size requested by peer. When window size is increased, it does not send any pending frames. If this method returns {@code true
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:59
↓ 2 callersMethodinitializeBalancingState
()
xds/src/main/java/io/grpc/xds/LazyLoadBalancer.java:87
↓ 2 callersMethodinsertIntoDynamicTable
index == -1 when new.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:304
↓ 2 callersMethodinsertIntoDynamicTable
(io.grpc.okhttp.internal.framed.Header entry)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:573
↓ 2 callersMethodinstance
()
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:52
↓ 2 callersMethodintArrayToByteArray
(int[] bytes)
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java:1184
↓ 2 callersMethodinterceptForward
Create a new {@link Channel} that will call {@code interceptors} before starting a call on the given channel. The first interceptor will have its {@li
api/src/main/java/io/grpc/ClientInterceptors.java:44
↓ 2 callersMethodinterleave
(List<UnwrappedEag> firstFamily, List<UnwrappedEag> secondFamily)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:812
↓ 2 callersMethodinternalCancel
(Status clientStatus)
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:640
↓ 2 callersMethodinternalCancel
( Status serverListenerStatus, Status serverTracerStatus)
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:853
↓ 2 callersMethodinternalShutdown
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:267
↓ 2 callersMethodinternalStart
Starts stream without synchronization. {@code listener} should be same instance as {@link #listener}.
core/src/main/java/io/grpc/internal/DelayedStream.java:262
↓ 2 callersMethodinternalStart
(Listener<RespT> listener)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:191
↓ 2 callersMethodintersect
Returns an array containing containing only elements found in {@code first} and also in {@code second}. The returned elements are in the same order a
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Util.java:53
↓ 2 callersMethodinverted
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:75
↓ 2 callersMethodisAndroid
Returns true if the {@link ClassLoader} is for android.
api/src/main/java/io/grpc/ServiceProviders.java:97
↓ 2 callersMethodisAvailable
Whether this provider is available for use, taking the current environment into consideration. If {@code false}, {@link #newLoadBalancer} is not safe
api/src/main/java/io/grpc/LoadBalancerProvider.java:52
↓ 2 callersMethodisCached
Returns whether the resource was cached.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:238
↓ 2 callersMethodisCancelled
()
core/src/main/java/io/grpc/internal/ServerCallImpl.java:233
↓ 2 callersMethodisCancelled
()
api/src/context/java/io/grpc/Context.java:894
↓ 2 callersMethodisCancelled
()
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:372
↓ 2 callersMethodisClosed
Indicates whether or not this framer has been closed via a call to either {@link #close()} or {@link #dispose()}.
core/src/main/java/io/grpc/internal/MessageFramer.java:318
↓ 2 callersMethodisConscrypt
Same as {@code Conscrypt.isConscrypt(Provider)}.
core/src/main/java/io/grpc/internal/ConscryptLoader.java:56
↓ 2 callersMethodisDisabled
()
services/src/main/java/io/grpc/services/CallMetricRecorder.java:275
↓ 2 callersMethodisDone
()
binder/src/testFixtures/java/io/grpc/binder/internal/MainThreadScheduledExecutorService.java:170
↓ 2 callersMethodisEscapingChar
(byte b)
api/src/main/java/io/grpc/Status.java:590
↓ 2 callersMethodisExpired
Determines if the entry is already expired or not.
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:94
↓ 2 callersMethodisFullStateOfTheWorld
()
xds/src/main/java/io/grpc/xds/client/XdsResourceType.java:79
↓ 2 callersMethodisGrpc
Checks whether an incoming {@code HttpServletRequest} may come from a gRPC client. @return true if the request comes from a gRPC client
servlet/src/main/java/io/grpc/servlet/ServletAdapter.java:343
↓ 2 callersMethodisHealthy
()
xds/src/main/java/io/grpc/xds/Endpoints.java:66
↓ 2 callersMethodisNonExistent
()
netty/src/main/java/io/grpc/netty/NettyClientStream.java:261
↓ 2 callersMethodisOk
Fails if the subject is not OK.
api/src/testFixtures/java/io/grpc/StatusSubject.java:42
↓ 2 callersMethodisReady
()
core/src/main/java/io/grpc/internal/ClientCallImpl.java:548
↓ 2 callersMethodisReady
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5259
↓ 2 callersMethodisRequired
Indicates whether or not this parameter is required and must therefore be set before the configuration can be successfully built.
benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java:100
↓ 2 callersMethodisRetryTimerPending
()
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:328
↓ 2 callersMethodisRetryTimerPending
()
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:421
↓ 2 callersMethodisSet
Returns true if a value has been assigned for the setting {@code id}.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Settings.java:115
↓ 2 callersMethodisStaticHeader
(int index)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:299
↓ 2 callersMethodisStreamDeallocated
()
core/src/main/java/io/grpc/internal/AbstractStream.java:330
↓ 2 callersMethodisTerminalFilter
(Filter.FilterConfig filterConfig)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:576
↓ 2 callersMethodisTraceable
(ChannelLogLevel level)
core/src/main/java/io/grpc/internal/ChannelLoggerImpl.java:71
↓ 2 callersMethodisUsingPlaintext
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:405
↓ 2 callersMethodisValidHostName
(String name)
okhttp/src/main/java/io/grpc/okhttp/OkHttpProtocolNegotiator.java:368
↓ 2 callersMethodisValidSocketAddress
(SocketAddress address)
benchmarks/src/main/java/io/grpc/benchmarks/SocketAddressValidator.java:32
↓ 2 callersMethodisWatched
()
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:820
↓ 2 callersMethodisWriteLegal
Check whether we'll ever be able to do writes or should terminate. @return True if writes haven't been closed and the server hasn't closed the stream
stub/src/main/java/io/grpc/stub/BlockingClientCall.java:320
↓ 2 callersMethodjavaName
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/TlsVersion.java:57
↓ 2 callersMethodjsonMarshaller
Create a {@code Marshaller} for json protos of the same type as {@code defaultInstance}. <p>This is an unstable API and has not been optimized yet fo
examples/src/main/java/io/grpc/examples/advanced/JsonMarshaller.java:47
↓ 2 callersMethodkeepAliveManager
()
netty/src/main/java/io/grpc/netty/NettyClientTransport.java:449
← previousnext →4,801–4,900 of 22,628, ranked by callers