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 callersMethodshutdown
()
core/src/main/java/io/grpc/internal/AutoConfiguredLoadBalancerFactory.java:140
↓ 1 callersMethodshutdown
(final Status reason)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:438
↓ 1 callersMethodshutdown
Prevents creating any new streams. Buffered streams are not failed and may still proceed when {@link #reprocess} is called. The delayed transport will
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:208
↓ 1 callersMethodshutdown
Initiates an orderly shutdown in which preexisting calls continue but new calls are rejected.
core/src/main/java/io/grpc/internal/ServerImpl.java:253
↓ 1 callersMethodshutdown
()
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:458
↓ 1 callersMethodshutdown
Initiates an orderly shutdown in which preexisting calls continue but new calls are immediately cancelled.
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:708
↓ 1 callersMethodshutdown
()
core/src/main/java/io/grpc/internal/PickFirstLoadBalancer.java:158
↓ 1 callersMethodshutdown
()
core/src/main/java/io/grpc/internal/ManagedChannelOrphanWrapper.java:63
↓ 1 callersMethodshutdown
()
inprocess/src/main/java/io/grpc/inprocess/InProcessServer.java:116
↓ 1 callersMethodshutdown
(Status reason)
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:262
↓ 1 callersMethodshutdown
Stops the resolution. Updates to the Listener will stop. @since 1.0.0
api/src/main/java/io/grpc/NameResolver.java:132
↓ 1 callersMethodshutdown
The channel asks the load-balancer to shutdown. No more methods on this class will be called after this method. The implementation should shutdown a
api/src/main/java/io/grpc/LoadBalancer.java:408
↓ 1 callersMethodshutdown
()
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:143
↓ 1 callersMethodshutdown
()
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbLongLivedAffinityTestClient.java:136
↓ 1 callersMethodshutdown
()
examples/example-oauth/src/main/java/io/grpc/examples/oauth/AuthClient.java:62
↓ 1 callersMethodshutdown
()
examples/src/main/java/io/grpc/examples/hedging/HedgingHelloWorldClient.java:75
↓ 1 callersMethodshutdown
()
examples/src/main/java/io/grpc/examples/header/CustomHeaderClient.java:55
↓ 1 callersMethodshutdown
()
examples/src/main/java/io/grpc/examples/advanced/HelloJsonClient.java:58
↓ 1 callersMethodshutdown
()
examples/src/main/java/io/grpc/examples/experimental/CompressingHelloWorldClient.java:51
↓ 1 callersMethodshutdown
()
examples/src/main/java/io/grpc/examples/retrying/RetryingHelloWorldClient.java:81
↓ 1 callersMethodshutdown
()
examples/example-gauth/src/main/java/io/grpc/examples/googleAuth/GoogleAuthClient.java:73
↓ 1 callersMethodshutdown
()
examples/example-jwt-auth/src/main/java/io/grpc/examples/jwtauth/AuthClient.java:61
↓ 1 callersMethodshutdown
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:279
↓ 1 callersMethodshutdown
(Status reason)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:990
↓ 1 callersMethodshutdown
(List<ManagedChannel> channels)
benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java:286
↓ 1 callersMethodshutdown
Override for unique behavior such as delayed shutdowns of subchannels.
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:286
↓ 1 callersMethodshutdown
Called after final call to {@link #waitAndDrain()}, from same thread.
stub/src/main/java/io/grpc/stub/ClientCalls.java:838
↓ 1 callersMethodshutdown
()
cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java:185
↓ 1 callersMethodshutdownInput
()
android/src/main/java/io/grpc/android/UdsSocket.java:295
↓ 1 callersMethodshutdownLbRpc
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:397
↓ 1 callersMethodshutdownLowerPriorityCpcs
(ControlPlaneClient activatedCpc)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:649
↓ 1 callersMethodshutdownNow
Initiates a forceful shutdown in which preexisting and new calls are closed. Existing calls should be closed with the provided {@code reason}.
core/src/main/java/io/grpc/internal/ManagedClientTransport.java:64
↓ 1 callersMethodshutdownRemaining
Shuts down remaining subchannels. Called when a subchannel becomes ready, which means that all other subchannels must be shutdown.
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:482
↓ 1 callersMethodsize
()
core/src/test/java/io/grpc/internal/MessageFramerTest.java:434
↓ 1 callersMethodsize
Returns the number of field values.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Headers.java:49
↓ 1 callersMethodsize
()
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:33
↓ 1 callersMethodskip
(long n)
binder/src/main/java/io/grpc/binder/internal/ParcelableInputStream.java:121
↓ 1 callersMethodsortByName
(List<MetricData> metrics)
opentelemetry/src/test/java/io/grpc/opentelemetry/OpenTelemetryMetricsModuleTest.java:2158
↓ 1 callersMethodspecialStatusMessage
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1576
↓ 1 callersMethodstart
(ResolvedAddressFactory childLbResolvedAddressFactory)
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:312
↓ 1 callersMethodstart
(final ClientStreamListener listener)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:781
↓ 1 callersMethodstart
(ServerListener serverListener)
inprocess/src/main/java/io/grpc/inprocess/InProcessServer.java:75
↓ 1 callersMethodstart
Bind and start the server. After this call returns, clients may begin connecting to the listening socket(s). @return {@code this} object @throws Ill
api/src/main/java/io/grpc/Server.java:50
↓ 1 callersMethodstart
()
examples/example-oauth/src/main/java/io/grpc/examples/oauth/AuthServer.java:44
↓ 1 callersMethodstart
()
examples/example-gcp-observability/src/main/java/io/grpc/examples/gcpobservability/GcpObservabilityServer.java:40
↓ 1 callersMethodstart
()
examples/example-tls/src/main/java/io/grpc/examples/helloworldtls/HelloWorldServerTls.java:47
↓ 1 callersMethodstart
()
examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsServer.java:51
↓ 1 callersMethodstart
(int port)
examples/example-opentelemetry/src/main/java/io/grpc/example/opentelemetry/OpenTelemetryServer.java:42
↓ 1 callersMethodstart
(int port)
examples/example-opentelemetry/src/main/java/io/grpc/example/opentelemetry/logging/LoggingOpenTelemetryServer.java:44
↓ 1 callersMethodstart
(int port)
examples/example-gcp-csm-observability/src/main/java/io/grpc/examples/csmobservability/CsmObservabilityServer.java:44
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/helloworld/HelloWorldServer.java:36
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/healthservice/HealthServiceServer.java:42
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/multiplex/MultiplexingServer.java:49
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/preserialized/PreSerializedServer.java:50
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/deadline/DeadlineServer.java:37
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/nameresolve/NameResolveServer.java:42
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/hedging/HedgingHelloWorldServer.java:44
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/loadbalance/LoadBalanceServer.java:37
↓ 1 callersMethodstart
Start serving requests.
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideServer.java:72
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/header/CustomHeaderServer.java:42
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/advanced/HelloJsonServer.java:51
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/experimental/CompressingHelloWorldServerPerMethod.java:41
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/experimental/CompressingHelloWorldServerAllMethods.java:45
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/keepalive/KeepAliveServer.java:38
↓ 1 callersMethodstart
()
examples/src/main/java/io/grpc/examples/retrying/RetryingHelloWorldServer.java:44
↓ 1 callersMethodstart
()
examples/example-dualstack/src/main/java/io/grpc/examples/dualstack/DualStackServer.java:48
↓ 1 callersMethodstart
()
examples/example-reflection/src/main/java/io/grpc/examples/reflection/ReflectionServer.java:24
↓ 1 callersMethodstart
()
examples/example-jwt-auth/src/main/java/io/grpc/examples/jwtauth/AuthServer.java:44
↓ 1 callersMethodstart
(ServerTransportListener listener)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:159
↓ 1 callersMethodstart
Initializes this transport instance. <p>Must be called exactly once, even if {@link #shutdown} or {@link #shutdownNow} was called first. @param serv
binder/src/main/java/io/grpc/binder/internal/BinderServerTransport.java:86
↓ 1 callersMethodstart
()
benchmarks/src/main/java/io/grpc/benchmarks/driver/LoadWorker.java:62
↓ 1 callersMethodstart
(ServerTransportListener listener)
netty/src/main/java/io/grpc/netty/NettyServerTransport.java:139
↓ 1 callersMethodstart
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:861
↓ 1 callersMethodstart
()
xds/src/main/java/io/grpc/xds/internal/security/certprovider/SystemRootCertificateProvider.java:42
↓ 1 callersMethodstart
Starts the async cert refresh and watcher update cycle.
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:170
↓ 1 callersMethodstart
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:250
↓ 1 callersMethodstartAltsServer
()
interop-testing/src/test/java/io/grpc/testing/integration/AltsHandshakerTest.java:52
↓ 1 callersMethodstartCallTreeServer
Create a tree of client to server calls where each received call on the server fans out to two downstream calls. Uses SimpleRequest.response_size to l
interop-testing/src/test/java/io/grpc/testing/integration/CascadingTest.java:278
↓ 1 callersMethodstartGoAway
(Status status)
cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java:221
↓ 1 callersMethodstartHandshake
()
okhttp/src/main/java/io/grpc/okhttp/NoopSslSocket.java:73
↓ 1 callersMethodstartInternal
(Listener<RespT> observer, Metadata headers)
core/src/main/java/io/grpc/internal/ClientCallImpl.java:188
↓ 1 callersMethodstartIo
(SerializingExecutor serializingExecutor)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:166
↓ 1 callersMethodstartLbComm
(List<EquivalentAddressGroup> overrideAuthorityEags)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:404
↓ 1 callersMethodstartMetricsLogging
Starts logging gauge information at a given rate (if rate > -1).
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:236
↓ 1 callersMethodstartServer
(int serverFlowControlWindow)
interop-testing/src/test/java/io/grpc/testing/integration/NettyFlowControlTest.java:172
↓ 1 callersMethodstartServer
(@Nullable ServerBuilder<?> builder)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:251
↓ 1 callersMethodstartServer
(Map<String, ?> bootstrapOverride)
xds/src/test/java/io/grpc/xds/DataPlaneRule.java:128
↓ 1 callersMethodstartServerAsync
(final Server xdsServer)
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:862
↓ 1 callersMethodstartServerCallHelper
( final ServerMethodDefinition<ReqT, RespT> methodDef, final List<Object> serializedResp)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:285
↓ 1 callersMethodstartStream
Reports a new ServerStream requested by the remote client. <p>Precondition: {@link #start(ServerTransportListener)} must already have been called.
binder/src/main/java/io/grpc/binder/internal/BinderServerTransport.java:115
↓ 1 callersMethodstartStream
(CronetClientStream stream)
cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java:155
↓ 1 callersMethodstartStreamingCalls
Start a continuously executing set of duplex streaming ping-pong calls that will terminate when {@code done.get()} is true. Each completed call will i
benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java:438
↓ 1 callersMethodstartUnaryCalls
Start a continuously executing set of unary calls that will terminate when {@code done.get()} is true. Each completed call will increment the counter
benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java:402
↓ 1 callersMethodstartWorkers
(LocalSocket clientSocket, Socket serverSocket)
android-interop-testing/src/main/java/io/grpc/android/integrationtest/UdsTcpEndpointConnector.java:122
↓ 1 callersMethodstartWorkers
()
interop-testing/src/test/java/io/grpc/testing/integration/TrafficControlProxy.java:122
↓ 1 callersMethodstartWrappedCall
( String fullMethodName, ServerCallParameters<WReqT, WRespT> params, Metadata headers)
core/src/main/java/io/grpc/internal/ServerImpl.java:689
↓ 1 callersMethodstatusCodeAndMessage
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1535
↓ 1 callersMethodstatusFromFailedFuture
(ChannelFuture f)
netty/src/main/java/io/grpc/netty/NettyClientTransport.java:216
↓ 1 callersMethodstatusFromTrailers
Extract the response status from trailers.
core/src/main/java/io/grpc/internal/Http2ClientStreamTransportState.java:193
↓ 1 callersMethodstop
()
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestServer.java:290
← previousnext →7,601–7,700 of 22,628, ranked by callers