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
↓ 2 callersMethodstartHandshake
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpProtocolNegotiatorTest.java:153
↓ 2 callersMethodstartMetricsService
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:225
↓ 2 callersMethodstartMissingResourceTimers
For any of the subscribers to one of the specified resources, if there isn't a result or an existing timer for the resource, start a timer for the res
xds/src/main/java/io/grpc/xds/client/XdsClient.java:493
↓ 2 callersMethodstartPendingStreams
Starts pending streams, returns true if at least one pending stream is started.
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:635
↓ 2 callersMethodstartServerAndGetChannel
(BindableService orcaService)
xds/src/test/java/io/grpc/xds/orca/OrcaServiceImplTest.java:88
↓ 2 callersMethodstartStream
(OkHttpClientStream stream)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:606
↓ 2 callersMethodstartWriteQueue
(Channel channel)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:396
↓ 2 callersMethodstatusFromFailedFuture
Intended to be overridden by NettyClientTransport, which has more information about failures. May only be called from event loop.
netty/src/main/java/io/grpc/netty/NettyClientStream.java:292
↓ 2 callersMethodstatusToPrettyString
Returns a "clean" representation of a status code and description (not cause) like "UNAVAILABLE: The description". Should be similar to Status.formatT
core/src/main/java/io/grpc/internal/GrpcUtil.java:834
↓ 2 callersMethodstopLoadReporting
Terminates load reporting. Calling this method on an already stopped {@link LoadReportClient} is no-op.
xds/src/main/java/io/grpc/xds/client/LoadReportClient.java:125
↓ 2 callersMethodstopRpc
(String msg)
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:366
↓ 2 callersMethodstopRpc
(String msg)
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:410
↓ 2 callersMethodstopTimer
()
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:799
↓ 2 callersMethodstreamGone
(int streamId, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:763
↓ 2 callersMethodstreamToBytes
(InputStream stream)
api/src/main/java/io/grpc/Metadata.java:1044
↓ 2 callersMethodstreamWrite
(ByteBuffer buffer, boolean endOfStream, boolean flush)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:391
↓ 2 callersMethodstreamingFromServer
<pre> Single-sided unbounded streaming from server to client The server repeatedly returns the client payload as-is </pre>
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java:273
↓ 2 callersMethodstripAttrs
(EquivalentAddressGroup eag)
core/src/testFixtures/java/io/grpc/internal/TestUtils.java:148
↓ 2 callersMethodstripForceXds
(QueryParams params)
googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:414
↓ 2 callersMethodstripOverrideAuthorityAttributes
( List<EquivalentAddressGroup> eags)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1974
↓ 2 callersMethodstripTransportDetails
Strip HTTP transport implementation details so they don't leak via metadata into the application layer.
core/src/main/java/io/grpc/internal/Http2ClientStreamTransportState.java:255
↓ 2 callersMethodstubsPerChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:731
↓ 2 callersMethodsubstreamDrained
The given substream is drained.
core/src/main/java/io/grpc/internal/RetriableStream.java:1237
↓ 2 callersMethodsubtestShutdownWithoutSubchannel
(GrpclbConfig grpclbConfig)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2134
↓ 2 callersMethodsubtest_maxConcurrentRequests_appliedByLbConfig
(boolean enableCircuitBreaking)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:697
↓ 2 callersMethodsubtest_maxConcurrentRequests_appliedWithDefaultValue
( boolean enableCircuitBreaking)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:792
↓ 2 callersMethodsuccessRateEjection
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:349
↓ 2 callersMethodsuffix
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:63
↓ 2 callersMethodswapCounters
Swaps the active and inactive counters. <p>Note that this method is not thread safe as the swap is not done atomically. This is expected to only be c
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:606
↓ 2 callersMethodswitchToInternal
(LoadBalancer.Factory newBalancerFactory)
util/src/main/java/io/grpc/util/GracefulSwitchLoadBalancer.java:108
↓ 2 callersMethodtearDown
()
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbFallbackTestClient.java:175
↓ 2 callersMethodterminated
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:388
↓ 2 callersMethodtest
(XxHash64 f, long[] hashesOfLoopingBytes)
xds/third_party/zero-allocation-hashing/test/java/io/grpc/xds/XxHash64Test.java:71
↓ 2 callersMethodtestCaseWeightPairs
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:716
↓ 2 callersMethodtestClientInterceptors
(boolean nonDefaultContext)
census/src/test/java/io/grpc/census/CensusModulesTest.java:266
↓ 2 callersMethodtestClientInterceptors
(boolean nonDefaultOtelContext)
opentelemetry/src/test/java/io/grpc/opentelemetry/OpenTelemetryTracingModuleTest.java:394
↓ 2 callersMethodtestInvalidTarget
(String target)
core/src/test/java/io/grpc/internal/ManagedChannelImplGetNameResolverTest.java:152
↓ 2 callersMethodthisT
Returns the correctly typed version of the builder.
api/src/main/java/io/grpc/ManagedChannelBuilder.java:674
↓ 2 callersMethodthrowIfInterrupted
()
stub/src/main/java/io/grpc/stub/ClientCalls.java:829
↓ 2 callersMethodtimeoutOnSleepingServer
Start a fullDuplexCall which the server will not respond, and verify the deadline expires.
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1628
↓ 2 callersMethodtls
Returns a {@link ProtocolNegotiator} that ensures the pipeline is set up so that TLS will be negotiated, the {@code handler} is added and writes to th
netty/src/main/java/io/grpc/netty/InternalProtocolNegotiators.java:44
↓ 2 callersMethodtlsClientFactory
(SslContext sslContext, X509TrustManager x509ExtendedTrustManager)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:793
↓ 2 callersMethodtoAddrString
(InetAddress ip)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InetAddressUtil.java:32
↓ 2 callersMethodtoAddrString
(InetAddress ip)
services/src/main/java/io/grpc/protobuf/services/InetAddressUtil.java:32
↓ 2 callersMethodtoAsciiString
Serialize a metadata value to a ASCII string that contains only the characters listed in the class comment of {@link AsciiMarshaller}. Otherwise the o
api/src/main/java/io/grpc/Metadata.java:608
↓ 2 callersMethodtoContextString
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:693
↓ 2 callersMethodtoGrpcStatus
(UrlResponseInfo info)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:579
↓ 2 callersMethodtoNegotiator
Converts a {@link ServerCredentials} to a negotiator, in similar fashion as for a new server. @throws IllegalArgumentException if unable to convert
netty/src/main/java/io/grpc/netty/InternalNettyServerCredentials.java:51
↓ 2 callersMethodtoServerData
(ServerStats stats)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:137
↓ 2 callersMethodtoServerRef
(InternalWithLogId obj)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:109
↓ 2 callersMethodtoSocketOptionAdditional
(String name, String value)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:317
↓ 2 callersMethodtoSocketOptionTcpInfo
(InternalChannelz.TcpInfo i)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:279
↓ 2 callersMethodtoSocketOptionTimeout
(String name, int timeoutMillis)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:266
↓ 2 callersMethodtoStream
()
api/src/main/java/io/grpc/Metadata.java:934
↓ 2 callersMethodtoString
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3191
↓ 2 callersMethodtoString
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:474
↓ 2 callersMethodtoString
()
core/src/main/java/io/grpc/internal/GrpcUtil.java:501
↓ 2 callersMethodtoString
()
core/src/main/java/io/grpc/internal/DelayedClientCall.java:424
↓ 2 callersMethodtoString
()
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:97
↓ 2 callersMethodtoString
()
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:123
↓ 2 callersMethodtoString
()
api/src/main/java/io/grpc/InternalChannelz.java:568
↓ 2 callersMethodtoString
()
istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:497
↓ 2 callersMethodtoString
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:944
↓ 2 callersMethodtoString
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:118
↓ 2 callersMethodtoString
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:546
↓ 2 callersMethodtoString
()
util/src/testFixtures/java/io/grpc/util/AbstractTestHelper.java:167
↓ 2 callersMethodtoString
()
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:409
↓ 2 callersMethodtoString
()
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:497
↓ 2 callersMethodtoString
()
xds/src/test/java/io/grpc/xds/LeastRequestLoadBalancerTest.java:659
↓ 2 callersMethodtoString
()
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:199
↓ 2 callersMethodtoString
()
cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java:180
↓ 2 callersMethodtoWriteBufferWithMinSize
(byte[] data, int minFrameSize)
core/src/test/java/io/grpc/internal/MessageFramerTest.java:360
↓ 2 callersMethodtraceOnly
(Event event)
core/src/main/java/io/grpc/internal/ChannelTracer.java:115
↓ 2 callersMethodtrackersWithVolume
Returns only the trackers that have the minimum configured volume to be considered.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:931
↓ 2 callersMethodtransact
(int code, ParcelHolder data)
binder/src/testFixtures/java/io/grpc/binder/internal/OneWayBinderProxies.java:95
↓ 2 callersMethodtransactAndRecycleParcel
(int code, Parcel data)
binder/src/main/java/io/grpc/binder/internal/OneWayBinderProxy.java:121
↓ 2 callersMethodtransportReportStatus
Report stream closure with status to the application layer if not already reported. This method must be called from the transport thread. @param stat
core/src/main/java/io/grpc/internal/AbstractClientStream.java:401
↓ 2 callersMethodtryFailure
(Throwable cause)
alts/src/main/java/io/grpc/alts/internal/ProtectedPromise.java:88
↓ 2 callersMethodtrySuccessInternal
()
alts/src/main/java/io/grpc/alts/internal/ProtectedPromise.java:140
↓ 2 callersMethodtypeUrl
()
xds/src/main/java/io/grpc/xds/RouteLookupServiceClusterSpecifierPlugin.java:93
↓ 2 callersMethodunallocatedBytes
()
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:245
↓ 2 callersMethodunaryEcho
Echos the request after a delay. It processes the request in-line within the callback. It uses Context to be notified of RPC cancellation.
examples/src/main/java/io/grpc/examples/cancellation/CancellationServer.java:162
↓ 2 callersMethodunaryRpc
<pre> Simple unary RPC. </pre>
testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/SimpleServiceGrpc.java:417
↓ 2 callersMethoduneject
()
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:381
↓ 2 callersMethodunejectSubchannels
Uneject a currently ejected address.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:624
↓ 2 callersMethodunimplementedMethod
Sends an rpc to an unimplemented method within TestService.
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1598
↓ 2 callersMethodunimplementedService
Sends an rpc to an unimplemented service on the server.
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1612
↓ 2 callersMethodunregister
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:165
↓ 2 callersMethodunregisterCall
(int callId)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:399
↓ 2 callersMethodunregisterNetworkListener
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:241
↓ 2 callersMethodupdateAddresses
(List<EquivalentAddressGroup> eags)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1580
↓ 2 callersMethodupdateAddresses
(List<EquivalentAddressGroup> addrs)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2894
↓ 2 callersMethodupdateAddresses
(List<EquivalentAddressGroup> addrs)
util/src/testFixtures/java/io/grpc/util/AbstractTestHelper.java:228
↓ 2 callersMethodupdateBalancingState
(ConnectivityState newState, SubchannelPicker newPicker)
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:398
↓ 2 callersMethodupdateBalancingState
(@Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker)
interop-testing/src/main/java/io/grpc/testing/integration/RpcBehaviorLoadBalancerProvider.java:151
↓ 2 callersMethodupdateBalancingState
(ConnectivityState newState, SubchannelPicker newPicker)
util/src/main/java/io/grpc/util/GracefulSwitchLoadBalancer.java:132
↓ 2 callersMethodupdateBalancingState
(final ConnectivityState newState, final SubchannelPicker newPicker)
xds/src/main/java/io/grpc/xds/WeightedTargetLoadBalancer.java:206
↓ 2 callersMethodupdateBalancingState
(final ConnectivityState newState, final SubchannelPicker newPicker)
xds/src/main/java/io/grpc/xds/ClusterManagerLoadBalancer.java:235
↓ 2 callersMethodupdateHealthCheckedState
(SubchannelData subchannelData)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:432
↓ 2 callersMethodupdateInternalInterceptor
()
authz/src/main/java/io/grpc/authz/FileWatcherAuthorizationServerInterceptor.java:64
← previousnext →5,301–5,400 of 22,628, ranked by callers