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
↓ 1 callers
Method
onComplete
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:450
↓ 1 callers
Method
onCompleted
()
interop-testing/src/test/java/io/grpc/testing/integration/NettyFlowControlTest.java:229
↓ 1 callers
Method
onCompleted
()
xds/src/test/java/io/grpc/xds/XdsTestControlPlaneService.java:181
↓ 1 callers
Method
onCompleted
()
xds/src/main/java/io/grpc/xds/CsdsService.java:112
↓ 1 callers
Method
onConfigError
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:929
↓ 1 callers
Method
onConnectedServiceInfo
(ServiceInfo serviceInfo)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:418
↓ 1 callers
Method
onData
(ParsedResource<T> parsedResource, String version, long updateTime, ProcessingTracker processi
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:828
↓ 1 callers
Method
onDataRead
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1071
↓ 1 callers
Method
onEarlyCancellation
(Status reason)
core/src/main/java/io/grpc/internal/DelayedStream.java:343
↓ 1 callers
Method
onEndOfStream
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java:344
↓ 1 callers
Method
onError
(final Status error)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1737
↓ 1 callers
Method
onError
Propagates error to all the callback receivers.
xds/src/main/java/io/grpc/xds/internal/security/DynamicSslContextProvider.java:143
↓ 1 callers
Method
onException
Finish all active streams due to an IOException, then close the transport.
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:1081
↓ 1 callers
Method
onFinished
()
android-interop-testing/src/main/java/io/grpc/android/integrationtest/UdsTcpEndpointConnector.java:154
↓ 1 callers
Method
onHeaders
(Metadata metadata)
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:283
↓ 1 callers
Method
onHeaders
(Metadata headers)
api/src/test/java/io/grpc/ClientInterceptorsTest.java:287
↓ 1 callers
Method
onHeaders
(Metadata headers)
examples/src/main/java/io/grpc/examples/grpcproxy/GrpcProxy.java:144
↓ 1 callers
Method
onHeaders
(Metadata headers)
xds/src/test/java/io/grpc/xds/FakeControlPlaneXdsIntegrationTest.java:301
↓ 1 callers
Method
onInUse
Called when the subchannel's in-use state has changed to true, which means at least one transport is in use.
core/src/main/java/io/grpc/internal/InternalSubchannel.java:744
↓ 1 callers
Method
onLoadReport
Invoked when a per-request ORCA report is received. <p>Note this callback will be invoked from the network thread as the RPC finishes, implementation
xds/src/main/java/io/grpc/xds/orca/OrcaPerRequestUtil.java:187
↓ 1 callers
Method
onNotInUse
Called when the subchannel's in-use state has changed to false, which means no transport is in use.
core/src/main/java/io/grpc/internal/InternalSubchannel.java:751
↓ 1 callers
Method
onPingTimeout
()
core/src/main/java/io/grpc/internal/KeepAliveManager.java:302
↓ 1 callers
Method
onReady
()
stub/src/main/java/io/grpc/stub/ServerCalls.java:202
↓ 1 callers
Method
onRecvMessage
Called when a message is received on the stream.
xds/src/main/java/io/grpc/xds/client/XdsTransportFactory.java:86
↓ 1 callers
Method
onRejected
(String rejectedVersion, long rejectedTime, String rejectedDetails)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:1004
↓ 1 callers
Method
onReport
(OrcaLoadReport report)
xds/src/main/java/io/grpc/xds/orca/OrcaPerRequestUtil.java:274
↓ 1 callers
Method
onResult
(final NameResolver.ResolutionResult resolutionResult)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:888
↓ 1 callers
Method
onResult2
(final ResolutionResult resolutionResult)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1599
↓ 1 callers
Method
onServerAuthorizationOk
Notifies the implementation that the SecurityPolicy check of the server succeeded.
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:480
↓ 1 callers
Method
onServerMessageHelper
(ServerCall.Listener listener, Object request)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:280
↓ 1 callers
Method
onServerReady
()
examples/src/main/java/io/grpc/examples/grpcproxy/GrpcProxy.java:167
↓ 1 callers
Method
onShutdownNow
(Status reason)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1296
↓ 1 callers
Method
onStart
()
stub/src/main/java/io/grpc/stub/ClientCalls.java:440
↓ 1 callers
Method
onStateChange
Called when the subchannel's connectivity state has changed.
core/src/main/java/io/grpc/internal/InternalSubchannel.java:737
↓ 1 callers
Method
onStreamAllocated
()
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:284
↓ 1 callers
Method
onTerminated
Called when the subchannel is terminated, which means it's shut down and all transports have been terminated.
core/src/main/java/io/grpc/internal/InternalSubchannel.java:731
↓ 1 callers
Method
onTransact
(int code, Parcel data, Parcel reply, int flags)
binder/src/test/java/io/grpc/binder/internal/OneWayBinderProxyTest.java:167
↓ 1 callers
Method
onTransportReady
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:201
↓ 1 callers
Method
onTransportReady
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:306
↓ 1 callers
Method
onTransportTermination
Transport is being terminated.
core/src/main/java/io/grpc/internal/MaxConnectionIdleManager.java:112
↓ 1 callers
Method
onUnbound
We've disconnected from (or failed to bind to) the service. This will only be called once, after which no other calls will be made (but see note on th
binder/src/main/java/io/grpc/binder/internal/Bindable.java:46
↓ 1 callers
Method
onWriteFrameData
(ChannelFuture future, int numMessages, int numBytes)
netty/src/main/java/io/grpc/netty/NettyServerStream.java:195
↓ 1 callers
Method
onWriteFrameData
(ChannelFuture future, int numMessages, int numBytes)
netty/src/main/java/io/grpc/netty/NettyClientStream.java:300
↓ 1 callers
Method
outboundHeaders
()
core/src/main/java/io/grpc/internal/ForwardingClientStreamTracer.java:42
↓ 1 callers
Method
outlierDetection
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:630
↓ 1 callers
Method
outlierDetectionEnabled
Determine if any outlier detection algorithms are enabled in the config.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:1161
↓ 1 callers
Method
overrideAuthority
(String authority)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:1141
↓ 1 callers
Method
parse
(String statusLine)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/StatusLine.java:26
↓ 1 callers
Method
parseAggregateCluster
(Cluster cluster)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:197
↓ 1 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:90
↓ 1 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbLongLivedAffinityTestClient.java:76
↓ 1 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/ReconnectTestClient.java:46
↓ 1 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/XdsFederationTestClient.java:65
↓ 1 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbFallbackTestClient.java:83
↓ 1 callers
Method
parseArgs
(String[] args)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:130
↓ 1 callers
Method
parseArgs
(String[] args)
examples/example-alts/src/main/java/io/grpc/examples/alts/HelloWorldAltsClient.java:43
↓ 1 callers
Method
parseArgs
(String[] args)
examples/example-alts/src/main/java/io/grpc/examples/alts/HelloWorldAltsServer.java:44
↓ 1 callers
Method
parseArgs
(String[] args)
examples/example-debug/src/main/java/io/grpc/examples/debug/HostnameDebuggableServer.java:52
↓ 1 callers
Method
parseAsciiStringSlow
(byte[] value)
api/src/main/java/io/grpc/Status.java:634
↓ 1 callers
Method
parseAuthenticatedMatcher
( Principal.Authenticated proto)
xds/src/main/java/io/grpc/xds/RbacFilter.java:333
↓ 1 callers
Method
parseCallCredentials
(List<Map<String, ?>> jsonList, String targetUri)
xds/src/main/java/io/grpc/xds/GrpcBootstrapperImpl.java:211
↓ 1 callers
Method
parseChannelCredentials
(List<Map<String, ?>> jsonList, String serverUri)
xds/src/main/java/io/grpc/xds/GrpcBootstrapperImpl.java:147
↓ 1 callers
Method
parseConfig
(String json)
core/src/test/java/io/grpc/internal/ManagedChannelServiceConfigTest.java:297
↓ 1 callers
Method
parseConfig
(Map<String, ?> config)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:89
↓ 1 callers
Method
parseCustomTags
(Map<String, ?> rawCustomTags)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:171
↓ 1 callers
Method
parseDestinationPortRangeMatcher
(Int32Range range)
xds/src/main/java/io/grpc/xds/RbacFilter.java:343
↓ 1 callers
Method
parseDropOverload
( io.envoyproxy.envoy.config.endpoint.v3.ClusterLoadAssignment.Policy.DropOverload proto)
xds/src/main/java/io/grpc/xds/XdsEndpointResource.java:163
↓ 1 callers
Method
parseDuration
Parse from a string to produce a duration. Copy of {@link com.google.protobuf.util.Durations#parse}. @return A Duration parsed from the string. @thr
core/src/main/java/io/grpc/internal/JsonUtil.java:309
↓ 1 callers
Method
parseFaultDelay
( io.envoyproxy.envoy.extensions.filters.common.fault.v3.FaultDelay faultDelay)
xds/src/main/java/io/grpc/xds/FaultFilter.java:152
↓ 1 callers
Method
parseFilterChainMatch
( io.envoyproxy.envoy.config.listener.v3.FilterChainMatch proto)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:449
↓ 1 callers
Method
parseFilterConfig
( Message rawProtoMessage, FilterConfigParseContext context)
xds/src/main/java/io/grpc/xds/GcpAuthenticationFilter.java:88
↓ 1 callers
Method
parseFilterConfig
( Message rawProtoMessage, FilterConfigParseContext context)
xds/src/main/java/io/grpc/xds/FaultFilter.java:106
↓ 1 callers
Method
parseHeader
(Map<String, ?> header)
authz/src/main/java/io/grpc/authz/AuthorizationPolicyTranslator.java:74
↓ 1 callers
Method
parseHelper
(InputStream stream)
gcp-observability/src/test/java/io/grpc/gcp/observability/interceptors/LogHelperTest.java:760
↓ 1 callers
Method
parseHelper
(InputStream stream)
services/src/main/java/io/grpc/protobuf/services/BinaryLogProvider.java:128
↓ 1 callers
Method
parseHttpFault
(HTTPFault httpFault)
xds/src/main/java/io/grpc/xds/FaultFilter.java:128
↓ 1 callers
Method
parseImplSpecificObject
( @Nullable Map<String, ?> rawAllowedGrpcServices)
xds/src/main/java/io/grpc/xds/client/BootstrapperImpl.java:250
↓ 1 callers
Method
parseJsonArray
(JsonReader jr)
core/src/main/java/io/grpc/internal/JsonParser.java:95
↓ 1 callers
Method
parseJsonLogFilter
(Map<String, ?> logFilterMap)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:192
↓ 1 callers
Method
parseJsonNull
(JsonReader jr)
core/src/main/java/io/grpc/internal/JsonParser.java:107
↓ 1 callers
Method
parseJsonObject
(JsonReader jr)
core/src/main/java/io/grpc/internal/JsonParser.java:81
↓ 1 callers
Method
parseLoadBalancingConfigPolicy
Parses raw load balancing config and returns a {@link ConfigOrError} that contains a {@link CdsConfig} if parsing is successful.
xds/src/main/java/io/grpc/xds/CdsLoadBalancerProvider.java:85
↓ 1 callers
Method
parseLoadBalancingConfigPolicyInternal
( Map<String, ?> rawLoadBalancingPolicyConfig)
grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancerProvider.java:85
↓ 1 callers
Method
parseLoadBalancingPolicyConfig
(Map<String, ?> rawLbPolicyConfig)
core/src/main/java/io/grpc/internal/PickFirstLoadBalancerProvider.java:71
↓ 1 callers
Method
parseLoadBalancingPolicyConfig
(Map<String, ?> rawConfig)
xds/src/main/java/io/grpc/xds/WeightedTargetLoadBalancerProvider.java:78
↓ 1 callers
Method
parseLoadBalancingPolicyConfig
(Map<String, ?> rawConfig)
xds/src/main/java/io/grpc/xds/WrrLocalityLoadBalancerProvider.java:60
↓ 1 callers
Method
parseLoadBalancingPolicyConfigInternal
(Map<String, ?> rawConfig)
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancerProvider.java:67
↓ 1 callers
Method
parseLoadBalancingPolicyConfigInternal
(Map<String, ?> rawConfig)
util/src/main/java/io/grpc/util/RandomSubsettingLoadBalancerProvider.java:63
↓ 1 callers
Method
parseLoadBalancingPolicyConfigInternal
(Map<String, ?> rawConfig)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancerProvider.java:75
↓ 1 callers
Method
parseLoadBalancingPolicyConfigInternal
( Map<String, ?> rawLoadBalancingPolicyConfig)
xds/src/main/java/io/grpc/xds/RingHashLoadBalancerProvider.java:81
↓ 1 callers
Method
parseLocality
(io.envoyproxy.envoy.config.core.v3.Locality proto)
xds/src/main/java/io/grpc/xds/XdsEndpointResource.java:159
↓ 1 callers
Method
parseLoggingObject
( Map<String, ?> rawLoggingConfig, ImmutableList.Builder<LogFilter> clientFilters, Immutable
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:148
↓ 1 callers
Method
parseMetadata
(String metadataArg)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:234
↓ 1 callers
Method
parseNanos
Copy of {@link com.google.protobuf.util.Timestamps#parseNanos}.
core/src/main/java/io/grpc/internal/JsonUtil.java:345
↓ 1 callers
Method
parseNonAggregateCluster
( Cluster cluster, Set<String> certProviderInstances, ServerInfo serverInfo)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:221
↓ 1 callers
Method
parsePermission
(Permission permission)
xds/src/main/java/io/grpc/xds/RbacFilter.java:220
↓ 1 callers
Method
parsePrincipal
(Principal principal)
xds/src/main/java/io/grpc/xds/RbacFilter.java:263
↓ 1 callers
Method
parseRaw
(List<Permission> permissionList, List<Principal> princi
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:397
↓ 1 callers
Method
parseRequest
(Map<String, ?> request)
authz/src/main/java/io/grpc/authz/AuthorizationPolicyTranslator.java:99
↓ 1 callers
Method
parseRequestedServerNameMatcher
( io.envoyproxy.envoy.type.matcher.v3.StringMatcher proto)
xds/src/main/java/io/grpc/xds/RbacFilter.java:315
← previous
next →
7,001–7,100 of 22,628, ranked by callers