MCPcopy Create free account

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

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

↓ 3 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/FaultFilter.java:223
↓ 3 callersMethoddeliver
()
api/src/context/java/io/grpc/Context.java:1055
↓ 3 callersMethoddeliver
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:200
↓ 3 callersMethoddeliverError
(final Status error)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2877
↓ 3 callersMethoddeliverSubchannelState
(final Subchannel subchannel, ConnectivityState state)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1190
↓ 3 callersMethoddenyAtDisable
Specifies whether to deny requests when the filter is disabled. Defaults to {@code false}. @see ExtAuthz#getDenyAtDisable()
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:88
↓ 3 callersMethodderegister
Deregisters a provider. No-op if the provider is not in the registry. If there are more than one providers with the same policy name as the deregist
api/src/main/java/io/grpc/LoadBalancerRegistry.java:81
↓ 3 callersMethodderegister
Deregisters a provider. No-op if the provider is not in the registry. @param provider the provider that was added to the register via
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:83
↓ 3 callersMethoddescription
Returns a description of the test case.
interop-testing/src/main/java/io/grpc/testing/integration/TestCases.java:73
↓ 3 callersMethoddetermineCustomLabel
(PickSubchannelArgs args)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:1083
↓ 3 callersMethoddnsHostName
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:604
↓ 3 callersMethoddoExecute
Executes the given runnable. This prevents exceptions from propagating so that an exception thrown by one callback won't prevent subsequent callbacks
core/src/main/java/io/grpc/internal/Http2Ping.java:179
↓ 3 callersMethoddoRpc
(Channel channel)
alts/src/test/java/io/grpc/alts/HandshakerServiceChannelTest.java:115
↓ 3 callersMethoddoTest
Main testing method. Streams 2 MB of data from a server and records the final window and average bandwidth usage.
interop-testing/src/test/java/io/grpc/testing/integration/NettyFlowControlTest.java:128
↓ 3 callersMethoddrain
Executes all queued Runnables and if there were any wakes up any waiting threads.
stub/src/main/java/io/grpc/stub/ClientCalls.java:939
↓ 3 callersMethoddrainTo
(OutputStream output)
binder/src/main/java/io/grpc/binder/internal/BlockInputStream.java:128
↓ 3 callersMethodeag
()
xds/src/main/java/io/grpc/xds/Endpoints.java:60
↓ 3 callersMethodecho
(io.istio.test.Echo.EchoRequest request, io.grpc.stub.StreamObserver<io.istio.test.Echo.EchoResponse>
istio-interop-testing/src/generated/main/grpc/io/istio/test/EchoTestServiceGrpc.java:142
↓ 3 callersMethodechoAsync
Say hello to the server, but using async API and cancelling.
examples/src/main/java/io/grpc/examples/cancellation/CancellationClient.java:146
↓ 3 callersMethodeject
()
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:373
↓ 3 callersMethodelapseBackoff
(long time, TimeUnit unit)
interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:217
↓ 3 callersMethodemptyGrpcFrame
(int streamId, boolean endStream)
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:1403
↓ 3 callersMethodemptyUnary
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:425
↓ 3 callersMethodencode
(byte[] data, OutputStream out)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Huffman.java:93
↓ 3 callersMethodendOfMessages
Closes the underlying framer. Should be called when the outgoing stream is gracefully closed (half closure on client; closure on server).
core/src/main/java/io/grpc/internal/AbstractStream.java:101
↓ 3 callersMethodendSpanWithStatus
(Span span, io.grpc.Status status)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:483
↓ 3 callersMethodendStream
()
netty/src/main/java/io/grpc/netty/SendGrpcFrameCommand.java:53
↓ 3 callersMethodendpoints
()
xds/src/main/java/io/grpc/xds/Endpoints.java:38
↓ 3 callersMethodenforcementPercentage
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:427
↓ 3 callersMethodenforcementPercentage
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:452
↓ 3 callersMethodenqueue
Adds the given chunks to the response stream and schedules the next chunk to be delivered if needed.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:345
↓ 3 callersMethodenterIdle
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:303
↓ 3 callersMethodenterTerminalState
enterTerminalState causes the health status manager to mark all services as not serving, and prevents future updates to services. This method is mean
services/src/main/java/io/grpc/services/HealthStatusManager.java:87
↓ 3 callersMethodeqMetricInstrumentName
(String name)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:703
↓ 3 callersMethodequals
(Object other)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:986
↓ 3 callersMethodequals
Returns true if the two objects are both Keys, and their names match (case insensitive).
api/src/main/java/io/grpc/Metadata.java:797
↓ 3 callersMethodequals
Returns true if the {@link Subchannel}, {@link Status}, and {@link ClientStreamTracer.Factory} all match.
api/src/main/java/io/grpc/LoadBalancer.java:802
↓ 3 callersMethodequals
(Object o)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:110
↓ 3 callersMethodequals
(Object o)
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:56
↓ 3 callersMethoderrorPrefix
()
xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:227
↓ 3 callersMethodexact
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:209
↓ 3 callersMethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:764
↓ 3 callersMethodexceptionThrown
Cancels call and schedules onClose() notification. May only be called from the application thread.
core/src/main/java/io/grpc/internal/ClientCallImpl.java:589
↓ 3 callersMethodexceptionThrown
Cancels call and schedules onClose() notification. May only be called from within a DelayedListener callback dispatch (either queued drain or passThro
core/src/main/java/io/grpc/internal/DelayedClientCall.java:467
↓ 3 callersMethodexecute
(Runnable command)
api/src/context/java/io/grpc/Context.java:1080
↓ 3 callersMethodexecute
Adds a task and run it in this synchronization context as soon as possible. The task may run inline. If there are tasks that are previously queued b
api/src/main/java/io/grpc/SynchronizationContext.java:125
↓ 3 callersMethodexecuteNoThrow
(NoThrowReadOperation<T> op, int length, T dest, int value)
core/src/main/java/io/grpc/internal/CompositeReadableBuffer.java:287
↓ 3 callersMethodexpand
(int newCapacity)
api/src/main/java/io/grpc/Metadata.java:362
↓ 3 callersMethodfactory
(HandshakerSocketFactory factory)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:516
↓ 3 callersMethodfailed
Completes this operation exceptionally. Registered callbacks are invoked and provided the given throwable as the cause of failure. @param failureCaus
core/src/main/java/io/grpc/internal/Http2Ping.java:148
↓ 3 callersMethodfailureModeAllow
Changes the filter's behavior on errors from the authorization service. If {@code true}, the filter will accept the request even if the authorization
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:58
↓ 3 callersMethodfailureModeAllowHeaderAdd
Determines if the {@code x-envoy-auth-failure-mode-allowed} header is added to the request when {@link #failureModeAllow()} is true. @see ExtAuthz#ge
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:66
↓ 3 callersMethodfilterMetadata
(ImmutableMap<String, Struct> filterMetadata)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:776
↓ 3 callersMethodfinalizeAndDump
(CallMetricRecorder recorder)
services/src/main/java/io/grpc/services/InternalCallMetricRecorder.java:40
↓ 3 callersMethodflush
()
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:137
↓ 3 callersMethodforChannelId
(boolean isTerminal)
xds/src/main/java/io/grpc/xds/VirtualHost.java:264
↓ 3 callersMethodforDevicePolicyAdmin
Creates a BinderChannelCredentials to be used with DevicePolicyManager API. @param devicePolicyAdminComponentName the admin component to be specified
binder/src/main/java/io/grpc/binder/BinderChannelCredentials.java:45
↓ 3 callersMethodforImmutableInstance
Create a stream for a Parcelable object, treating the object as immutable.
binder/src/main/java/io/grpc/binder/internal/ParcelableInputStream.java:95
↓ 3 callersMethodforLocalComponent
Creates an address referencing a {@link android.app.Service} hosted by this application and using the default binding {@link Intent}.
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:81
↓ 3 callersMethodforNonForwardingAction
(RouteMatch routeMatch, Map<String, FilterConfig> filterConfigOverrides)
xds/src/main/java/io/grpc/xds/VirtualHost.java:73
↓ 3 callersMethodforPort
Always throws, to shadow {@code ServerBuilder.forPort()}. @deprecated Use {@link #forPort(int, ServerCredentials)} instead
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:92
↓ 3 callersMethodforPrefix
The input string should have the prefix.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:239
↓ 3 callersMethodforTarget
(String target)
rls/src/main/java/io/grpc/rls/ChildLoadBalancerHelper.java:84
↓ 3 callersMethodforcefulClose
(final ChannelHandlerContext ctx, final ForcefulCloseCommand msg, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:872
↓ 3 callersMethodformatDeadlineExceededStatus
()
core/src/main/java/io/grpc/internal/ClientCallImpl.java:396
↓ 3 callersMethodformatHeader
(boolean inbound, int streamId, int length, byte type, byte flags)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:685
↓ 3 callersMethodforwardTimeByBackoffDelay
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3134
↓ 3 callersMethodframeWriter
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:232
↓ 3 callersMethodfreezeHedging
()
core/src/main/java/io/grpc/internal/RetriableStream.java:823
↓ 3 callersMethodfromRegEx
(Pattern regEx)
xds/src/main/java/io/grpc/xds/VirtualHost.java:136
↓ 3 callersMethodgeneratePerRouteInterceptors
( @Nullable List<NamedFilterConfig> filterConfigs, List<VirtualHost> virtualHosts, Map
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:657
↓ 3 callersMethodgetAccessToken
()
s2a/src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/SingleTokenFetcher.java:44
↓ 3 callersMethodgetActiveRequests
()
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:317
↓ 3 callersMethodgetAttributeOrDefault
(Attributes attributes, Attributes.Key<String> key)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:711
↓ 3 callersMethodgetAuthMechanism
Retrieves the authentication mechanism for a given local identity. @param localIdentity the identity for which to fetch a token. @param tokenManager
s2a/src/main/java/io/grpc/s2a/internal/handshaker/GetAuthenticationMechanisms.java:37
↓ 3 callersMethodgetAuthority
Returns the Authority which is the package name of the target app. <p>See {@link android.content.ComponentName} and {@link Intent#getPackage()}.
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:130
↓ 3 callersMethodgetAutoHostSni
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:115
↓ 3 callersMethodgetBackendServiceOrDefault
(Attributes attributes)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:716
↓ 3 callersMethodgetByte
(CharSequence name)
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:88
↓ 3 callersMethodgetCacheSize
()
xds/src/main/java/io/grpc/xds/GcpAuthenticationFilter.java:223
↓ 3 callersMethodgetCallCredentials
()
api/src/main/java/io/grpc/CompositeChannelCredentials.java:45
↓ 3 callersMethodgetCallOptions
Returns the effective CallOptions of the call.
api/src/main/java/io/grpc/ClientStreamTracer.java:149
↓ 3 callersMethodgetCertificateChain
The certificate chain for the server's identity, as a new byte array. Generally should be PEM-encoded. If {@code null}, some feature is providing key
api/src/main/java/io/grpc/TlsServerCredentials.java:87
↓ 3 callersMethodgetChildPickers
()
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:218
↓ 3 callersMethodgetClientAccumulatedStats
<pre> Gets the accumulated stats for RPCs sent by a test client. </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/LoadBalancerStatsServiceGrpc.java:161
↓ 3 callersMethodgetClientAliases
(String keyType, Principal[] issuers)
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:93
↓ 3 callersMethodgetClientConfigForXdsClient
(XdsClient xdsClient, String target)
xds/src/main/java/io/grpc/xds/CsdsService.java:188
↓ 3 callersMethodgetClientInterceptor
Returns the client interceptor that facilitates Census-based stats reporting.
census/src/main/java/io/grpc/census/CensusStatsModule.java:162
↓ 3 callersMethodgetClientInterceptor
Returns the client interceptor that facilitates otel tracing reporting.
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:132
↓ 3 callersMethodgetClientStats
<pre> Gets the backend distribution for RPCs sent by a test client. </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/LoadBalancerStatsServiceGrpc.java:151
↓ 3 callersMethodgetCompressor
Returns the compressor's name.
api/src/main/java/io/grpc/CallOptions.java:260
↓ 3 callersMethodgetConditionalInterceptor
(ClientInterceptor interceptor)
gcp-observability/src/main/java/io/grpc/gcp/observability/GcpObservability.java:216
↓ 3 callersMethodgetConfigurators
Returns a list of the configurators in this registry.
api/src/main/java/io/grpc/ConfiguratorRegistry.java:69
↓ 3 callersMethodgetConfiguratorsCallCountBeforeSet
()
api/src/main/java/io/grpc/InternalConfiguratorRegistry.java:52
↓ 3 callersMethodgetCredentialsList
Non-empty list of credentials, in preference order.
api/src/main/java/io/grpc/ChoiceServerCredentials.java:53
↓ 3 callersMethodgetCurrentRecordSink
()
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:160
↓ 3 callersMethodgetDefaultPickSubchannelArgsForServer
(int serverid)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:621
↓ 3 callersMethodgetDefaultRegistry
Returns the default registry that loads providers via the Java service loader mechanism.
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:109
↓ 3 callersMethodgetDefaultRoutingConfig
()
xds/src/main/java/io/grpc/xds/FilterChainMatchingProtocolNegotiators.java:163
↓ 3 callersMethodgetDefaultScheme
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:965
← previousnext →3,601–3,700 of 22,628, ranked by callers