Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/grpc/grpc-java
/ functions
Functions
22,628 in github.com/grpc/grpc-java
⨍
Functions
22,628
◇
Types & classes
3,835
↓ 3 callers
Method
callMeMaybe
(Runnable r)
core/src/test/java/io/grpc/internal/DelayedClientCallTest.java:458
↓ 3 callers
Method
cancelAfterBegin
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:796
↓ 3 callers
Method
cancelAfterFirstResponse
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:820
↓ 3 callers
Method
cancelThrow
Cancels a call, and throws the exception. @param t must be a RuntimeException or Error
stub/src/main/java/io/grpc/stub/ClientCalls.java:381
↓ 3 callers
Method
cap
()
api/src/main/java/io/grpc/Metadata.java:205
↓ 3 callers
Method
channelCredsConfig
()
xds/src/main/java/io/grpc/xds/client/ConfiguredChannelCredentials.java:31
↓ 3 callers
Method
channelFactory
Specifies the {@link ChannelFactory} to create {@link ServerChannel} instances. This method is usually only used if the specific {@code ServerChannel}
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:241
↓ 3 callers
Method
channelType
Specifies the channel type to use, by default we use {@code EpollSocketChannel} if available, otherwise using {@link NioSocketChannel}. <p>You either
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:267
↓ 3 callers
Method
checkAddressTypes
( Collection<Class<? extends SocketAddress>> channelTransportSocketAddressTypes)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:831
↓ 3 callers
Method
checkAuthorizationAsync
Decides whether the given Android UID is authorized. (Validity is implementation dependent). <p>As long as any given UID has active processes, this m
binder/src/main/java/io/grpc/binder/AsyncSecurityPolicy.java:69
↓ 3 callers
Method
checkClientTrusted
(X509Certificate[] x509Certificates, String s)
okhttp/src/test/java/io/grpc/okhttp/TlsTest.java:632
↓ 3 callers
Method
checkDifferentInstances
( CertificateProvider.Watcher mockWatcher1, CertificateProviderStore.Handle handle1, Certifi
xds/src/test/java/io/grpc/xds/internal/security/certprovider/CertificateProviderStoreTest.java:276
↓ 3 callers
Method
checkForNullAndGet
(Map<String, ?> map, String key)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderProvider.java:97
↓ 3 callers
Method
checkForTermination
Notify of complete shutdown if necessary.
core/src/main/java/io/grpc/internal/ServerImpl.java:353
↓ 3 callers
Method
checkStarted
()
api/src/test/java/io/grpc/ClientInterceptorsTest.java:475
↓ 3 callers
Method
checkTicker
(Deadline other)
api/src/context/java/io/grpc/Deadline.java:281
↓ 3 callers
Method
chooseClientAlias
(String[] keyType, Principal[] issuers, Socket socket)
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:99
↓ 3 callers
Method
chooseServerAlias
(String keyType, Principal[] issuers, Socket socket)
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:115
↓ 3 callers
Method
cleanUpRoutes
(Status error)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:908
↓ 3 callers
Method
clearKeysAndCerts
()
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertProviderSslContextProvider.java:189
↓ 3 callers
Method
clearServer
(InProcessServer server)
inprocess/src/main/java/io/grpc/inprocess/AnonymousInProcessSocketAddress.java:61
↓ 3 callers
Method
clearStatus
Clears the health status record of a service. The health service will respond with NOT_FOUND error on checking the status of a cleared service. @param
services/src/main/java/io/grpc/services/HealthStatusManager.java:78
↓ 3 callers
Method
clientAttemptDurationCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:35
↓ 3 callers
Method
clientAuthorizationCheck
Given a server call, performs client authorization check, i.e., checks if the client service account matches one of the expected service accounts. It
alts/src/main/java/io/grpc/alts/AuthorizationUtil.java:35
↓ 3 callers
Method
clientCallDurationCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:29
↓ 3 callers
Method
clientCallHedgesCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:50
↓ 3 callers
Method
clientCallRetriesCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:44
↓ 3 callers
Method
clientCallRetryDelayCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:53
↓ 3 callers
Method
clientCallTransparentRetriesCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:47
↓ 3 callers
Method
clientInboundHeaders
See {@link ClientStreamTracer#inboundHeaders}. For client-side only. <p>Called from abstract stream implementations.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:113
↓ 3 callers
Method
clientListenerResourceNameTemplate
A template for the name of the Listener resource to subscribe to for a gRPC client channel. Used only when the channel is created using an "xds:" URI
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:119
↓ 3 callers
Method
clientStreaming
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:585
↓ 3 callers
Method
clientTotalReceivedCompressedMessageSizeCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:41
↓ 3 callers
Method
clientTotalSentCompressedMessageSizeCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:38
↓ 3 callers
Method
close
()
core/src/main/java/io/grpc/internal/MessageDeframer.java:212
↓ 3 callers
Method
close
()
services/src/main/java/io/grpc/protobuf/services/TempFileSink.java:64
↓ 3 callers
Method
close
Cleans up this object by calling {@code cancel(null)}.
api/src/context/java/io/grpc/Context.java:926
↓ 3 callers
Method
close
(ChannelHandlerContext ctx, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:487
↓ 3 callers
Method
close
Called by consumer when tlsContext changes.
xds/src/main/java/io/grpc/xds/internal/security/SslContextProviderSupplier.java:123
↓ 3 callers
Method
close
()
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertProviderSslContextProvider.java:226
↓ 3 callers
Method
closeObserver
(Listener<RespT> observer, Status status, Metadata trailers)
core/src/main/java/io/grpc/internal/ClientCallImpl.java:564
↓ 3 callers
Method
closeThenThrow
(NamingEnumeration<?> namingEnumeration, NamingException e)
core/src/main/java/io/grpc/internal/JndiResourceResolverFactory.java:245
↓ 3 callers
Method
clusterName
()
xds/src/main/java/io/grpc/xds/client/Stats.java:34
↓ 3 callers
Method
commit
(final Substream winningSubstream)
core/src/main/java/io/grpc/internal/RetriableStream.java:152
↓ 3 callers
Method
commitToSink
(boolean endOfStream, boolean flush)
core/src/main/java/io/grpc/internal/MessageFramer.java:357
↓ 3 callers
Method
commonErrorTest
( String certFile, String keyFile, String rootFile, String spiffeFile, Class<?>
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:413
↓ 3 callers
Method
complete
Called from application thread.
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:165
↓ 3 callers
Method
completeInput
Indicates that the input is completed and the currently enqueued response chunks are all that remain to be scheduled for dispatch to the client.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:356
↓ 3 callers
Method
compress
Wraps an existing output stream with a compressing output stream. @param os The output stream of uncompressed data @return An output stream that compr
api/src/main/java/io/grpc/Compressor.java:39
↓ 3 callers
Method
compressorRegistry
(@Nullable CompressorRegistry registry)
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:192
↓ 3 callers
Method
configProto
()
xds/src/main/java/io/grpc/xds/GrpcServiceConfigParser.java:314
↓ 3 callers
Method
configure
<pre> Update the tes client's configuration. </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/XdsUpdateClientConfigureServiceGrpc.java:120
↓ 3 callers
Method
configureBuilder
(ManagedChannelImplBuilder channelBuilder)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:365
↓ 3 callers
Method
convertStatus
(io.grpc.Status grpcStatus)
census/src/main/java/io/grpc/census/CensusTracingModule.java:147
↓ 3 callers
Method
copyKey
( Metadata.Key<T> key, Metadata.BinaryStreamMarshaller<T> marshaller)
api/src/test/java/io/grpc/MetadataTest.java:507
↓ 3 callers
Method
create
Creates ChildLoadBalancingPolicy.
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:126
↓ 3 callers
Method
create
(ImmutableMap<String, String> keyMap, Reason reason)
rls/src/main/java/io/grpc/rls/RlsProtoData.java:64
↓ 3 callers
Method
create
Constructs with the provided {@code creds} as options, with preferred credentials first. @throws IllegalArgumentException if no creds are provided
api/src/main/java/io/grpc/ChoiceServerCredentials.java:34
↓ 3 callers
Method
create
(SSLSocketFactory factory)
okhttp/src/main/java/io/grpc/okhttp/SslSocketFactoryChannelCredentials.java:28
↓ 3 callers
Method
create
Creates a {@link ServerCredentials} that will use the provided {@code negotiator}.
netty/src/main/java/io/grpc/netty/InternalNettyServerCredentials.java:33
↓ 3 callers
Method
create
(@Nullable String path, @Nullable String prefix, @Nullable Pattern regEx, boolean caseSensitive)
xds/src/main/java/io/grpc/xds/VirtualHost.java:141
↓ 3 callers
Method
create
( List<HashPolicy> hashPolicies, @Nullable Long timeoutNano, @Nullable String cl
xds/src/main/java/io/grpc/xds/VirtualHost.java:199
↓ 3 callers
Method
create
( int maxAttempts, List<Code> retryableStatusCodes, Duration initialBackoff, Duration
xds/src/main/java/io/grpc/xds/VirtualHost.java:292
↓ 3 callers
Method
create
(InetAddress addressPrefix, int prefixLen)
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:214
↓ 3 callers
Method
create
( int numerator, DenominatorType denominatorType)
xds/src/main/java/io/grpc/xds/FaultConfig.java:120
↓ 3 callers
Method
createAndStartChannel
Resets client/server and their flow control windows.
interop-testing/src/test/java/io/grpc/testing/integration/NettyFlowControlTest.java:162
↓ 3 callers
Method
createChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/XdsFederationTestClient.java:267
↓ 3 callers
Method
createData
(int flag, int length, int paddingLength)
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/Http2Test.java:78
↓ 3 callers
Method
createEndSpanOptions
( io.grpc.Status status, boolean sampledToLocalTracing)
census/src/main/java/io/grpc/census/CensusTracingModule.java:211
↓ 3 callers
Method
createException
(String message)
xds/src/main/java/io/grpc/xds/XdsEndpointResource.java:343
↓ 3 callers
Method
createFilters
( @Nullable List<NamedFilterConfig> filterConfigs, VirtualHost virtualHost, Route rout
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:870
↓ 3 callers
Method
createMethod
(String path)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:2021
↓ 3 callers
Method
createOobChannel
Create an out-of-band channel for the LoadBalancer’s own RPC needs, e.g., talking to an external load-balancer service. <p>The LoadBalancer is respon
api/src/main/java/io/grpc/LoadBalancer.java:1065
↓ 3 callers
Method
createPendingStream
Name resolution is completed and the connection starts getting established. This method is only invoked on the streams that encounter such delay. </p
api/src/main/java/io/grpc/ClientStreamTracer.java:57
↓ 3 callers
Method
createResolver
()
googleapis/src/test/java/io/grpc/googleapis/GoogleCloudToProdNameResolverTest.java:161
↓ 3 callers
Method
createResolvingOobChannelBuilder
(String target)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1420
↓ 3 callers
Method
createRoutingConfig
(String path, String domain)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:2001
↓ 3 callers
Method
createServerReflectionResponse
( ServerReflectionRequest request, FileDescriptor fd)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:296
↓ 3 callers
Method
createSocket
(String s, int i)
okhttp/src/test/java/io/grpc/okhttp/OkHttpChannelBuilderTest.java:478
↓ 3 callers
Method
createSourceIpMatcher
(CidrRange cidrRange)
xds/src/main/java/io/grpc/xds/RbacFilter.java:352
↓ 3 callers
Method
createSslSocketFactory
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:585
↓ 3 callers
Method
createState
(Stream stream, int streamId)
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:145
↓ 3 callers
Method
createSubchannel
(CreateSubchannelArgs args)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:1061
↓ 3 callers
Method
createWithThrowable
(Throwable throwable)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AStub.java:221
↓ 3 callers
Method
data
(int size)
api/src/main/java/io/grpc/Attributes.java:227
↓ 3 callers
Method
decode
(byte[] buf)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Huffman.java:130
↓ 3 callers
Method
decodeHexDigit
(char c)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:429
↓ 3 callers
Method
decompressorRegistry
(@Nullable DecompressorRegistry registry)
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:186
↓ 3 callers
Method
defaultBootstrap
()
xds/src/main/java/io/grpc/xds/GrpcBootstrapperImpl.java:119
↓ 3 callers
Method
defaultFilterChain
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:310
↓ 3 callers
Method
defaultPort
Returns 80 if {@code scheme.equals("http")}, 443 if {@code scheme.equals("https")} and -1 otherwise.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:91
↓ 3 callers
Method
defaultServiceConfig
(Map<String, ?> serviceConfig)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:1134
↓ 3 callers
Method
delayedAddValue
(int delayMillis, Integer... values)
stub/src/test/java/io/grpc/stub/BlockingClientCallTest.java:384
↓ 3 callers
Method
delegate
()
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:2849
↓ 3 callers
Method
delegate
()
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:109
↓ 3 callers
Method
delegate
()
util/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java:483
↓ 3 callers
Method
delegate
()
util/src/main/java/io/grpc/util/GracefulSwitchLoadBalancer.java:170
↓ 3 callers
Method
delegate
()
xds/src/main/java/io/grpc/xds/XdsServerBuilder.java:68
↓ 3 callers
Method
delegate
()
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:299
↓ 3 callers
Method
delegate
()
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:343
← previous
next →
3,501–3,600 of 22,628, ranked by callers