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 callersMethodparseRetryPolicy
( io.envoyproxy.envoy.config.route.v3.RetryPolicy retryPolicyProto)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:526
↓ 1 callersMethodparseRpcs
(String rpcArg)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:226
↓ 1 callersMethodparseServerAddresses
(String addressesStr)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:340
↓ 1 callersMethodparseServerSocketAddress
Parse a {@link SocketAddress} from the given string.
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:84
↓ 1 callersMethodparseServiceConfig
(Map<String, ?> rawServiceConfig)
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:650
↓ 1 callersMethodparseSource
(Map<String, ?> source)
authz/src/main/java/io/grpc/authz/AuthorizationPolicyTranslator.java:59
↓ 1 callersMethodparseTestCases
(String testCasesStr)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:352
↓ 1 callersMethodparseTracingObject
(Map<String, ?> rawCloudTracingConfig)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:156
↓ 1 callersMethodparseVirtualHost
( io.envoyproxy.envoy.config.route.v3.VirtualHost proto, FilterRegistry filterRegistry, Map<Strin
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:181
↓ 1 callersMethodpath
()
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:416
↓ 1 callersMethodpathMatcher
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:87
↓ 1 callersMethodpeekNextMessage
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:159
↓ 1 callersMethodpendingRpcComplete
(PendingCacheEntry entry)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:438
↓ 1 callersMethodperRpcBufferLimit
()
core/src/test/java/io/grpc/internal/ManagedChannelImplBuilderTest.java:684
↓ 1 callersMethodperRpcBufferLimit
Sets the per RPC buffer limit in bytes used for retry. The RPC is not retriable if its buffer limit is exceeded. The implementation may only estimate
api/src/main/java/io/grpc/ManagedChannelBuilder.java:496
↓ 1 callersMethodperRpcCreds
Sends a unary rpc with "per rpc" raw oauth2 access token credentials.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:919
↓ 1 callersMethodperTenThousand
(int numerator)
xds/src/main/java/io/grpc/xds/FaultConfig.java:112
↓ 1 callersMethodpercentDecode
(String encoded, int pos, int limit, boolean plusIsSpace)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:393
↓ 1 callersMethodperformCallback
( final SslContextGetter sslContextGetter, final Callback callback)
xds/src/main/java/io/grpc/xds/internal/security/SslContextProvider.java:116
↓ 1 callersMethodperformOneSoakIteration
( TestServiceGrpc.TestServiceBlockingStub soakStub, int soakRequestSize, int soakResponseSize)
interop-testing/src/main/java/io/grpc/testing/integration/SoakClient.java:90
↓ 1 callersMethodpermissions
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:129
↓ 1 callersMethodpermitKeepAliveTime
Specify the most aggressive keep-alive time clients are permitted to configure. The server will try to detect clients exceeding this rate and when det
api/src/main/java/io/grpc/ServerBuilder.java:351
↓ 1 callersMethodpermitKeepAliveTime
Specify the most aggressive keep-alive time clients are permitted to configure. The server will try to detect clients exceeding this rate and when det
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:654
↓ 1 callersMethodpermitKeepAliveWithoutCalls
Sets whether to allow clients to send keep-alive HTTP/2 PINGs even if there are no outstanding RPCs on the connection. Defaults to {@code false} when
api/src/main/java/io/grpc/ServerBuilder.java:366
↓ 1 callersMethodpersistValue
Returns true if this user agent should use this setting in future spdy/3 connections to the same host.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Settings.java:221
↓ 1 callersMethodpick
()
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:753
↓ 1 callersMethodpickAfterResolved_shuffle
()
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:162
↓ 1 callersMethodpickAfterResolved_shuffle
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:259
↓ 1 callersMethodpickAfterResolved_shuffleExplicitUniform
()
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:229
↓ 1 callersMethodpickAfterResolved_shuffleExplicitUniform
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:346
↓ 1 callersMethodpickAfterResolved_shuffleImplicitUniform
()
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:211
↓ 1 callersMethodpickAfterResolved_shuffleImplicitUniform
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:328
↓ 1 callersMethodpickFirstUnary
Assuming "pick_first" policy is used, tests that all requests are sent to the same server.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:729
↓ 1 callersMethodpickSubchannel
(PickSubchannelArgs args)
api/src/main/java/io/grpc/LoadBalancer.java:144
↓ 1 callersMethodpickSubchannel
(PickSubchannelArgs args)
interop-testing/src/main/java/io/grpc/testing/integration/RpcBehaviorLoadBalancerProvider.java:173
↓ 1 callersMethodpickUnusedPort
Picks a port that is not used right at this moment. Warning: Not thread safe. May see "BindException: Address already in use: bind" if using the retur
interop-testing/src/main/java/io/grpc/testing/integration/Util.java:105
↓ 1 callersMethodpicked
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:970
↓ 1 callersMethodping
()
core/src/main/java/io/grpc/internal/KeepAliveManager.java:287
↓ 1 callersMethodping
(final PingCallback callback, final Executor executor)
netty/src/main/java/io/grpc/netty/NettyClientTransport.java:169
↓ 1 callersMethodpingPong
()
alts/src/test/java/io/grpc/alts/internal/FakeTsiTest.java:170
↓ 1 callersMethodpingPong
Issues request and waits for response.
benchmarks/src/jmh/java/io/grpc/benchmarks/TransportBenchmark.java:248
↓ 1 callersMethodplaintext
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:753
↓ 1 callersMethodplaintextClientFactory
()
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:940
↓ 1 callersMethodplaintextUpgradeClientFactory
()
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:838
↓ 1 callersMethodplugin
(OpenTelemetryPlugin plugin)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:394
↓ 1 callersMethodpolicies
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:107
↓ 1 callersMethodpollNextTransaction
Returns the next transaction that was queued in order, waiting up to the specified timeout.
binder/src/testFixtures/java/io/grpc/binder/internal/OneWayBinderProxies.java:163
↓ 1 callersMethodpopulate
(int count)
core/src/jmh/java/io/grpc/internal/ChannelzBenchmark.java:76
↓ 1 callersMethodport
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:236
↓ 1 callersMethodpreAuthorize
(ServiceInfo serviceInfo)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:187
↓ 1 callersMethodpreAuthorizeServers
Checks servers against this Channel's {@link SecurityPolicy} before binding. <p>Android users can be tricked into installing a malicious app with the
binder/src/main/java/io/grpc/binder/BinderChannelBuilder.java:277
↓ 1 callersMethodprestart
Runs pre-start tasks. Returns the Status of shutdown if the channel is shutdown.
core/src/main/java/io/grpc/internal/RetriableStream.java:379
↓ 1 callersMethodprincipals
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:131
↓ 1 callersMethodprintStats
(Histogram histogram, long elapsedTime)
benchmarks/src/main/java/io/grpc/benchmarks/qps/OpenLoopClient.java:104
↓ 1 callersMethodprintStats
(Histogram histogram, long elapsedTime)
benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java:261
↓ 1 callersMethodprintSummary
()
examples/src/main/java/io/grpc/examples/hedging/HedgingHelloWorldClient.java:107
↓ 1 callersMethodprintSummary
()
examples/src/main/java/io/grpc/examples/retrying/RetryingHelloWorldClient.java:108
↓ 1 callersMethodpriority
()
core/src/main/java/io/grpc/internal/DnsNameResolverProvider.java:107
↓ 1 callersMethodpriority
A priority, from 0 to 10 that this provider should be used, taking the current environment into consideration. 5 should be considered the default, and
api/src/main/java/io/grpc/NameResolverProvider.java:56
↓ 1 callersMethodpriority
A priority, from 0 to 10 that this provider should be used, taking the current environment into consideration. 5 should be considered the default, and
xds/src/main/java/io/grpc/xds/XdsCredentialsProvider.java:73
↓ 1 callersMethodpriority
()
xds/src/main/java/io/grpc/xds/Endpoints.java:44
↓ 1 callersMethodpriorityName
Generates a string that represents the priority in the LB policy config. The string is unique across priorities in all clusters and priorityName(c, p1
xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:274
↓ 1 callersMethodprocessBody
Processes the GRPC message body, which depending on frame header flags may be compressed.
core/src/main/java/io/grpc/internal/MessageDeframer.java:411
↓ 1 callersMethodprocessClientSideListener
(Listener listener, XdsResourceType.Args args)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:117
↓ 1 callersMethodprocessClusterLoadAssignment
(ClusterLoadAssignment assignment)
xds/src/main/java/io/grpc/xds/XdsEndpointResource.java:115
↓ 1 callersMethodprocessFileDescriptor
(FileDescriptor fd)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:479
↓ 1 callersMethodprocessHeader
Processes the GRPC compression header which is composed of the compression flag and the outer frame length.
core/src/main/java/io/grpc/internal/MessageDeframer.java:383
↓ 1 callersMethodprocessHeader
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:318
↓ 1 callersMethodprocessHeaderComment
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:368
↓ 1 callersMethodprocessHeaderCrc
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:380
↓ 1 callersMethodprocessHeaderExtra
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:347
↓ 1 callersMethodprocessHeaderExtraLen
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:334
↓ 1 callersMethodprocessHeaderName
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:356
↓ 1 callersMethodprocessRouteConfiguration
( RouteConfiguration routeConfig, FilterRegistry filterRegistry, XdsResourceType.Args args)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:138
↓ 1 callersMethodprocessServerSideListener
(Listener proto, XdsResourceType.Args args)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:133
↓ 1 callersMethodprocessService
(ServiceDescriptor service, FileDescriptor fd)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:494
↓ 1 callersMethodprocessSubchannelState
(SubchannelData subchannelData, ConnectivityStateInfo stateInfo)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:286
↓ 1 callersMethodprocessSubchannelState
(Subchannel subchannel, ConnectivityStateInfo stateInfo)
core/src/main/java/io/grpc/internal/PickFirstLoadBalancer.java:107
↓ 1 callersMethodprocessSubchannelState
(Subchannel subchannel, ConnectivityStateInfo stateInfo)
examples/src/main/java/io/grpc/examples/customloadbalance/ShufflingPickFirstLoadBalancer.java:114
↓ 1 callersMethodprocessType
(Descriptor type, FileDescriptor fd)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:511
↓ 1 callersMethodpropagateTlsComplete
(ChannelHandlerContext ctx, SSLSession session)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:729
↓ 1 callersMethodprotoToMapConverter
(GrpcLogRecord logProto)
gcp-observability/src/main/java/io/grpc/gcp/observability/logging/GcpLogSink.java:179
↓ 1 callersMethodprotocol
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:313
↓ 1 callersMethodprotocolIds
(List<Protocol> protocols)
okhttp/src/main/java/io/grpc/okhttp/OkHttpProtocolNegotiator.java:360
↓ 1 callersMethodprotocolNegotiationEventTriggered
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:1189
↓ 1 callersMethodprotocolNegotiator
Sets the {@link ProtocolNegotiator} to be used. Overrides the value specified in {@link #sslContext(SslContext)}.
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:378
↓ 1 callersMethodproxyDetector
Sets the proxy detector to be used in addresses name resolution. If <code>null</code> is passed the default proxy detector will be used. For how prox
api/src/main/java/io/grpc/ManagedChannelBuilder.java:561
↓ 1 callersMethodproxyFor
(SocketAddress targetServerAddress)
core/src/main/java/io/grpc/internal/ProxyDetectorImpl.java:173
↓ 1 callersMethodpushbackHedging
(@Nullable Integer delayMillis)
core/src/main/java/io/grpc/internal/RetriableStream.java:433
↓ 1 callersMethodputNewTrackers
Adds a new tracker for every given address.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:690
↓ 1 callersMethodqueryIntentServices
(Intent intent)
binder/src/main/java/io/grpc/binder/internal/IntentNameResolver.java:226
↓ 1 callersMethodqueryIpv6SupportMetadata
(String url)
googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:373
↓ 1 callersMethodqueryZoneMetadata
(String url)
googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:353
↓ 1 callersMethodquotedAV
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/DistinguishedNameParser.java:107
↓ 1 callersMethodrandomFloat
()
rls/src/main/java/io/grpc/rls/AdaptiveThrottler.java:128
↓ 1 callersMethodrawBinderSupplier
()
binder/src/androidTest/java/io/grpc/binder/HostServices.java:67
↓ 1 callersMethodreactivate
Called when the child becomes a priority that is or appears before the first READY one in the {@code priorities} list, due to either config update or
xds/src/main/java/io/grpc/xds/PriorityLoadBalancer.java:258
↓ 1 callersMethodreactivateChild
()
xds/src/main/java/io/grpc/xds/ClusterManagerLoadBalancer.java:207
↓ 1 callersMethodread
This method can also be used to simultaneously perform operation-specific int-valued aggregation over the sequence of buffers in a {@link CompositeRea
core/src/main/java/io/grpc/internal/CompositeReadableBuffer.java:333
↓ 1 callersMethodreadBytes
Reads bytes from input, parsing them into a frame. Returns false if and only if more data is needed. To obtain a full frame this method must be called
alts/src/main/java/io/grpc/alts/internal/AltsFraming.java:145
← previousnext →7,101–7,200 of 22,628, ranked by callers