MCPcopy Create free account

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

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

↓ 41 callersMethodcreateLoadBalancingPolicyConfig
Directly create a config to pass to GracefulSwitch. The object returned is the same as would be found in {@code ConfigOrError.getConfig()}.
util/src/main/java/io/grpc/util/GracefulSwitchLoadBalancer.java:233
↓ 41 callersMethodequals
{@inheritDoc} <p>Two instances of {@link Uri} are equal if and only if they have the same string representation, which RFC 3986 calls "Simple String
api/src/main/java/io/grpc/Uri.java:651
↓ 41 callersMethodgetAttributes
Gets the attributes associated with the addresses resolved by name resolution. If there are no attributes, {@link Attributes#EMPTY} will be returned.
api/src/main/java/io/grpc/NameResolver.java:831
↓ 41 callersMethodnewBuilder
Creates a builder for changing default configuration. There is no default key manager, so key material must be specified. The default trust manager us
api/src/main/java/io/grpc/TlsServerCredentials.java:236
↓ 41 callersMethodonLoadReport
Invoked when an out-of-band ORCA report is received. <p>Note this callback will be invoked from the {@link SynchronizationContext} of the delegated h
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:175
↓ 41 callersMethodtakeListenerOrFail
(long timeout, TimeUnit unit)
core/src/testFixtures/java/io/grpc/internal/MockServerListener.java:70
↓ 41 callersMethodtakeStreamOrFail
(long timeout, TimeUnit unit)
core/src/testFixtures/java/io/grpc/internal/MockServerTransportListener.java:71
↓ 40 callersMethodcreate
( String name, List<String> domains, List<Route> routes, Map<String, FilterConfig> filterConfigOve
xds/src/main/java/io/grpc/xds/VirtualHost.java:52
↓ 40 callersMethoddiscardAll
Remove all values for the given key without returning them. This is a minor performance optimization if you do not need the previous values.
api/src/main/java/io/grpc/Metadata.java:430
↓ 40 callersMethodgetAddressesOrError
Gets the addresses resolved by name resolution or the error in doing so. @since 1.65.0
api/src/main/java/io/grpc/NameResolver.java:821
↓ 40 callersMethodgetDeadline
A context may have an associated {@link Deadline} at which it will be automatically cancelled. @return A {@link io.grpc.Deadline} or {@code null} if n
api/src/context/java/io/grpc/Context.java:489
↓ 40 callersMethodgetServiceDescriptor
Returns service descriptor to the proto service.
protobuf/src/main/java/io/grpc/protobuf/ProtoServiceDescriptorSupplier.java:30
↓ 40 callersMethodreadInt
Reads a 4-byte signed integer from this buffer using big-endian byte ordering. Increments the read position by 4. @throws IndexOutOfBoundsException i
core/src/main/java/io/grpc/internal/ReadableBuffer.java:53
↓ 40 callersMethodrequestConnectionSafely
(Helper helper, final Subchannel subchannel)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4687
↓ 40 callersMethodsetChildConfig
(Object childConfig)
util/src/main/java/io/grpc/util/RandomSubsettingLoadBalancer.java:148
↓ 40 callersMethodtoString
(InputStream in)
netty/src/test/java/io/grpc/netty/NettyTestUtil.java:35
↓ 40 callersMethodupdateBalancingStateSafely
( final Helper helper, final ConnectivityState state, final SubchannelPicker picker)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4697
↓ 40 callersMethodwithPathExactOnly
(String path)
xds/src/main/java/io/grpc/xds/VirtualHost.java:95
↓ 39 callersMethodbootstrap
Returns system-loaded bootstrap configuration.
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:43
↓ 39 callersMethodbuildResolvedAddress
(OutlierDetectionLoadBalancerConfig config, EquivalentAddressGroup... servers)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1317
↓ 39 callersMethodequals
(Object buffer)
core/src/test/java/io/grpc/internal/MessageFramerTest.java:438
↓ 39 callersMethodfakeClock
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:110
↓ 39 callersMethodfromError
Returns a {@link ConfigOrError} for the failure to convert the data object.
xds/src/main/java/io/grpc/xds/ConfigOrError.java:35
↓ 39 callersMethodgetCurrentAddress
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:836
↓ 39 callersMethodgetLogId
Returns an ID that is primarily used in debug logs. It usually contains the class name and a numeric ID that is unique among the instances. <p>The su
api/src/main/java/io/grpc/InternalWithLogId.java:33
↓ 39 callersMethodgetStreamTracerFactory
The stream tracer factory this result was created with. @since 1.3.0
api/src/main/java/io/grpc/LoadBalancer.java:751
↓ 39 callersMethodisPending
Returns {@code true} if the task will eventually run, meaning that it has neither started running nor been cancelled.
api/src/main/java/io/grpc/SynchronizationContext.java:261
↓ 39 callersMethodloadCert
Saves a file from the classpath resources in src/main/resources/certs as a file on the filesystem. @param name name of a file in src/main/resources/
testing/src/main/java/io/grpc/internal/testing/TestUtils.java:103
↓ 39 callersMethodnewCall
( MethodDescriptor<ReqT, RespT> methodDescriptor, CallOptions callOptions)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2920
↓ 39 callersMethodwithCancellation
Create a new context which is independently cancellable and also cascades cancellation from its parent. Callers <em>must</em> ensure that either {@lin
api/src/context/java/io/grpc/Context.java:239
↓ 39 callersMethodwithDeadlineAfter
Create a new context which will cancel itself after the given {@code duration} from now. The returned context will cascade cancellation of its parent.
api/src/context/java/io/grpc/Context.java:268
↓ 38 callersMethodassertIsOk
(Status status)
util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:717
↓ 38 callersMethodcontains
(T[] array, T value)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/ConnectionSpec.java:229
↓ 38 callersMethoddirectExecutor
()
core/src/test/java/io/grpc/internal/ManagedChannelImplBuilderTest.java:198
↓ 38 callersMethodeventLoop
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:144
↓ 38 callersMethodexecute
(Runnable r)
binder/src/test/java/io/grpc/binder/internal/OneWayBinderProxyTest.java:130
↓ 38 callersMethodgetInSyncContext
( final RlsProtoData.RouteLookupRequestKey routeLookupRequestKey)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:210
↓ 38 callersMethodgetType
A string representation of the parameter type. If not applicable, just returns an empty string.
benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java:83
↓ 38 callersMethodintercept
Create a new {@code ServerServiceDefinition} whose {@link ServerCallHandler}s will call {@code interceptors} before calling the pre-existing {@code Se
api/src/main/java/io/grpc/ServerInterceptors.java:85
↓ 38 callersMethodparse
Parses a URI from its string form. @throws URISyntaxException if 's' is not a valid RFC 3986 URI.
api/src/main/java/io/grpc/Uri.java:199
↓ 38 callersMethodshutdownNow
Initiates a forceful shutdown in which preexisting and new calls are cancelled. Although forceful, the shutdown process is still not instantaneous; {@
api/src/main/java/io/grpc/ManagedChannel.java:63
↓ 38 callersMethodthrowIfNotInThisSynchronizationContext
Throw {@link IllegalStateException} if this method is not called from this synchronization context.
api/src/main/java/io/grpc/SynchronizationContext.java:135
↓ 38 callersMethodupdateCertificate
(PrivateKey key, List<X509Certificate> certChain)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:45
↓ 38 callersMethodwithDeadline
Create a new context which will cancel itself at the given {@link Deadline}. The returned context will cascade cancellation of its parent. Callers may
api/src/context/java/io/grpc/Context.java:298
↓ 37 callersMethodadd
(CharSequence csName, CharSequence csValue)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:354
↓ 37 callersMethodbalanceLoad
<pre> Bidirectional rpc to get a list of servers. </pre>
grpclb/src/generated/main/grpc/io/grpc/lb/v1/LoadBalancerGrpc.java:114
↓ 37 callersMethodcancel
Abnormally terminates the stream. After calling this method, no further messages will be sent or received, however it may still be possible to receive
core/src/main/java/io/grpc/internal/ClientStream.java:41
↓ 37 callersMethodcreate
Matches when any of the matcher matches.
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:427
↓ 37 callersMethodintercept
Create a new {@link Channel} that will call {@code interceptors} before starting a call on the given channel. The last interceptor will have its {@lin
api/src/main/java/io/grpc/ClientInterceptors.java:73
↓ 37 callersMethodparseBoolean
(String value)
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:77
↓ 37 callersMethodresolveAddress
(String host)
core/src/main/java/io/grpc/internal/DnsNameResolver.java:592
↓ 37 callersMethodsetPath
Specifies the new URI's path component as a string of zero or more '/' delimited segments. <p>Path segments can consist of any string of codepoints.
api/src/main/java/io/grpc/Uri.java:752
↓ 36 callersMethodassertBytes
(int... bytes)
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java:1178
↓ 36 callersMethodassertNoCallbackInvoke
()
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:1674
↓ 36 callersMethodcreateSubchannel
(CreateSubchannelArgs args)
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:221
↓ 36 callersMethoddelegate
Returns the delegated {@code ManagedChannelBuilder}.
api/src/main/java/io/grpc/ForwardingChannelBuilder2.java:65
↓ 36 callersMethodforAddress
Creates a new builder with the given server address. This factory method is primarily intended for using Netty Channel types other than SocketChannel.
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:132
↓ 36 callersMethodforCluster
( String cluster, List<HashPolicy> hashPolicies, @Nullable Long timeoutNano, @Nullable Ret
xds/src/main/java/io/grpc/xds/VirtualHost.java:171
↓ 36 callersMethodforResource
(SharedResourceHolder.Resource<T> resource)
core/src/main/java/io/grpc/internal/SharedResourcePool.java:29
↓ 36 callersMethodgetAllInstances
()
xds/src/test/java/io/grpc/xds/StatefulFilter.java:121
↓ 36 callersMethodgetHost
Returns the percent-decoded "host" component of this URI, or null if not present. <p>This method assumes the host was encoded as UTF-8, as mandated b
api/src/main/java/io/grpc/Uri.java:429
↓ 36 callersMethodgoAway
The peer tells us to stop creating streams. It is safe to replay streams with {@code ID > lastGoodStreamId} on a new connection. In- flight streams
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:82
↓ 36 callersMethodnewChildConfig
(LoadBalancerProvider provider, Object config)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1387
↓ 36 callersMethodor
(BitSet... bitsets)
api/src/test/java/io/grpc/UriTest.java:821
↓ 36 callersMethodpickSubchannel
(PickSubchannelArgs args)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:1218
↓ 36 callersMethodrefreshNameResolution
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3223
↓ 36 callersMethodreturnObject
Return the object to the pool. The caller should not use the object beyond this point. @return always {@code null}
core/src/main/java/io/grpc/internal/ObjectPool.java:35
↓ 36 callersMethodreturnSubchannel
Puts a {@link Subchannel} back to the pool. From this point the Subchannel is owned by the pool, and the caller should stop referencing to this Subch
grpclb/src/main/java/io/grpc/grpclb/SubchannelPool.java:49
↓ 36 callersMethodsetCluster
(String cluster)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:158
↓ 36 callersMethodsetScheme
Sets the scheme, e.g. "https", "dns" or "xds". <p>This field is required. @return this, for fluent building @throws IllegalArgumentException if the
api/src/main/java/io/grpc/Uri.java:711
↓ 36 callersMethodsubmit
(Callable<T> task)
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:207
↓ 36 callersMethodverifySubjectAltNameInChain
Verifies SANs in the peer cert chain against verify_subject_alt_name in the certContext. This is called from various check Trusted methods.
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:216
↓ 35 callersMethodaddressesBuilder
()
util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:721
↓ 35 callersMethodcreateWeightedServerAddrs
(long... weights)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:1266
↓ 35 callersMethoddecision
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:94
↓ 35 callersMethodgetTypeUrl
()
xds/src/main/java/io/grpc/xds/MetadataRegistry.java:114
↓ 35 callersMethodsetFileReader
(FileReader reader)
xds/src/main/java/io/grpc/xds/client/BootstrapperImpl.java:295
↓ 35 callersMethodsetLocality
(Locality locality)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:170
↓ 35 callersMethodsetMinimumHosts
The minimum amount of hosts needed for success rate ejection.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:1081
↓ 35 callersMethodsetRequestVolume
The minimum address request volume to be considered for success rate ejection.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:1088
↓ 35 callersMethodsetServiceName
(@Nullable String newServiceName)
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:299
↓ 35 callersMethodtakeOrCreateSubchannel
Takes a {@link Subchannel} from the pool for the given {@code eag} if there is one available. Otherwise, creates and returns a new {@code Subchannel}
grpclb/src/main/java/io/grpc/grpclb/SubchannelPool.java:43
↓ 35 callersMethodwith
Registers a decompressor for both decompression and message encoding negotiation. Returns a new registry. @param d The decompressor to register @par
api/src/main/java/io/grpc/DecompressorRegistry.java:63
↓ 35 callersMethodwrap
(URI uri)
core/src/main/java/io/grpc/internal/UriWrapper.java:29
↓ 34 callersMethodblockingBidiStreamingCall
Initiate a bidirectional-streaming {@link ClientCall} and returning a stream object ({@link BlockingClientCall}) which can be used by the client to se
stub/src/main/java/io/grpc/stub/ClientCalls.java:299
↓ 34 callersMethodcancellationCause
If a context {@link #isCancelled()} then return the cause of the cancellation or {@code null} if context was cancelled without a cause. If the context
api/src/context/java/io/grpc/Context.java:477
↓ 34 callersMethoddestroy
Must be called to release all associated resources (instance cannot be used afterwards).
alts/src/main/java/io/grpc/alts/internal/TsiFrameProtector.java:54
↓ 34 callersMethodequals
(Object object)
examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptor.java:51
↓ 34 callersMethodevaluate
Return the auth decision for the request argument against the policies.
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:66
↓ 34 callersMethodfilter
Filters the given header mutations based on the configured rules and returns the allowed mutations. @param mutations The header mutations to filter @
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationFilter.java:47
↓ 34 callersMethodgetChildLbStates
()
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:236
↓ 34 callersMethodgetSubchannel
(List<EquivalentAddressGroup> servers, int serverIndex)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:778
↓ 34 callersMethodgetSubchannelStateListener
(Subchannel mockSubChannel)
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:433
↓ 34 callersMethodnewPromise
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:331
↓ 34 callersMethodoverrideAuthority
Overrides the authority used with TLS and HTTP virtual hosting. It does not change what host is actually connected to. Is commonly in the form {@code
api/src/main/java/io/grpc/ManagedChannelBuilder.java:213
↓ 34 callersMethodreadHeaders
Read {@code byteCount} bytes of headers from the source stream. This implementation does not propagate the never indexed flag of a header.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:209
↓ 34 callersMethodregister
Register a provider. <p>If the provider's {@link NameResolverProvider#isAvailable isAvailable()} returns {@code false}, this method will throw {@link
api/src/main/java/io/grpc/NameResolverRegistry.java:82
↓ 34 callersMethodsetDecompressorRegistry
Sets the registry to find a decompressor for the framer. May only be called before {@link #start}. If the transport does not support compression, this
core/src/main/java/io/grpc/internal/ClientStream.java:69
↓ 34 callersMethodsetFullStreamDecompression
Enables full-stream decompression, allowing the client stream to use {@link GzipInflatingBuffer} to decode inbound GZIP compressed streams.
core/src/main/java/io/grpc/internal/ClientStream.java:61
↓ 34 callersMethodsetServers
(List<EquivalentAddressGroup> servers)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4620
← previousnext →401–500 of 22,628, ranked by callers