MCPcopy Create free account

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

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

↓ 8 callersMethodmaybeUpdatePicker
Make and use a picker out of the current lists and the states of subchannels if they have changed since the last picker created.
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:862
↓ 8 callersMethodmessageFrame
(String message)
netty/src/test/java/io/grpc/netty/NettyTestUtil.java:41
↓ 8 callersMethodminimum
Return the minimum deadline of {@code this} or an other deadline. They must be created using the same {@link Ticker}. @param other deadline to compa
api/src/context/java/io/grpc/Deadline.java:148
↓ 8 callersMethodnewBuilder
Creates an empty Builder. @since 1.21.0
api/src/main/java/io/grpc/ClientStreamTracer.java:199
↓ 8 callersMethodnewChannelBuilder
(String target, ChannelCredentials creds)
api/src/main/java/io/grpc/ManagedChannelRegistry.java:157
↓ 8 callersMethodnewChildConfig
(LoadBalancerProvider provider, Object config)
xds/src/test/java/io/grpc/xds/WrrLocalityLoadBalancerTest.java:211
↓ 8 callersMethodnewInstance
Creates a instance of {@link ProtoReflectionServiceV1}.
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:77
↓ 8 callersMethodnewMeasureMap
()
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:137
↓ 8 callersMethodnewNameResolver
(String uriString, NameResolver.Args args)
core/src/test/java/io/grpc/internal/DnsNameResolverProviderTest.java:140
↓ 8 callersMethodnewPickSubchannelArgs
(MethodDescriptor<?, ?> method)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:713
↓ 8 callersMethodnewServerStreamTracer
(String fullMethodName, Metadata headers)
census/src/main/java/io/grpc/census/CensusStatsModule.java:779
↓ 8 callersMethodnotify
Indicates that the associated SimplePromise has been fulfilled with the given `value`.
binder/src/main/java/io/grpc/binder/internal/SimplePromise.java:95
↓ 8 callersMethodonClose
(Status status, Metadata trailers)
core/src/test/java/io/grpc/internal/DelayedClientCallTest.java:318
↓ 8 callersMethodonClose
(Status status, Metadata trailers)
stub/src/test/java/io/grpc/stub/ClientCallsTest.java:965
↓ 8 callersMethodonClose
(Status status, Metadata trailers)
xds/src/test/java/io/grpc/xds/orca/OrcaMetricReportingServerInterceptorTest.java:322
↓ 8 callersMethodonDeliveryState
(State deliveryState)
binder/src/main/java/io/grpc/binder/internal/Inbound.java:176
↓ 8 callersMethodonFailure
Invoked when a ping fails. The given argument is the cause of the failure. @param cause the cause of the ping failure
core/src/main/java/io/grpc/internal/ClientTransport.java:94
↓ 8 callersMethodonHalfClose
()
stub/src/main/java/io/grpc/stub/ServerCalls.java:169
↓ 8 callersMethodonResponseHeadersReceived
(BidirectionalStream stream, UrlResponseInfo info)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:433
↓ 8 callersMethodonSendingBytes
Event handler to be called by the subclass when a number of bytes are being queued for sending to the remote endpoint. @param numBytes the number of
core/src/main/java/io/grpc/internal/AbstractStream.java:121
↓ 8 callersMethodonSuccess
Invoked when a ping is acknowledged. The given argument is the round-trip time of the ping, in nanoseconds. @param roundTripTimeNanos the round-trip
core/src/main/java/io/grpc/internal/ClientTransport.java:87
↓ 8 callersMethodoutboundMessageSent
( int seqNo, long optionalWireSize, long optionalUncompressedSize)
census/src/main/java/io/grpc/census/CensusTracingModule.java:333
↓ 8 callersMethodparseLocalityLbEndpoints
( io.envoyproxy.envoy.config.endpoint.v3.LocalityLbEndpoints proto)
xds/src/main/java/io/grpc/xds/XdsEndpointResource.java:192
↓ 8 callersMethodparseOverrideFilterConfigs
( Map<String, Any> rawFilterConfigMap, FilterRegistry filterRegistry, XdsResourceType.Args args)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:210
↓ 8 callersMethodparseRoute
( io.envoyproxy.envoy.config.route.v3.Route proto, FilterRegistry filterRegistry, Map<String, Plug
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:271
↓ 8 callersMethodpercentEncodePath
(String input)
xds/src/main/java/io/grpc/xds/client/XdsClient.java:112
↓ 8 callersMethodpickByWeight
(MetricReport r1, MetricReport r2, MetricReport r3, double subchannel1PickRatio, d
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:384
↓ 8 callersMethodpickUnusedPort
Picks a port that is not used right at this moment. Warning: Not thread safe. May see "BindException: Address already in use: bind" if using the retur
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:292
↓ 8 callersMethodprepareHeaders
( Metadata headers, DecompressorRegistry decompressorRegistry, Compressor compressor,
core/src/main/java/io/grpc/internal/ClientCallImpl.java:154
↓ 8 callersMethodproviders
Returns effective providers, in priority order.
api/src/main/java/io/grpc/ServerRegistry.java:114
↓ 8 callersMethodrawValue
()
xds/src/main/java/io/grpc/xds/internal/grpcservice/HeaderValue.java:43
↓ 8 callersMethodreadPingAck
(long pingData)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:614
↓ 8 callersMethodreceiveMaxConcurrentStreams
(int max)
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:1117
↓ 8 callersMethodrecordNamedMetric
Records an application-specific opaque custom metric measurement. If RPC has already finished, this method is no-op. <p>A latter record will overwrit
services/src/main/java/io/grpc/services/CallMetricRecorder.java:140
↓ 8 callersMethodrecordRealTimeMetric
(TagContext ctx, MeasureDouble measure, double value)
census/src/main/java/io/grpc/census/CensusStatsModule.java:166
↓ 8 callersMethodrefreshNameResolution
()
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:671
↓ 8 callersMethodreleaseServerSslContextProvider
Releases an instance of the given server-side {@link SslContextProvider}. <p>The instance must have been obtained from {@link #findOrCreateServerSslC
xds/src/main/java/io/grpc/xds/TlsContextManager.java:55
↓ 8 callersMethodreschedule
(long delay, TimeUnit timeUnit)
core/src/main/java/io/grpc/internal/Rescheduler.java:55
↓ 8 callersMethodresponseHeader
(String status)
cronet/src/test/java/io/grpc/cronet/CronetClientStreamTest.java:204
↓ 8 callersMethodroutes
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:48
↓ 8 callersMethodrstStreamFrame
(int streamId, int errorCode)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:313
↓ 8 callersMethodsetArg
See {@link Args#getArg(Key)}.
api/src/main/java/io/grpc/NameResolver.java:669
↓ 8 callersMethodsetBootstrapInfoAndBuildUpstreamTlsContextForUsingSystemRootCerts
( String clientKeyFile, String clientPemFile, boolean useCombinedValidationContext, St
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:705
↓ 8 callersMethodsetEnableOobLoadReport
(boolean enableOobLoadReport)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:856
↓ 8 callersMethodsetErrorUtilizationPenalty
(float errorUtilizationPenalty)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:871
↓ 8 callersMethodsetInitialWindowSize
(int size)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2271
↓ 8 callersMethodsetMetricNamesForComputingUtilization
( List<String> metricNamesForComputingUtilization)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:876
↓ 8 callersMethodsetOnCancelHandler
Sets a {@link Runnable} to be called if the call is cancelled and the server is encouraged to abort processing to save resources, since the client wil
stub/src/main/java/io/grpc/stub/ServerCallStreamObserver.java:67
↓ 8 callersMethodsetPassword
Sets the password used to connect to the proxy. This is an optional field and can be {@code null}.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:199
↓ 8 callersMethodsetRawAuthority
Specifies the userinfo, host and port URI components all at once using a single string. <p>This setter is "raw" in the sense that special characters
api/src/main/java/io/grpc/Uri.java:1007
↓ 8 callersMethodsetRecordEvents
(boolean recordEvents)
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:388
↓ 8 callersMethodsetResult
Provides this SecurityPolicy's response to this authorization request.
binder/src/testFixtures/java/io/grpc/binder/internal/SettableAsyncSecurityPolicy.java:69
↓ 8 callersMethodsetRingSizeCap
Set the global limit for the min and max number of ring hash entries per ring. Note that this limit is clamped between 1 entry and 8,388,608 entries,
xds/src/main/java/io/grpc/xds/RingHashOptions.java:48
↓ 8 callersMethodsetSSLParameters
(SSLParameters sslParameters)
xds/src/test/java/io/grpc/xds/internal/security/trust/XdsX509TrustManagerTest.java:798
↓ 8 callersMethodsetSecurityPolicy
(SecurityPolicy securityPolicy)
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:158
↓ 8 callersMethodsetServer
(InProcessServer server)
inprocess/src/main/java/io/grpc/inprocess/AnonymousInProcessSocketAddress.java:54
↓ 8 callersMethodsetState
(ChildPolicyWrapper policyWrapper, ConnectivityState newState)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:859
↓ 8 callersMethodsetTargetUserHandle
(UserHandle targetUserHandle)
binder/src/test/java/io/grpc/binder/internal/ServiceBindingTest.java:524
↓ 8 callersMethodsetTrustStoreSystemProperties
(String trustStoreFilePath)
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:891
↓ 8 callersMethodsmallMessage
()
netty/src/test/java/io/grpc/netty/NettyStreamTestBase.java:187
↓ 8 callersMethodstartGoAway
(int lastKnownStreamId, ErrorCode errorCode, Status status)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:1095
↓ 8 callersMethodstatusHasCode
(ArgumentMatcher<Status.Code> codeMatcher)
api/src/testFixtures/java/io/grpc/StatusMatcher.java:28
↓ 8 callersMethodstreamClosed
See {@link StreamTracer#streamClosed}. This may be called multiple times, and only the first value will be taken. <p>Called from abstract stream impl
core/src/main/java/io/grpc/internal/StatsTraceContext.java:176
↓ 8 callersMethodstreamClosed
()
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:383
↓ 8 callersMethodstreamClosed
(Status status)
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:498
↓ 8 callersMethodsubchannelsEjected
()
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:632
↓ 8 callersMethodtest
(String target)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:367
↓ 8 callersMethodtestValidTarget
(String target, String expectedUriString, Uri expectedUri)
core/src/test/java/io/grpc/internal/ManagedChannelImplGetNameResolverRfc3986Test.java:163
↓ 8 callersMethodtoBuilder
Returns a new instance of {@link Builder} with the same set of flags as {@code this}.
binder/src/main/java/io/grpc/binder/BindServiceFlags.java:72
↓ 8 callersMethodtoChannel
(InternalInstrumented<ChannelStats> channel)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:341
↓ 8 callersMethodtoServer
(InternalInstrumented<ServerStats> obj)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:125
↓ 8 callersMethodtoSocketRef
(InternalWithLogId obj)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:117
↓ 8 callersMethodtoString
()
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:999
↓ 8 callersMethodtransportDataReceived
(ByteBuf frame, boolean endOfStream)
netty/src/main/java/io/grpc/netty/NettyClientStream.java:354
↓ 8 callersMethodtransportLogger
()
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:144
↓ 8 callersMethodtransportReportStatus
Notifies failure to the listener of the stream. The transport is responsible for notifying the client of the failure independent of this method. <p>U
core/src/main/java/io/grpc/internal/AbstractServerStream.java:295
↓ 8 callersMethodtransportState
()
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:137
↓ 8 callersMethodunimplementedCall
<pre> A call that no server should implement </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/UnimplementedServiceGrpc.java:122
↓ 8 callersMethodunquote
Undo the quoting done in {@link com.sun.jndi.dns.ResourceRecord#decodeTxt}.
core/src/main/java/io/grpc/internal/JndiResourceResolverFactory.java:168
↓ 8 callersMethodupdateConfigSelector
(@Nullable InternalConfigSelector config)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:918
↓ 8 callersMethoduserAgent
(@Nullable String userAgent)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:474
↓ 8 callersMethodverifyGoldenClusterRoundRobin
Verifies the CDS update against the golden Round Robin Cluster {@link #testClusterRoundRobin}.
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:600
↓ 8 callersMethodverifyResourceMetadataNacked
Verify the resource to be nacked, and every i-th line of error details to begin with corresponding i-th element of {@code List<String> failedDetails}.
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:504
↓ 8 callersMethodverifyRpcSucceeded
(ClientCall.Listener<Void> observer)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2459
↓ 8 callersMethodverifyServerStarted
(SettableFuture<Server> serverStart)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1902
↓ 8 callersMethodverifyTimeServiceAndScheduledFuture
()
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:483
↓ 8 callersMethodwaitForStreamPending
(int expected)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2245
↓ 8 callersMethodwithoutWaitForReady
Disables 'wait for ready' feature for the call. This method should be rarely used because the default is without 'wait for ready'.
api/src/main/java/io/grpc/CallOptions.java:211
↓ 8 callersMethodwriteHeaders
Writes custom metadata as headers on the response stream sent to the client. This method may only be called once and cannot be called after calls to {
core/src/main/java/io/grpc/internal/ServerStream.java:39
↓ 8 callersMethodwriteRstStream
( ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/Http2ControlFrameLimitEncoder.java:83
↓ 7 callersMethodacceptResolvedAddresses
Accepts newly resolved addresses from the name resolution system. The {@link EquivalentAddressGroup} addresses should be considered equivalent but may
api/src/main/java/io/grpc/LoadBalancer.java:188
↓ 7 callersMethodaddInTwoChunksAndVerifyIsStalled
(byte[] input)
core/src/test/java/io/grpc/internal/GzipInflatingBufferTest.java:740
↓ 7 callersMethodaddListeningAddresses
(Address address)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:176
↓ 7 callersMethodaddStreamTracerFactory
(ServerStreamTracer.Factory factory)
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:174
↓ 7 callersMethodandDescriptionContains
(String substring)
api/src/testFixtures/java/io/grpc/StatusMatcher.java:58
↓ 7 callersMethodasRuntimeExceptionWithoutStacktrace
Create a new {@link StatusRuntimeException} skipping the filling of the stack trace.
api/src/main/java/io/grpc/InternalStatus.java:43
↓ 7 callersMethodasciiString
(ByteString value)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:479
↓ 7 callersMethodassertCallFailure
( MethodDescriptor<Empty, Empty> method, Status status)
binder/src/androidTest/java/io/grpc/binder/BinderSecurityTest.java:144
↓ 7 callersMethodassertContainsKeyAndValue
(String str, CharSequence key, CharSequence value)
netty/src/test/java/io/grpc/netty/GrpcHttp2HeadersUtilsTest.java:378
↓ 7 callersMethodassertNoServerContent
(StatsTestUtils.MetricsRecord record)
census/src/test/java/io/grpc/census/CensusModulesTest.java:1418
← previousnext →1,901–2,000 of 22,628, ranked by callers