MCPcopy Create free account

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

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

↓ 5 callersMethodawaitTermination
()
core/src/test/java/io/grpc/internal/ForwardingManagedChannelTest.java:80
↓ 5 callersMethodblockingClientStreamingCall
Initiates a server streaming call and sends the specified request to the server. It returns an object which can be used in a blocking manner to retri
stub/src/main/java/io/grpc/stub/ClientCalls.java:286
↓ 5 callersMethodbootstrapInfo
()
xds/src/main/java/io/grpc/xds/Filter.java:137
↓ 5 callersMethodbuild
Returns a new {@link CsmObservability} built with the configuration of this {@link Builder}.
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/CsmObservability.java:156
↓ 5 callersMethodbuildListenerWithApiListenerInvalid
(String name)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5298
↓ 5 callersMethodbuildRecursiveMessage
(int depth)
protobuf-lite/src/test/java/io/grpc/protobuf/lite/ProtoLiteUtilsTest.java:304
↓ 5 callersMethodbuildStaticValidationContext
( String... verifySans)
xds/src/test/java/io/grpc/xds/internal/security/trust/XdsTrustManagerFactoryTest.java:311
↓ 5 callersMethodbuildTransportFactory
()
inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:244
↓ 5 callersMethodbuildTransportServers
( List<? extends ServerStreamTracer.Factory> streamTracerFactories, MetricRecorder metricRecorder)
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:709
↓ 5 callersMethodbuildTrustManagerAndGetSslEngine
()
xds/src/test/java/io/grpc/xds/internal/security/trust/XdsX509TrustManagerTest.java:757
↓ 5 callersMethodbuildUpdate
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:219
↓ 5 callersMethodbuildUpstreamTlsContext
(String instanceName, String certName)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5341
↓ 5 callersMethodbuildWrappedResource
(Any originalResource)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5283
↓ 5 callersMethodbytebuf
()
netty/src/main/java/io/grpc/netty/NettyWritableBuffer.java:58
↓ 5 callersMethodcallUpdateSslContext
(SslContextProviderSupplier sslContextProviderSupplier)
xds/src/test/java/io/grpc/xds/XdsClientWrapperForServerSdsTestMisc.java:305
↓ 5 callersMethodcancel
Cancel this context and optionally provide a cause (can be {@code null}) for the cancellation. This will trigger notification of listeners. It is safe
api/src/context/java/io/grpc/Context.java:813
↓ 5 callersMethodcancelFallbackTimer
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:447
↓ 5 callersMethodcancellableAncestor
Returns {@code parent} if it is a {@link CancellableContext}, otherwise returns the parent's {@link #cancellableAncestor}.
api/src/context/java/io/grpc/Context.java:1095
↓ 5 callersMethodchannelCredentials
()
xds/src/test/java/io/grpc/xds/internal/TlsXdsCredentialsProviderTest.java:52
↓ 5 callersMethodcheckAuthorizationForServiceAsync
Returns whether the given Android UID is authorized to access a particular service. <p>This method never throws an exception. If the execution of the
binder/src/main/java/io/grpc/binder/internal/BinderTransportSecurity.java:246
↓ 5 callersMethodcheckContext
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1279
↓ 5 callersMethodcheckNotDone
()
api/src/test/java/io/grpc/ClientInterceptorsTest.java:469
↓ 5 callersMethodcheckProductNameOnLinux
(BufferedReader reader)
alts/src/main/java/io/grpc/alts/InternalCheckGcpEnvironment.java:56
↓ 5 callersMethodcheckServerTrusted
(X509Certificate[] chain, String authType, SSLEngine engine)
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:92
↓ 5 callersMethodclientAttemptCountCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:32
↓ 5 callersMethodcloseWithException
(StatusRuntimeException t)
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:107
↓ 5 callersMethodclosed
(Status status)
core/src/main/java/io/grpc/internal/ServerCallImpl.java:360
↓ 5 callersMethodcompareTo
{@inheritDoc} <p>Both deadlines must be created with the same {@link Ticker}.
api/src/context/java/io/grpc/Deadline.java:227
↓ 5 callersMethodcontainsSubchannel
(InternalLogId subchannelRef)
api/src/main/java/io/grpc/InternalChannelz.java:229
↓ 5 callersMethodconvertHeaders
(Http2Headers http2Headers)
netty/src/main/java/io/grpc/netty/Utils.java:193
↓ 5 callersMethodconvertToJson
(Struct struct)
xds/src/main/java/io/grpc/xds/internal/ProtobufJsonConverter.java:33
↓ 5 callersMethodcreate
(Channel channel)
stub/src/test/java/io/grpc/stub/BaseAbstractStubTest.java:44
↓ 5 callersMethodcreate
Creates a {@link ChannelCredentials} that will use the provided {@code negotiator}.
netty/src/main/java/io/grpc/netty/InternalNettyChannelCredentials.java:31
↓ 5 callersMethodcreate
(String category, int dropsPerMillion)
xds/src/main/java/io/grpc/xds/Endpoints.java:98
↓ 5 callersMethodcreate
(@Nullable String exact, @Nullable String prefix, @Nullable String suffix, @Nullable Pattern regEx, @N
xds/src/main/java/io/grpc/xds/internal/Matchers.java:289
↓ 5 callersMethodcreate
(Matchers.CidrMatcher delegate)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:182
↓ 5 callersMethodcreateBinaryLog
Returns a binlog with the correct header and message limits or {@code null} if the input is malformed. The input should be a string that is in one of
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:720
↓ 5 callersMethodcreateForTest
A convenient method to allow creating a {@link XdsNameResolverProvider} with custom scheme and bootstrap.
xds/src/main/java/io/grpc/xds/XdsNameResolverProvider.java:75
↓ 5 callersMethodcreateKeyManager
(byte[] certChain, byte[] privateKey)
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:687
↓ 5 callersMethodcreateMatchSrcIp
(String srcCidr)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1986
↓ 5 callersMethodcreateMetricReport
(double cpu, double app, double mem, double qps, double eps, Map<String, Double> namedMetrics)
xds/src/test/java/io/grpc/xds/internal/MetricReportUtilsTest.java:110
↓ 5 callersMethodcreateNewChannel
()
interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:195
↓ 5 callersMethodcreateProtocolNegotiatorByType
( NegotiationType negotiationType, SslContext sslContext, ObjectPool<? extends Executor> exe
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:644
↓ 5 callersMethodcreateRandomSubsettingLbConfig
( int subsetSize, LoadBalancerProvider childLbProvider, Object childConfig)
util/src/test/java/io/grpc/util/RandomSubsettingLoadBalancerTest.java:99
↓ 5 callersMethodcreateSocket
(Socket s, String host, int port, boolean autoClose)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:545
↓ 5 callersMethodcreateSubchannel
(CreateSubchannelArgs args)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:720
↓ 5 callersMethodcreateXdsClient
(List<String> serverUris, XdsTransportFactory xdsTransportFactor
xds/src/test/java/io/grpc/xds/client/CommonBootstrapperTestUtils.java:169
↓ 5 callersMethoddeadline
()
api/src/testFixtures/java/io/grpc/testing/DeadlineSubject.java:39
↓ 5 callersMethoddeframeFailed
(Throwable cause)
core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java:422
↓ 5 callersMethoddelayOrExecute
(Runnable runnable)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:277
↓ 5 callersMethoddelegate
()
core/src/main/java/io/grpc/internal/ForwardingClientStreamListener.java:25
↓ 5 callersMethoddelegate
Returns the delegated {@code ServerCall.Listener}.
api/src/main/java/io/grpc/PartialForwardingServerCallListener.java:31
↓ 5 callersMethoddeliverAddresses
(WrrLocalityConfig config, List<EquivalentAddressGroup> addresses)
xds/src/test/java/io/grpc/xds/WrrLocalityLoadBalancerTest.java:215
↓ 5 callersMethoddeliverSubchannelState
(LoadBalancer.Subchannel subchannel, ConnectivityStateInfo newState)
util/src/test/java/io/grpc/util/MultiChildLoadBalancerTest.java:363
↓ 5 callersMethodderegister
Deregisters a provider. No-op if the provider is not in the registry. @param provider the provider that was added to the register via {@link #regist
api/src/main/java/io/grpc/NameResolverRegistry.java:97
↓ 5 callersMethoddetach
(Context toAttach)
api/src/context/java/io/grpc/Context.java:717
↓ 5 callersMethoddisableRetry
()
core/src/test/java/io/grpc/internal/ManagedChannelImplBuilderTest.java:702
↓ 5 callersMethoddisableServiceConfigLookUp
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:640
↓ 5 callersMethoddisallowedHeaders
Specifies which request headers are not sent to the authorization service. This overrides {@link #allowedHeaders()}. @see ExtAuthz#getDisallowedHeade
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:112
↓ 5 callersMethoddoUnaryRpc
(ManagedChannel channel)
s2a/src/test/java/io/grpc/s2a/IntegrationTest.java:196
↓ 5 callersMethoddroppedCount
()
xds/src/main/java/io/grpc/xds/client/Stats.java:89
↓ 5 callersMethodedsServiceName
(String edsServiceName)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:755
↓ 5 callersMethodemptyBuilder
()
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:177
↓ 5 callersMethodenableButtons
(boolean enable)
android-interop-testing/src/main/java/io/grpc/android/integrationtest/TesterActivity.java:114
↓ 5 callersMethodenableRetry
Enables the retry and hedging subsystem which will use <a href="https://github.com/grpc/proposal/blob/master/A6-client-retries.md#integration-with-ser
api/src/main/java/io/grpc/ManagedChannelBuilder.java:524
↓ 5 callersMethoderror
(String error)
api/src/main/java/io/grpc/ManagedChannelProvider.java:102
↓ 5 callersMethoderror
(String error)
api/src/main/java/io/grpc/ServerProvider.java:90
↓ 5 callersMethoderror
(String error)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:307
↓ 5 callersMethodestimatedMaxSizeBytes
()
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:105
↓ 5 callersMethodexecute
(Runnable action)
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:278
↓ 5 callersMethodexists
Indicates whether the given feature exists (i.e. has a valid name).
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideUtil.java:77
↓ 5 callersMethodextractChannelData
(InternalChannelz.ChannelStats stats)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:354
↓ 5 callersMethodfailWrites
Propagate failures to all buffered writes.
netty/src/main/java/io/grpc/netty/WriteBufferingAndExceptionHandler.java:234
↓ 5 callersMethodfinalizeAndDump2
(CallMetricRecorder recorder)
services/src/main/java/io/grpc/services/InternalCallMetricRecorder.java:44
↓ 5 callersMethodfindClusterStats
( List<ClusterStats> statsList, String cluster, @Nullable String edsServiceName)
xds/src/test/java/io/grpc/xds/client/LoadStatsManager2Test.java:359
↓ 5 callersMethodfindOrCreateClientSslContextProvider
( UpstreamTlsContext upstreamTlsContext)
xds/src/main/java/io/grpc/xds/internal/security/TlsContextManagerImpl.java:70
↓ 5 callersMethodfindOrCreateServerSslContextProvider
( DownstreamTlsContext downstreamTlsContext)
xds/src/main/java/io/grpc/xds/internal/security/TlsContextManagerImpl.java:59
↓ 5 callersMethodfireOnEviction
(K key, SizedValue value, EvictionType cause)
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:286
↓ 5 callersMethodforAddress
Creates a channel builder that will bind to a remote Android service. <p>The underlying Android binding will be torn down when the channel becomes id
binder/src/main/java/io/grpc/binder/BinderChannelBuilder.java:60
↓ 5 callersMethodforContext
Creates an address for the given {@link android.app.Service} instance with the default binding {@link Intent}.
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:73
↓ 5 callersMethodforDefault
Creates the default BinderChannelCredentials. @return a BinderChannelCredentials
binder/src/main/java/io/grpc/binder/BinderChannelCredentials.java:34
↓ 5 callersMethodforHeader
(boolean isTerminal, String headerName, @Nullable Pattern regEx, @Nullable String regExSubstitutio
xds/src/main/java/io/grpc/xds/VirtualHost.java:258
↓ 5 callersMethodforRange
The request header value should be within the range.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:94
↓ 5 callersMethodforWeightedClusters
( List<ClusterWeight> weightedClusters, List<HashPolicy> hashPolicies, @Nullable Long time
xds/src/main/java/io/grpc/xds/VirtualHost.java:179
↓ 5 callersMethodget
(K key, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:72
↓ 5 callersMethodget
(K key, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:295
↓ 5 callersMethodget
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpProtocolNegotiator.java:61
↓ 5 callersMethodgetActiveCpc
(String authority)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:169
↓ 5 callersMethodgetAdvertisedMessageEncodings
Provides a list of all message encodings that have decompressors available and should be advertised. <p>The specification doesn't say anything about
api/src/main/java/io/grpc/DecompressorRegistry.java:115
↓ 5 callersMethodgetAllGauges
<pre> Returns the values of all the gauges that are currently being maintained by the service </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/MetricsServiceGrpc.java:146
↓ 5 callersMethodgetAltsMaxConcurrentHandshakes
(String altsMaxConcurrentHandshakes)
alts/src/main/java/io/grpc/alts/internal/AltsProtocolNegotiator.java:426
↓ 5 callersMethodgetAppListener
()
core/src/main/java/io/grpc/internal/ApplicationThreadDeframer.java:136
↓ 5 callersMethodgetChannelLogger
()
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:802
↓ 5 callersMethodgetClientInterceptor
Returns a {@link ClientInterceptor} with default stats implementation.
census/src/main/java/io/grpc/census/InternalCensusStatsAccessor.java:49
↓ 5 callersMethodgetConfig
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplDataTest.java:1270
↓ 5 callersMethodgetCurrentAddress
()
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:716
↓ 5 callersMethodgetDeadline
Returns the deadline or {@code null} if the deadline is not set.
api/src/main/java/io/grpc/CallOptions.java:189
↓ 5 callersMethodgetDelegate
Returns the wrapped {@link IBinder} for the purpose of calling methods other than {@link IBinder#transact(int, Parcel, Parcel, int)}.
binder/src/main/java/io/grpc/binder/internal/OneWayBinderProxy.java:102
↓ 5 callersMethodgetDetails
()
api/src/main/java/io/grpc/InternalLogId.java:79
↓ 5 callersMethodgetErrorState
The metadata capturing the error details of the last rejected update of the resource.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:249
← previousnext →2,601–2,700 of 22,628, ranked by callers