MCPcopy Create free account

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

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

↓ 1 callersMethodcommitted
(Substream winningSubstream)
core/src/main/java/io/grpc/internal/RetriableStream.java:1286
↓ 1 callersMethodcompareTo
(RingEntry entry)
xds/src/main/java/io/grpc/xds/RingHashLoadBalancer.java:525
↓ 1 callersMethodcomplete
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 callersMethodcompleteQueuedTasks
()
core/src/main/java/io/grpc/internal/SerializeReentrantCallsDirectExecutor.java:63
↓ 1 callersMethodcompressLongestRunOfZeroes
(int[] hextets)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InetAddressUtil.java:48
↓ 1 callersMethodcompressLongestRunOfZeroes
(int[] hextets)
services/src/main/java/io/grpc/protobuf/services/InetAddressUtil.java:48
↓ 1 callersMethodcompressionFrame
(byte[] data)
netty/src/test/java/io/grpc/netty/NettyTestUtil.java:51
↓ 1 callersMethodcomputeAndReportResourceCounts
( Map<XdsResourceType<?>, Map<String, ResourceMetadata>> metadataByType, MetricReporterCallback ca
xds/src/main/java/io/grpc/xds/XdsClientMetricReporterImpl.java:158
↓ 1 callersMethodcomputeDelaySecondsToCertExpiry
(X509Certificate lastCert)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProvider.java:189
↓ 1 callersMethodcomputeDurationSecs
(long lastMetricsCollectionTime)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:521
↓ 1 callersMethodcomputeEngineChannelCredentials
Sends an unary rpc with ComputeEngineChannelBuilder.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:855
↓ 1 callersMethodcomputeEngineCreds
Sends a large unary rpc with compute engine credentials.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:827
↓ 1 callersMethodconfigBuilder
(@Nullable ServerBuilder<?> builder)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:230
↓ 1 callersMethodconfigureChannelBuilder
(ManagedChannelBuilder<?> channelBuilder)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:161
↓ 1 callersMethodconfigureNetworkMonitoring
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:211
↓ 1 callersMethodconfigureServerBuilder
(ServerBuilder<?> serverBuilder)
api/src/main/java/io/grpc/InternalConfiguratorRegistry.java:42
↓ 1 callersMethodconfigureServerBuilder
(ServerBuilder<?> serverBuilder)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:166
↓ 1 callersMethodconfigureSslContextWithClientTlsConfiguration
( GetTlsConfigurationResp.ClientTlsConfiguration clientTlsConfiguration, SslContextBuilder sslCont
s2a/src/main/java/io/grpc/s2a/internal/handshaker/SslContextFactory.java:139
↓ 1 callersMethodconfigureTlsExtensions
Configure TLS extensions.
okhttp/src/main/java/io/grpc/okhttp/OkHttpProtocolNegotiator.java:115
↓ 1 callersMethodcontainsInvalidHostnameAsciiCodes
(String hostnameAscii)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:340
↓ 1 callersMethodconvertLeastRequestConfig
Converts a least_request {@link Any} configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:334
↓ 1 callersMethodconvertLeastRequestConfig
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 callersMethodconvertPickFirstConfig
"Converts" a pick_first configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:327
↓ 1 callersMethodconvertRingHashConfig
Converts a ring_hash {@link Any} configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:275
↓ 1 callersMethodconvertRingHashConfig
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 callersMethodconvertRoundRobinConfig
"Converts" a round_robin configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:320
↓ 1 callersMethodconvertStringToX509Cert
(String certificate)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/SslContextFactory.java:179
↓ 1 callersMethodconvertToServiceConfig
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 callersMethodconvertToValue
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 callersMethodconvertTrailers
(List<Header> http2Headers)
okhttp/src/main/java/io/grpc/okhttp/Utils.java:52
↓ 1 callersMethodconvertValue
(Value value)
xds/src/main/java/io/grpc/xds/internal/ProtobufJsonConverter.java:41
↓ 1 callersMethodconvertWeightedRoundRobinConfig
( ClientSideWeightedRoundRobin wrr)
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:289
↓ 1 callersMethodconvertWrrLocalityConfig
Converts a wrr_locality {@link Any} configuration to service config format.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:310
↓ 1 callersMethodcopy
Copies the data from input stream to output stream.
gcp-observability/src/test/java/io/grpc/gcp/observability/interceptors/LogHelperTest.java:783
↓ 1 callersMethodcopy
Copies the data from input stream to output stream.
protobuf-lite/src/main/java/io/grpc/protobuf/lite/ProtoLiteUtils.java:113
↓ 1 callersMethodcopyAllNameResolverCustomArgsTo
(NameResolver.Args.Builder dest)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:631
↓ 1 callersMethodcopyCustomOptions
(Object[][] options)
api/src/main/java/io/grpc/LoadBalancer.java:897
↓ 1 callersMethodcoreCount
<pre> Just return the core count - unary call </pre>
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java:237
↓ 1 callersMethodcountsForInUse
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:169
↓ 1 callersMethodcountsForInUse
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:583
↓ 1 callersMethodcovertAll
(List<Map<String, ?>> keyBuilders)
rls/src/main/java/io/grpc/rls/RlsProtoConverters.java:208
↓ 1 callersMethodcreate
(String authority)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/S2AProtocolNegotiatorFactoryTest.java:191
↓ 1 callersMethodcreate
(Key<T> key, T value)
api/src/main/java/io/grpc/Metadata.java:924
↓ 1 callersMethodcreate
( ServerCallInfo<ReqT, RespT> callInfo)
api/src/main/java/io/grpc/ServerStreamTracer.java:95
↓ 1 callersMethodcreate
( ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler)
api/src/main/java/io/grpc/ServerInterceptors.java:251
↓ 1 callersMethodcreate
(ExecutorService threadPool)
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1556
↓ 1 callersMethodcreate
(Channel channel, CallOptions callOptions)
stub/src/test/java/io/grpc/stub/AbstractFutureStubTest.java:36
↓ 1 callersMethodcreate
(Channel channel, CallOptions callOptions)
stub/src/test/java/io/grpc/stub/AbstractBlockingStubTest.java:36
↓ 1 callersMethodcreate
(Channel channel, CallOptions callOptions)
stub/src/test/java/io/grpc/stub/AbstractAsyncStubTest.java:36
↓ 1 callersMethodcreate
Creates an insecure credential that will upgrade from HTTP/1 to HTTP/2.
netty/src/main/java/io/grpc/netty/InsecureFromHttp1ChannelCredentials.java:28
↓ 1 callersMethodcreate
(String goAwayDebugString)
netty/src/main/java/io/grpc/netty/InternalGracefulServerCloseCommand.java:29
↓ 1 callersMethodcreate
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 callersMethodcreate
( @Nullable Long intervalNanos, @Nullable Long baseEjectionTimeNanos, @Nullable Long m
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:355
↓ 1 callersMethodcreate
( @Nullable Integer stdevFactor, @Nullable Integer enforcementPercentage, @Nullable In
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:436
↓ 1 callersMethodcreate
( @Nullable Integer threshold, @Nullable Integer enforcementPercentage, @Nullable Inte
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:461
↓ 1 callersMethodcreate
(String category, long droppedCount)
xds/src/main/java/io/grpc/xds/client/Stats.java:91
↓ 1 callersMethodcreate
(Locality locality, long totalIssuedRequests, long totalSuccessfulRequ
xds/src/main/java/io/grpc/xds/client/Stats.java:111
↓ 1 callersMethodcreate
(int numerator, int denominator)
xds/src/main/java/io/grpc/xds/internal/Matchers.java:201
↓ 1 callersMethodcreate
(Action decisionType, @Nullable String matchingPolicy)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:99
↓ 1 callersMethodcreate
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 callersMethodcreate
(Matchers.StringMatcher delegate)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:270
↓ 1 callersMethodcreate
Creates a new instance of {@code HeaderMutator}.
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutator.java:36
↓ 1 callersMethodcreateAdsService
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:419
↓ 1 callersMethodcreateAndApplyOrcaListeners
()
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:447
↓ 1 callersMethodcreateArgs
()
api/src/test/java/io/grpc/NameResolverTest.java:107
↓ 1 callersMethodcreateChannel
(int port, String target)
interop-testing/src/test/java/io/grpc/testing/integration/XdsTestServerTest.java:88
↓ 1 callersMethodcreateChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:353
↓ 1 callersMethodcreateChannel
(InetSocketAddress address)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:378
↓ 1 callersMethodcreateChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:583
↓ 1 callersMethodcreateChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbLongLivedAffinityTestClient.java:213
↓ 1 callersMethodcreateChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:368
↓ 1 callersMethodcreateChildAddressesMap
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 callersMethodcreateChildHelper
()
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:279
↓ 1 callersMethodcreateChildLbState
Override to create an instance of a subclass.
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:105
↓ 1 callersMethodcreateClientFactory
()
alts/src/main/java/io/grpc/alts/GoogleDefaultChannelCredentials.java:105
↓ 1 callersMethodcreateClientFactory
()
alts/src/main/java/io/grpc/alts/ComputeEngineChannelCredentials.java:60
↓ 1 callersMethodcreateContext
( Metadata headers, StatsTraceContext statsTraceCtx)
core/src/main/java/io/grpc/internal/ServerImpl.java:639
↓ 1 callersMethodcreateContextForTargetUserOrThrow
(Context context, UserHandle targetUser)
binder/src/main/java/io/grpc/binder/internal/IntentNameResolver.java:100
↓ 1 callersMethodcreateDataEntry
( RouteLookupRequestKey routeLookupRequestKey, RouteLookupResponse routeLookupResponse)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:458
↓ 1 callersMethodcreateDestinationIpMatcher
(CidrRange cidrRange)
xds/src/main/java/io/grpc/xds/RbacFilter.java:347
↓ 1 callersMethodcreateDestinationPortMatcher
(int port)
xds/src/main/java/io/grpc/xds/RbacFilter.java:339
↓ 1 callersMethodcreateEag
(String... names)
util/src/test/java/io/grpc/util/MultiChildLoadBalancerTest.java:329
↓ 1 callersMethodcreateEpollEventLoopGroup
( int parallelism, ThreadFactory threadFactory)
netty/src/main/java/io/grpc/netty/Utils.java:442
↓ 1 callersMethodcreateEventLoop
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:152
↓ 1 callersMethodcreateForClient
( ObjectPool<Channel> channelPool, @Nullable S2AIdentity localIdentity, @Nullable S2AStub stub
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AProtocolNegotiatorFactory.java:114
↓ 1 callersMethodcreateForHardCoded
(Class<T> klass, Class<?> rawClass)
api/src/main/java/io/grpc/ServiceProviders.java:138
↓ 1 callersMethodcreateFromParcel
(Parcel parcel)
binder/src/test/java/io/grpc/binder/internal/TestParcelable.java:61
↓ 1 callersMethodcreateHandler
Creates the Netty handler to be used in the channel pipeline.
netty/src/main/java/io/grpc/netty/NettyServerTransport.java:274
↓ 1 callersMethodcreateHttpProxyRequest
(InetSocketAddress address, String proxyUsername, String proxyPasswor
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:912
↓ 1 callersMethodcreateHttpProxySocket
(InetSocketAddress address, InetSocketAddress proxyAddress, String proxyUsername, String proxyPassword)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:839
↓ 1 callersMethodcreateHttpResponseHeaders
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 callersMethodcreateInbound
(int callId)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:520
↓ 1 callersMethodcreateInterceptor
Parses RBAC filter config and creates AuthorizationServerInterceptor.
xds/src/main/java/io/grpc/xds/InternalRbacFilter.java:30
↓ 1 callersMethodcreateKeyBuilderTable
( RouteLookupConfig config)
rls/src/main/java/io/grpc/rls/RlsRequestFactory.java:50
↓ 1 callersMethodcreateKeylessManager
( GetTlsConfigurationResp.ClientTlsConfiguration clientTlsConfiguration)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/SslContextFactory.java:159
↓ 1 callersMethodcreateLoggingClient
()
gcp-observability/src/main/java/io/grpc/gcp/observability/logging/GcpLogSink.java:151
↓ 1 callersMethodcreateLrsService
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:421
↓ 1 callersMethodcreateLrsService
(AtomicBoolean lrsEnded, Queue<LrsRpcCall> loadReportCalls)
xds/src/test/java/io/grpc/xds/XdsTestUtils.java:99
↓ 1 callersMethodcreateMessageFactory
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:423
↓ 1 callersMethodcreateMetricInstrumentRegistry
()
api/src/testFixtures/java/io/grpc/MetricInstrumentRegistryAccessor.java:27
← previousnext →5,801–5,900 of 22,628, ranked by callers