MCPcopy Create free account

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

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

↓ 2 callersMethodonAbsent
(@Nullable ProcessingTracker processingTracker, ServerInfo serverInfo)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:868
↓ 2 callersMethodonAddresses
Handles updates on resolved addresses and attributes. <p>Implementations will not modify the given {@code servers}. @param servers the resolved serv
api/src/main/java/io/grpc/NameResolver.java:232
↓ 2 callersMethodonCancel
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1268
↓ 2 callersMethodonCancel
()
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:582
↓ 2 callersMethodonCancel
()
api/src/test/java/io/grpc/ContextsTest.java:71
↓ 2 callersMethodonCancel
()
binder/src/main/java/io/grpc/binder/internal/PendingAuthListener.java:61
↓ 2 callersMethodonCancel
()
opentelemetry/src/test/java/io/grpc/opentelemetry/OpenTelemetryTracingModuleTest.java:704
↓ 2 callersMethodonClose
(Status status, Metadata trailers)
interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:557
↓ 2 callersMethodonCloseSent
(Status status)
binder/src/main/java/io/grpc/binder/internal/Inbound.java:671
↓ 2 callersMethodonDataRead
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:952
↓ 2 callersMethodonHalfClose
()
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:573
↓ 2 callersMethodonHalfClose
()
api/src/test/java/io/grpc/ContextsTest.java:66
↓ 2 callersMethodonHalfClose
()
opentelemetry/src/test/java/io/grpc/opentelemetry/OpenTelemetryTracingModuleTest.java:699
↓ 2 callersMethodonHandshakeComplete
()
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:440
↓ 2 callersMethodonHeaders
(final Metadata headers)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:485
↓ 2 callersMethodonHeaders
(Metadata headers)
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:436
↓ 2 callersMethodonNullBinding
(ComponentName name)
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:357
↓ 2 callersMethodonReady
()
core/src/main/java/io/grpc/internal/ServerImpl.java:936
↓ 2 callersMethodonResult
(ResolutionResult resolutionResultArg)
api/src/test/java/io/grpc/NameResolverTest.java:154
↓ 2 callersMethodonResult
Handles updates on resolved addresses and attributes. If {@link ResolutionResult#getAddressesOrError()} is empty, {@link #onError(Status)} will be ca
api/src/main/java/io/grpc/NameResolver.java:289
↓ 2 callersMethodonSentBytes
Event handler to be called by the subclass when a number of bytes has been sent to the remote endpoint. May call back the listener's {@link StreamList
core/src/main/java/io/grpc/internal/AbstractStream.java:356
↓ 2 callersMethodonServiceDisconnected
(ComponentName name)
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:349
↓ 2 callersMethodonStatusReceived
Called when status is received on the stream.
xds/src/main/java/io/grpc/xds/client/XdsTransportFactory.java:91
↓ 2 callersMethodonStreamAllocated
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java:264
↓ 2 callersMethodonSucceeded
(BidirectionalStream stream, UrlResponseInfo info)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:507
↓ 2 callersMethodonTransportActive
There are outstanding RPCs on the transport.
core/src/main/java/io/grpc/internal/MaxConnectionIdleManager.java:91
↓ 2 callersMethodonWritePossible
()
servlet/src/main/java/io/grpc/servlet/ServletServerStream.java:222
↓ 2 callersMethodorDefault
(@Nullable T value, T defaultValue)
rls/src/main/java/io/grpc/rls/RlsProtoConverters.java:188
↓ 2 callersMethodoutboundMessage
See {@link StreamTracer#outboundMessage(int)}. <p>Called from {@link io.grpc.internal.Framer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:189
↓ 2 callersMethodoutboundMessageSent
See {@link StreamTracer#outboundMessageSent}. <p>Called from {@link io.grpc.internal.Framer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:211
↓ 2 callersMethodoutboundUncompressedSize
See {@link StreamTracer#outboundUncompressedSize}. <p>Called from {@link io.grpc.internal.Framer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:233
↓ 2 callersMethodoverrideAuthorityIsReadableHelper
(OkHttpChannelBuilder builder, String overrideAuthority)
okhttp/src/test/java/io/grpc/okhttp/OkHttpChannelBuilderTest.java:91
↓ 2 callersMethodparse
(String config)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:83
↓ 2 callersMethodparse
Pre-parses a custom metric name into a {@link ParsedMetricName}. @param name The custom metric name to parse. @return The parsed metric name.
xds/src/main/java/io/grpc/xds/internal/MetricReportUtils.java:57
↓ 2 callersMethodparseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestServer.java:121
↓ 2 callersMethodparseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceServer.java:84
↓ 2 callersMethodparseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:143
↓ 2 callersMethodparseAsciiString
Parse a serialized metadata value from an ASCII string. @param serialized value of metadata to parse @return a parsed instance of type T
api/src/main/java/io/grpc/Metadata.java:616
↓ 2 callersMethodparseAssumedUtf8PathIntoSegments
( String path, ImmutableList.Builder<String> out)
api/src/main/java/io/grpc/Uri.java:303
↓ 2 callersMethodparseBootstrap
(Map<String, ?> bootstrap)
xds/src/main/java/io/grpc/xds/InternalGrpcBootstrapperImpl.java:31
↓ 2 callersMethodparseClusterWeight
( io.envoyproxy.envoy.config.route.v3.WeightedCluster.ClusterWeight proto, FilterRegistry filterRe
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:584
↓ 2 callersMethodparseCommaSeparatedTuples
(String str)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:364
↓ 2 callersMethodparseCustomConfigJson
Print the config Struct into JSON and then parse that into our internal representation.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:365
↓ 2 callersMethodparseCustomConfigTypeName
(String customConfigTypeName)
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:381
↓ 2 callersMethodparseFeatures
Parses the JSON input file containing the list of features.
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideUtil.java:58
↓ 2 callersMethodparseGoogleGrpcConfig
Parses the {@link io.envoyproxy.envoy.config.core.v3.GrpcService.GoogleGrpc} proto to create a {@link GrpcServiceConfig.GoogleGrpcConfig} instance. @
xds/src/main/java/io/grpc/xds/GrpcServiceConfigParser.java:131
↓ 2 callersMethodparseHeaderMatcher
( io.envoyproxy.envoy.config.route.v3.HeaderMatcher proto)
xds/src/main/java/io/grpc/xds/RbacFilter.java:320
↓ 2 callersMethodparseHeaderMatcher
Translates envoy proto HeaderMatcher to internal HeaderMatcher.
xds/src/main/java/io/grpc/xds/internal/MatcherParser.java:25
↓ 2 callersMethodparseJsonObject
(String json)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerProviderTest.java:145
↓ 2 callersMethodparseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:988
↓ 2 callersMethodparseLoadBalancingPolicyConfig
(Map<String, ?> rawLoadBalancingPolicyConfig)
interop-testing/src/main/java/io/grpc/testing/integration/RpcBehaviorLoadBalancerProvider.java:52
↓ 2 callersMethodparseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
xds/src/test/java/io/grpc/xds/ClusterManagerLoadBalancerProviderTest.java:69
↓ 2 callersMethodparseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
xds/src/main/java/io/grpc/xds/CdsLoadBalancerProvider.java:75
↓ 2 callersMethodparseOverride
(List<Permission> permissionList, List<Principal> principalList)
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:464
↓ 2 callersMethodparsePathMatcher
( io.envoyproxy.envoy.type.matcher.v3.PathMatcher proto)
xds/src/main/java/io/grpc/xds/RbacFilter.java:303
↓ 2 callersMethodparsePercent
(FractionalPercent proto)
xds/src/main/java/io/grpc/xds/FaultFilter.java:181
↓ 2 callersMethodparsePermissionList
(List<Permission> permissions)
xds/src/main/java/io/grpc/xds/RbacFilter.java:212
↓ 2 callersMethodparsePrincipalList
(List<Principal> principals)
xds/src/main/java/io/grpc/xds/RbacFilter.java:255
↓ 2 callersMethodparseRegex
(String regex, String fieldName)
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationRulesParser.java:46
↓ 2 callersMethodparseRpc
(String rpc)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:255
↓ 2 callersMethodparseRpcEvents
(List<?> rpcEvents, ImmutableList.Builder<LogFilter> filters)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:182
↓ 2 callersMethodparseRules
( List<Map<String, ?>> objects, String name)
authz/src/main/java/io/grpc/authz/AuthorizationPolicyTranslator.java:126
↓ 2 callersMethodparseServerInfos
(List<?> rawServerConfigs, XdsLogger logger)
xds/src/main/java/io/grpc/xds/client/BootstrapperImpl.java:256
↓ 2 callersMethodparseUnixSocketAddress
(String value)
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:110
↓ 2 callersMethodparseUriArg
(String targetUri)
binder/src/main/java/io/grpc/binder/internal/IntentNameResolverProvider.java:81
↓ 2 callersMethodpendingResponse
(PendingCacheEntry pendingEntry)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:557
↓ 2 callersMethodpercentDecode
Decodes a string of characters in the range [U+0000, U+007F] to bytes. <p>Each percent-encoded sequence (e.g. "%F0" or "%2a", as defined by RFC 3986
api/src/main/java/io/grpc/Uri.java:1057
↓ 2 callersMethodpickFirstModeFallback
(long timeout)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2162
↓ 2 callersMethodpickSubchannel
(PickSubchannelArgs args)
core/src/main/java/io/grpc/internal/PickFirstLoadBalancer.java:176
↓ 2 callersMethodpickSubchannel
(PickSubchannelArgs args)
xds/src/test/java/io/grpc/xds/ClusterManagerLoadBalancerTest.java:401
↓ 2 callersMethodpickSubchannel
(PickSubchannelArgs args)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:470
↓ 2 callersMethodpicked
(PickSubchannelArgs args)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:998
↓ 2 callersMethodping
Sends out a keep-alive ping.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:253
↓ 2 callersMethodpingBinder
()
binder/src/testFixtures/java/io/grpc/binder/internal/FakeDeadBinder.java:43
↓ 2 callersMethodpingPong
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:708
↓ 2 callersMethodpingPongExactFrameSizeTest
Ping pong test with exact frame size.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:175
↓ 2 callersMethodpingPongSmallBufferTest
Ping pong test with small buffer size.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:197
↓ 2 callersMethodpingPongSmallFrameSmallBufferTest
Ping pong test with small frame and small buffer.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:231
↓ 2 callersMethodpingPongSmallFrameTest
Ping pong test with small frame size.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:212
↓ 2 callersMethodpingPongTest
Ping pong test.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:160
↓ 2 callersMethodprefixLen
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:303
↓ 2 callersMethodprefixedClusterSpecifierPluginName
(String pluginName)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:661
↓ 2 callersMethodprintResultMessage
(String type, List<String> result, long millis)
examples/src/main/java/io/grpc/examples/manualflowcontrol/BidiBlockingClient.java:89
↓ 2 callersMethodprintShortStatus
(Status status)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:870
↓ 2 callersMethodprioritizedClusterNames
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:626
↓ 2 callersMethodprocessExtension
(FieldDescriptor extension, FileDescriptor fd)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:524
↓ 2 callersMethodprocessTrailer
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:456
↓ 2 callersMethodpromise
Returns the promise beeing notified of the success/failure of the write.
netty/src/main/java/io/grpc/netty/WriteQueue.java:222
↓ 2 callersMethodpropagateCauseWithStatus
Sets whether to include the cause with the status that is propagated forward from the InProcessTransport. This was added to make debugging failing tes
inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:224
↓ 2 callersMethodprotocolNegotiatorFactory
(ProtocolNegotiator.ClientFactory protocolNegotiatorFactory)
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:673
↓ 2 callersMethodprovideNextCheckAuthorizationResult
(Status status)
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:665
↓ 2 callersMethodprovider
Returns the ClassLoader-wide default channel. @throws ProviderNotFoundException if no provider is available
api/src/main/java/io/grpc/ManagedChannelProvider.java:42
↓ 2 callersMethodproviders
Returns effective providers in a new map.
api/src/main/java/io/grpc/LoadBalancerRegistry.java:132
↓ 2 callersMethodproxyDetector
(@Nullable ProxyDetector proxyDetector)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:550
↓ 2 callersMethodquitWorker
<pre> Quit this worker </pre>
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java:247
↓ 2 callersMethodrandomString
()
util/src/jmh/java/io/grpc/util/HandlerRegistryBenchmark.java:103
↓ 2 callersMethodrapidReset
(int burstSize)
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:1322
↓ 2 callersMethodreadAndDiscardMessages
Blocks until {@code n} messages can be produced (and discarded).
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:597
↓ 2 callersMethodreadBytesChecked
Read a byte array checking that we're not reading too much.
binder/src/main/java/io/grpc/binder/internal/MetadataHelper.java:187
↓ 2 callersMethodreadBytesUntilZero
Skip over a zero-terminated byte sequence. Returns true when the zero byte is read.
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:117
← previousnext →5,001–5,100 of 22,628, ranked by callers