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 callersMethodreadConnectionPreface
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:31
↓ 2 callersMethodreadFromParcel
Create a stream from a {@link Parcel} object. Note that this immediately reads the Parcelable object, allowing the Parcel to be recycled after calling
binder/src/main/java/io/grpc/binder/internal/ParcelableInputStream.java:79
↓ 2 callersMethodreadHeaderBlock
(int length, short padding, byte flags, int streamId)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:210
↓ 2 callersMethodreadHeaders
(Handler handler, int length, byte flags, int streamId)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:190
↓ 2 callersMethodreadMedium
(BufferedSource source)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:775
↓ 2 callersMethodreadPriority
( Handler handler, int length, @SuppressWarnings("UnusedVariable") byte flags, int streamId)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:240
↓ 2 callersMethodreadStatus
(int flags, Parcel parcel)
binder/src/main/java/io/grpc/binder/internal/TransactionUtils.java:82
↓ 2 callersMethodreadUnsignedInt
Reads unsigned integer in Little-Endian byte order.
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:132
↓ 2 callersMethodreadUtf8LineStrictUnbuffered
(Source source)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:932
↓ 2 callersMethodreceivedAllTransactions
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:192
↓ 2 callersMethodrecordClientCallInterceptor
Captures the request attributes. Useful for testing ClientCalls. {@link ClientCall#getAttributes()}
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:2053
↓ 2 callersMethodrecordFinishedAttempt
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:281
↓ 2 callersMethodrecordFinishedCall
()
census/src/main/java/io/grpc/census/CensusStatsModule.java:527
↓ 2 callersMethodrecordFinishedCall
(CallOptions callOptions)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:463
↓ 2 callersMethodrecordInboundCompressedMessage
(Span span, int seqNo, long optionalWireSize)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:469
↓ 2 callersMethodrecordInboundMessageSize
(Span span, int seqNo, long bytes)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:476
↓ 2 callersMethodrecordMessageEvent
( Span span, MessageEvent.Type type, int seqNo, long optionalWireSize, long optionalUncompressedSi
census/src/main/java/io/grpc/census/CensusTracingModule.java:219
↓ 2 callersMethodrecordOutboundMessageSentEvent
(Span span, int seqNo, long optionalWireSize, long optionalUncompressedSize)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:456
↓ 2 callersMethodrecordRequestHeadersInterceptor
Capture the request headers from a client. Useful for testing metadata propagation.
testing/src/main/java/io/grpc/testing/TestUtils.java:52
↓ 2 callersMethodrecordRpcFinished
(RpcType rpcType, Status status)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:575
↓ 2 callersMethodrecordTopLevelMetrics
Records top-level ORCA metrics (CPU, memory, application utilization) for per-call load reporting. Metrics are filtered based on the backend metric pr
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:415
↓ 2 callersMethodrecreateStates
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java:136
↓ 2 callersMethodref
(ByteBuf buf)
alts/src/test/java/io/grpc/alts/internal/NettyTsiHandshakerTest.java:193
↓ 2 callersMethodreflectedCiphertextTest
Test reflected ciphertext.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:372
↓ 2 callersMethodrefresh
()
core/src/main/java/io/grpc/internal/DnsNameResolver.java:206
↓ 2 callersMethodrefreshNameResolution
()
xds/src/main/java/io/grpc/xds/PriorityLoadBalancer.java:318
↓ 2 callersMethodregister
(ClusterSpecifierPlugin... plugins)
xds/src/main/java/io/grpc/xds/ClusterSpecifierPluginRegistry.java:43
↓ 2 callersMethodregisterGlobal
Registers CsmObservability globally, applying its configuration to all subsequently created gRPC channels and servers. <p>Note: Only one of CsmObserv
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/CsmObservability.java:61
↓ 2 callersMethodregisterListener
Registers a listener to received Subchannel status updates.
grpclb/src/main/java/io/grpc/grpclb/SubchannelPool.java:36
↓ 2 callersMethodrelease
Release the <i>hard</i> reference for this stats object (previously obtained via {@link LoadStatsManager2#getClusterDropStats}). The object may still
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:298
↓ 2 callersMethodreleaseBuffer
()
core/src/main/java/io/grpc/internal/MessageFramer.java:350
↓ 2 callersMethodreleaseSslContextProvider
(SslContextProvider toRelease)
xds/src/main/java/io/grpc/xds/internal/security/SslContextProviderSupplier.java:94
↓ 2 callersMethodreleaseSuppliersInFlight
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:775
↓ 2 callersMethodremoveListenSocket
(InternalInstrumented<SocketStats> socket)
api/src/main/java/io/grpc/InternalChannelz.java:132
↓ 2 callersMethodremoveListenerInternal
(CancellationListener cancellationListener, Context context)
api/src/context/java/io/grpc/Context.java:763
↓ 2 callersMethodremoveParser
(MetadataValueParser parser)
xds/src/main/java/io/grpc/xds/MetadataRegistry.java:60
↓ 2 callersMethodremoveWatcher
(String service, StreamObserver<HealthCheckResponse> responseObserver)
services/src/main/java/io/grpc/protobuf/services/HealthServiceImpl.java:113
↓ 2 callersMethodremoveWatcher
(Watcher watcher)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:77
↓ 2 callersMethodreplaceOnActive
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:1127
↓ 2 callersMethodreportInboundMessage
(int numBytes)
binder/src/main/java/io/grpc/binder/internal/Inbound.java:538
↓ 2 callersMethodreportLoadOnRpc
( PickResult pickResult, double cpuUtilization, double applicationUtilization, double
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:1635
↓ 2 callersMethodreportLocalStreamStarted
Called by the client to report a stream has started.
core/src/main/java/io/grpc/internal/TransportTracer.java:81
↓ 2 callersMethodreportServerConnectionGauge
(boolean isConnected, String xdsServer)
xds/src/main/java/io/grpc/xds/XdsClientMetricReporterImpl.java:227
↓ 2 callersMethodreportServerConnectionGauge
(boolean isConnected, String xdsServer)
xds/src/main/java/io/grpc/xds/client/XdsClient.java:421
↓ 2 callersMethodrequestMessagesFromDeframer
Called to request the given number of messages from the deframer. May be called from any thread.
core/src/main/java/io/grpc/internal/AbstractStream.java:257
↓ 2 callersMethodrequireHttp2Stream
(int streamId)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:918
↓ 2 callersMethodrequireHttp2Stream
(int streamId)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1050
↓ 2 callersMethodrescheduleIdleTimer
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:443
↓ 2 callersMethodreset
Resets the state, preparing to construct a new frame. Must be called between frames.
alts/src/main/java/io/grpc/alts/internal/AltsFraming.java:187
↓ 2 callersMethodresetStates
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java:129
↓ 2 callersMethodresolve
()
core/src/main/java/io/grpc/internal/DnsNameResolver.java:362
↓ 2 callersMethodresolve
()
examples/src/main/java/io/grpc/examples/nameresolve/ExampleNameResolver.java:78
↓ 2 callersMethodresolve
()
examples/src/main/java/io/grpc/examples/loadbalance/ExampleNameResolver.java:79
↓ 2 callersMethodresolve
()
examples/example-dualstack/src/main/java/io/grpc/examples/dualstack/ExampleDualStackNameResolver.java:82
↓ 2 callersMethodresolve
()
googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:236
↓ 2 callersMethodresolve
()
netty/src/main/java/io/grpc/netty/UdsNameResolver.java:67
↓ 2 callersMethodresolve
(CidrRange cidrRange)
xds/src/main/java/io/grpc/xds/RbacFilter.java:357
↓ 2 callersMethodresolved
()
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:989
↓ 2 callersMethodrestoreSystemPropertyAfterTest
(String key, @Nullable String oldValue)
api/src/testFixtures/java/io/grpc/FlagResetRule.java:67
↓ 2 callersMethodreturnProcessedBytes
Returns the given processed bytes back to inbound flow control.
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:745
↓ 2 callersMethodreturnSubchannelToPool
(Subchannel subchannel)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:497
↓ 2 callersMethodrolloverRecords
()
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:156
↓ 2 callersMethodrouteLookup
<pre> Lookup returns a target for a single key. </pre>
rls/src/generated/main/grpc/io/grpc/lookup/v1/RouteLookupServiceGrpc.java:114
↓ 2 callersMethodrunClient
<pre> Start client with specified workload. First request sent specifies the ClientConfig followed by ClientStatus response. After that, a "Mark" can
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java:227
↓ 2 callersMethodrunInExecutor
()
core/src/main/java/io/grpc/internal/ConnectivityStateManager.java:99
↓ 2 callersMethodrunQuietly
(Runnable runnable)
stub/src/main/java/io/grpc/stub/ClientCalls.java:846
↓ 2 callersMethodrunQuietly
(Runnable runnable)
stub/src/main/java/io/grpc/stub/ClientCalls.java:962
↓ 2 callersMethodrunServer
( int port, ServerServiceDefinition service, ServerCredentials serverCredentials, String credTypeS
istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:231
↓ 2 callersMethodrunServer
<pre> Start server with specified workload. First request sent specifies the ServerConfig followed by ServerStatus response. After that, a "Mark" can
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java:212
↓ 2 callersMethodrunShellCmd
(String cmd)
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbFallbackTestClient.java:186
↓ 2 callersMethodrunStateSet
(SerializingExecutor obj, int newValue)
core/src/main/java/io/grpc/internal/SerializingExecutor.java:151
↓ 2 callersMethodrunStressTest
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:253
↓ 2 callersMethodrunTest
(String target, String[] users, boolean enableHealthChecking)
examples/src/main/java/io/grpc/examples/healthservice/HealthServiceClient.java:82
↓ 2 callersMethodrunWith
Replays the buffer entry with the given stream.
core/src/main/java/io/grpc/internal/RetriableStream.java:877
↓ 2 callersMethodsafeRegEx
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:47
↓ 2 callersMethodsaturatedAdd
Returns the sum of {@code a} and {@code b} unless it would overflow or underflow in which case {@code Long.MAX_VALUE} or {@code Long.MIN_VALUE} is ret
core/src/main/java/io/grpc/internal/JsonUtil.java:422
↓ 2 callersMethodsaveHistogram
Save a {@link Histogram} to a file.
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:233
↓ 2 callersMethodsayHello
(HelloRequest req, StreamObserver<HelloReply> responseObserver)
examples/example-hostname/src/main/java/io/grpc/examples/hostname/HostnameGreeter.java:42
↓ 2 callersMethodsayHelloStreaming
(final StreamObserver<HelloReply> responseObserver)
examples/src/main/java/io/grpc/examples/manualflowcontrol/ManualFlowControlServer.java:36
↓ 2 callersMethodschedule
(@Nullable Runnable removable)
core/src/main/java/io/grpc/internal/SerializingExecutor.java:98
↓ 2 callersMethodscheduleBackoff
Only called after all addresses attempted and failed (TRANSIENT_FAILURE).
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:402
↓ 2 callersMethodscheduleNextConnection
Happy Eyeballs Schedules connection attempt to happen after a delay to the next available address.
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:552
↓ 2 callersMethodscheduleNextLoadReport
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:706
↓ 2 callersMethodscheduleNextLoadReport
()
xds/src/main/java/io/grpc/xds/client/LoadReportClient.java:267
↓ 2 callersMethodscheduleNextRefreshCertificate
(long delayInSeconds)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProvider.java:106
↓ 2 callersMethodscheduledExecutorService
Provides a custom scheduled executor service. <p>It's an optional parameter. If the user has not provided a scheduled executor service when the chann
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:341
↓ 2 callersMethodsecondGoAwayAndClose
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:1117
↓ 2 callersMethodselectLbPolicyFromList
Parses and selects a load balancing policy from a non-empty list of raw configs. If selection is successful, the returned ConfigOrError object will in
core/src/main/java/io/grpc/internal/ServiceConfigUtil.java:340
↓ 2 callersMethodsemaphoreRelease
()
alts/src/main/java/io/grpc/alts/internal/TsiHandshakeHandler.java:245
↓ 2 callersMethodsendAndExpectComplete
Send a message and expect an IOException on closing.
alts/src/test/java/io/grpc/alts/internal/AltsHandshakerStubTest.java:76
↓ 2 callersMethodsendHeaders
(Metadata headers)
gcp-observability/src/test/java/io/grpc/gcp/observability/interceptors/InternalLoggingServerInterceptorTest.java:123
↓ 2 callersMethodsendHeaders
Send response header metadata prior to sending a response message. This method may only be called once and cannot be called after calls to {@link #sen
api/src/main/java/io/grpc/ServerCall.java:130
↓ 2 callersMethodsendHeaders
(Metadata responseHeaders)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:527
↓ 2 callersMethodsendInitialConnectionWindow
Sends initial connection window to the remote endpoint if necessary.
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:118
↓ 2 callersMethodsendLastCertificateUpdate
(Watcher watcher)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:85
↓ 2 callersMethodsendLastSpiffeTrustMapUpdate
(Watcher watcher)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:93
↓ 2 callersMethodsendLastTrustedRootsUpdate
(Watcher watcher)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:89
↓ 2 callersMethodsendLoadStatsRequest
(List<ClusterStats> clusterStatsList)
xds/src/main/java/io/grpc/xds/client/LoadReportClient.java:218
↓ 2 callersMethodsendMessage_serverSendsOne_closeOnSecondCall
( MethodDescriptor<Long, Long> method)
core/src/test/java/io/grpc/internal/ServerCallImplTest.java:238
↓ 2 callersMethodsendMessage_serverSendsOne_closeOnSecondCall_appRunToCompletion
( MethodDescriptor<Long, Long> method)
core/src/test/java/io/grpc/internal/ServerCallImplTest.java:273
← previousnext →5,101–5,200 of 22,628, ranked by callers