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
↓ 6 callers
Method
addListenSocket
(InternalInstrumented<SocketStats> socket)
api/src/main/java/io/grpc/InternalChannelz.java:100
↓ 6 callers
Method
addServices
Adds a list of service implementations to the handler registry together. This exists for convenience - equivalent to repeatedly calling addService() w
api/src/main/java/io/grpc/ServerBuilder.java:126
↓ 6 callers
Method
alias
()
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:64
↓ 6 callers
Method
appendNameAndValue
(StringBuilder builder, CharSequence name, CharSequence value, boolean prependSeparator)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:299
↓ 6 callers
Method
applyRequestMetadata
( CallCredentials.RequestInfo requestInfo, Executor appExecutor, CallCredentials.MetadataApp
alts/src/main/java/io/grpc/alts/DualCallCredentials.java:35
↓ 6 callers
Method
asBindIntent
Returns this address as an explicit {@link Intent} suitable for passing to {@link Context#bindService}. <p>NB: The returned Intent does not specify a
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:159
↓ 6 callers
Method
assertClusterImplConfig
(ClusterImplConfig config, String cluster, @Nullable String edsServiceName, ServerInfo lrsServerInfo, Lo
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1076
↓ 6 callers
Method
assertCurrentPicker
(ConnectivityState state, PickResult result)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1041
↓ 6 callers
Method
assertDuplicatelPatternDetected
(String factoryConfigStr)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:344
↓ 6 callers
Method
assertRpcStatusRecorded
( Status.Code code, long roundtripLatencyMs, long outboundMessages)
interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:258
↓ 6 callers
Method
asyncPolicy
(Function<Integer, ListenableFuture<Status>> func)
binder/src/test/java/io/grpc/binder/ServerSecurityPolicyTest.java:356
↓ 6 callers
Method
authority
()
core/src/test/java/io/grpc/internal/ForwardingManagedChannelTest.java:97
↓ 6 callers
Method
awaitClose
()
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:616
↓ 6 callers
Method
bb
(String s, Channel c)
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:1545
↓ 6 callers
Method
buildDropOverload
(String category, int dropPerMillion)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5365
↓ 6 callers
Method
buildFilterChain
( List<String> alpn, Message tlsContext, String transportSocketName, Message... filters)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5367
↓ 6 callers
Method
buildHttpConnectionManagerFilter
( @Nullable String rdsName, @Nullable Message routeConfig, List<Message> httpFilters)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5374
↓ 6 callers
Method
buildListenerWithFilterChain
( String name, int portValue, String address, Message... filterChains)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5371
↓ 6 callers
Method
buildLogicalDnsCluster
(String clusterName, String dnsHostAddr, int dnsHostPort, String lbPolicy, @Nullable Message ringHashL
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5327
↓ 6 callers
Method
buildNewUpstreamTlsContextForCertProviderInstance
Helper method to build UpstreamTlsContext for CertProvider tests.
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:374
↓ 6 callers
Method
buildTerminalFilter
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5377
↓ 6 callers
Method
buildTestDownstreamTlsContext
Helper method for creating DownstreamTlsContext values with names.
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:126
↓ 6 callers
Method
buildTlsProtocolVersionSet
Builds a set of strings representing all {@link TLSVersion}s between {@code minTlsVersion} and {@code maxTlsVersion}.
s2a/src/main/java/io/grpc/s2a/internal/handshaker/ProtoUtil.java:55
↓ 6 callers
Method
builder
()
binder/src/androidTest/java/io/grpc/binder/HostServices.java:75
↓ 6 callers
Method
callUpdateSslContext
()
xds/src/test/java/io/grpc/xds/internal/security/SslContextProviderSupplierTest.java:69
↓ 6 callers
Method
canHandleEmptyAddressListFromNameResolution
()
util/src/main/java/io/grpc/util/ForwardingLoadBalancer.java:55
↓ 6 callers
Method
canonicalizeHost
Converts a host from URI to X509 format. <p>IPv6 host addresses derived from URIs are enclosed in square brackets per RFC2732, but omit these bracket
okhttp/src/main/java/io/grpc/okhttp/OkHttpTlsUpgrader.java:87
↓ 6 callers
Method
check
Checks if the {@link ServerCall} contains ALTS information. @param call the {@link ServerCall} to check @return true, if the {@link ServerCall} conta
alts/src/main/java/io/grpc/alts/AltsContextUtil.java:75
↓ 6 callers
Method
checkClientTrusted
Validates the given certificate chain provided by the peer. @param chain the peer certificate chain @param authType the authentication type based on
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2ATrustManager.java:68
↓ 6 callers
Method
checkObject
(Object o)
core/src/test/java/io/grpc/internal/ServiceConfigUtilTest.java:122
↓ 6 callers
Method
checkPercentEncodedArg
(String s, String what, BitSet allowedChars)
api/src/main/java/io/grpc/Uri.java:1146
↓ 6 callers
Method
checkServerTrusted
Validates the given certificate chain provided by the peer. @param chain the peer certificate chain @param authType the authentication type based on
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2ATrustManager.java:83
↓ 6 callers
Method
chooseDelegate
(X509Certificate[] chain)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:326
↓ 6 callers
Method
chooseEngineServerAlias
(String keyType, Principal[] issuers, SSLEngine engine)
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:120
↓ 6 callers
Method
cleanupExpiredEntries
Returns {@code true} if any entries were removed.
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:256
↓ 6 callers
Method
combine
( Node<K,V> node1, int hash1, Node<K,V> node2, int hash2, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:246
↓ 6 callers
Method
connectionError
Send GOAWAY to the server, then finish all streams and close the transport. RFC7540 §5.4.1.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:1043
↓ 6 callers
Method
connectionSourceType
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:246
↓ 6 callers
Method
convertTlsProtocolVersion
Converts a {@link TLSVersion} object to its {@link String} representation. @param tlsVersion the {@link TLSVersion} object to be converted. @return a
s2a/src/main/java/io/grpc/s2a/internal/handshaker/ProtoUtil.java:34
↓ 6 callers
Method
create
Creates an {@code AccessTokenManager} based on the environment where the application runs.
s2a/src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/AccessTokenManager.java:29
↓ 6 callers
Method
create
Creates credentials for Google Compute Engine. This class sets up a secure channel using ALTS if applicable and using TLS as fallback.
alts/src/main/java/io/grpc/alts/ComputeEngineChannelCredentials.java:46
↓ 6 callers
Method
create
(ProtocolNegotiator.ClientFactory negotiator)
netty/src/main/java/io/grpc/netty/NettyChannelCredentials.java:24
↓ 6 callers
Method
create
Creates credentials to be configured by xDS, falling back to other credentials if no TLS configuration is provided by xDS. @param fallback Credential
xds/src/main/java/io/grpc/xds/XdsChannelCredentials.java:39
↓ 6 callers
Method
create
Creates credentials to be configured by xDS, falling back to other credentials if no TLS configuration is provided by xDS. @param fallback Credential
xds/src/main/java/io/grpc/xds/XdsServerCredentials.java:39
↓ 6 callers
Method
create
(ChannelCredentials creds, ChannelCredsConfig config)
xds/src/main/java/io/grpc/xds/client/ConfiguredChannelCredentials.java:33
↓ 6 callers
Method
create
(MetricType metricType, Optional<String> key)
xds/src/main/java/io/grpc/xds/internal/MetricReportUtils.java:47
↓ 6 callers
Method
create
(Matchers.StringMatcher delegate)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:210
↓ 6 callers
Method
createAnonymousServer
()
inprocess/src/test/java/io/grpc/inprocess/AnonymousInProcessSocketAddressTest.java:99
↓ 6 callers
Method
createAttributes
(List<String> requiredLabelKeys, List<String> optionalLabelKeys, List<String> requiredLabelValues,
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricSink.java:302
↓ 6 callers
Method
createCustomCensusTracerFactory
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:404
↓ 6 callers
Method
createMatch
Returns the least-specific match-all Filter Chain Match.
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1974
↓ 6 callers
Method
createServer
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1776
↓ 6 callers
Method
createTls
()
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:2030
↓ 6 callers
Method
cumulate
"Adaptive" cumulator: cumulate {@link ByteBuf}s by dynamically switching between merge and compose strategies. <p>This cumulator applies a heuristic
netty/src/main/java/io/grpc/netty/NettyAdaptiveCumulator.java:75
↓ 6 callers
Method
currentTimeMillis
()
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:597
↓ 6 callers
Method
delayOrExecute
Enqueue the runnable or execute it now. Call sites that may be called many times may want avoid this method if {@code passThrough == true}. <p>Note t
core/src/main/java/io/grpc/internal/DelayedStream.java:209
↓ 6 callers
Method
deliverResolvedAddresses
()
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:616
↓ 6 callers
Method
destinationPort
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:238
↓ 6 callers
Method
disableButtons
()
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:125
↓ 6 callers
Method
disableServiceConfigLookUp
Disables service config look-up from the naming system, which is enabled by default. @return this @since 1.20.0
api/src/main/java/io/grpc/ManagedChannelBuilder.java:630
↓ 6 callers
Method
discard
Removes the key and associated value from the attributes. @since 1.22.0 @param key The key to remove @return this
api/src/main/java/io/grpc/Attributes.java:249
↓ 6 callers
Method
doHandshake
()
alts/src/test/java/io/grpc/alts/internal/AltsProtocolNegotiatorTest.java:385
↓ 6 callers
Method
drainTo
Transfers the entire contents of this stream to the specified target. @param target to write to. @return number of bytes written.
api/src/main/java/io/grpc/Drainable.java:39
↓ 6 callers
Method
empty
Returns an empty {@link ManagedChannelServiceConfig}.
core/src/main/java/io/grpc/internal/ManagedChannelServiceConfig.java:75
↓ 6 callers
Method
enablePluginForChannel
(String target)
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:177
↓ 6 callers
Method
enableRetry
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:531
↓ 6 callers
Method
enableUntrustedAltsForTesting
Enables untrusted ALTS for testing. If this function is called, we will not check whether ALTS is running on Google Cloud Platform.
alts/src/main/java/io/grpc/alts/AltsServerBuilder.java:61
↓ 6 callers
Method
encode
(String hex)
opentelemetry/src/test/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagatorTest.java:300
↓ 6 callers
Method
endsWith
Returns {@code true} if {@code subject} ends with {@code suffix}.
core/src/main/java/io/grpc/internal/TransportFrameUtil.java:153
↓ 6 callers
Method
ensureServerStateNotLeaked
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1798
↓ 6 callers
Method
enterIdle
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1245
↓ 6 callers
Method
eqMetricInstrumentName
(String name)
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:1687
↓ 6 callers
Method
eqPickSubchannelArgs
( MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions)
api/src/testFixtures/java/io/grpc/PickSubchannelArgsMatcher.java:55
↓ 6 callers
Method
equals
(Object o)
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:76
↓ 6 callers
Method
equals
(Object other)
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:392
↓ 6 callers
Method
equals
(Object o)
xds/src/main/java/io/grpc/xds/GrpcServiceConfigParser.java:318
↓ 6 callers
Method
equals
(Object o)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:664
↓ 6 callers
Method
equals
(Object o)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:107
↓ 6 callers
Method
error
(String error)
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:748
↓ 6 callers
Method
executor
()
netty/src/main/java/io/grpc/netty/SendPingCommand.java:38
↓ 6 callers
Method
expectSuccessfulHandshake
( ChannelCredentials channelCreds, ServerCredentials serverCreds)
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:373
↓ 6 callers
Method
expectUpdates
()
core/src/main/java/io/grpc/internal/ServiceConfigState.java:123
↓ 6 callers
Method
fallbackHandlerRegistry
Sets a fallback handler registry that will be looked up in if a method is not found in the primary registry. The primary registry (configured via {@co
api/src/main/java/io/grpc/ServerBuilder.java:181
↓ 6 callers
Method
fetchClientStatus
(io.envoyproxy.envoy.service.status.v3.ClientStatusRequest request, io.grpc.stub.StreamObserver<io.env
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/status/v3/ClientStatusDiscoveryServiceGrpc.java:159
↓ 6 callers
Method
filterContext
Called before the interceptors and the call handlers and make changes to the Context object if needed.
api/src/main/java/io/grpc/ServerStreamTracer.java:32
↓ 6 callers
Method
filterEnabled
The fraction of requests that will be checked by the authorization service. Defaults to all requests. @see ExtAuthz#getFilterEnabled()
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:96
↓ 6 callers
Method
finalize
(long hash)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:196
↓ 6 callers
Method
findVirtualHostForHostName
Returns the {@link VirtualHost} with the best match domain for the given hostname.
xds/src/main/java/io/grpc/xds/RoutingUtils.java:43
↓ 6 callers
Method
forAddress
Creates a server builder that will listen for bindings to the specified address. <p>The listening {@link IBinder} associated with new {@link Server}s
binder/src/main/java/io/grpc/binder/BinderServerBuilder.java:50
↓ 6 callers
Method
forAddress
Creates a new builder for the given server host, port and CronetEngine.
cronet/src/main/java/io/grpc/cronet/CronetChannelBuilder.java:63
↓ 6 callers
Method
forEds
(String clusterName, @Nullable String edsServiceName, @Nullable ServerInfo lrsServer
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:659
↓ 6 callers
Method
forFixedDelay
(long delayNanos, FractionalPercent percent)
xds/src/main/java/io/grpc/xds/FaultConfig.java:59
↓ 6 callers
Method
forRemoteComponent
Creates an address referencing a {@link android.app.Service} in another application and using the default binding {@link Intent}. @param applicationP
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:92
↓ 6 callers
Method
forSuffix
The request header value should have this suffix.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:115
↓ 6 callers
Method
forTarget
Create a channel builder that will connect to the server referenced by the given target URI. Only intended for use with a custom name resolver. @para
inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:72
↓ 6 callers
Method
forwardEcho
(io.istio.test.Echo.ForwardEchoRequest request, io.grpc.stub.StreamObserver<io.istio.test.Echo.Forward
istio-interop-testing/src/generated/main/grpc/io/istio/test/EchoTestServiceGrpc.java:149
↓ 6 callers
Method
get
(String target)
xds/src/main/java/io/grpc/xds/SharedXdsClientPoolProvider.java:75
↓ 6 callers
Method
getAggregatedState
Returns representative subchannel status from all registered subchannels.
rls/src/main/java/io/grpc/rls/SubchannelStateManager.java:43
↓ 6 callers
Method
getBidiStreamingRpcMethod
()
testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/SimpleServiceGrpc.java:114
↓ 6 callers
Method
getCacheableUnaryCallMethod
()
android-interop-testing/src/generated/release/grpc/io/grpc/testing/integration/TestServiceGrpc.java:82
← previous
next →
2,201–2,300 of 22,628, ranked by callers