Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/grpc/grpc-java
/ functions
Functions
22,628 in github.com/grpc/grpc-java
⨍
Functions
22,628
◇
Types & classes
3,835
↓ 1 callers
Method
committed
(Substream winningSubstream)
core/src/main/java/io/grpc/internal/RetriableStream.java:1286
↓ 1 callers
Method
compareTo
(RingEntry entry)
xds/src/main/java/io/grpc/xds/RingHashLoadBalancer.java:525
↓ 1 callers
Method
complete
Indicates the stream is considered completely closed and there is no further opportunity for error. It calls the listener's {@code closed()} if it was
core/src/main/java/io/grpc/internal/AbstractServerStream.java:319
↓ 1 callers
Method
completeQueuedTasks
()
core/src/main/java/io/grpc/internal/SerializeReentrantCallsDirectExecutor.java:63
↓ 1 callers
Method
compressLongestRunOfZeroes
(int[] hextets)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InetAddressUtil.java:48
↓ 1 callers
Method
compressLongestRunOfZeroes
(int[] hextets)
services/src/main/java/io/grpc/protobuf/services/InetAddressUtil.java:48
↓ 1 callers
Method
compressionFrame
(byte[] data)
netty/src/test/java/io/grpc/netty/NettyTestUtil.java:51
↓ 1 callers
Method
computeAndReportResourceCounts
( Map<XdsResourceType<?>, Map<String, ResourceMetadata>> metadataByType, MetricReporterCallback ca
xds/src/main/java/io/grpc/xds/XdsClientMetricReporterImpl.java:158
↓ 1 callers
Method
computeDelaySecondsToCertExpiry
(X509Certificate lastCert)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProvider.java:189
↓ 1 callers
Method
computeDurationSecs
(long lastMetricsCollectionTime)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:521
↓ 1 callers
Method
computeEngineChannelCredentials
Sends an unary rpc with ComputeEngineChannelBuilder.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:855
↓ 1 callers
Method
computeEngineCreds
Sends a large unary rpc with compute engine credentials.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:827
↓ 1 callers
Method
configBuilder
(@Nullable ServerBuilder<?> builder)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:230
↓ 1 callers
Method
configureChannelBuilder
(ManagedChannelBuilder<?> channelBuilder)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:161
↓ 1 callers
Method
configureNetworkMonitoring
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:211
↓ 1 callers
Method
configureServerBuilder
(ServerBuilder<?> serverBuilder)
api/src/main/java/io/grpc/InternalConfiguratorRegistry.java:42
↓ 1 callers
Method
configureServerBuilder
(ServerBuilder<?> serverBuilder)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:166
↓ 1 callers
Method
configureSslContextWithClientTlsConfiguration
( GetTlsConfigurationResp.ClientTlsConfiguration clientTlsConfiguration, SslContextBuilder sslCont
s2a/src/main/java/io/grpc/s2a/internal/handshaker/SslContextFactory.java:139
↓ 1 callers
Method
configureTlsExtensions
Configure TLS extensions.
okhttp/src/main/java/io/grpc/okhttp/OkHttpProtocolNegotiator.java:115
↓ 1 callers
Method
containsInvalidHostnameAsciiCodes
(String hostnameAscii)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:340
↓ 1 callers
Method
convertLeastRequestConfig
Converts a least_request {@link Any} configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:334
↓ 1 callers
Method
convertLeastRequestConfig
Creates a new least_request service config JSON object based on the old {@link LeastRequestLbConfig} config message.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:450
↓ 1 callers
Method
convertPickFirstConfig
"Converts" a pick_first configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:327
↓ 1 callers
Method
convertRingHashConfig
Converts a ring_hash {@link Any} configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:275
↓ 1 callers
Method
convertRingHashConfig
Creates a new ring_hash service config JSON object based on the old {@link RingHashLbConfig} config message.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:430
↓ 1 callers
Method
convertRoundRobinConfig
"Converts" a round_robin configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:320
↓ 1 callers
Method
convertStringToX509Cert
(String certificate)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/SslContextFactory.java:179
↓ 1 callers
Method
convertToServiceConfig
Factory method for creating a new {link LoadBalancerConfigConverter} for a given xDS {@link Cluster}. @throws ResourceInvalidException If the {@link
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:408
↓ 1 callers
Method
convertToValue
Converts Java representation of the given JSON value to protobuf's {@link com.google.protobuf.Value} representation. <p>The given {@code rawObject} m
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:294
↓ 1 callers
Method
convertTrailers
(List<Header> http2Headers)
okhttp/src/main/java/io/grpc/okhttp/Utils.java:52
↓ 1 callers
Method
convertValue
(Value value)
xds/src/main/java/io/grpc/xds/internal/ProtobufJsonConverter.java:41
↓ 1 callers
Method
convertWeightedRoundRobinConfig
( ClientSideWeightedRoundRobin wrr)
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:289
↓ 1 callers
Method
convertWrrLocalityConfig
Converts a wrr_locality {@link Any} configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:310
↓ 1 callers
Method
copy
Copies the data from input stream to output stream.
gcp-observability/src/test/java/io/grpc/gcp/observability/interceptors/LogHelperTest.java:783
↓ 1 callers
Method
copy
Copies the data from input stream to output stream.
protobuf-lite/src/main/java/io/grpc/protobuf/lite/ProtoLiteUtils.java:113
↓ 1 callers
Method
copyAllNameResolverCustomArgsTo
(NameResolver.Args.Builder dest)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:631
↓ 1 callers
Method
copyCustomOptions
(Object[][] options)
api/src/main/java/io/grpc/LoadBalancer.java:897
↓ 1 callers
Method
coreCount
<pre> Just return the core count - unary call </pre>
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java:237
↓ 1 callers
Method
countsForInUse
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:169
↓ 1 callers
Method
countsForInUse
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:583
↓ 1 callers
Method
covertAll
(List<Map<String, ?>> keyBuilders)
rls/src/main/java/io/grpc/rls/RlsProtoConverters.java:208
↓ 1 callers
Method
create
(String authority)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/S2AProtocolNegotiatorFactoryTest.java:191
↓ 1 callers
Method
create
(Key<T> key, T value)
api/src/main/java/io/grpc/Metadata.java:924
↓ 1 callers
Method
create
( ServerCallInfo<ReqT, RespT> callInfo)
api/src/main/java/io/grpc/ServerStreamTracer.java:95
↓ 1 callers
Method
create
( ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler)
api/src/main/java/io/grpc/ServerInterceptors.java:251
↓ 1 callers
Method
create
(ExecutorService threadPool)
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1556
↓ 1 callers
Method
create
(Channel channel, CallOptions callOptions)
stub/src/test/java/io/grpc/stub/AbstractFutureStubTest.java:36
↓ 1 callers
Method
create
(Channel channel, CallOptions callOptions)
stub/src/test/java/io/grpc/stub/AbstractBlockingStubTest.java:36
↓ 1 callers
Method
create
(Channel channel, CallOptions callOptions)
stub/src/test/java/io/grpc/stub/AbstractAsyncStubTest.java:36
↓ 1 callers
Method
create
Creates an insecure credential that will upgrade from HTTP/1 to HTTP/2.
netty/src/main/java/io/grpc/netty/InsecureFromHttp1ChannelCredentials.java:28
↓ 1 callers
Method
create
(String goAwayDebugString)
netty/src/main/java/io/grpc/netty/InternalGracefulServerCloseCommand.java:29
↓ 1 callers
Method
create
Create a credential using Netty's SslContext as configuration. It must have been configured with {@link GrpcSslContexts}, but options could have been
netty/src/main/java/io/grpc/netty/NettySslContextChannelCredentials.java:33
↓ 1 callers
Method
create
( @Nullable Long intervalNanos, @Nullable Long baseEjectionTimeNanos, @Nullable Long m
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:355
↓ 1 callers
Method
create
( @Nullable Integer stdevFactor, @Nullable Integer enforcementPercentage, @Nullable In
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:436
↓ 1 callers
Method
create
( @Nullable Integer threshold, @Nullable Integer enforcementPercentage, @Nullable Inte
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:461
↓ 1 callers
Method
create
(String category, long droppedCount)
xds/src/main/java/io/grpc/xds/client/Stats.java:91
↓ 1 callers
Method
create
(Locality locality, long totalIssuedRequests, long totalSuccessfulRequ
xds/src/main/java/io/grpc/xds/client/Stats.java:111
↓ 1 callers
Method
create
(int numerator, int denominator)
xds/src/main/java/io/grpc/xds/internal/Matchers.java:201
↓ 1 callers
Method
create
(Action decisionType, @Nullable String matchingPolicy)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:99
↓ 1 callers
Method
create
Start of the range is inclusive. End of the range is exclusive.
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:255
↓ 1 callers
Method
create
(Matchers.StringMatcher delegate)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:270
↓ 1 callers
Method
create
Creates a new instance of {@code HeaderMutator}.
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutator.java:36
↓ 1 callers
Method
createAdsService
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:419
↓ 1 callers
Method
createAndApplyOrcaListeners
()
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:447
↓ 1 callers
Method
createArgs
()
api/src/test/java/io/grpc/NameResolverTest.java:107
↓ 1 callers
Method
createChannel
(int port, String target)
interop-testing/src/test/java/io/grpc/testing/integration/XdsTestServerTest.java:88
↓ 1 callers
Method
createChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:353
↓ 1 callers
Method
createChannel
(InetSocketAddress address)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:378
↓ 1 callers
Method
createChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:583
↓ 1 callers
Method
createChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbLongLivedAffinityTestClient.java:213
↓ 1 callers
Method
createChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:368
↓ 1 callers
Method
createChildAddressesMap
Override to utilize parsing of the policy configuration or alternative helper/lb generation. Override this if keys are not Endpoints or if child polic
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:87
↓ 1 callers
Method
createChildHelper
()
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:279
↓ 1 callers
Method
createChildLbState
Override to create an instance of a subclass.
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:105
↓ 1 callers
Method
createClientFactory
()
alts/src/main/java/io/grpc/alts/GoogleDefaultChannelCredentials.java:105
↓ 1 callers
Method
createClientFactory
()
alts/src/main/java/io/grpc/alts/ComputeEngineChannelCredentials.java:60
↓ 1 callers
Method
createContext
( Metadata headers, StatsTraceContext statsTraceCtx)
core/src/main/java/io/grpc/internal/ServerImpl.java:639
↓ 1 callers
Method
createContextForTargetUserOrThrow
(Context context, UserHandle targetUser)
binder/src/main/java/io/grpc/binder/internal/IntentNameResolver.java:100
↓ 1 callers
Method
createDataEntry
( RouteLookupRequestKey routeLookupRequestKey, RouteLookupResponse routeLookupResponse)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:458
↓ 1 callers
Method
createDestinationIpMatcher
(CidrRange cidrRange)
xds/src/main/java/io/grpc/xds/RbacFilter.java:347
↓ 1 callers
Method
createDestinationPortMatcher
(int port)
xds/src/main/java/io/grpc/xds/RbacFilter.java:339
↓ 1 callers
Method
createEag
(String... names)
util/src/test/java/io/grpc/util/MultiChildLoadBalancerTest.java:329
↓ 1 callers
Method
createEpollEventLoopGroup
( int parallelism, ThreadFactory threadFactory)
netty/src/main/java/io/grpc/netty/Utils.java:442
↓ 1 callers
Method
createEventLoop
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:152
↓ 1 callers
Method
createForClient
( ObjectPool<Channel> channelPool, @Nullable S2AIdentity localIdentity, @Nullable S2AStub stub
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AProtocolNegotiatorFactory.java:114
↓ 1 callers
Method
createForHardCoded
(Class<T> klass, Class<?> rawClass)
api/src/main/java/io/grpc/ServiceProviders.java:138
↓ 1 callers
Method
createFromParcel
(Parcel parcel)
binder/src/test/java/io/grpc/binder/internal/TestParcelable.java:61
↓ 1 callers
Method
createHandler
Creates the Netty handler to be used in the channel pipeline.
netty/src/main/java/io/grpc/netty/NettyServerTransport.java:274
↓ 1 callers
Method
createHttpProxyRequest
(InetSocketAddress address, String proxyUsername, String proxyPasswor
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:912
↓ 1 callers
Method
createHttpProxySocket
(InetSocketAddress address, InetSocketAddress proxyAddress, String proxyUsername, String proxyPassword)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:839
↓ 1 callers
Method
createHttpResponseHeaders
Serializes the given headers and creates a list of OkHttp {@link Header}s to be used when failing with an HTTP response.
okhttp/src/main/java/io/grpc/okhttp/Headers.java:124
↓ 1 callers
Method
createInbound
(int callId)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:520
↓ 1 callers
Method
createInterceptor
Parses RBAC filter config and creates AuthorizationServerInterceptor.
xds/src/main/java/io/grpc/xds/InternalRbacFilter.java:30
↓ 1 callers
Method
createKeyBuilderTable
( RouteLookupConfig config)
rls/src/main/java/io/grpc/rls/RlsRequestFactory.java:50
↓ 1 callers
Method
createKeylessManager
( GetTlsConfigurationResp.ClientTlsConfiguration clientTlsConfiguration)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/SslContextFactory.java:159
↓ 1 callers
Method
createLoggingClient
()
gcp-observability/src/main/java/io/grpc/gcp/observability/logging/GcpLogSink.java:151
↓ 1 callers
Method
createLrsService
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:421
↓ 1 callers
Method
createLrsService
(AtomicBoolean lrsEnded, Queue<LrsRpcCall> loadReportCalls)
xds/src/test/java/io/grpc/xds/XdsTestUtils.java:99
↓ 1 callers
Method
createMessageFactory
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:423
↓ 1 callers
Method
createMetricInstrumentRegistry
()
api/src/testFixtures/java/io/grpc/MetricInstrumentRegistryAccessor.java:27
← previous
next →
5,801–5,900 of 22,628, ranked by callers