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
↓ 1 callersMethodverifyDnsNameContains
( String altNameFromCert, String sanToVerifySubstring, boolean ignoreCase)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:142
↓ 1 callersMethodverifyDnsNameExact
( String altNameFromCert, String sanToVerifyExact, boolean ignoreCase)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:153
↓ 1 callersMethodverifyDnsNameInPattern
( String altNameFromCert, StringMatcher sanToVerifyMatcher)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:88
↓ 1 callersMethodverifyDnsNameInSanList
( String altNameFromCert, List<StringMatcher> verifySanList)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:166
↓ 1 callersMethodverifyDnsNamePrefix
( String altNameFromCert, String sanToVerifyPrefix, boolean ignoreCase)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:120
↓ 1 callersMethodverifyDnsNameSafeRegex
( String altNameFromCert, RegexMatcher sanToVerifySafeRegex)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:114
↓ 1 callersMethodverifyDnsNameSuffix
( String altNameFromCert, String sanToVerifySuffix, boolean ignoreCase)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:131
↓ 1 callersMethodverifyDnsNameWildcard
( String altNameFromCert, String sanToVerify, boolean ignoreCase)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:356
↓ 1 callersMethodverifyFailedPicksCounterAdd
(int times, long value)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:695
↓ 1 callersMethodverifyHostName
Returns true if {@code certificate} matches {@code hostName}.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OkHostnameVerifier.java:106
↓ 1 callersMethodverifyIpAddress
Returns true if {@code certificate} matches {@code ipAddress}.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OkHostnameVerifier.java:93
↓ 1 callersMethodverifyMultiResponse
(ClientStatusResponse response, int numExpected)
xds/src/test/java/io/grpc/xds/CsdsServiceTest.java:306
↓ 1 callersMethodverifyNotClosed
()
core/src/main/java/io/grpc/internal/MessageFramer.java:364
↓ 1 callersMethodverifyOneSanInList
(List<?> entry, List<StringMatcher> verifySanList)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:176
↓ 1 callersMethodverifyShutdown
()
xds/src/test/java/io/grpc/xds/XdsServerBuilderTest.java:122
↓ 1 callersMethodverifySubjectAltNameInLeaf
( X509Certificate cert, List<StringMatcher> verifyList)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:197
↓ 1 callersMethodverifyValidatePeerCertificateChainReq
(ValidatePeerCertificateChainReq req)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:327
↓ 1 callersMethodveryLargeResponse
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:989
↓ 1 callersMethodwaitForNext
()
stub/src/main/java/io/grpc/stub/ClientCalls.java:702
↓ 1 callersMethodwaitForRpcStats
(long timeoutSeconds)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:667
↓ 1 callersMethodwaitForRpcsToComplete
(int duration)
benchmarks/src/main/java/io/grpc/benchmarks/qps/OpenLoopClient.java:203
↓ 1 callersMethodwaitForShutdown
(long timeout, TimeUnit unit)
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:1579
↓ 1 callersMethodwarmup
()
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbFallbackTestClient.java:284
↓ 1 callersMethodwarmup
(SimpleRequest req, List<? extends Channel> channels)
benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java:109
↓ 1 callersMethodwindowUpdate
(int streamId, int delta)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:325
↓ 1 callersMethodwithCallCredentials
(CallCredentials callCreds)
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:763
↓ 1 callersMethodwithCallCredentials
(CallCredentials callCreds)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:286
↓ 1 callersMethodwithDeadline
Returns a new stub with an absolute deadline. <p>This is mostly used for propagating an existing deadline. {@link #withDeadlineAfter} is the recommen
stub/src/main/java/io/grpc/stub/AbstractStub.java:141
↓ 1 callersMethodwithDeadlineAfter
Returns a new {@code CallOptions} with a deadline that is after the given {@code duration} from now.
api/src/main/java/io/grpc/CallOptions.java:177
↓ 1 callersMethodwithOnReadyThreshold
()
api/src/test/java/io/grpc/CallOptionsTest.java:85
↓ 1 callersMethodwithOption
Adding custom call options without duplicate keys.
api/src/jmh/java/io/grpc/CallOptionsBenchmark.java:70
↓ 1 callersMethodwithPicker
(SubchannelPicker newPicker)
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:449
↓ 1 callersMethodwithShutdownStatus
(Status newShutdownStatus)
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:453
↓ 1 callersMethodwithWaitForReady
Returns a new stub that uses <a href="https://github.com/grpc/grpc/blob/master/doc/wait-for-ready.md">'wait for ready'</a> for the call. Wait-for-read
stub/src/main/java/io/grpc/stub/AbstractStub.java:238
↓ 1 callersMethodwithoutBearerTokens
()
okhttp/src/main/java/io/grpc/okhttp/SslSocketFactoryChannelCredentials.java:44
↓ 1 callersMethodwordWrap
(String text, int startPos, int maxPos)
benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java:214
↓ 1 callersMethodwrapAndAddMethod
( ServerServiceDefinition.Builder serviceDefBuilder, ServerMethodDefinition<ReqT, RespT> method, L
api/src/main/java/io/grpc/ServerInterceptors.java:240
↓ 1 callersMethodwrapAwareMax
(long a, long b)
binder/src/main/java/io/grpc/binder/internal/FlowController.java:81
↓ 1 callersMethodwrapChannel
(Channel channel)
core/src/test/java/io/grpc/internal/ServerImplTest.java:1721
↓ 1 callersMethodwrapClientInterceptor
Creates a new ClientInterceptor that transforms requests into {@code WReqT} and responses into {@code WRespT} before passing them into the {@code inte
api/src/main/java/io/grpc/ClientInterceptors.java:98
↓ 1 callersMethodwrapClientInterceptor
( final ClientInterceptor interceptor, final Marshaller<ReqT> reqMarshaller, final Marshalle
api/src/main/java/io/grpc/InternalClientInterceptors.java:26
↓ 1 callersMethodwrapHandler
( final ServerCallHandler<OReqT, ORespT> originalHandler, final MethodDescriptor<OReqT, ORespT> or
api/src/main/java/io/grpc/ServerInterceptors.java:283
↓ 1 callersMethodwrapMethod
Never returns {@code null}.
core/src/main/java/io/grpc/internal/ServerImpl.java:660
↓ 1 callersMethodwrapMethod
( final ServerMethodDefinition<OrigReqT, OrigRespT> definition, final MethodDescriptor<WrapReqT, W
api/src/main/java/io/grpc/InternalServerInterceptors.java:24
↓ 1 callersMethodwrapMethodDefinition
( ServerMethodDefinition<ReqT, RespT> oMethodDef)
core/src/test/java/io/grpc/internal/ServerImplTest.java:1711
↓ 1 callersMethodwritableBytes
()
core/src/test/java/io/grpc/internal/MessageFramerTest.java:419
↓ 1 callersMethodwrite
(byte[] bytes, int srcIndex, int length)
core/src/test/java/io/grpc/internal/MessageFramerTest.java:408
↓ 1 callersMethodwriteAllPendingData
()
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:352
↓ 1 callersMethodwriteCompressed
(InputStream message, int unusedMessageLength)
core/src/main/java/io/grpc/internal/MessageFramer.java:184
↓ 1 callersMethodwriteFrameInternal
( WritableBuffer frame, boolean endOfStream, boolean flush, final int numMessages)
netty/src/main/java/io/grpc/netty/NettyClientStream.java:176
↓ 1 callersMethodwriteHeaders
(List<io.grpc.okhttp.internal.framed.Header> headerBlock)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:437
↓ 1 callersMethodwriteHeadersInternal
(Metadata headers, byte[] requestPayload)
netty/src/main/java/io/grpc/netty/NettyClientStream.java:127
↓ 1 callersMethodwriteKeyValueForRequest
(String requestHeader, String key, String value)
istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:491
↓ 1 callersMethodwriteKnownLengthUncompressed
Write an unserialized message with a known length, uncompressed.
core/src/main/java/io/grpc/internal/MessageFramer.java:216
↓ 1 callersMethodwriteLength
(BufferedSink sink, int length)
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1380
↓ 1 callersMethodwriteLength
(BufferedSink sink, int length)
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/Http2Test.java:93
↓ 1 callersMethodwriteMedium
(BufferedSink sink, int i)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:781
↓ 1 callersMethodwriteMessageData
(Parcel parcel, InputStream stream)
binder/src/main/java/io/grpc/binder/internal/Outbound.java:301
↓ 1 callersMethodwriteOut
Take a message off the queue and write it to an endpoint. Blocks until a message becomes available.
interop-testing/src/test/java/io/grpc/testing/integration/TrafficControlProxy.java:200
↓ 1 callersMethodwritePayload
Writes out a payload message. @param message contains the message to be written out. It will be completely consumed.
core/src/main/java/io/grpc/internal/MessageFramer.java:132
↓ 1 callersMethodwritePing
( ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1167
↓ 1 callersMethodwritePrefix
Write prefix data to the given {@link Parcel}. @param parcel the transaction parcel to write to. @return any additional flags to be set on the transa
binder/src/main/java/io/grpc/binder/internal/Outbound.java:289
↓ 1 callersMethodwriteRstStream
( ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:1209
↓ 1 callersMethodwriteSuffix
Write suffix data to the given {@link Parcel}. @param parcel the transaction parcel to write to. @return any additional flags to be set on the transa
binder/src/main/java/io/grpc/binder/internal/Outbound.java:298
↓ 1 callersMethodwriteToParcel
(Parcel parcel, int flags)
binder/src/test/java/io/grpc/binder/internal/TestParcelable.java:41
↓ 1 callersMethodwriteUncompressed
(InputStream message, int messageLength)
core/src/main/java/io/grpc/internal/MessageFramer.java:173
↓ 1 callersMethodwriteWindowUpdate
( ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1160
↓ 1 callersMethodxdsServingStatusListener
Set the {@link XdsServingStatusListener} to receive "serving" and "not serving" states.
xds/src/main/java/io/grpc/xds/XdsServerBuilder.java:76
MethodAbstractAsyncStub
(Channel channel, CallOptions callOptions)
stub/src/main/java/io/grpc/stub/AbstractAsyncStub.java:37
MethodAbstractBenchmark
()
benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java:188
MethodAbstractBlockingStub
(Channel channel, CallOptions callOptions)
stub/src/main/java/io/grpc/stub/AbstractBlockingStub.java:38
MethodAbstractClientStream
( WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx, TransportTracer
core/src/main/java/io/grpc/internal/AbstractClientStream.java:104
MethodAbstractFutureStub
(Channel channel, CallOptions callOptions)
stub/src/main/java/io/grpc/stub/AbstractFutureStub.java:37
MethodAbstractInteropTest
Constructor for tests.
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:205
MethodAbstractNettyHandler
( ChannelPromise channelUnused, Http2ConnectionDecoder decoder, Http2ConnectionEncoder encod
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:55
MethodAbstractQueuedCommand
()
netty/src/main/java/io/grpc/netty/WriteQueue.java:190
MethodAbstractServerStream
( WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx)
core/src/main/java/io/grpc/internal/AbstractServerStream.java:78
MethodAbstractServerStreamBase
(WritableBufferAllocator bufferAllocator, Sink sink, AbstractServerStream.TransportState state)
core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java:400
MethodAbstractStub
Constructor for use by subclasses, with the default {@code CallOptions}. @since 1.0.0 @param channel the channel that this stub will use to do commun
stub/src/main/java/io/grpc/stub/AbstractStub.java:64
MethodAbstractTestHelper
()
util/src/testFixtures/java/io/grpc/util/AbstractTestHelper.java:73
MethodAccessTokenManager
(TokenFetcher tokenFetcher)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/AccessTokenManager.java:36
MethodActiveTransportTracker
@param delegate the original server listener that this object decorates. Usually passed to {@link BinderServer#start(ServerListener)}. @param term
binder/src/main/java/io/grpc/binder/internal/ActiveTransportTracker.java:33
MethodAdaptiveThrottler
(Builder builder)
rls/src/main/java/io/grpc/rls/AdaptiveThrottler.java:78
MethodAddToRuns
(int val)
core/src/test/java/io/grpc/internal/SerializingExecutorTest.java:43
MethodAddress
(String address, int port)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:330
MethodAddressFilter
()
xds/src/main/java/io/grpc/xds/AddressFilter.java:36
MethodAddressOverrideEmbeddedChannel
(SocketAddress local, SocketAddress remote)
netty/src/test/java/io/grpc/netty/TcpMetricsTest.java:349
MethodAdminInterface
()
services/src/main/java/io/grpc/services/AdminInterface.java:44
MethodAdsStream
()
xds/src/main/java/io/grpc/xds/client/ControlPlaneClient.java:356
MethodAdvancedTlsX509KeyManager
()
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:62
MethodAdvancedTlsX509TrustManager
(Verification verification, SslSocketAndEnginePeerVerifier socketAndEnginePeerVerifier)
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:68
MethodAesGcmAeadCrypter
(byte[] key)
alts/src/main/java/io/grpc/alts/internal/AesGcmAeadCrypter.java:48
MethodAesGcmHkdfAeadCrypter
(byte[] key)
alts/src/main/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypter.java:51
MethodAggregateConfig
(List<String> leafNames)
xds/src/main/java/io/grpc/xds/XdsConfig.java:197
MethodAggregatedDiscoveryServiceBaseDescriptorSupplier
()
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/discovery/v3/AggregatedDiscoveryServiceGrpc.java:396
MethodAggregatedDiscoveryServiceBlockingStub
( io.grpc.Channel channel, io.grpc.CallOptions callOptions)
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/discovery/v3/AggregatedDiscoveryServiceGrpc.java:296
MethodAggregatedDiscoveryServiceBlockingV2Stub
( io.grpc.Channel channel, io.grpc.CallOptions callOptions)
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/discovery/v3/AggregatedDiscoveryServiceGrpc.java:250
MethodAggregatedDiscoveryServiceFileDescriptorSupplier
()
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/discovery/v3/AggregatedDiscoveryServiceGrpc.java:411
MethodAggregatedDiscoveryServiceFutureStub
( io.grpc.Channel channel, io.grpc.CallOptions callOptions)
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/discovery/v3/AggregatedDiscoveryServiceGrpc.java:321
MethodAggregatedDiscoveryServiceGrpc
()
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/discovery/v3/AggregatedDiscoveryServiceGrpc.java:18
← previousnext →7,901–8,000 of 22,628, ranked by callers