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
↓ 34 callersMethodsetSeverity
(Severity severity)
api/src/main/java/io/grpc/InternalChannelz.java:596
↓ 34 callersMethodshouldWaitOnServiceConfig
Returns {@code true} if it RPCs should wait on a service config resolution. This can return {@code false} if: <ul> <li>There is a valid service co
core/src/main/java/io/grpc/internal/ServiceConfigState.java:71
↓ 34 callersMethodthisT
Returns the correctly typed version of the builder.
api/src/main/java/io/grpc/ForwardingChannelBuilder2.java:289
↓ 33 callersMethodcreateVirtualHost
(String name)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1949
↓ 33 callersMethoddeliverRdsUpdate
(String resourceName, List<VirtualHost> virtualHosts)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2826
↓ 33 callersMethodforwardTime
(OutlierDetectionLoadBalancerConfig config)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1373
↓ 33 callersMethodgetAddresses
Returns an immutable list of the addresses.
api/src/main/java/io/grpc/EquivalentAddressGroup.java:117
↓ 33 callersMethodgetCurrentEagAttributes
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:840
↓ 33 callersMethodgetListOfObjects
Gets a list from an object for the given key, and verifies all entries are objects. If the key is not present, this returns null. If the value is no
core/src/main/java/io/grpc/internal/JsonUtil.java:56
↓ 33 callersMethodgetLoadRecorder
()
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2769
↓ 33 callersMethodkey
Create a {@link Key} with the given debug name. @param debugString a name intended for debugging purposes and does not impact behavior.
api/src/context/java/io/grpc/Context.java:149
↓ 33 callersMethodnewChildConfig
(LoadBalancerProvider provider, Object config)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1047
↓ 33 callersMethodsetPackageName
(String packageName)
binder/src/test/java/io/grpc/binder/SecurityPoliciesTest.java:473
↓ 33 callersMethodstartNewCall
( MethodDescriptor<ReqT, RespT> method, InternalConfigSelector selector, Map<String, String> heade
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2443
↓ 33 callersMethodtoStatus
Returns a {@link Status} object corresponding to this status code.
api/src/main/java/io/grpc/Status.java:227
↓ 33 callersMethodwrite
Writes the {@code message} to the destination.
gcp-observability/src/main/java/io/grpc/gcp/observability/logging/Sink.java:31
↓ 32 callersMethodbuilder
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:69
↓ 32 callersMethodchannel
()
netty/src/main/java/io/grpc/netty/NettyClientTransport.java:444
↓ 32 callersMethodcreate
Creates ResolvedAddress with given childLbConfig.
rls/src/main/java/io/grpc/rls/ResolvedAddressFactory.java:25
↓ 32 callersMethodcreateFileReader
( final String expectedPath, final String rawData)
xds/src/test/java/io/grpc/xds/GrpcBootstrapperImplTest.java:1040
↓ 32 callersMethodcreateResolvedBalancerAddresses
(int n)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2782
↓ 32 callersMethoddetach
Reverse an {@code attach()}, restoring the previous context and exiting the current scope. <p>This context should be the same context that was previo
api/src/context/java/io/grpc/Context.java:448
↓ 32 callersMethodexecuteLater
Adds a task that will be run when {@link #drain} is called. <p>This is useful for cases where you want to enqueue a task while under a lock of your o
api/src/main/java/io/grpc/SynchronizationContext.java:115
↓ 32 callersMethodgetRoutingConfigs
()
xds/src/main/java/io/grpc/xds/FilterChainMatchingProtocolNegotiators.java:158
↓ 32 callersMethodgetServiceConfig
Gets the Service Config parsed by {@link Args#getServiceConfigParser}. @since 1.21.0
api/src/main/java/io/grpc/NameResolver.java:841
↓ 32 callersMethodgetTrustManagers
Returns the trust manager list which verifies the client's identity. Entries are scanned checking for specific types, like {@link javax.net.ssl.X509Tr
api/src/main/java/io/grpc/TlsServerCredentials.java:144
↓ 32 callersMethodisAvailable
Checks this provider is available for use, taking the current environment into consideration. If {@code false}, no other methods are safe to be called
api/src/main/java/io/grpc/ServiceProviders.java:163
↓ 32 callersMethodof
(Deadline expected)
api/src/testFixtures/java/io/grpc/testing/DeadlineSubject.java:58
↓ 32 callersMethodstreamCreated
Called when a new stream was created by the remote client. @param stream the newly created stream. @param method the fully qualified method name bein
core/src/main/java/io/grpc/internal/ServerTransportListener.java:34
↓ 32 callersMethodwarning
(String msg, Object... params)
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideClient.java:294
↓ 31 callersMethodassertLog
(List<String> logs, String expectedLog)
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:155
↓ 31 callersMethodcallMeMaybe
(Runnable r)
netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java:1208
↓ 31 callersMethodclientAuth
Indicates whether the server should expect a client's identity. Must not be {@code null}. Defaults to {@link ClientAuth#NONE}.
api/src/main/java/io/grpc/TlsServerCredentials.java:341
↓ 31 callersMethodcreateInternalSubchannel
(SocketAddress ... addrs)
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:1472
↓ 31 callersMethoddecode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
alts/src/main/java/io/grpc/alts/internal/TsiFrameHandler.java:60
↓ 31 callersMethodempty
()
api/src/test/java/io/grpc/AttributesTest.java:65
↓ 31 callersMethodflowControlPing
()
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:129
↓ 31 callersMethodfromConfig
Returns a {@link ConfigOrError} for the successfully converted data object.
xds/src/main/java/io/grpc/xds/ConfigOrError.java:28
↓ 31 callersMethodgetClusterStatsReports
Gets the traffic stats (drops and loads) as a list of {@link ClusterStats} recorded for the specified cluster since the previous call of this method o
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:160
↓ 31 callersMethodgetId
()
api/src/main/java/io/grpc/InternalLogId.java:84
↓ 31 callersMethodgetTagBytes
()
alts/src/test/java/io/grpc/alts/internal/FakeChannelCrypter.java:33
↓ 31 callersMethodmethod
(io.grpc.reflection.testing.Request request, io.grpc.stub.StreamObserver<io.grpc.reflection.testing.Re
services/src/generated/test/grpc/io/grpc/reflection/testing/ReflectableServiceGrpc.java:111
↓ 31 callersMethodnewBuilder
()
binder/src/test/java/io/grpc/binder/SecurityPoliciesTest.java:464
↓ 31 callersMethodobtain
Creates a new instance that owns a {@link Parcel} newly obtained from Android's object pool.
binder/src/main/java/io/grpc/binder/internal/ParcelHolder.java:21
↓ 31 callersMethodonAmbientError
Called to deliver a transient error that should not affect the watcher's use of any previously received resource.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:165
↓ 31 callersMethodonClose
(Status status, Metadata metadata)
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:287
↓ 31 callersMethodonResult2
Handles updates on resolved addresses and attributes. Must be called from the same {@link SynchronizationContext} available in {@link NameResolver.Arg
api/src/main/java/io/grpc/NameResolver.java:316
↓ 31 callersMethodpickSubchannel
(PickSubchannelArgs args)
core/src/test/java/io/grpc/internal/DelayedClientTransportTest.java:712
↓ 31 callersMethodreplace
(ByteBuf content)
netty/src/main/java/io/grpc/netty/SendGrpcFrameCommand.java:57
↓ 31 callersMethodsetMaxEjectionPercent
The algorithm agnostic maximum percentage of addresses that can be ejected.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:1006
↓ 31 callersMethodstart
(Listener transportListener)
netty/src/main/java/io/grpc/netty/NettyClientTransport.java:233
↓ 31 callersMethodstartSpan
()
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:393
↓ 31 callersMethodstreamClosed
(Status status)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:263
↓ 31 callersMethodupdateTrustedRoots
(List<X509Certificate> trustedRoots)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:47
↓ 30 callersMethodbuildInitialResponse
()
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2802
↓ 30 callersMethodbuildRouteConfiguration
(String name, List<Message> virtualHostList)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5308
↓ 30 callersMethodcreate
(ImmutableList<HeaderValueOption> headers, ImmutableList<String> headersToRemove)
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutations.java:26
↓ 30 callersMethoddelegate
Returns the delegated {@code ManagedChannelBuilder}. <p>NOTE: this method is marked deprecated instead the class itself, so that classes extending {@
api/src/main/java/io/grpc/ForwardingChannelBuilder.java:60
↓ 30 callersMethodgetFullMethodNameForPath
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2913
↓ 30 callersMethodgetName
The name of the parameter as it would appear on the command-line.
benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java:77
↓ 30 callersMethodgetProvider
Returns the effective provider for the given xds credential name, or {@code null} if no suitable provider can be found. Each provider declares its nam
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:148
↓ 30 callersMethodgetServerCallHandler
Handler for incoming calls.
api/src/main/java/io/grpc/ServerMethodDefinition.java:53
↓ 30 callersMethodhash
()
inprocess/src/test/java/io/grpc/inprocess/InProcessSocketAddressTest.java:45
↓ 30 callersMethodlogRpcMethod
Checks if the corresponding service/method passed needs to be logged according to user provided observability configuration. Filters are evaluated in
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/ConfigFilterHelper.java:63
↓ 30 callersMethodnewBuilder
()
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:365
↓ 30 callersMethodnewTransport
(ProtocolNegotiator negotiator)
netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java:1112
↓ 30 callersMethodonException
Handles exception.
okhttp/src/main/java/io/grpc/okhttp/ExceptionHandlingFrameWriter.java:232
↓ 30 callersMethodpath
(CharSequence value)
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:533
↓ 30 callersMethodping
Read a connection-level ping from the peer. {@code ack} indicates this is a reply. Payload parameters are different between SPDY/3 and HTTP/2. <p>
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:68
↓ 30 callersMethodsetTimestampNanos
(long timestampNanos)
api/src/main/java/io/grpc/InternalChannelz.java:591
↓ 30 callersMethodthisT
Returns the correctly typed version of the builder.
api/src/main/java/io/grpc/ForwardingChannelBuilder.java:248
↓ 30 callersMethodupdateBalancingState
(ConnectivityState newState, SubchannelPicker newPicker)
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:661
↓ 30 callersMethodverifyRequestNack
( XdsResourceType<?> type, List<String> resources, String versionInfo, String nonce, Node node
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5225
↓ 30 callersMethodwritableBytes
Returns the number of bytes one can write to the buffer.
core/src/main/java/io/grpc/internal/WritableBuffer.java:46
↓ 30 callersMethodwrite
Writes the {@code message} to the destination.
services/src/main/java/io/grpc/protobuf/services/BinaryLogSink.java:31
↓ 29 callersMethodapply
()
stub/src/test/java/io/grpc/stub/BlockingClientCallTest.java:400
↓ 29 callersMethodavailable
Returns the total number of bytes that can be read (or skipped over) from this object until all bytes have been read out.
api/src/main/java/io/grpc/KnownLength.java:34
↓ 29 callersMethodbuildLbResponse
(List<ServerEntry> servers)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2820
↓ 29 callersMethodcurrentTimeMillis
()
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:406
↓ 29 callersMethodexecute
(Runnable r)
core/src/test/java/io/grpc/internal/SerializingExecutorTest.java:164
↓ 29 callersMethodforApiListener
(io.grpc.xds.HttpConnectionManager httpConnectionManager)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:644
↓ 29 callersMethodforwardTimeByConnectionDelay
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3124
↓ 29 callersMethodfrom
(ChannelCredentials creds)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:112
↓ 29 callersMethodgetCertFromResourceName
(String resourceName)
xds/src/test/java/io/grpc/xds/internal/security/certprovider/CommonCertProviderTestUtils.java:39
↓ 29 callersMethodgetClusters
()
xds/src/main/java/io/grpc/xds/XdsConfig.java:101
↓ 29 callersMethodgetMockListener
()
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1229
↓ 29 callersMethodgetTestBootstrapInfo
Creates a test bootstrap info object.
xds/src/test/java/io/grpc/xds/client/CommonBootstrapperTestUtils.java:73
↓ 29 callersMethodincrement
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:822
↓ 29 callersMethodinit
Initializes server and returns its listening port.
interop-testing/src/test/java/io/grpc/testing/integration/ProxyTest.java:198
↓ 29 callersMethodisExpired
Returns whether this has deadline expired. @return {@code true} if it has, otherwise {@code false}.
api/src/context/java/io/grpc/Deadline.java:122
↓ 29 callersMethodnewBuilder
Creates a new builder.
api/src/main/java/io/grpc/LoadBalancer.java:872
↓ 29 callersMethodnewChannelBuilderForAddress
Creates a channel builder from a host, port, and credentials. The host and port are combined to form an authority string and then passed to {@link #ne
api/src/main/java/io/grpc/Grpc.java:116
↓ 29 callersMethodonNotServing
Callback invoked when server is forced to be "not serving" due to an error. @param throwable cause of the error
xds/src/main/java/io/grpc/xds/XdsServerBuilder.java:171
↓ 29 callersMethodparseRouteAction
Parses the RouteAction config. The returned result may contain a (parsed form) {@link RouteAction} or an error message. Returns {@code null} if the Ro
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:402
↓ 29 callersMethodrequestConnection
()
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2903
↓ 29 callersMethodupdateSelector
(FilterChainSelector newSelector)
xds/src/main/java/io/grpc/xds/FilterChainSelectorManager.java:61
↓ 29 callersMethodupdateTrustCredentials
Updates the current cached trust certificates as well as the key store. @param trustCerts the trust certificates that are going to be used
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:208
↓ 28 callersMethodcache
Populates a cache entry. If the cache entry for given key already exists, the value will be replaced to the new value. @return the previous value ass
rls/src/main/java/io/grpc/rls/LruCache.java:31
↓ 28 callersMethodclose
Closes resources.
alts/src/main/java/io/grpc/alts/internal/TsiHandshaker.java:113
↓ 28 callersMethodcreateSubchannel
(CreateSubchannelArgs args)
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3236
← previousnext →501–600 of 22,628, ranked by callers