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
↓ 14 callersMethodisCancelled
()
api/src/testFixtures/java/io/grpc/NoopServerCall.java:46
↓ 14 callersMethodisWaitForReady
Returns whether <a href="https://github.com/grpc/grpc/blob/master/doc/wait-for-ready.md"> 'wait for ready'</a> option is enabled for the call. 'Fail f
api/src/main/java/io/grpc/CallOptions.java:458
↓ 14 callersMethodloadTrustBundleFromFile
Loads a SPIFFE trust bundle from a file, parsing it from the JSON format. In case of success, returns {@link SpiffeBundle}. If any element of the JSON
core/src/main/java/io/grpc/internal/SpiffeUtil.java:168
↓ 14 callersMethodlogClientHeader
Logs the request header. Binary logging equivalent of logClientHeader.
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:81
↓ 14 callersMethodmaxTraceEvents
(int maxTraceEvents)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:543
↓ 14 callersMethodmsg
(int bytes)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1527
↓ 14 callersMethodnewBuilder
()
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:87
↓ 14 callersMethodnewLbConfig
(Cluster cluster, boolean enableLeastRequest)
xds/src/test/java/io/grpc/xds/LoadBalancerConfigFactoryTest.java:409
↓ 14 callersMethodnextLong
()
xds/src/main/java/io/grpc/xds/ThreadSafeRandom.java:26
↓ 14 callersMethodnotifyWhenStateChanged
()
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:2343
↓ 14 callersMethodnumWatchersForTest
(String service)
services/src/main/java/io/grpc/protobuf/services/HealthServiceImpl.java:170
↓ 14 callersMethodonResult
(ResolutionResult result)
core/src/test/java/io/grpc/internal/ForwardingNameResolverTest.java:82
↓ 14 callersMethodoperationTimeoutMillis
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1742
↓ 14 callersMethodparseJsonObject
(String json)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerProviderTest.java:284
↓ 14 callersMethodparseResponse
Parse a response payload from the given {@link InputStream}. @param input stream containing response message to parse. @return parsed response messag
api/src/main/java/io/grpc/MethodDescriptor.java:283
↓ 14 callersMethodprocessCluster
(Cluster cluster, Set<String> certProviderInstances,
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:140
↓ 14 callersMethodreadByteString
Reads a potentially Huffman encoded byte string.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:373
↓ 14 callersMethodreleaseInternal
Visible to unit tests.
core/src/main/java/io/grpc/internal/SharedResourceHolder.java:118
↓ 14 callersMethodsetRawQuery
Specifies the query component of the new URI, possibly percent-encoded, exactly as it will appear in the string form of the built URI. <p>'query' mus
api/src/main/java/io/grpc/Uri.java:809
↓ 14 callersMethodstart
(Listener<RespT> listener, final Metadata headers)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:197
↓ 14 callersMethodstreamingOutputCall
<pre> One request followed by a sequence of responses (streamed download). The server returns the payload with client desired type and sizes. </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/TestServiceGrpc.java:372
↓ 14 callersMethodsubchannelIsReady
(Subchannel subchannel)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:915
↓ 14 callersMethodtoEnvoyProtoNode
()
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:253
↓ 14 callersMethodtoString
()
netty/src/main/java/io/grpc/netty/NettyServer.java:397
↓ 14 callersMethodtoWriteBuffer
(byte[] data)
core/src/test/java/io/grpc/internal/MessageFramerTest.java:356
↓ 14 callersMethodtransportCreated
Called upon the establishment of a new client connection. @param transport the new transport to be observed. @return a listener for stream creation e
core/src/main/java/io/grpc/internal/ServerListener.java:31
↓ 14 callersMethodtransportReady
The transport has finished all handshakes and is ready to process streams. @param attributes transport attributes @return the effective transport at
core/src/main/java/io/grpc/internal/ServerTransportListener.java:43
↓ 14 callersMethodupdateAddresses
(List<EquivalentAddressGroup> addrs)
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:630
↓ 14 callersMethodupdateBuilder
(ChannelStats.Builder builder)
core/src/main/java/io/grpc/internal/ChannelTracer.java:139
↓ 13 callersMethodappendKeyValue
Appends a piece of information which is a key-value , which will be formatted into {@code "key=value"}. Value's {@code toString()} or {@code null} is
core/src/main/java/io/grpc/internal/InsightBuilder.java:43
↓ 13 callersMethodappendLogs
(StringBuffer logs, String msg, Object... params)
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:434
↓ 13 callersMethodapply
(T t)
alts/src/test/java/io/grpc/alts/internal/NettyTsiHandshakerTest.java:202
↓ 13 callersMethodauthority
(CharSequence value)
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:523
↓ 13 callersMethodbuild
()
api/src/main/java/io/grpc/CallOptions.java:115
↓ 13 callersMethodbuildClusterLoadAssignment
Builds a new default EDS configuration.
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:289
↓ 13 callersMethodbuildOrcaRequestFromConfig
( OrcaReportingConfig config)
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:148
↓ 13 callersMethodbuildServerListener
Builds a new server listener.
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:349
↓ 13 callersMethodbyteBufferSupported
Indicates whether or not {@link #getByteBuffer} operation is supported for this buffer.
core/src/main/java/io/grpc/internal/ReadableBuffer.java:147
↓ 13 callersMethodclose
Releases any resources. <p>After this method has been called, it's no longer valid to call {@link #newClientTransport}. No guarantees about thread-sa
core/src/main/java/io/grpc/internal/ClientTransportFactory.java:75
↓ 13 callersMethodclose
()
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:350
↓ 13 callersMethodclusterServiceName
()
xds/src/main/java/io/grpc/xds/client/Stats.java:36
↓ 13 callersMethodconvert
(Duration duration)
api/src/main/java/io/grpc/InternalTimeUtils.java:23
↓ 13 callersMethodcreate
(ImmutableList<String> targets, String getHeaderData)
rls/src/main/java/io/grpc/rls/RlsProtoData.java:88
↓ 13 callersMethodcreate
( ImmutableList<Name> names, ImmutableList<NameMatcher> headers, ExtraKeys extraKeys,
rls/src/main/java/io/grpc/rls/RlsProtoData.java:209
↓ 13 callersMethodcreate
(String service, @Nullable String method)
rls/src/main/java/io/grpc/rls/RlsProtoData.java:231
↓ 13 callersMethodcreate
(List<LbEndpoint> endpoints, int localityWeight, int priority, ImmutableMap<String, Object> localityMe
xds/src/main/java/io/grpc/xds/Endpoints.java:48
↓ 13 callersMethodcreate
(int port)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:238
↓ 13 callersMethodcreateResolvedBackendAddresses
(int n)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2773
↓ 13 callersMethoddelayOrExecute
(BufferEntry bufferEntry)
core/src/main/java/io/grpc/internal/RetriableStream.java:554
↓ 13 callersMethodemptyInstance
()
api/src/main/java/io/grpc/DecompressorRegistry.java:40
↓ 13 callersMethodencrypt
Encrypt plaintext into ciphertext buffer using the given nonce. @param ciphertext the encrypted plaintext and the tag will be written into this buffe
alts/src/main/java/io/grpc/alts/internal/AeadCrypter.java:36
↓ 13 callersMethodequals
(Object otherObj)
binder/src/main/java/io/grpc/binder/PeerUid.java:57
↓ 13 callersMethodestimatedSizeBytes
Returns estimated cache size bytes. Each entry size is calculated by {@link #estimateSizeOf(java.lang.Object, java.lang.Object)}.
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:125
↓ 13 callersMethodextractPeer
Returns the peer extracted from a completed handshake. @return the extracted peer.
alts/src/main/java/io/grpc/alts/internal/TsiHandshaker.java:82
↓ 13 callersMethodfromPath
(String path, boolean caseSensitive)
xds/src/main/java/io/grpc/xds/VirtualHost.java:126
↓ 13 callersMethodgetAddresses
()
grpclb/src/main/java/io/grpc/grpclb/BackendAddressGroup.java:34
↓ 13 callersMethodgetAttributes
Returns the attributes.
api/src/main/java/io/grpc/EquivalentAddressGroup.java:124
↓ 13 callersMethodgetAttributes
Gets the attributes associated with these addresses. If this was not previously set, {@link Attributes#EMPTY} will be returned. @since 1.21.0
api/src/main/java/io/grpc/LoadBalancer.java:268
↓ 13 callersMethodgetChildConfig
(Object config)
util/src/testFixtures/java/io/grpc/util/GracefulSwitchLoadBalancerAccessor.java:33
↓ 13 callersMethodgetChildren
()
xds/src/main/java/io/grpc/xds/XdsConfig.java:150
↓ 13 callersMethodgetCurrent
Returns the call metric recorder attached to the current {@link Context}. If there is none, returns a no-op recorder. <p><strong>IMPORTANT:</strong>
services/src/main/java/io/grpc/services/CallMetricRecorder.java:66
↓ 13 callersMethodgetDefaultRegistry
Returns the default global instance of the configurator registry.
api/src/main/java/io/grpc/ConfiguratorRegistry.java:45
↓ 13 callersMethodgetHighestCommonVersion
()
alts/src/main/java/io/grpc/alts/internal/RpcProtocolVersionsUtil.java:106
↓ 13 callersMethodgetInboundTrailers
Returns the inbound trailers if {@link ClientStreamTracer#inboundTrailers} has been called, or {@code null}.
testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java:60
↓ 13 callersMethodgetInternal
Visible to unit tests. @see #get(Resource)
core/src/main/java/io/grpc/internal/SharedResourceHolder.java:100
↓ 13 callersMethodgetPathSegments
Returns this URI's path as a list of path segments not including the '/' segment delimiters. <p>Prefer this method over {@link #getPath()} because it
api/src/main/java/io/grpc/Uri.java:497
↓ 13 callersMethodgetPolicyName
()
xds/src/test/java/io/grpc/xds/MetadataLoadBalancerProvider.java:79
↓ 13 callersMethodgetService
Returns the test control plane service interface.
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:107
↓ 13 callersMethodhalfClosed
Called when the remote side of the transport gracefully closed, indicating the client had no more data to send. No further messages will be received o
core/src/main/java/io/grpc/internal/ServerStreamListener.java:29
↓ 13 callersMethodimplSpecificConfig
()
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:61
↓ 13 callersMethodisDisallowed
Returns true if the header key is disallowed for mutations or validation. @param key The header key (e.g., "content-type")
xds/src/main/java/io/grpc/xds/internal/grpcservice/HeaderValueValidationUtils.java:34
↓ 13 callersMethodisMetricEnabled
(String metricName, Map<String, Boolean> enableMetrics, boolean disableDefault)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:352
↓ 13 callersMethodisValid
()
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:690
↓ 13 callersMethodlbPolicyConfig
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:585
↓ 13 callersMethodmaxInboundMessageSize
(int max)
inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:133
↓ 13 callersMethodnewBuilder
Creates a new builder for {@link GrpcCensus}.
census/src/main/java/io/grpc/census/GrpcCensus.java:48
↓ 13 callersMethodnewInetSocketAddress
(String ip, int port)
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1101
↓ 13 callersMethodnewIntent
()
binder/src/test/java/io/grpc/binder/internal/IntentNameResolverTest.java:438
↓ 13 callersMethodnewNameResolver
(Intent targetIntent)
binder/src/test/java/io/grpc/binder/internal/IntentNameResolverTest.java:492
↓ 13 callersMethodnewReader
(Buffer source)
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java:1164
↓ 13 callersMethodnotifyBytesSent
Informs this flow controller that more data has been sent. @param numBytesSent a non-negative number of additional bytes sent @return true iff this r
binder/src/main/java/io/grpc/binder/internal/FlowController.java:56
↓ 13 callersMethodonRpcError
Used for verify/inspect error received from server.
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideClient.java:324
↓ 13 callersMethodparseAsciiString
(String serialized)
core/src/main/java/io/grpc/internal/GrpcUtil.java:682
↓ 13 callersMethodparseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingConfigPolicy)
grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancerProvider.java:73
↓ 13 callersMethodpickSubchannel
(PickSubchannelArgs args)
xds/src/main/java/io/grpc/xds/WeightedRandomPicker.java:112
↓ 13 callersMethodputUtilizationMetric
Update the metrics value in the range [0, 1] corresponding to the specified key. Values outside the valid range are ignored.
services/src/main/java/io/grpc/services/MetricRecorder.java:47
↓ 13 callersMethodrdsName
()
xds/src/main/java/io/grpc/xds/HttpConnectionManager.java:36
↓ 13 callersMethodregister
Register a provider. <p>If the provider's {@link ServerProvider#isAvailable isAvailable()} returns {@code false}, this method will throw {@link Illeg
api/src/main/java/io/grpc/ServerRegistry.java:57
↓ 13 callersMethodreleaseClientSslContextProvider
Releases an instance of the given client-side {@link SslContextProvider}. <p>The instance must have been obtained from {@link #findOrCreateClientSslC
xds/src/main/java/io/grpc/xds/TlsContextManager.java:44
↓ 13 callersMethodrun
()
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:251
↓ 13 callersMethodsendError
(Throwable t)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5251
↓ 13 callersMethodsendHeaders
(Metadata headers)
core/src/main/java/io/grpc/internal/ServerCallImpl.java:100
↓ 13 callersMethodsetOnReadyHandler
Set a {@link Runnable} that will be executed every time the stream {@link #isReady()} state changes from {@code false} to {@code true}. While it is n
stub/src/main/java/io/grpc/stub/CallStreamObserver.java:87
↓ 13 callersMethodsetSuccess
(Void unused)
alts/src/main/java/io/grpc/alts/internal/ProtectedPromise.java:119
↓ 13 callersMethodsetTimeout
Sets a positive total time limit for the automatic resource cleanup. If any of the resources registered to the rule fails to be released in time, the
testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java:91
↓ 13 callersMethodstart
Starts the Subchannel. Can only be called once. <p>Must be called prior to any other method on this class, except for {@link #shutdown} which may be
api/src/main/java/io/grpc/LoadBalancer.java:1364
↓ 13 callersMethodstartClientHandshake
Starts a client handshake. A GeneralSecurityException is thrown if the handshaker service is interrupted or fails. Note that isFinished() must be fals
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerClient.java:173
↓ 13 callersMethodstartServerHandshake
Starts a server handshake. A GeneralSecurityException is thrown if the handshaker service is interrupted or fails. Note that isFinished() must be fals
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerClient.java:197
↓ 13 callersMethodtoBuilder
Copy CallOptions.
api/src/main/java/io/grpc/CallOptions.java:510
↓ 13 callersMethodtoString
()
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:143
← previousnext →1,201–1,300 of 22,628, ranked by callers