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
↓ 5 callersMethodparse
(HeaderMutationRules proto)
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationRulesParser.java:30
↓ 5 callersMethodparseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
core/src/test/java/io/grpc/internal/ServiceConfigErrorHandlingTest.java:141
↓ 5 callersMethodparseStream
Parses a serialized metadata value from an {@link InputStream}. @param stream of metadata to parse @return a parsed instance of type T
api/src/main/java/io/grpc/Metadata.java:636
↓ 5 callersMethodparseTxtResults
Parse TXT service config records as JSON. @throws IOException if one of the txt records contains improperly formatted JSON.
core/src/main/java/io/grpc/internal/DnsNameResolver.java:396
↓ 5 callersMethodparsedMetadata
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:635
↓ 5 callersMethodpercentEncode
(String s, BitSet allowedCodePoints)
api/src/main/java/io/grpc/Uri.java:1113
↓ 5 callersMethodpickSubchannel
(PickSubchannelArgs args)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:552
↓ 5 callersMethodpickerOf
Creates a {@link SubchannelPicker} that returns the given {@link Subchannel} on every pick.
core/src/testFixtures/java/io/grpc/internal/TestUtils.java:75
↓ 5 callersMethodprefix
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:59
↓ 5 callersMethodprovider
Returns the ClassLoader-wide default server. @throws ProviderNotFoundException if no provider is available
api/src/main/java/io/grpc/ServerProvider.java:41
↓ 5 callersMethodreadBytes
Reads bytes from input, parsing them into a frame. Returns false if and only if more data is needed. To obtain a full frame this method must be called
alts/src/main/java/io/grpc/alts/internal/AltsFraming.java:267
↓ 5 callersMethodreadInt
(int firstByte, int prefixMask)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:343
↓ 5 callersMethodreadUnsignedShort
Reads unsigned short in Little-Endian byte order.
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:127
↓ 5 callersMethodreadableBytes
()
core/src/test/java/io/grpc/internal/MessageFramerTest.java:424
↓ 5 callersMethodreadableBytes
Returns the number of bytes one can read from the buffer.
core/src/main/java/io/grpc/internal/WritableBuffer.java:51
↓ 5 callersMethodref
(ByteBuf buf)
alts/src/test/java/io/grpc/alts/internal/AltsTsiFrameProtectorTest.java:485
↓ 5 callersMethodrefreshNameResolution
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1375
↓ 5 callersMethodregEx
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:221
↓ 5 callersMethodregisterBackendResponse
Registers a response received from the backend for a request allowed by shouldThrottle. This should be called for every response received from the bac
rls/src/main/java/io/grpc/rls/Throttler.java:44
↓ 5 callersMethodregisterLongHistogram
Registers a new Long Histogram metric instrument. @param name the name of the metric @param description a description of the metric @param unit the u
api/src/main/java/io/grpc/MetricInstrumentRegistry.java:242
↓ 5 callersMethodrelease
()
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:1142
↓ 5 callersMethodremoteAddress
()
netty/src/test/java/io/grpc/netty/TcpMetricsTest.java:359
↓ 5 callersMethodremove
Removes the first occurrence of {@code value} for {@code key}. @param key key for value @param value value @return {@code true} if {@code value} remo
api/src/main/java/io/grpc/Metadata.java:378
↓ 5 callersMethodremoveAll
Remove all values for the given key. If there were no values, {@code null} is returned.
api/src/main/java/io/grpc/Metadata.java:402
↓ 5 callersMethodreportHeaders
(List<Map.Entry<String, String>> headers, boolean endOfStream)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:552
↓ 5 callersMethodrequestConnection
()
xds/src/main/java/io/grpc/xds/LazyLoadBalancer.java:95
↓ 5 callersMethodrequireFakeFeature
Requires {@link Feature#FAKE} to be understood. For use in testing consumers of this credential.
api/src/main/java/io/grpc/TlsServerCredentials.java:257
↓ 5 callersMethodreturnObject
(Object object)
xds/src/main/java/io/grpc/xds/SharedXdsClientPoolProvider.java:194
↓ 5 callersMethodrouteMatch
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:61
↓ 5 callersMethodrunWhereAppropriate
(Op op)
core/src/main/java/io/grpc/internal/MigratingThreadDeframer.java:90
↓ 5 callersMethodsayHello
(HelloRequest req, StreamObserver<HelloReply> responseObserver)
examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java:50
↓ 5 callersMethodsendError
An error is encountered. Sends the error.
xds/src/main/java/io/grpc/xds/client/XdsTransportFactory.java:62
↓ 5 callersMethodsendErrorResponse
( ServerReflectionRequest request, Status.Code code, String message)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:282
↓ 5 callersMethodsendHeaders
(List<Header> responseHeaders)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java:257
↓ 5 callersMethodsendIoError
()
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:136
↓ 5 callersMethodsendListenerUpdate
( final SocketAddress localAddress, DownstreamTlsContext tlsContext, DownstreamTlsContext
xds/src/test/java/io/grpc/xds/XdsClientWrapperForServerSdsTestMisc.java:311
↓ 5 callersMethodsendMessage
(RespT message)
core/src/main/java/io/grpc/internal/ServerCallImpl.java:148
↓ 5 callersMethodsendPing
(PingCallback callback)
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:1112
↓ 5 callersMethodsendResponse
(List<String> clusters, long loadReportIntervalNano)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5273
↓ 5 callersMethodserverBuilder
(int port, File serverCertChainFile, File serverPrivateKeyFile, X509Certificate[] serverTrustedCaCerts)
netty/src/test/java/io/grpc/netty/TlsTest.java:388
↓ 5 callersMethodserverCallDurationCounter
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsResource.java:60
↓ 5 callersMethodserverInfo
()
xds/src/main/java/io/grpc/xds/Filter.java:139
↓ 5 callersMethodserverSendsOneMessage
Returns {@code true} for {@code UNARY} and {@code CLIENT_STREAMING}, which do not permit the server to stream. @since 1.0.0
api/src/main/java/io/grpc/MethodDescriptor.java:124
↓ 5 callersMethodserverTlsFactory
(SslContext sslContext)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:359
↓ 5 callersMethodsetAllUtilizationMetrics
Replace the whole metrics data using the specified map. No range validation.
services/src/main/java/io/grpc/services/MetricRecorder.java:57
↓ 5 callersMethodsetApplicationUtilizationMetric
Update the application specific utilization metrics data in the range [0, inf). Values outside the valid range are ignored.
services/src/main/java/io/grpc/services/MetricRecorder.java:90
↓ 5 callersMethodsetBindIntentFromComponent
Sets the binding {@link Intent} to one with the specified 'component' and default values for all other fields, for convenience.
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:248
↓ 5 callersMethodsetByte
(CharSequence name, byte value)
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:443
↓ 5 callersMethodsetCdsConfig
(Cluster cluster)
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:220
↓ 5 callersMethodsetCompression
Sets the compression algorithm for this call. This compression is utilized for sending. If the server does not support the compression algorithm, th
api/src/main/java/io/grpc/ServerCall.java:210
↓ 5 callersMethodsetDecompressor
Sets the decompressor available to use. The message encoding for the stream comes later in time, and thus will not be available at the time of constru
core/src/main/java/io/grpc/internal/Deframer.java:33
↓ 5 callersMethodsetEpsMetric
Update the EPS metrics data in the range [0, inf). Values outside the valid range are ignored.
services/src/main/java/io/grpc/services/MetricRecorder.java:142
↓ 5 callersMethodsetFragment
Specifies the fragment component of the new URI (not including the leading '#'). <p>The fragment can contain any string of codepoints. Codepoints tha
api/src/main/java/io/grpc/Uri.java:836
↓ 5 callersMethodsetHostname
(String arg)
okhttp/src/test/java/io/grpc/okhttp/OkHttpProtocolNegotiatorTest.java:208
↓ 5 callersMethodsetLastCallStartedNanos
(long lastCallStartedNanos)
api/src/main/java/io/grpc/InternalChannelz.java:337
↓ 5 callersMethodsetLocalSpiffeId
Sets the local identity of the client in the form of a SPIFFE ID. The client may set at most 1 local identity. If no local identity is specified, then
s2a/src/main/java/io/grpc/s2a/S2AChannelCredentials.java:76
↓ 5 callersMethodsetNameResolverRegistry
See {@link Args#getNameResolverRegistry}. This is an optional field. @since 1.74.0
api/src/main/java/io/grpc/NameResolver.java:692
↓ 5 callersMethodsetNumEventsLogged
(long numEventsLogged)
api/src/main/java/io/grpc/InternalChannelz.java:503
↓ 5 callersMethodsetProjectId
()
gcp-observability/src/test/java/io/grpc/gcp/observability/ObservabilityConfigImplTest.java:251
↓ 5 callersMethodsetQpsMetric
Update the QPS metrics data in the range [0, inf). Values outside the valid range are ignored.
services/src/main/java/io/grpc/services/MetricRecorder.java:125
↓ 5 callersMethodsetResult
(boolean result)
alts/src/main/java/io/grpc/alts/internal/RpcProtocolVersionsUtil.java:114
↓ 5 callersMethodsetResultText
(String text)
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:121
↓ 5 callersMethodsetSecurityPolicy
(SecurityPolicy securityPolicy)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransportFactory.java:168
↓ 5 callersMethodsetSocketOptionLingerSeconds
The value of {@link java.net.Socket#getSoLinger()}. Note: SO_LINGER is typically expressed in seconds.
api/src/main/java/io/grpc/InternalChannelz.java:1020
↓ 5 callersMethodsetSockets
Sets the sockets.
api/src/main/java/io/grpc/InternalChannelz.java:462
↓ 5 callersMethodsetSslSocketAndEnginePeerVerifier
Sets {@link SslSocketAndEnginePeerVerifier}, which methods will be called in addition to verifying certificates. @param verifier SslSocketAndEngineP
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:462
↓ 5 callersMethodsetState
(TransportState newState)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:275
↓ 5 callersMethodsetStatsEnabled
(NettyServerBuilder builder, boolean value)
netty/src/main/java/io/grpc/netty/InternalNettyServerBuilder.java:30
↓ 5 callersMethodsetStdevFactor
The product of this and the standard deviation of success rates determine the ejection threshold.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:1068
↓ 5 callersMethodsetSubchannelRef
(InternalWithLogId subchannelRef)
api/src/main/java/io/grpc/InternalChannelz.java:606
↓ 5 callersMethodsetThrottler
(Throttler throttler)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:876
↓ 5 callersMethodsetUp
Set up for test.
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:179
↓ 5 callersMethodsetWeightUpdatePeriodNanos
(long weightUpdatePeriodNanos)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:866
↓ 5 callersMethodsetXdsClient
(XdsClient xdsClient)
xds/src/main/java/io/grpc/xds/XdsClientMetricReporterImpl.java:117
↓ 5 callersMethodshouldThrottle
Checks if a given request should be throttled by the client. This should be called for every request before allowing it to hit the network. If the ret
rls/src/main/java/io/grpc/rls/Throttler.java:34
↓ 5 callersMethodshutdown
()
netty/src/main/java/io/grpc/netty/NettyServer.java:363
↓ 5 callersMethodstartAndAwaitReady
( BinderClientTransport transport, TestTransportListener transportListener)
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:520
↓ 5 callersMethodstartAndGetUniqueResolvedAddress
(UdsNameResolver udsNameResolver)
netty/src/test/java/io/grpc/netty/UdsNameResolverProviderTest.java:142
↓ 5 callersMethodstartNewTransport
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:247
↓ 5 callersMethodstartPing
Start a ping. <p>See also {@link ClientTransport#ping}. @param callback The callback to report the ping result on. @param executor An executor to ca
binder/src/main/java/io/grpc/binder/internal/PingTracker.java:65
↓ 5 callersMethodstartTest
(String testCase)
android-interop-testing/src/main/java/io/grpc/android/integrationtest/TesterActivity.java:120
↓ 5 callersMethodstatus
Gets the {@link Status} associated with this HTTP/2 code.
core/src/main/java/io/grpc/internal/GrpcUtil.java:395
↓ 5 callersMethodstatusOnError
The gRPC status returned to the client when the authorization server returns an error or is unreachable. Defaults to {@code PERMISSION_DENIED}. @see
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:81
↓ 5 callersMethodstatusWithDetails
Create a status with contextual information, propagating details from a non-null status that contributed to the failure. For example, if UNAVAILABLE,
core/src/main/java/io/grpc/internal/GrpcUtil.java:849
↓ 5 callersMethodstreamClientStatus
( io.grpc.stub.StreamObserver<io.envoyproxy.envoy.service.status.v3.ClientStatusResponse> responseObse
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/status/v3/ClientStatusDiscoveryServiceGrpc.java:152
↓ 5 callersMethodstreamClosed
Notify the transport that the stream was closed. Any frames for the stream must be enqueued before calling.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:460
↓ 5 callersMethodsubtestClientBasicStatsDefaultContext
( boolean recordStarts, boolean recordFinishes, boolean recordRealTime)
census/src/test/java/io/grpc/census/CensusModulesTest.java:420
↓ 5 callersMethodsubtestServerBasicStatsNoHeaders
( boolean recordStarts, boolean recordFinishes, boolean recordRealTime)
census/src/test/java/io/grpc/census/CensusModulesTest.java:1183
↓ 5 callersMethodsubtest_altsHandler
(Attributes eagAttributes)
alts/src/test/java/io/grpc/alts/internal/GoogleDefaultProtocolNegotiatorTest.java:102
↓ 5 callersMethodtargets
Returns list of targets. Prioritized list (best one first) of addressable entities to use for routing, using syntax requested by the request target_ty
rls/src/main/java/io/grpc/rls/RlsProtoData.java:79
↓ 5 callersMethodtestInvalidTarget
(String target)
core/src/test/java/io/grpc/internal/ManagedChannelImplGetNameResolverRfc3986Test.java:172
↓ 5 callersMethodtestServerAddress
Creates a new {@link InetSocketAddress} that overrides the host with {@link #TEST_SERVER_HOST}.
testing/src/main/java/io/grpc/internal/testing/TestUtils.java:55
↓ 5 callersMethodthisT
Returns the correctly typed version of the builder.
api/src/main/java/io/grpc/ServerBuilder.java:452
↓ 5 callersMethodtoAddress
(SocketAddress address)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:193
↓ 5 callersMethodtoBuilder
Returns a builder with the same initial values as this object.
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:596
↓ 5 callersMethodtoGetServerSocketsResponse
(ServerSocketsList serverSockets)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:471
↓ 5 callersMethodtoGetServersResponse
(ServerList servers)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:461
↓ 5 callersMethodtoGetTopChannelResponse
(RootChannelList rootChannels)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:451
↓ 5 callersMethodtoInteger
Returns the sum of all set flags as an int suitable for passing to ({@link android.content.Context#bindService}.
binder/src/main/java/io/grpc/binder/BindServiceFlags.java:58
↓ 5 callersMethodtoMetadata
(com.google.rpc.Status statusProto)
protobuf/src/main/java/io/grpc/protobuf/StatusProto.java:131
← previousnext →2,801–2,900 of 22,628, ranked by callers