MCPcopy Create free account

hub / github.com/grpc/grpc-java / functions

Functions22,628 in github.com/grpc/grpc-java

↓ 6 callersMethodaddListenSocket
(InternalInstrumented<SocketStats> socket)
api/src/main/java/io/grpc/InternalChannelz.java:100
↓ 6 callersMethodaddServices
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 callersMethodalias
()
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:64
↓ 6 callersMethodappendNameAndValue
(StringBuilder builder, CharSequence name, CharSequence value, boolean prependSeparator)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:299
↓ 6 callersMethodapplyRequestMetadata
( CallCredentials.RequestInfo requestInfo, Executor appExecutor, CallCredentials.MetadataApp
alts/src/main/java/io/grpc/alts/DualCallCredentials.java:35
↓ 6 callersMethodasBindIntent
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 callersMethodassertClusterImplConfig
(ClusterImplConfig config, String cluster, @Nullable String edsServiceName, ServerInfo lrsServerInfo, Lo
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1076
↓ 6 callersMethodassertCurrentPicker
(ConnectivityState state, PickResult result)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1041
↓ 6 callersMethodassertDuplicatelPatternDetected
(String factoryConfigStr)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:344
↓ 6 callersMethodassertRpcStatusRecorded
( Status.Code code, long roundtripLatencyMs, long outboundMessages)
interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:258
↓ 6 callersMethodasyncPolicy
(Function<Integer, ListenableFuture<Status>> func)
binder/src/test/java/io/grpc/binder/ServerSecurityPolicyTest.java:356
↓ 6 callersMethodauthority
()
core/src/test/java/io/grpc/internal/ForwardingManagedChannelTest.java:97
↓ 6 callersMethodawaitClose
()
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:616
↓ 6 callersMethodbb
(String s, Channel c)
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:1545
↓ 6 callersMethodbuildDropOverload
(String category, int dropPerMillion)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5365
↓ 6 callersMethodbuildFilterChain
( List<String> alpn, Message tlsContext, String transportSocketName, Message... filters)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5367
↓ 6 callersMethodbuildHttpConnectionManagerFilter
( @Nullable String rdsName, @Nullable Message routeConfig, List<Message> httpFilters)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5374
↓ 6 callersMethodbuildListenerWithFilterChain
( String name, int portValue, String address, Message... filterChains)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5371
↓ 6 callersMethodbuildLogicalDnsCluster
(String clusterName, String dnsHostAddr, int dnsHostPort, String lbPolicy, @Nullable Message ringHashL
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5327
↓ 6 callersMethodbuildNewUpstreamTlsContextForCertProviderInstance
Helper method to build UpstreamTlsContext for CertProvider tests.
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:374
↓ 6 callersMethodbuildTerminalFilter
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5377
↓ 6 callersMethodbuildTestDownstreamTlsContext
Helper method for creating DownstreamTlsContext values with names.
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:126
↓ 6 callersMethodbuildTlsProtocolVersionSet
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 callersMethodbuilder
()
binder/src/androidTest/java/io/grpc/binder/HostServices.java:75
↓ 6 callersMethodcallUpdateSslContext
()
xds/src/test/java/io/grpc/xds/internal/security/SslContextProviderSupplierTest.java:69
↓ 6 callersMethodcanHandleEmptyAddressListFromNameResolution
()
util/src/main/java/io/grpc/util/ForwardingLoadBalancer.java:55
↓ 6 callersMethodcanonicalizeHost
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 callersMethodcheck
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 callersMethodcheckClientTrusted
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 callersMethodcheckObject
(Object o)
core/src/test/java/io/grpc/internal/ServiceConfigUtilTest.java:122
↓ 6 callersMethodcheckPercentEncodedArg
(String s, String what, BitSet allowedChars)
api/src/main/java/io/grpc/Uri.java:1146
↓ 6 callersMethodcheckServerTrusted
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 callersMethodchooseDelegate
(X509Certificate[] chain)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:326
↓ 6 callersMethodchooseEngineServerAlias
(String keyType, Principal[] issuers, SSLEngine engine)
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:120
↓ 6 callersMethodcleanupExpiredEntries
Returns {@code true} if any entries were removed.
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:256
↓ 6 callersMethodcombine
( Node<K,V> node1, int hash1, Node<K,V> node2, int hash2, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:246
↓ 6 callersMethodconnectionError
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 callersMethodconnectionSourceType
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:246
↓ 6 callersMethodconvertTlsProtocolVersion
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 callersMethodcreate
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 callersMethodcreate
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 callersMethodcreate
(ProtocolNegotiator.ClientFactory negotiator)
netty/src/main/java/io/grpc/netty/NettyChannelCredentials.java:24
↓ 6 callersMethodcreate
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 callersMethodcreate
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 callersMethodcreate
(ChannelCredentials creds, ChannelCredsConfig config)
xds/src/main/java/io/grpc/xds/client/ConfiguredChannelCredentials.java:33
↓ 6 callersMethodcreate
(MetricType metricType, Optional<String> key)
xds/src/main/java/io/grpc/xds/internal/MetricReportUtils.java:47
↓ 6 callersMethodcreate
(Matchers.StringMatcher delegate)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:210
↓ 6 callersMethodcreateAnonymousServer
()
inprocess/src/test/java/io/grpc/inprocess/AnonymousInProcessSocketAddressTest.java:99
↓ 6 callersMethodcreateAttributes
(List<String> requiredLabelKeys, List<String> optionalLabelKeys, List<String> requiredLabelValues,
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricSink.java:302
↓ 6 callersMethodcreateCustomCensusTracerFactory
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:404
↓ 6 callersMethodcreateMatch
Returns the least-specific match-all Filter Chain Match.
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1974
↓ 6 callersMethodcreateServer
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1776
↓ 6 callersMethodcreateTls
()
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:2030
↓ 6 callersMethodcumulate
"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 callersMethodcurrentTimeMillis
()
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:597
↓ 6 callersMethoddelayOrExecute
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 callersMethoddeliverResolvedAddresses
()
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:616
↓ 6 callersMethoddestinationPort
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:238
↓ 6 callersMethoddisableButtons
()
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:125
↓ 6 callersMethoddisableServiceConfigLookUp
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 callersMethoddiscard
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 callersMethoddoHandshake
()
alts/src/test/java/io/grpc/alts/internal/AltsProtocolNegotiatorTest.java:385
↓ 6 callersMethoddrainTo
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 callersMethodempty
Returns an empty {@link ManagedChannelServiceConfig}.
core/src/main/java/io/grpc/internal/ManagedChannelServiceConfig.java:75
↓ 6 callersMethodenablePluginForChannel
(String target)
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:177
↓ 6 callersMethodenableRetry
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:531
↓ 6 callersMethodenableUntrustedAltsForTesting
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 callersMethodencode
(String hex)
opentelemetry/src/test/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagatorTest.java:300
↓ 6 callersMethodendsWith
Returns {@code true} if {@code subject} ends with {@code suffix}.
core/src/main/java/io/grpc/internal/TransportFrameUtil.java:153
↓ 6 callersMethodensureServerStateNotLeaked
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1798
↓ 6 callersMethodenterIdle
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1245
↓ 6 callersMethodeqMetricInstrumentName
(String name)
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:1687
↓ 6 callersMethodeqPickSubchannelArgs
( MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions)
api/src/testFixtures/java/io/grpc/PickSubchannelArgsMatcher.java:55
↓ 6 callersMethodequals
(Object o)
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:76
↓ 6 callersMethodequals
(Object other)
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:392
↓ 6 callersMethodequals
(Object o)
xds/src/main/java/io/grpc/xds/GrpcServiceConfigParser.java:318
↓ 6 callersMethodequals
(Object o)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:664
↓ 6 callersMethodequals
(Object o)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:107
↓ 6 callersMethoderror
(String error)
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:748
↓ 6 callersMethodexecutor
()
netty/src/main/java/io/grpc/netty/SendPingCommand.java:38
↓ 6 callersMethodexpectSuccessfulHandshake
( ChannelCredentials channelCreds, ServerCredentials serverCreds)
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:373
↓ 6 callersMethodexpectUpdates
()
core/src/main/java/io/grpc/internal/ServiceConfigState.java:123
↓ 6 callersMethodfallbackHandlerRegistry
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 callersMethodfetchClientStatus
(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 callersMethodfilterContext
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 callersMethodfilterEnabled
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 callersMethodfinalize
(long hash)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:196
↓ 6 callersMethodfindVirtualHostForHostName
Returns the {@link VirtualHost} with the best match domain for the given hostname.
xds/src/main/java/io/grpc/xds/RoutingUtils.java:43
↓ 6 callersMethodforAddress
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 callersMethodforAddress
Creates a new builder for the given server host, port and CronetEngine.
cronet/src/main/java/io/grpc/cronet/CronetChannelBuilder.java:63
↓ 6 callersMethodforEds
(String clusterName, @Nullable String edsServiceName, @Nullable ServerInfo lrsServer
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:659
↓ 6 callersMethodforFixedDelay
(long delayNanos, FractionalPercent percent)
xds/src/main/java/io/grpc/xds/FaultConfig.java:59
↓ 6 callersMethodforRemoteComponent
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 callersMethodforSuffix
The request header value should have this suffix.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:115
↓ 6 callersMethodforTarget
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 callersMethodforwardEcho
(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 callersMethodget
(String target)
xds/src/main/java/io/grpc/xds/SharedXdsClientPoolProvider.java:75
↓ 6 callersMethodgetAggregatedState
Returns representative subchannel status from all registered subchannels.
rls/src/main/java/io/grpc/rls/SubchannelStateManager.java:43
↓ 6 callersMethodgetBidiStreamingRpcMethod
()
testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/SimpleServiceGrpc.java:114
↓ 6 callersMethodgetCacheableUnaryCallMethod
()
android-interop-testing/src/generated/release/grpc/io/grpc/testing/integration/TestServiceGrpc.java:82
← previousnext →2,201–2,300 of 22,628, ranked by callers