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
↓ 28 callersMethodend
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:186
↓ 28 callersMethodequal
(CallOptions o1, CallOptions o2)
api/src/test/java/io/grpc/CallOptionsTest.java:270
↓ 28 callersMethodequals
(Object o)
grpclb/src/main/java/io/grpc/grpclb/GrpclbConfig.java:67
↓ 28 callersMethodfromError
Returns a {@link ConfigOrError} for the failure to parse the config. @param status a non-OK status
api/src/main/java/io/grpc/NameResolver.java:969
↓ 28 callersMethodgetAddresses
Returns the addresses, which is an unmodifiable list.
api/src/main/java/io/grpc/LoadBalancer.java:835
↓ 28 callersMethodgetProperty
Get peer property.
alts/src/main/java/io/grpc/alts/internal/TsiPeer.java:38
↓ 28 callersMethodgetSpanContext
(Context context)
opentelemetry/src/test/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagatorTest.java:71
↓ 28 callersMethodgetSslContextAndTrustManager
()
xds/src/main/java/io/grpc/xds/internal/security/DynamicSslContextProvider.java:54
↓ 28 callersMethodgetTransportStats
(InternalInstrumented<SocketStats> socket)
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:2230
↓ 28 callersMethodisCancelled
()
core/src/test/java/io/grpc/internal/SharedResourceHolderTest.java:296
↓ 28 callersMethodisCancelled
Is this context cancelled.
api/src/context/java/io/grpc/Context.java:461
↓ 28 callersMethodmerge
Perform a simple merge of two sets of metadata. <p>This is a purely additive operation, because a single key can be associated with multiple values.
api/src/main/java/io/grpc/Metadata.java:507
↓ 28 callersMethodnewBuilder
()
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:777
↓ 28 callersMethodnewBuilder
()
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:213
↓ 28 callersMethodonDataReceived
Transport has received some data so that we can delay sending keepalives.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:160
↓ 28 callersMethodonTransportActive
Transport has active streams. Start sending keepalives if necessary.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:188
↓ 28 callersMethodpingFrame
(boolean ack, long payload)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:291
↓ 28 callersMethodsetListener
Update {@link OrcaOobReportListener} to receive Out-of-Band metrics report for the particular subchannel connection, and set the configuration of rec
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:204
↓ 28 callersMethodsetRoute
(RdsUpdate route)
xds/src/main/java/io/grpc/xds/XdsConfig.java:231
↓ 28 callersMethodsetSuccessRateEjection
Set to enable success rate ejection.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:1012
↓ 28 callersMethodstartServer
()
netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java:1160
↓ 28 callersMethodvalidateCommonTlsContext
( CommonTlsContext commonTlsContext, Set<String> certProviderInstances, boolean server)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:450
↓ 28 callersMethodverifyResourceMetadataDoesNotExist
Verify that the requested resource does not exist.
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:487
↓ 28 callersMethodwriteBytes
Writes up to the number of bytes from the pending queue.
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:287
↓ 27 callersMethodassertRealTimeMetric
( Measure measure, long expectedValue, boolean recordRealTimeMetrics, boolean clientSide)
census/src/test/java/io/grpc/census/CensusModulesTest.java:719
↓ 27 callersMethodcreate
(PathMatcher pathMatcher, List<HeaderMatcher> headerMatchers, @Nullable FractionMatcher fractionMatc
xds/src/main/java/io/grpc/xds/VirtualHost.java:101
↓ 27 callersMethodcreate
(String region, String zone, String subZone)
xds/src/main/java/io/grpc/xds/client/Locality.java:32
↓ 27 callersMethodcreateAndStartServer
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1771
↓ 27 callersMethoddelegate
Returns the delegated {@code ServerBuilder}.
api/src/main/java/io/grpc/ForwardingServerBuilder.java:49
↓ 27 callersMethoddummyBootstrapInfo
()
xds/src/test/java/io/grpc/xds/GrpcServiceConfigParserTest.java:68
↓ 27 callersMethoddummyServerInfo
()
xds/src/test/java/io/grpc/xds/GrpcServiceConfigParserTest.java:79
↓ 27 callersMethodfine
(String str, Object...params)
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:260
↓ 27 callersMethodgetConfig
()
xds/src/test/java/io/grpc/xds/StatefulFilter.java:167
↓ 27 callersMethodgetFlag
(String envVarName, boolean enableByDefault)
core/src/main/java/io/grpc/internal/GrpcUtil.java:966
↓ 27 callersMethodgetHeaders
Headers of the call. {@link SubchannelPicker#pickSubchannel} may mutate it before before returning. @since 1.2.0
api/src/main/java/io/grpc/LoadBalancer.java:485
↓ 27 callersMethodgetPort
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:311
↓ 27 callersMethodinitializeLbSubchannels
(RingHashConfig config, List<EquivalentAddressGroup> servers, InitializationFlags... initFlags)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:1164
↓ 27 callersMethodinstallPackages
(int uid, PackageInfo... packageInfo)
binder/src/test/java/io/grpc/binder/SecurityPoliciesTest.java:77
↓ 27 callersMethodisAboveThreshold
()
core/src/main/java/io/grpc/internal/RetriableStream.java:1500
↓ 27 callersMethodlog
()
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/ConfigFilterHelper.java:95
↓ 27 callersMethodpingAcceptable
Returns {@code false} when client is misbehaving and should be disconnected.
core/src/main/java/io/grpc/internal/KeepAliveEnforcer.java:56
↓ 27 callersMethodpingPong
Send a ping and wait for the ping ack.
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1420
↓ 27 callersMethodsetCompressor
Sets the compressor on the framer. @param compressor the compressor to use
core/src/main/java/io/grpc/internal/Stream.java:82
↓ 27 callersMethodshutdownAndTerminate
(int lastStreamId)
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1409
↓ 27 callersMethodtoBuilder
Creates a new builder that is pre-populated with the content of this container. @return a new builder.
api/src/main/java/io/grpc/Attributes.java:108
↓ 27 callersMethodupdateIdentityCredentials
Updates the current cached private key and cert chains. @param key the private key that is going to be used @param certs the certificate chain that
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:133
↓ 27 callersMethodverifyConnection
(int times)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:261
↓ 27 callersMethodwritePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/Http2ControlFrameLimitEncoder.java:70
↓ 26 callersMethodawaitClose
Returns the stream's status or throws {@link java.util.concurrent.TimeoutException} if it isn't closed before the timeout.
core/src/testFixtures/java/io/grpc/internal/ClientStreamListenerBase.java:42
↓ 26 callersMethodbuilder
()
alts/src/test/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypterTest.java:50
↓ 26 callersMethodcheckAuthorizationForServiceAsync
Shortcut for invoking {@link ServerSecurityPolicy#checkAuthorizationForServiceAsync} without dealing with concurrency details. Returns a {link @Status
binder/src/test/java/io/grpc/binder/ServerSecurityPolicyTest.java:340
↓ 26 callersMethodcreateMessageFrame
(String message)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2277
↓ 26 callersMethodgenerateLoad
(Map<Subchannel, Status> statusMap, int expectedStateChanges)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1333
↓ 26 callersMethodgetAndResetBytesConsumed
Reports bytes consumed by calls to {@link #inflateBytes} since the last invocation of this method, then resets the count to zero.
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:231
↓ 26 callersMethodgetDirectBuffer
(int len, RegisterRef ref)
alts/src/test/java/io/grpc/alts/internal/ByteBufTestUtils.java:36
↓ 26 callersMethodgetMethodConfig
(MethodDescriptor<?, ?> method)
core/src/main/java/io/grpc/internal/ManagedChannelServiceConfig.java:199
↓ 26 callersMethodioException
(String message, Object... args)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:597
↓ 26 callersMethodisTerminated
()
core/src/test/java/io/grpc/internal/ForwardingManagedChannelTest.java:67
↓ 26 callersMethodnewBuilder
Create a new builder.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:138
↓ 26 callersMethodreadUnsignedByte
Reads the next unsigned byte from this buffer and increments the read position by 1. @throws IndexOutOfBoundsException if required bytes are not read
core/src/main/java/io/grpc/internal/ReadableBuffer.java:45
↓ 26 callersMethodrecordLongGauge
Record a long gauge value. @param value The value to record. @param requiredLabelValues A list of required label values for the metric. @param option
api/src/main/java/io/grpc/MetricSink.java:123
↓ 26 callersMethodrequestConnection
()
util/src/testFixtures/java/io/grpc/util/AbstractTestHelper.java:223
↓ 26 callersMethodservicePolicy
Specify a policy specific to a particular gRPC service. @param serviceName The fully qualified name of the gRPC service (from the proto). @param poli
binder/src/main/java/io/grpc/binder/ServerSecurityPolicy.java:105
↓ 26 callersMethodsetAddressesOrError
Sets the addresses resolved by name resolution or the error in doing so. This field is required. @param addresses Resolved addresses or an error in re
api/src/main/java/io/grpc/NameResolver.java:910
↓ 26 callersMethodsetProxyAddress
Sets the address to the proxy, which is already resolved. This is a required field.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:161
↓ 26 callersMethodsetTargetAddress
Sets the address to the target. This is a required field.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:169
↓ 26 callersMethodstreamRequest
Convert a request message to an {@link InputStream}. The returned InputStream should be closed by the caller. @param requestMessage to serialize usin
api/src/main/java/io/grpc/MethodDescriptor.java:295
↓ 26 callersMethodtoBuilder
Converts this back to a builder. @since 1.21.0
api/src/main/java/io/grpc/LoadBalancer.java:246
↓ 26 callersMethodtoString
()
core/src/main/java/io/grpc/internal/GrpcUtil.java:570
↓ 26 callersMethodwithAuthority
Override the HTTP/2 authority the channel claims to be connecting to. <em>This is not generally safe.</em> Overriding allows advanced users to re-use
api/src/main/java/io/grpc/CallOptions.java:129
↓ 25 callersMethodbuildWrrPolicy
(Policy... childPolicy)
xds/src/test/java/io/grpc/xds/LoadBalancerConfigFactoryTest.java:402
↓ 25 callersMethodcalculateBackoffWithRetries
(int retryCount)
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:150
↓ 25 callersMethodcertProviders
Returns the cert-providers config map.
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:152
↓ 25 callersMethodcreate
()
api/src/test/java/io/grpc/InternalChannelzTest.java:304
↓ 25 callersMethodcreateFrameProtector
Creates a frame protector from a completed handshake. No other methods may be called after the frame protector is created. @param maxFrameSize the re
alts/src/main/java/io/grpc/alts/internal/TsiHandshaker.java:99
↓ 25 callersMethodget
Gets the value for the key, or {@code null} if it's not present.
api/src/main/java/io/grpc/Attributes.java:63
↓ 25 callersMethodgetLocality
()
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:244
↓ 25 callersMethodgetNumberAsInteger
Gets a number from an object for the given key, casted to an integer. If the key is not present, this returns null. If the value does not represent
core/src/main/java/io/grpc/internal/JsonUtil.java:155
↓ 25 callersMethodgetRawQuery
Returns the query component of this URI in its originally parsed, possibly percent-encoded form, without any leading '?' character, or null if not pre
api/src/main/java/io/grpc/Uri.java:562
↓ 25 callersMethodgetTlsContext
()
xds/src/main/java/io/grpc/xds/internal/security/SslContextProviderSupplier.java:52
↓ 25 callersMethodgetValueThruCallback
Helper method to get the value thru directExecutor callback. Because of directExecutor this is a synchronous callback - so need to provide a listener.
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:455
↓ 25 callersMethodload
( Class<T> klass, Supplier<Iterable<Class<?>>> hardCoded, ClassLoader cl, PriorityAcce
api/src/test/java/io/grpc/ServiceProvidersTest.java:258
↓ 25 callersMethodnewBidirectionalStreamBuilder
( String url, BidirectionalStream.Callback callback, Executor executor)
cronet/src/main/java/io/grpc/cronet/CronetChannelBuilder.java:58
↓ 25 callersMethodonComplete
Notify that the metadata has been successfully applied, or failed.
core/src/main/java/io/grpc/internal/MetadataApplierImpl.java:135
↓ 25 callersMethodpick
()
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:1668
↓ 25 callersMethodrandomConfig
(String domain)
xds/src/test/java/io/grpc/xds/FilterChainMatchingProtocolNegotiatorsTest.java:1211
↓ 25 callersMethodrun
()
binder/src/test/java/io/grpc/binder/internal/OneWayBinderProxyTest.java:176
↓ 25 callersMethodshouldPropagateNamedMetric
Returns whether the given named metric key should be propagated.
xds/src/main/java/io/grpc/xds/client/BackendMetricPropagation.java:108
↓ 25 callersMethodstatsTraceContext
The context for recording stats and traces for this stream.
core/src/main/java/io/grpc/internal/ServerStream.java:93
↓ 25 callersMethodthisT
Returns the correctly typed version of the builder.
api/src/main/java/io/grpc/ForwardingServerBuilder.java:218
↓ 25 callersMethodtransportState
()
core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java:589
↓ 25 callersMethodtransportState
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java:106
↓ 25 callersMethodupstreamLocalityStatsList
()
xds/src/main/java/io/grpc/xds/client/Stats.java:39
↓ 24 callersMethodaddServer
Adds a server.
api/src/main/java/io/grpc/InternalChannelz.java:79
↓ 24 callersMethodassertEjectedSubchannels
(Collection<Set<SocketAddress>> addresses)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1378
↓ 24 callersMethodawaitReleased
Returns true if the resource is released in time.
testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java:222
↓ 24 callersMethodchannelType
Specifies the channel type to use, by default we use {@code EpollServerSocketChannel} if available, otherwise using {@link NioServerSocketChannel}. <
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:221
↓ 24 callersMethodconvert
(Map<String, ?> keyBuilder)
rls/src/main/java/io/grpc/rls/RlsProtoConverters.java:216
↓ 24 callersMethoddeframe
Adds the given data to this deframer and attempts delivery to the listener. @param data the raw data read from the remote endpoint. Must be non-null.
core/src/main/java/io/grpc/internal/Deframer.java:58
↓ 24 callersMethoddeliverFrame
Delivers a frame via the transport. @param frame a non-empty buffer to deliver or {@code null} if the framer is being closed and there i
core/src/main/java/io/grpc/internal/MessageFramer.java:63
← previousnext →601–700 of 22,628, ranked by callers