Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/grpc/grpc-java
/ functions
Functions
22,628 in github.com/grpc/grpc-java
⨍
Functions
22,628
◇
Types & classes
3,835
↓ 2 callers
Method
onAbsent
(@Nullable ProcessingTracker processingTracker, ServerInfo serverInfo)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:868
↓ 2 callers
Method
onAddresses
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 callers
Method
onCancel
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1268
↓ 2 callers
Method
onCancel
()
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:582
↓ 2 callers
Method
onCancel
()
api/src/test/java/io/grpc/ContextsTest.java:71
↓ 2 callers
Method
onCancel
()
binder/src/main/java/io/grpc/binder/internal/PendingAuthListener.java:61
↓ 2 callers
Method
onCancel
()
opentelemetry/src/test/java/io/grpc/opentelemetry/OpenTelemetryTracingModuleTest.java:704
↓ 2 callers
Method
onClose
(Status status, Metadata trailers)
interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:557
↓ 2 callers
Method
onCloseSent
(Status status)
binder/src/main/java/io/grpc/binder/internal/Inbound.java:671
↓ 2 callers
Method
onDataRead
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:952
↓ 2 callers
Method
onHalfClose
()
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:573
↓ 2 callers
Method
onHalfClose
()
api/src/test/java/io/grpc/ContextsTest.java:66
↓ 2 callers
Method
onHalfClose
()
opentelemetry/src/test/java/io/grpc/opentelemetry/OpenTelemetryTracingModuleTest.java:699
↓ 2 callers
Method
onHandshakeComplete
()
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:440
↓ 2 callers
Method
onHeaders
(final Metadata headers)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:485
↓ 2 callers
Method
onHeaders
(Metadata headers)
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:436
↓ 2 callers
Method
onNullBinding
(ComponentName name)
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:357
↓ 2 callers
Method
onReady
()
core/src/main/java/io/grpc/internal/ServerImpl.java:936
↓ 2 callers
Method
onResult
(ResolutionResult resolutionResultArg)
api/src/test/java/io/grpc/NameResolverTest.java:154
↓ 2 callers
Method
onResult
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 callers
Method
onSentBytes
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 callers
Method
onServiceDisconnected
(ComponentName name)
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:349
↓ 2 callers
Method
onStatusReceived
Called when status is received on the stream.
xds/src/main/java/io/grpc/xds/client/XdsTransportFactory.java:91
↓ 2 callers
Method
onStreamAllocated
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java:264
↓ 2 callers
Method
onSucceeded
(BidirectionalStream stream, UrlResponseInfo info)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:507
↓ 2 callers
Method
onTransportActive
There are outstanding RPCs on the transport.
core/src/main/java/io/grpc/internal/MaxConnectionIdleManager.java:91
↓ 2 callers
Method
onWritePossible
()
servlet/src/main/java/io/grpc/servlet/ServletServerStream.java:222
↓ 2 callers
Method
orDefault
(@Nullable T value, T defaultValue)
rls/src/main/java/io/grpc/rls/RlsProtoConverters.java:188
↓ 2 callers
Method
outboundMessage
See {@link StreamTracer#outboundMessage(int)}. <p>Called from {@link io.grpc.internal.Framer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:189
↓ 2 callers
Method
outboundMessageSent
See {@link StreamTracer#outboundMessageSent}. <p>Called from {@link io.grpc.internal.Framer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:211
↓ 2 callers
Method
outboundUncompressedSize
See {@link StreamTracer#outboundUncompressedSize}. <p>Called from {@link io.grpc.internal.Framer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:233
↓ 2 callers
Method
overrideAuthorityIsReadableHelper
(OkHttpChannelBuilder builder, String overrideAuthority)
okhttp/src/test/java/io/grpc/okhttp/OkHttpChannelBuilderTest.java:91
↓ 2 callers
Method
parse
(String config)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:83
↓ 2 callers
Method
parse
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 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestServer.java:121
↓ 2 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceServer.java:84
↓ 2 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:143
↓ 2 callers
Method
parseAsciiString
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 callers
Method
parseAssumedUtf8PathIntoSegments
( String path, ImmutableList.Builder<String> out)
api/src/main/java/io/grpc/Uri.java:303
↓ 2 callers
Method
parseBootstrap
(Map<String, ?> bootstrap)
xds/src/main/java/io/grpc/xds/InternalGrpcBootstrapperImpl.java:31
↓ 2 callers
Method
parseClusterWeight
( io.envoyproxy.envoy.config.route.v3.WeightedCluster.ClusterWeight proto, FilterRegistry filterRe
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:584
↓ 2 callers
Method
parseCommaSeparatedTuples
(String str)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:364
↓ 2 callers
Method
parseCustomConfigJson
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 callers
Method
parseCustomConfigTypeName
(String customConfigTypeName)
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:381
↓ 2 callers
Method
parseFeatures
Parses the JSON input file containing the list of features.
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideUtil.java:58
↓ 2 callers
Method
parseGoogleGrpcConfig
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 callers
Method
parseHeaderMatcher
( io.envoyproxy.envoy.config.route.v3.HeaderMatcher proto)
xds/src/main/java/io/grpc/xds/RbacFilter.java:320
↓ 2 callers
Method
parseHeaderMatcher
Translates envoy proto HeaderMatcher to internal HeaderMatcher.
xds/src/main/java/io/grpc/xds/internal/MatcherParser.java:25
↓ 2 callers
Method
parseJsonObject
(String json)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerProviderTest.java:145
↓ 2 callers
Method
parseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:988
↓ 2 callers
Method
parseLoadBalancingPolicyConfig
(Map<String, ?> rawLoadBalancingPolicyConfig)
interop-testing/src/main/java/io/grpc/testing/integration/RpcBehaviorLoadBalancerProvider.java:52
↓ 2 callers
Method
parseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
xds/src/test/java/io/grpc/xds/ClusterManagerLoadBalancerProviderTest.java:69
↓ 2 callers
Method
parseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
xds/src/main/java/io/grpc/xds/CdsLoadBalancerProvider.java:75
↓ 2 callers
Method
parseOverride
(List<Permission> permissionList, List<Principal> principalList)
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:464
↓ 2 callers
Method
parsePathMatcher
( io.envoyproxy.envoy.type.matcher.v3.PathMatcher proto)
xds/src/main/java/io/grpc/xds/RbacFilter.java:303
↓ 2 callers
Method
parsePercent
(FractionalPercent proto)
xds/src/main/java/io/grpc/xds/FaultFilter.java:181
↓ 2 callers
Method
parsePermissionList
(List<Permission> permissions)
xds/src/main/java/io/grpc/xds/RbacFilter.java:212
↓ 2 callers
Method
parsePrincipalList
(List<Principal> principals)
xds/src/main/java/io/grpc/xds/RbacFilter.java:255
↓ 2 callers
Method
parseRegex
(String regex, String fieldName)
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationRulesParser.java:46
↓ 2 callers
Method
parseRpc
(String rpc)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:255
↓ 2 callers
Method
parseRpcEvents
(List<?> rpcEvents, ImmutableList.Builder<LogFilter> filters)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:182
↓ 2 callers
Method
parseRules
( List<Map<String, ?>> objects, String name)
authz/src/main/java/io/grpc/authz/AuthorizationPolicyTranslator.java:126
↓ 2 callers
Method
parseServerInfos
(List<?> rawServerConfigs, XdsLogger logger)
xds/src/main/java/io/grpc/xds/client/BootstrapperImpl.java:256
↓ 2 callers
Method
parseUnixSocketAddress
(String value)
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:110
↓ 2 callers
Method
parseUriArg
(String targetUri)
binder/src/main/java/io/grpc/binder/internal/IntentNameResolverProvider.java:81
↓ 2 callers
Method
pendingResponse
(PendingCacheEntry pendingEntry)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:557
↓ 2 callers
Method
percentDecode
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 callers
Method
pickFirstModeFallback
(long timeout)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2162
↓ 2 callers
Method
pickSubchannel
(PickSubchannelArgs args)
core/src/main/java/io/grpc/internal/PickFirstLoadBalancer.java:176
↓ 2 callers
Method
pickSubchannel
(PickSubchannelArgs args)
xds/src/test/java/io/grpc/xds/ClusterManagerLoadBalancerTest.java:401
↓ 2 callers
Method
pickSubchannel
(PickSubchannelArgs args)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:470
↓ 2 callers
Method
picked
(PickSubchannelArgs args)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:998
↓ 2 callers
Method
ping
Sends out a keep-alive ping.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:253
↓ 2 callers
Method
pingBinder
()
binder/src/testFixtures/java/io/grpc/binder/internal/FakeDeadBinder.java:43
↓ 2 callers
Method
pingPong
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:708
↓ 2 callers
Method
pingPongExactFrameSizeTest
Ping pong test with exact frame size.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:175
↓ 2 callers
Method
pingPongSmallBufferTest
Ping pong test with small buffer size.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:197
↓ 2 callers
Method
pingPongSmallFrameSmallBufferTest
Ping pong test with small frame and small buffer.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:231
↓ 2 callers
Method
pingPongSmallFrameTest
Ping pong test with small frame size.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:212
↓ 2 callers
Method
pingPongTest
Ping pong test.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:160
↓ 2 callers
Method
prefixLen
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:303
↓ 2 callers
Method
prefixedClusterSpecifierPluginName
(String pluginName)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:661
↓ 2 callers
Method
printResultMessage
(String type, List<String> result, long millis)
examples/src/main/java/io/grpc/examples/manualflowcontrol/BidiBlockingClient.java:89
↓ 2 callers
Method
printShortStatus
(Status status)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:870
↓ 2 callers
Method
prioritizedClusterNames
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:626
↓ 2 callers
Method
processExtension
(FieldDescriptor extension, FileDescriptor fd)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:524
↓ 2 callers
Method
processTrailer
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:456
↓ 2 callers
Method
promise
Returns the promise beeing notified of the success/failure of the write.
netty/src/main/java/io/grpc/netty/WriteQueue.java:222
↓ 2 callers
Method
propagateCauseWithStatus
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 callers
Method
protocolNegotiatorFactory
(ProtocolNegotiator.ClientFactory protocolNegotiatorFactory)
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:673
↓ 2 callers
Method
provideNextCheckAuthorizationResult
(Status status)
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:665
↓ 2 callers
Method
provider
Returns the ClassLoader-wide default channel. @throws ProviderNotFoundException if no provider is available
api/src/main/java/io/grpc/ManagedChannelProvider.java:42
↓ 2 callers
Method
providers
Returns effective providers in a new map.
api/src/main/java/io/grpc/LoadBalancerRegistry.java:132
↓ 2 callers
Method
proxyDetector
(@Nullable ProxyDetector proxyDetector)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:550
↓ 2 callers
Method
quitWorker
<pre> Quit this worker </pre>
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java:247
↓ 2 callers
Method
randomString
()
util/src/jmh/java/io/grpc/util/HandlerRegistryBenchmark.java:103
↓ 2 callers
Method
rapidReset
(int burstSize)
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:1322
↓ 2 callers
Method
readAndDiscardMessages
Blocks until {@code n} messages can be produced (and discarded).
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:597
↓ 2 callers
Method
readBytesChecked
Read a byte array checking that we're not reading too much.
binder/src/main/java/io/grpc/binder/internal/MetadataHelper.java:187
↓ 2 callers
Method
readBytesUntilZero
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
← previous
next →
5,001–5,100 of 22,628, ranked by callers