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
↓ 2 callersMethodkeepAliveTime
Does nothing.
inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:156
↓ 2 callersMethodkeepAliveTime
{@inheritDoc} @since 1.3.0
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:518
↓ 2 callersMethodkeepAliveTimeout
Does nothing.
inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:162
↓ 2 callersMethodkeepEmptyValue
()
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderValueOption.java:38
↓ 2 callersMethodkeyForProto
Produce a metadata key for a generated protobuf type. @since 1.0.0
protobuf/src/main/java/io/grpc/protobuf/ProtoUtils.java:75
↓ 2 callersMethodkeyWithDefault
Create a {@link Key} with the given debug name and default value. @param debugString a name intended for debugging purposes and does not impact behav
api/src/context/java/io/grpc/Context.java:160
↓ 2 callersMethodlimitControlFramesWriter
(FrameWriter delegate)
okhttp/src/main/java/io/grpc/okhttp/AsyncSink.java:94
↓ 2 callersMethodlistener
()
core/src/main/java/io/grpc/internal/AbstractClientStream.java:286
↓ 2 callersMethodlistener
()
stub/src/main/java/io/grpc/stub/ClientCalls.java:698
↓ 2 callersMethodlistener
()
netty/src/test/java/io/grpc/netty/NettyServerStreamTest.java:440
↓ 2 callersMethodlistenerMessageQueue
()
netty/src/test/java/io/grpc/netty/NettyStreamTestBase.java:207
↓ 2 callersMethodloadEpollInfo
()
netty/src/main/java/io/grpc/netty/TcpMetrics.java:67
↓ 2 callersMethodlogClientHeader
Logs the client header. This method logs the appropriate number of bytes as determined by the binary logging configuration.
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:301
↓ 2 callersMethodlogOnly
(String prefix, Level logLevel, String msg)
xds/src/main/java/io/grpc/xds/client/XdsLogger.java:68
↓ 2 callersMethodlogPingAck
(Direction direction, long data)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:145
↓ 2 callersMethodlogServerHeader
()
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:672
↓ 2 callersMethodlogServerHeader
Logs the server header. This method logs the appropriate number of bytes as determined by the binary logging configuration.
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:317
↓ 2 callersMethodlogTrailer
()
gcp-observability/src/test/java/io/grpc/gcp/observability/interceptors/LogHelperTest.java:459
↓ 2 callersMethodlogTrailer
Logs the server trailer.
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:167
↓ 2 callersMethodlogTrailer
Logs the server trailer. This method logs the appropriate number of bytes as determined by the binary logging configuration.
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:329
↓ 2 callersMethodlookupCompressor
(String compressorName)
api/src/main/java/io/grpc/CompressorRegistry.java:62
↓ 2 callersMethodlookupMethod
(String methodName, @Nullable String authority)
core/src/main/java/io/grpc/internal/InternalHandlerRegistry.java:49
↓ 2 callersMethodlrsStreamIsNull
()
xds/src/main/java/io/grpc/xds/client/LoadReportClient.java:101
↓ 2 callersMethodmadeYouReset
(int burstSize)
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:1364
↓ 2 callersMethodmakeRequest
Construct a {@link SimpleRequest} with the specified dimensions.
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:271
↓ 2 callersMethodmakeTargetStringForDirectAddress
Returns a target string for the SocketAddress. It is only used as a placeholder, because DirectAddressNameResolverProvider will not actually try to us
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:315
↓ 2 callersMethodmanageControlPlaneClient
Gets a ControlPlaneClient for the subscriber's authority, creating one if necessary. If there already was an active CPC for this authority, and it is
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:292
↓ 2 callersMethodmanualSetUp
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:153
↓ 2 callersMethodmaxAttempts
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:281
↓ 2 callersMethodmaxConcurrentCallsPerConnection
The maximum number of concurrent calls permitted for each incoming connection. Defaults to no limit.
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:407
↓ 2 callersMethodmaxConnectionAgeGrace
Sets a custom grace time for the graceful connection termination. Once the max connection age is reached, RPCs have the grace time to complete. RPCs t
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:261
↓ 2 callersMethodmaybeExpand
()
api/src/main/java/io/grpc/Metadata.java:355
↓ 2 callersMethodmaybeShutdownNowSubchannels
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:306
↓ 2 callersMethodmaybeTerminateChannel
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1176
↓ 2 callersMethodmean
Calculates the mean of the given values.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:853
↓ 2 callersMethodmessage
()
protobuf-lite/src/main/java/io/grpc/protobuf/lite/ProtoInputStream.java:115
↓ 2 callersMethodmessageReadQueuePoll
()
core/src/main/java/io/grpc/internal/ApplicationThreadDeframerListener.java:90
↓ 2 callersMethodmessagesAvailable
(final MessageProducer producer)
core/src/main/java/io/grpc/internal/ServerImpl.java:835
↓ 2 callersMethodmethod
()
rls/src/main/java/io/grpc/rls/RlsProtoData.java:246
↓ 2 callersMethodmetricsLogRateSecs
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:741
↓ 2 callersMethodmetricsPort
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:736
↓ 2 callersMethodmissingResult
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:616
↓ 2 callersMethodmockBytes
(int... bytes)
core/src/test/java/io/grpc/internal/AbstractReadableBufferTest.java:55
↓ 2 callersMethodname
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:219
↓ 2 callersMethodname
()
xds/src/main/java/io/grpc/xds/ClusterSpecifierPlugin.java:42
↓ 2 callersMethodnamesAndValuesToImmutableList
()
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:307
↓ 2 callersMethodnamesAndValuesToString
()
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:318
↓ 2 callersMethodnewBlockingStub
Creates a new blocking-style stub that supports unary and streaming output calls on the service
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ReconnectServiceGrpc.java:112
↓ 2 callersMethodnewBlockingStub
Creates a new blocking-style stub that supports unary and streaming output calls on the service
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java:202
↓ 2 callersMethodnewBlockingStub
Creates a new blocking-style stub that supports unary and streaming output calls on the service
xds/src/generated/thirdparty/grpc/com/github/xds/service/orca/v3/OpenRcaServiceGrpc.java:88
↓ 2 callersMethodnewBuilder
()
binder/src/main/java/io/grpc/binder/InboundParcelablePolicy.java:67
↓ 2 callersMethodnewBuilder
Constructs a builder for configuring a client application with supported parameters. If no parameters are provided, all parameters are assumed to be s
benchmarks/src/main/java/io/grpc/benchmarks/qps/ClientConfiguration.java:80
↓ 2 callersMethodnewCallerFilteringHandler
Decorates the given {@link TransactionHandler} with a wrapper that only forwards transactions from the given `allowedCallingUid`.
binder/src/main/java/io/grpc/binder/internal/TransactionUtils.java:111
↓ 2 callersMethodnewChannel
()
benchmarks/src/main/java/io/grpc/benchmarks/qps/ClientConfiguration.java:67
↓ 2 callersMethodnewChannelBuilder
(String target, ChannelCredentials creds)
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelProvider.java:52
↓ 2 callersMethodnewChildConfig
(LoadBalancerProvider provider, Object config)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerProviderTest.java:66
↓ 2 callersMethodnewClientCallPlugin
()
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:190
↓ 2 callersMethodnewClientChannel
Create a {@link ManagedChannel} for the given parameters.
benchmarks/src/main/java/io/grpc/benchmarks/Utils.java:180
↓ 2 callersMethodnewClientStreamTracer
( ClientStreamTracer.StreamInfo info, Metadata headers)
core/src/main/java/io/grpc/internal/RetriableStream.java:264
↓ 2 callersMethodnewClientTracer
(StreamInfo info)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:414
↓ 2 callersMethodnewClientTransportFactory
()
core/src/testFixtures/java/io/grpc/internal/AbstractClientTransportFactoryTest.java:28
↓ 2 callersMethodnewConfig
Factory method for creating a new {link LoadBalancerConfigConverter} for a given xDS {@link Cluster}. @throws ResourceInvalidException If the {@link
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:102
↓ 2 callersMethodnewFailingClientStream
( Status failure, Attributes attributes, Metadata headers, ClientStreamTracer[] tracers)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java:508
↓ 2 callersMethodnewFakeHandshakerClient
()
alts/src/test/java/io/grpc/alts/internal/FakeTsiHandshaker.java:88
↓ 2 callersMethodnewHandler
( ServerTransportListener transportListener, ChannelPromise channelUnused, List<? extends Se
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:159
↓ 2 callersMethodnewHandler
( ClientTransportLifecycleManager lifecycleManager, @Nullable KeepAliveManager keepAliveManager,
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:156
↓ 2 callersMethodnewHealthCheckingLoadBalancer
Creates a health-checking-capable LoadBalancer. This method is used to implement health-checking-capable {@link io.grpc.LoadBalancer.Factory}s, which
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerUtil.java:62
↓ 2 callersMethodnewInstance
(S2AServiceGrpc.S2AServiceStub serviceStub)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AStub.java:51
↓ 2 callersMethodnewLoadBalancer
(final Helper helper)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:994
↓ 2 callersMethodnewLoadBalancer
(Helper helper)
core/src/main/java/io/grpc/internal/AutoConfiguredLoadBalancerFactory.java:67
↓ 2 callersMethodnewLoadBalancer
(Helper helper)
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:148
↓ 2 callersMethodnewLoadBalancer
(LoadBalancer.Helper helper)
util/src/test/java/io/grpc/util/RandomSubsettingLoadBalancerTest.java:81
↓ 2 callersMethodnewLoadBalancer
(Helper helper)
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancerProvider.java:36
↓ 2 callersMethodnewNameResolver
(NameResolverProvider provider, String uri, Args args)
googleapis/src/test/java/io/grpc/googleapis/GoogleCloudToProdNameResolverProviderTest.java:112
↓ 2 callersMethodnewPeerIdentifyingServerInterceptor
Creates an interceptor that exposes the client's identity in the {@link Context} under {@link #REMOTE_PEER}. <p>The returned interceptor only works w
binder/src/main/java/io/grpc/binder/PeerUids.java:85
↓ 2 callersMethodnewPromise
Allocate a new promise for the write of a protected frame. This will be used to aggregate the overall success of the unprotected promises. @return {@
alts/src/main/java/io/grpc/alts/internal/ProtectedPromise.java:65
↓ 2 callersMethodnewResourceMetadataUnknown
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:190
↓ 2 callersMethodnewServerBuilderForPort
(int port, ServerCredentials creds)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerProvider.java:44
↓ 2 callersMethodnewServerBuilderForPort
(int port, ServerCredentials creds)
netty/src/main/java/io/grpc/netty/NettyServerProvider.java:43
↓ 2 callersMethodnewServerStreamPlugin
(Metadata inboundMetadata)
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:199
↓ 2 callersMethodnewServerStreamTracer
(String fullMethodName, Metadata headers)
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:200
↓ 2 callersMethodnewString
(int size)
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:2235
↓ 2 callersMethodnewStringOfLength
(int numChars)
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:693
↓ 2 callersMethodnewStub
Creates a new async stub that supports all call types for the service
alts/src/generated/main/grpc/io/grpc/alts/internal/HandshakerServiceGrpc.java:49
↓ 2 callersMethodnext16
()
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:277
↓ 2 callersMethodnext8
()
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:281
↓ 2 callersMethodnextAT
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/DistinguishedNameParser.java:51
↓ 2 callersMethodnextFrameAtEndOfStream
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2370
↓ 2 callersMethodnonEmptyIntersection
An N M intersection that terminates if any intersection is found. The sizes of both arguments are assumed to be so small, and the likelihood of an int
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/ConnectionSpec.java:217
↓ 2 callersMethodnoop
()
api/src/test/java/io/grpc/ServerInterceptorsTest.java:127
↓ 2 callersMethodnotifyClientClose
clientStream.serverClosed() must be called before this method.
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:610
↓ 2 callersMethodnotifyGracefulShutdown
Marks transport as shutdown, but does not set the error status. This must eventually be followed by a call to notifyShutdown.
netty/src/main/java/io/grpc/netty/ClientTransportLifecycleManager.java:59
↓ 2 callersMethodnotifyIfReady
()
core/src/main/java/io/grpc/internal/AbstractStream.java:375
↓ 2 callersMethodnotifyInUse
(boolean inUse)
netty/src/main/java/io/grpc/netty/ClientTransportLifecycleManager.java:78
↓ 2 callersMethodnotifyShutdown
(Status s)
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:326
↓ 2 callersMethodnotifyUnbound
(Status reason)
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:141
↓ 2 callersMethodnotifyWatchers
(String service, @Nullable ServingStatus status)
services/src/main/java/io/grpc/protobuf/services/HealthServiceImpl.java:182
↓ 2 callersMethodnotifyWatchers
( Set<XdsStatsWatcher> watchers, RpcType rpcType, long requestId, String hostname)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:486
↓ 2 callersMethodnotifyWhenNoPendingData
Transport lock must be held when calling.
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:128
↓ 2 callersMethodoauth2AuthToken
Sends a unary rpc with raw oauth2 access token credentials.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:893
← previousnext →4,901–5,000 of 22,628, ranked by callers