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
↓ 5 callersMethodtoRawSerializedHeaders
Transform HTTP/2-compliant headers to the raw serialized format which can be deserialized by metadata marshallers. It decodes the Base64-encoded binar
core/src/main/java/io/grpc/internal/TransportFrameUtil.java:99
↓ 5 callersMethodtoStatus
(com.google.rpc.Status statusProto)
protobuf/src/main/java/io/grpc/protobuf/StatusProto.java:125
↓ 5 callersMethodtoString
()
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:1096
↓ 5 callersMethodtoString
()
services/src/test/java/io/grpc/protobuf/services/ChannelzProtoUtilTest.java:548
↓ 5 callersMethodtoString
()
api/src/main/java/io/grpc/NameResolver.java:518
↓ 5 callersMethodtoString
()
api/src/main/java/io/grpc/Metadata.java:544
↓ 5 callersMethodtoString
()
util/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java:586
↓ 5 callersMethodtrailersFromThrowable
Extract an error trailers from the causal chain of a {@link Throwable}. @return the trailers or {@code null} if not found.
api/src/main/java/io/grpc/Status.java:415
↓ 5 callersMethodtransportState
Obtain the transport state corresponding to this stream. Each stream must have its own unique transport state.
core/src/main/java/io/grpc/internal/AbstractStream.java:48
↓ 5 callersMethodtransportTerminated
The transport completed shutting down. All resources have been released.
core/src/main/java/io/grpc/internal/ServerTransportListener.java:48
↓ 5 callersMethodtype
Returns the type of the credentials.
xds/src/main/java/io/grpc/xds/client/ConfiguredChannelCredentials.java:46
↓ 5 callersMethodunavailabilityCause
Returns the reason why the resource resolver cannot be created. The return value is {@code null} if {@link #newResourceResolver()} is suitable for us
core/src/main/java/io/grpc/internal/DnsNameResolver.java:584
↓ 5 callersMethodupdateActiveFiltersForChain
( Map<String, Filter> chainFilters, @Nullable List<NamedFilterConfig> filterConfigs)
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:601
↓ 5 callersMethodupdateLoadMetricStats
(String metricName, double value)
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:398
↓ 5 callersMethodupdateOobChannelAddresses
(ManagedChannel channel, EquivalentAddressGroup eag)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2974
↓ 5 callersMethodvalue
()
xds/src/main/java/io/grpc/xds/internal/grpcservice/HeaderValue.java:41
↓ 5 callersMethodverifyConnectionsByServer
( int clientsCount, int serversCount, int subsetSize, int expectedMaxConnections)
util/src/test/java/io/grpc/util/RandomSubsettingLoadBalancerTest.java:247
↓ 5 callersMethodverifyGracefulShutdown
(int lastStreamId)
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1397
↓ 5 callersMethodverifyResponse
(ClientStatusResponse response)
xds/src/test/java/io/grpc/xds/CsdsServiceTest.java:298
↓ 5 callersMethodverifyRpcDelayed
(ClientCall.Listener<Void> observer, long expectedDelayNanos)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2476
↓ 5 callersMethodverifyWatcherErrorUpdates
( Status.Code code, Class<?> throwableType, int updateCertCount, int updateRootCount,
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:457
↓ 5 callersMethodwaitForShutdown
(long timeout, TimeUnit unit)
core/src/testFixtures/java/io/grpc/internal/MockServerListener.java:66
↓ 5 callersMethodwaitForTermination
(long timeout, TimeUnit unit)
core/src/testFixtures/java/io/grpc/internal/MockServerTransportListener.java:63
↓ 5 callersMethodwithCompression
Sets the compression to use for the call. The compressor must be a valid name known in the {@link CompressorRegistry}. By default, the "gzip" compre
api/src/main/java/io/grpc/CallOptions.java:153
↓ 5 callersMethodwithDeadlineAfter
()
api/src/test/java/io/grpc/CallOptionsTest.java:146
↓ 5 callersMethodwritableNioBuffers
Called to get access to the underlying NIO buffers for a {@link ByteBuf} that will be used for writing.
alts/src/main/java/io/grpc/alts/internal/BufUnwrapper.java:33
↓ 5 callersMethodwriteByteString
(ByteString data)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:531
↓ 4 callersMethodabstractClientStreamSink
Sink for transport to be called to perform outbound operations. Each stream must have its own unique sink.
core/src/main/java/io/grpc/internal/AbstractClientStream.java:167
↓ 4 callersMethodabstractServerStreamSink
Sink for transport to be called to perform outbound operations. Each stream must have its own unique sink.
core/src/main/java/io/grpc/internal/AbstractServerStream.java:92
↓ 4 callersMethodacceptResolvedAddresses
()
xds/src/test/java/io/grpc/xds/WeightedTargetLoadBalancerTest.java:184
↓ 4 callersMethodaddListenSockets
Sets the listen sockets.
api/src/main/java/io/grpc/InternalChannelz.java:343
↓ 4 callersMethodaddMessage
Call to add a message to be delivered. Implies onPrefixReady().
binder/src/main/java/io/grpc/binder/internal/Outbound.java:115
↓ 4 callersMethodaddMetadata
(List<Header> okhttpHeaders, Metadata toAdd)
okhttp/src/main/java/io/grpc/okhttp/Headers.java:134
↓ 4 callersMethodadjustResourceSubscription
(XdsResourceType<?> resourceType)
xds/src/main/java/io/grpc/xds/client/ControlPlaneClient.java:147
↓ 4 callersMethodallResolved
()
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4545
↓ 4 callersMethodallocate
(int capacityHint)
cronet/src/main/java/io/grpc/cronet/CronetWritableBufferAllocator.java:36
↓ 4 callersMethodallocateService
Allocate a new host service. @param appContext The application context. @return The AndroidComponentAddress of the service.
binder/src/androidTest/java/io/grpc/binder/HostServices.java:158
↓ 4 callersMethodanyMatch
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:424
↓ 4 callersMethodasRunnable
Returns a runnable that, when run, invokes the given callback, providing the given round-trip duration.
core/src/main/java/io/grpc/internal/Http2Ping.java:191
↓ 4 callersMethodassertEventLoopAndChannelType
()
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:629
↓ 4 callersMethodassertEventLoopsAndChannelType
()
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:749
↓ 4 callersMethodassertPerCallMetrics
(double expectedLatencyValue)
census/src/test/java/io/grpc/census/CensusModulesTest.java:742
↓ 4 callersMethodassertPickerStatus
(SubchannelPicker picker, Status expectedStatus)
xds/src/test/java/io/grpc/xds/CdsLoadBalancer2Test.java:641
↓ 4 callersMethodassertStatusEquals
(Status expected, Status actual)
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:2138
↓ 4 callersMethodassertStatusEquals
(Status expected, Status actual)
netty/src/test/java/io/grpc/netty/UtilsTest.java:195
↓ 4 callersMethodassertWorkOccurred
(StreamObserver<Control.ClientArgs> clientObserver)
benchmarks/src/test/java/io/grpc/benchmarks/driver/LoadWorkerTest.java:193
↓ 4 callersMethodassertZeroRetryRecorded
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1778
↓ 4 callersMethodattach
()
api/src/context/java/io/grpc/Context.java:712
↓ 4 callersMethodauthorityToUri
Parse an authority into a URI for retrieving the host and port.
core/src/main/java/io/grpc/internal/GrpcUtil.java:517
↓ 4 callersMethodawaitHeaders
Returns response headers from the server or throws {@link java.util.concurrent.TimeoutException} if they aren't delivered before the timeout. <p>Call
core/src/testFixtures/java/io/grpc/internal/ClientStreamListenerBase.java:59
↓ 4 callersMethodawaitOnReadyAndDrain
(int timeout, TimeUnit unit)
core/src/testFixtures/java/io/grpc/internal/ClientStreamListenerBase.java:77
↓ 4 callersMethodawaitServiceShutdown
Wait for all services to shutdown. This should be called from a test's tearDown method, to ensure the next test is able to use this class again (since
binder/src/androidTest/java/io/grpc/binder/HostServices.java:120
↓ 4 callersMethodbackendMetricPropagation
( BackendMetricPropagation backendMetricPropagation)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:780
↓ 4 callersMethodblockUntilShutdown
()
istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:250
↓ 4 callersMethodbuildBuilder
(XdsServerBuilder.XdsServingStatusListener xdsServingStatusListener)
xds/src/test/java/io/grpc/xds/XdsServerBuilderTest.java:81
↓ 4 callersMethodbuildClusterInvalid
(String name)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5320
↓ 4 callersMethodbuildTransportServers
( List<? extends ServerStreamTracer.Factory> streamTracerFactories)
servlet/src/main/java/io/grpc/servlet/ServletServerBuilder.java:162
↓ 4 callersMethodbytes
()
benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java:86
↓ 4 callersMethodcall
Immediately call a {@link Callable} with this context as the {@link #current} context. @param c {@link Callable} to call. @return result of call.
api/src/context/java/io/grpc/Context.java:547
↓ 4 callersMethodcanHandleEmptyAddressListFromNameResolution
Whether this LoadBalancer can handle empty address group list to be passed to {@link #handleResolvedAddresses(ResolvedAddresses)}. The default implem
api/src/main/java/io/grpc/LoadBalancer.java:427
↓ 4 callersMethodcancelIdleTimer
(boolean permanent)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:438
↓ 4 callersMethodcancelScheduleTask
()
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:575
↓ 4 callersMethodcancelXdsResourceWatch
Unregisters the given resource watcher.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:362
↓ 4 callersMethodcaptureTransports
Stub the given mock {@link ClientTransportFactory} by returning mock {@link ManagedClientTransport}s which saves their listeners along with them. This
core/src/testFixtures/java/io/grpc/internal/TestUtils.java:108
↓ 4 callersMethodchannelActive
(Channel channel)
netty/src/main/java/io/grpc/netty/TcpMetrics.java:113
↓ 4 callersMethodchannelInactive
(Channel channel)
netty/src/main/java/io/grpc/netty/TcpMetrics.java:142
↓ 4 callersMethodcheckClientStatus
Verifies that the client status is as expected. By default, the code and description should be present, and the cause should be stripped away.
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:2153
↓ 4 callersMethodcheckClientTrusted
(X509Certificate[] chain, String authType, Socket socket)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:232
↓ 4 callersMethodcheckConnectionWorks
(String targetServer, String addressTypeArg)
interop-testing/src/test/java/io/grpc/testing/integration/XdsTestServerTest.java:68
↓ 4 callersMethodcheckContext
()
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:668
↓ 4 callersMethodcheckHealth
(String prefix)
examples/src/main/java/io/grpc/examples/healthservice/HealthServiceClient.java:57
↓ 4 callersMethodcheckServerTrusted
(X509Certificate[] x509Certificates, String s)
okhttp/src/test/java/io/grpc/okhttp/TlsTest.java:638
↓ 4 callersMethodcheckTrusted
(X509Certificate[] chain, String authType, SSLEngine sslEngine, Socket socket, boolean checkingServer)
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:153
↓ 4 callersMethodclampKeepAliveTimeInNanos
Bumps keepalive time to 10 seconds if the specified value was smaller than that.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:238
↓ 4 callersMethodclampKeepAliveTimeoutInNanos
Bumps keepalive timeout to 10 milliseconds if the specified value was smaller than that.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:245
↓ 4 callersMethodcleanQueue
(ReferenceQueue<ManagedChannelOrphanWrapper> refqueue)
core/src/main/java/io/grpc/internal/ManagedChannelOrphanWrapper.java:156
↓ 4 callersMethodclientChannel
(int port, SslContext sslContext)
netty/src/test/java/io/grpc/netty/TlsTest.java:405
↓ 4 callersMethodclientInboundTrailers
See {@link ClientStreamTracer#inboundTrailers}. For client-side only. <p>Called from abstract stream implementations.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:124
↓ 4 callersMethodclientSendsOneMessage
Returns {@code true} for {@code UNARY} and {@code SERVER_STREAMING}, which do not permit the client to stream. @since 1.0.0
api/src/main/java/io/grpc/MethodDescriptor.java:114
↓ 4 callersMethodclose
(Status status, Metadata trailers)
core/src/main/java/io/grpc/internal/ServerCallImpl.java:209
↓ 4 callersMethodclose
Un-initialize/shutdown grpc-observability.
gcp-observability/src/main/java/io/grpc/gcp/observability/GcpObservability.java:128
↓ 4 callersMethodcloseDeframer
Closes the deframer and frees any resources. After this method is called, additional calls will have no effect. <p>When {@code stopDelivery} is false
core/src/main/java/io/grpc/internal/AbstractStream.java:233
↓ 4 callersMethodcloseListener
Closes the listener if not previously closed and frees resources. {@code newStatus} is a status generated by gRPC. It is <b>not</b> the status the str
core/src/main/java/io/grpc/internal/AbstractServerStream.java:341
↓ 4 callersMethodcloseOnCancel
(Status status)
binder/src/main/java/io/grpc/binder/internal/Inbound.java:269
↓ 4 callersMethodclusterName
(String clusterName)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:723
↓ 4 callersMethodcommitAndRun
Calls commit() and if successful runs the post commit task. Post commit task will be non-null for only once. The post commit task cancels other non-wi
core/src/main/java/io/grpc/internal/RetriableStream.java:240
↓ 4 callersMethodcompare
(ServerProvider o1, ServerProvider o2)
api/src/main/java/io/grpc/ServerRegistry.java:82
↓ 4 callersMethodcompressorRegistry
Set the compression registry for use in the channel. This is an advanced API call and shouldn't be used unless you are using custom message encoding.
api/src/main/java/io/grpc/ServerBuilder.java:230
↓ 4 callersMethodconfigureService
Configure an allocated hosting service. @param androidComponentAddress The address of the service. @param params The parameters used to build the ser
binder/src/androidTest/java/io/grpc/binder/HostServices.java:175
↓ 4 callersMethodcontainsClientSocket
(InternalLogId transportRef)
api/src/main/java/io/grpc/InternalChannelz.java:238
↓ 4 callersMethodconvertClientHeaders
(Metadata headers, AsciiString scheme, AsciiString defaultPath, AsciiString authority,
netty/src/main/java/io/grpc/netty/Utils.java:279
↓ 4 callersMethodconvertSpec
Converts an instance of {@link com.squareup.okhttp.ConnectionSpec} for a secure connection into that of {@link ConnectionSpec} in the current package.
okhttp/src/main/java/io/grpc/okhttp/Utils.java:74
↓ 4 callersMethodconvertTrailers
(Http2Headers http2Headers)
netty/src/main/java/io/grpc/netty/Utils.java:312
↓ 4 callersMethodcopyWithStreamTracerFactory
Creates a new {@code PickResult} with the given {@code streamTracerFactory}, but retains all other properties from this {@code PickResult}. @since 1.
api/src/main/java/io/grpc/LoadBalancer.java:689
↓ 4 callersMethodcountAddressSelections
Returns int[index_of_eag] array with number of times each eag was selected.
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:277
↓ 4 callersMethodcountAddressSelections
Returns int[index_of_eag] array with number of times each eag was selected.
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:394
↓ 4 callersMethodcreate
(S2AStub stub, Optional<S2AIdentity> localIdentity)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2APrivateKeyMethod.java:72
↓ 4 callersMethodcreate
Creates a LongCounter.
core/src/main/java/io/grpc/internal/LongCounterFactory.java:27
↓ 4 callersMethodcreate
(File policyFile)
authz/src/main/java/io/grpc/authz/FileWatcherAuthorizationServerInterceptor.java:108
↓ 4 callersMethodcreate
(String authorizationPolicy)
authz/src/main/java/io/grpc/authz/AuthorizationServerInterceptor.java:70
← previousnext →2,901–3,000 of 22,628, ranked by callers