Functions — github.com/grpc/grpc-java

hub / github.com/grpc/grpc-java / functions

Functions22,628 in github.com/grpc/grpc-java

⨍ Functions 22,628◇ Types & classes 3,835

↓ 2 callersMethoddoBenchmark

(SimpleRequest req, List<? extends Channel> channels,

benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java:118

↓ 2 callersMethoddoClose

(ChannelHandlerContext ctx)

alts/src/main/java/io/grpc/alts/internal/TsiFrameHandler.java:101

↓ 2 callersMethoddoHandshake

<pre> Handshaker service accepts a stream of handshaker request, returning a stream of handshaker response. Client is expected to send exactly one mes

alts/src/generated/main/grpc/io/grpc/alts/internal/HandshakerServiceGrpc.java:119

↓ 2 callersMethoddoParse

(Args args, Message unpackedMessage)

xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:692

↓ 2 callersMethoddomains

()

xds/src/main/java/io/grpc/xds/VirtualHost.java:45

↓ 2 callersMethoddrain

()

xds/src/test/java/io/grpc/xds/internal/security/certprovider/CertProviderClientSslContextProviderTest.java:534

↓ 2 callersMethoddrainPendingCalls

Called to transition {@code passThrough} to {@code true}. This method is not safe to be called multiple times; the caller must ensure it will only be

core/src/main/java/io/grpc/internal/DelayedStream.java:170

↓ 2 callersMethoddrainPendingCalls

Called to transition {@code passThrough} to {@code true}. This method is not safe to be called multiple times; the caller must ensure it will only be

core/src/main/java/io/grpc/internal/DelayedClientCall.java:292

↓ 2 callersMethoddurationSecs

()

interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:721

↓ 2 callersMethodechoAdsService

()

xds/src/test/java/io/grpc/xds/GrpcXdsTransportFactoryTest.java:66

↓ 2 callersMethodechoBlocking

Say hello to server, just like in helloworld example.

examples/src/main/java/io/grpc/examples/cancellation/CancellationClient.java:113

↓ 2 callersMethodeffectiveDeadline

()

core/src/main/java/io/grpc/internal/ClientCallImpl.java:424

↓ 2 callersMethodeffectivePort

()

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:161

↓ 2 callersMethodejectSubchannels

(long ejectionTimeNanos)

util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:613

↓ 2 callersMethodejectionPercentage

How many percent of the addresses have been ejected.

util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:747

↓ 2 callersMethodemptyStream

()

interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:785

↓ 2 callersMethodenableButtons

()

examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:133

↓ 2 callersMethodenableCheckAuthority

Enable previously disabled authority check.

core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:709

↓ 2 callersMethodenableMetrics

Enables the specified metrics for collection and export. By default, only a subset of metrics are enabled.

opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:412

↓ 2 callersMethodenableTracing

(GrpcOpenTelemetry.Builder builder, boolean enable)

opentelemetry/src/main/java/io/grpc/opentelemetry/InternalGrpcOpenTelemetry.java:33

↓ 2 callersMethodencodedLength

(byte[] bytes)

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Huffman.java:119

↓ 2 callersMethodencrypt

(ByteBuf outBuf, List<ByteBuf> plainBufs)

alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:57

↓ 2 callersMethodencryptAad

( ByteBuffer ciphertext, ByteBuffer plaintext, @Nullable ByteBuffer aad, byte[] nonce)

alts/src/main/java/io/grpc/alts/internal/AesGcmAeadCrypter.java:58

↓ 2 callersMethodenhanceLogEntry

(LogEntry.Builder builder, SpanContext spanContext)

gcp-observability/src/main/java/io/grpc/gcp/observability/logging/TraceLoggingHelper.java:34

↓ 2 callersMethodenterIdleMode

()

core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:420

↓ 2 callersMethodequals

(Object o)

api/src/main/java/io/grpc/QueryParams.java:149

↓ 2 callersMethodequals

(Object o)

api/src/main/java/io/grpc/LoadBalancer.java:1617

↓ 2 callersMethodequals

(Object obj)

binder/src/main/java/io/grpc/binder/internal/BoundClientAddress.java:40

↓ 2 callersMethodequals

(Object o)

util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:601

↓ 2 callersMethodequals

(Object o)

util/src/main/java/io/grpc/util/GracefulSwitchLoadBalancer.java:248

↓ 2 callersMethodequals

(Object o)

xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1099

↓ 2 callersMethodestimateSizeOf

Returns estimated size of entry to keep track. If it always returns 1, the max size bytes behaves like max number of entry (default behavior).

rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:100

↓ 2 callersMethodevictToRecoverBytes

Returns the count of entries evicted.

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:188

↓ 2 callersMethodevictToRecoverBytes

Returns the count of entries evicted.

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:556

↓ 2 callersMethodexactValue

()

xds/src/main/java/io/grpc/xds/internal/Matchers.java:43

↓ 2 callersMethodexecute

Executes the given {@link ReadOperation} against the {@link ReadableBuffer}s required to satisfy the requested {@code length}.

core/src/main/java/io/grpc/internal/CompositeReadableBuffer.java:261

↓ 2 callersMethodexpectHandshake

( ChannelCredentials channelCreds, ServerCredentials serverCreds, boolean expectSuccess)

netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:383

↓ 2 callersMethodextraKeys

()

rls/src/main/java/io/grpc/rls/RlsProtoData.java:205

↓ 2 callersMethodextractSecurityLevel

(SecurityLevel securityLevel)

core/src/main/java/io/grpc/internal/InternalSubchannel.java:695

↓ 2 callersMethodextractVirtualHosts

( RouteConfiguration routeConfig, FilterRegistry filterRegistry, XdsResourceType.Args args)

xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:144

↓ 2 callersMethodfactory

( SSLSocketFactory factory)

okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:757

↓ 2 callersMethodfailedClientStream

( final StatsTraceContext statsTraceCtx, final Status status)

inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:230

↓ 2 callersMethodfailurePercentageEjection

()

xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:352

↓ 2 callersMethodfailureRate

()

util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:581

↓ 2 callersMethodfallbackTestVerifyUseOfBackendLists

( InOrder inOrder, List<EquivalentAddressGroup> addrs, @Nullable List<String> tokens)

grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:1694

↓ 2 callersMethodfillInFlags

(Parcel parcel, int flags)

binder/src/main/java/io/grpc/binder/internal/TransactionUtils.java:100

↓ 2 callersMethodfilterCollection

A generic helper to filter a collection based on a predicate.

xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationFilter.java:60

↓ 2 callersMethodfilterOnIpAddress

( Collection<FilterChain> filterChains, InetAddress address, boolean forDestination)

xds/src/main/java/io/grpc/xds/FilterChainMatchingProtocolNegotiators.java:334

↓ 2 callersMethodfinalizeWith

(ClientStream stream)

core/src/main/java/io/grpc/internal/MetadataApplierImpl.java:89

↓ 2 callersMethodfindClusterStats

(List<ClusterStats> clusterStatsList, String clusterName)

xds/src/test/java/io/grpc/xds/LoadReportClientTest.java:651

↓ 2 callersMethodfindJdkProvider

()

netty/src/main/java/io/grpc/netty/GrpcSslContexts.java:251

↓ 2 callersMethodfixedServerFactory

( ProtocolNegotiator negotiator)

netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:316

↓ 2 callersMethodflowControlWindow

Sets the flow control window in bytes. Setting flowControlWindow disables auto flow control tuning; use {@link #initialFlowControlWindow(int)} to enab

netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:417

↓ 2 callersMethodflush

Completes the current frame, signaling that no further data is available to be passed to readBytes and that the client requires writeBytes to start re

alts/src/main/java/io/grpc/alts/internal/AltsFraming.java:162

↓ 2 callersMethodflush

Process the queue of commands and dispatch them to the stream. This method is only called in the event loop

netty/src/main/java/io/grpc/netty/WriteQueue.java:122

↓ 2 callersMethodforContains

The input string should contain this substring.

xds/src/main/java/io/grpc/xds/internal/Matchers.java:260

↓ 2 callersMethodforJavaName

(String javaName)

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/TlsVersion.java:42

↓ 2 callersMethodforJavaName

(String javaName)

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/CipherSuite.java:397

↓ 2 callersMethodforPath

Returns a channel to the UDS endpoint specified by the file-path. @param path unix file system path to use for Unix Domain Socket. @param namespace t

android/src/main/java/io/grpc/android/UdsChannelBuilder.java:67

↓ 2 callersMethodforRlsPlugin

( AtomicInteger refCount, RlsPluginConfig rlsPluginConfig)

xds/src/main/java/io/grpc/xds/XdsNameResolver.java:1043

↓ 2 callersMethodforTarget

Creates a new builder with the given target string that will be resolved by {@link io.grpc.NameResolver}.

android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:99

↓ 2 callersMethodforTarget

"Overrides" the static method in {@link ManagedChannelBuilder}.

alts/src/main/java/io/grpc/alts/AltsChannelBuilder.java:41

↓ 2 callersMethodforTarget

"Overrides" the static method in {@link ManagedChannelBuilder}.

alts/src/main/java/io/grpc/alts/GoogleDefaultChannelBuilder.java:38

↓ 2 callersMethodformatThrowableMessage

(Status status)

api/src/main/java/io/grpc/Status.java:429

↓ 2 callersMethodfractionToFixedPoint

Divide two uint32s and produce a fixed-point uint32 result.

xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:241

↓ 2 callersMethodframeReader

()

netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:236

↓ 2 callersMethodfreeze

()

stub/src/main/java/io/grpc/stub/ServerCalls.java:345

↓ 2 callersMethodfromCallMetricReport

(MetricReport callMetricReport)

interop-testing/src/main/java/io/grpc/testing/integration/CustomBackendMetricsLoadBalancerProvider.java:148

↓ 2 callersMethodfromEnvoyProtoUpstreamTlsContext

( io.envoyproxy.envoy.extensions.transport_sockets.tls.v3.UpstreamTlsContext upstreamTlsCo

xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:105

↓ 2 callersMethodfromHttp2

(int code)

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/ErrorCode.java:82

↓ 2 callersMethodfromProto

(Message rawProtoMessage, String typeUrl)

xds/src/test/java/io/grpc/xds/StatefulFilter.java:162

↓ 2 callersMethodfromStatusAndTrailers

Extracts the {@code google.rpc.Status} from trailers, and makes sure they match the gRPC {@code status}. If the trailers do not contain a {@code googl

protobuf/src/main/java/io/grpc/protobuf/StatusProto.java:176

↓ 2 callersMethodfromValue

(Value value)

gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:134

↓ 2 callersMethodgeRawMethodName

(MethodDescriptor<?, ?> descriptor)

api/src/main/java/io/grpc/InternalMethodDescriptor.java:33

↓ 2 callersMethodgenerateBootstrap

( String zone, boolean supportIpv6)

googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:296

↓ 2 callersMethodgeneratePayload

Generates a payload of desired type and size. Reads compressableBuffer or uncompressableBuffer as a circular buffer.

interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:487

↓ 2 callersMethodgenerateResponse

(String resourceType, String version, String nonce, Set<String> r

xds/src/test/java/io/grpc/xds/XdsTestControlPlaneService.java:195

↓ 2 callersMethodgenerateRoutingConfig

( FilterChain filterChain, Map<String, Filter> chainFilters)

xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:628

↓ 2 callersMethodget

Returns the contents of this container or null if it is empty.

binder/src/main/java/io/grpc/binder/IBinderReceiver.java:30

↓ 2 callersMethodget

(AsciiString name)

netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:142

↓ 2 callersMethodgetActiveAuthorities

(ControlPlaneClient cpc)

xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:1091

↓ 2 callersMethodgetAggregationValueAsLong

(StatsComponent localStats, View view, List<TagValue> dimension)

census/src/test/java/io/grpc/census/CensusModulesTest.java:1492

↓ 2 callersMethodgetAllAddresses

()

core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:615

↓ 2 callersMethodgetAllAddresses

()

grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2879

↓ 2 callersMethodgetAllClusterStatsReports

Gets the traffic stats (drops and loads) as a list of {@link ClusterStats} recorded for all clusters since the previous call of this method or {@link

xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:244

↓ 2 callersMethodgetAndResetDeflatedBytesConsumed

Reports bytes consumed by the inflater since the last invocation of this method, then resets the count to zero.

core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:241

↓ 2 callersMethodgetApplicationProtocol

()

alts/src/main/java/io/grpc/alts/internal/AltsHandshakerClient.java:60

↓ 2 callersMethodgetAttributes

()

rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:886

↓ 2 callersMethodgetAttributes

Returns a set of attributes, which may vary depending on the state of the transport. The keys should define in what states they will be present.

core/src/main/java/io/grpc/internal/ConnectionClientTransport.java:31

↓ 2 callersMethodgetAttributes

()

core/src/main/java/io/grpc/internal/ClientCallImpl.java:556

↓ 2 callersMethodgetAttributes

()

netty/src/main/java/io/grpc/netty/NettyClientTransport.java:401

↓ 2 callersMethodgetAuthority

()

core/src/main/java/io/grpc/internal/ClientTransportFactory.java:116

↓ 2 callersMethodgetAuthorityFromAddress

(SocketAddress address)

netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:244

↓ 2 callersMethodgetAuthorityFromResourceName

Returns the authority from the resource name.

xds/src/main/java/io/grpc/xds/client/XdsClient.java:125

↓ 2 callersMethodgetAutoSniSanMatchers

(SSLParameters sslParams)

xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:309

↓ 2 callersMethodgetBinaryStreamMarshaller

(Key<T> key)

api/src/main/java/io/grpc/Metadata.java:959

↓ 2 callersMethodgetBit

()

okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:214

↓ 2 callersMethodgetByteBuffer

Gets a {@link ByteBuffer} containing some bytes of the content next to be read, or {@code null} if has reached end of the content. The number of bytes

api/src/main/java/io/grpc/HasByteBuffer.java:49

↓ 2 callersMethodgetCertFromResourceName

Gets a cert from contents of a resource.

xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:204

↓ 2 callersMethodgetCertProviderConfig

( @Nullable Map<String, CertificateProviderInfo> certProviders, String pluginInstanceName)

xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertProviderSslContextProvider.java:105

← previous next →4,501–4,600 of 22,628, ranked by callers