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
↓ 21 callersMethodgetDefaultRegistry
()
xds/src/main/java/io/grpc/xds/FilterRegistry.java:35
↓ 21 callersMethodgetDescription
A description of this parameter used when printing usage.
benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java:88
↓ 21 callersMethodgetHeaderBytes
()
alts/src/main/java/io/grpc/alts/internal/AltsTsiFrameProtector.java:61
↓ 21 callersMethodgetMode
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbConfig.java:49
↓ 21 callersMethodgetProvider
Returns the effective provider for the given load-balancing policy, or {@code null} if no suitable provider can be found. Each provider declares its
api/src/main/java/io/grpc/LoadBalancerRegistry.java:124
↓ 21 callersMethodgetRawConfigValue
()
core/src/main/java/io/grpc/internal/ServiceConfigUtil.java:385
↓ 21 callersMethodgetTimeProvider
Provides a {@link TimeProvider} that is backed by this FakeClock.
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:271
↓ 21 callersMethodgetUsername
Returns the username used to connect to the proxy. {@code null} if there is no username.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:78
↓ 21 callersMethodhandleNameResolutionError
(Status error)
core/src/test/java/io/grpc/internal/AutoConfiguredLoadBalancerFactoryTest.java:154
↓ 21 callersMethodhandleNameResolutionError
()
util/src/test/java/io/grpc/util/RandomSubsettingLoadBalancerTest.java:131
↓ 21 callersMethodhttpStatusToGrpcStatus
Maps HTTP error response status codes to transport codes, as defined in <a href="https://github.com/grpc/grpc/blob/master/doc/http-grpc-status-mapping
core/src/main/java/io/grpc/internal/GrpcUtil.java:300
↓ 21 callersMethodmark
Marks the current position in this buffer. A subsequent call to the {@link #reset} method repositions this stream at the last marked position so that
core/src/main/java/io/grpc/internal/ReadableBuffer.java:136
↓ 21 callersMethodnewSocketLbEndpoint
(String ip, int port)
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1110
↓ 21 callersMethodprocessBytesFromPeer
Process the bytes received from the peer. @param bytes The buffer containing the handshake bytes from the peer. @return true, if the handshake has al
alts/src/main/java/io/grpc/alts/internal/TsiHandshaker.java:68
↓ 21 callersMethodregister
Registers the given channel to the rule. Once registered, the channel will be automatically shutdown at the end of the test. <p>This method need be p
testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java:118
↓ 21 callersMethodregisterNewServerTransport
(SimpleServerTransport transport)
core/src/test/java/io/grpc/internal/ServerImplTest.java:1839
↓ 21 callersMethodremoveService
Removes a registered service. @return true if the service was found to be removed.
util/src/main/java/io/grpc/util/MutableHandlerRegistry.java:71
↓ 21 callersMethodsetActiveNetworkInfo
(android.net.NetworkInfo activeNetworkInfo)
android/src/test/java/io/grpc/android/AndroidChannelBuilderTest.java:275
↓ 21 callersMethodsetMaxOutboundMessageSize
Set a size limit for each outbound message.
core/src/main/java/io/grpc/internal/Framer.java:50
↓ 21 callersMethodshutdownInternal
(Status shutdownStatus, boolean forceTerminate)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:309
↓ 21 callersMethodtimeRemaining
How much time is remaining in the specified time unit. Internal units are maintained as nanoseconds and conversions are subject to the constraints doc
api/src/context/java/io/grpc/Deadline.java:176
↓ 21 callersMethodtoString
()
xds/src/test/java/io/grpc/xds/StatefulFilter.java:70
↓ 20 callersMethodappendTimeoutInsight
Append information that will be included in the locally generated DEADLINE_EXCEEDED errors to the given {@link InsightBuilder}, in order to tell the u
core/src/main/java/io/grpc/internal/ClientStream.java:107
↓ 20 callersMethodauthorities
A map of authority name to corresponding configuration. <p>This is used in the following cases: <ul> <li>A gRPC client channel is created using an "
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:207
↓ 20 callersMethodblockingServerStreamingCall
Executes a server-streaming call returning a blocking {@link Iterator} over the response stream. The {@code call} should not be already started. Aft
stub/src/main/java/io/grpc/stub/ClientCalls.java:211
↓ 20 callersMethodbuildTransportFactory
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:539
↓ 20 callersMethodcheckEntry
(Header entry, String name, String value, int size)
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java:1172
↓ 20 callersMethodconfig
()
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:97
↓ 20 callersMethodconnect
Connect failures do not show up as {@link #channelInactive} or {@link #exceptionCaught}, so it needs to be watched.
netty/src/main/java/io/grpc/netty/WriteBufferingAndExceptionHandler.java:142
↓ 20 callersMethodcontent
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:240
↓ 20 callersMethodcreate
(String key, ImmutableList<String> names)
rls/src/main/java/io/grpc/rls/RlsProtoData.java:181
↓ 20 callersMethodcreate
(Mode mode)
grpclb/src/main/java/io/grpc/grpclb/GrpclbConfig.java:40
↓ 20 callersMethodcreate
(boolean log, int headerBytes, int messageBytes)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/ConfigFilterHelper.java:101
↓ 20 callersMethodcreate
Use TLS with its defaults.
api/src/main/java/io/grpc/TlsChannelCredentials.java:41
↓ 20 callersMethodcreate
(List<PolicyMatcher> policies, Action action)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:111
↓ 20 callersMethodcreateAndDeliverClusterUpdates
Creates and delivers both CDS and EDS updates for the given clusters.
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:1262
↓ 20 callersMethodcreateHcm
( VirtualHost vhost, List<NamedFilterConfig> filterConfigs)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1955
↓ 20 callersMethodcreateMetricInstruments
(Meter meter, Map<String, Boolean> enableMetrics, boolean disableDefault)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:202
↓ 20 callersMethodcreateStream
()
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:1386
↓ 20 callersMethodcreateStream
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:1122
↓ 20 callersMethoddeliverAddressesAndConfig
(List<EquivalentAddressGroup> addresses, ClusterImplConfig config)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1053
↓ 20 callersMethodevaluate
()
testing/src/test/java/io/grpc/testing/GrpcServerRuleTest.java:175
↓ 20 callersMethodforExactValue
The request header value should exactly match the specified value.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:78
↓ 20 callersMethodforVirtualHosts
(long httpMaxStreamDurationNano, List<VirtualHost> virtualHosts, @Nullable List<NamedFilterConfig> httpF
xds/src/main/java/io/grpc/xds/HttpConnectionManager.java:53
↓ 20 callersMethodgetBlockingStub
( final UpstreamTlsContext upstreamTlsContext, String overrideAuthority)
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:813
↓ 20 callersMethodgetCpuUtilization
()
services/src/main/java/io/grpc/services/MetricReport.java:53
↓ 20 callersMethodgetListenSocketAddress
Returns the first listening socket address. May change after {@link #start(ServerListener)} is called.
core/src/main/java/io/grpc/internal/InternalServer.java:56
↓ 20 callersMethodgetLocalPort
()
android/src/main/java/io/grpc/android/UdsSocket.java:121
↓ 20 callersMethodgetMethod
Perform a lookup for the method. No caching. In order to return a method the method name and arguments must match those specified when the {@link Opti
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OptionalMethod.java:153
↓ 20 callersMethodgetScheme
Returns the scheme of this URI.
api/src/main/java/io/grpc/Uri.java:336
↓ 20 callersMethodgetUnaryRpcMethod
()
testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/SimpleServiceGrpc.java:21
↓ 20 callersMethodisSampledToLocalTracing
Returns whether RPCs for this method may be sampled into the local tracing store.
api/src/main/java/io/grpc/MethodDescriptor.java:377
↓ 20 callersMethodmaybeChooseServiceConfig
Determines if a given Service Config choice applies, and if so, returns it. @see <a href="https://github.com/grpc/proposal/blob/master/A2-service-con
core/src/main/java/io/grpc/internal/DnsNameResolver.java:467
↓ 20 callersMethodnegotiationType
Sets the negotiation type for the HTTP/2 connection. <p>Default: <code>TLS</code>
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:337
↓ 20 callersMethodoutboundMessage
An outbound message has been passed to the stream. This is called as soon as the stream knows about the message, but doesn't have further guarantee s
api/src/main/java/io/grpc/StreamTracer.java:42
↓ 20 callersMethodpickerReturns
(final PickResult result)
api/src/testFixtures/java/io/grpc/LoadBalancerMatchers.java:33
↓ 20 callersMethodpopulateTarget
( String certFileSource, String keyFileSource, String rootFileSource, String spiffeTru
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:109
↓ 20 callersMethodput
(Struct.Builder struct, String key, String value)
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:125
↓ 20 callersMethodregister
Register a provider. <p>If the provider's {@link ManagedChannelProvider#isAvailable isAvailable()} returns {@code false}, this method will throw {@li
api/src/main/java/io/grpc/ManagedChannelRegistry.java:64
↓ 20 callersMethodrunAll
()
okhttp/src/test/java/io/grpc/okhttp/AsyncSinkTest.java:294
↓ 20 callersMethodrunTest
(String testCase)
android-interop-testing/src/androidTest/java/io/grpc/android/integrationtest/InteropInstrumentationTest.java:106
↓ 20 callersMethodrunTest
(String testCase)
android-interop-testing/src/androidTest/java/io/grpc/android/integrationtest/UdsChannelInteropTest.java:116
↓ 20 callersMethodsetId
(int id)
netty/src/main/java/io/grpc/netty/NettyClientStream.java:245
↓ 20 callersMethodsetId
(String id)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:152
↓ 20 callersMethodsetupChannel
(final String localIp, final String remoteIp, final int remotePort, FilterChainMat
xds/src/test/java/io/grpc/xds/FilterChainMatchingProtocolNegotiatorsTest.java:1224
↓ 20 callersMethodstartXdsDepManager
()
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1026
↓ 20 callersMethodunaryRpc
Say hello to server.
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:855
↓ 20 callersMethodvirtualHosts
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:942
↓ 20 callersMethodwithInterceptors
Returns a new stub that has the given interceptors attached to the underlying channel. @since 1.0.0
stub/src/main/java/io/grpc/stub/AbstractStub.java:215
↓ 19 callersMethodaddBuffer
Adds a new {@link ReadableBuffer} at the end of the buffer list. After a buffer is added, it is expected that this {@code CompositeBuffer} has complet
core/src/main/java/io/grpc/internal/CompositeReadableBuffer.java:56
↓ 19 callersMethodbindService
Creates {@link ServerServiceDefinition} object for current instance of service implementation. @return ServerServiceDefinition object.
api/src/main/java/io/grpc/BindableService.java:40
↓ 19 callersMethodbuildAggCluster
(String name, List<String> childNames)
xds/src/test/java/io/grpc/xds/XdsTestUtils.java:317
↓ 19 callersMethodbuildServerWithTlsContext
(DownstreamTlsContext downstreamTlsContext)
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:738
↓ 19 callersMethodcallMeMaybe
(Runnable r)
core/src/test/java/io/grpc/internal/DelayedStreamTest.java:475
↓ 19 callersMethodcreate
Constructs a matcher for one RBAC policy.
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:134
↓ 19 callersMethodcreate
(String key, String value)
xds/src/main/java/io/grpc/xds/internal/grpcservice/HeaderValue.java:30
↓ 19 callersMethoddelegate
()
core/src/main/java/io/grpc/internal/ForwardingClientStream.java:28
↓ 19 callersMethoddrain
(Substream substream)
core/src/main/java/io/grpc/internal/RetriableStream.java:298
↓ 19 callersMethodemptyCall
<pre> One empty request followed by one empty response. </pre>
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/TestServiceGrpc.java:339
↓ 19 callersMethodenqueue
Enqueue a write command on the channel. @param command a write to be executed on the channel. @param flush true if a flush of the write should be sch
netty/src/main/java/io/grpc/netty/WriteQueue.java:79
↓ 19 callersMethodeqMetricInstrumentName
(String name)
xds/src/test/java/io/grpc/xds/XdsClientMetricReporterImplTest.java:377
↓ 19 callersMethodexecutor
Provides a custom executor. <p>It's an optional parameter. If the user has not provided an executor when the server is built, the builder will use a
api/src/main/java/io/grpc/ServerBuilder.java:75
↓ 19 callersMethodflowControlWindow
Sets the flow control window in bytes. Setting flowControlWindow disables auto flow control tuning; use {@link #initialFlowControlWindow(int)} to enab
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:434
↓ 19 callersMethodforceCleanUp
Error already happened, try the best to clean up. Never throws.
testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java:217
↓ 19 callersMethodfromStruct
Returns a {@link StructOrError} for the successfully converted data object.
xds/src/main/java/io/grpc/xds/StructOrError.java:30
↓ 19 callersMethodgetCommonTlsContext
()
xds/src/main/java/io/grpc/xds/internal/security/SslContextProvider.java:73
↓ 19 callersMethodgetCount
()
xds/src/test/java/io/grpc/xds/StatefulFilter.java:125
↓ 19 callersMethodgetPendingStreamsCount
()
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:269
↓ 19 callersMethodgetValues
Returns the current set of received values.
testing/src/main/java/io/grpc/testing/StreamRecorder.java:100
↓ 19 callersMethodgetWatcher
(TrackedWatcherType<T> watcherType, String name)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:565
↓ 19 callersMethodgoogleGrpc
()
xds/src/main/java/io/grpc/xds/internal/grpcservice/GrpcServiceConfig.java:39
↓ 19 callersMethodheadersFrame
(int streamId, Http2Headers headers)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:297
↓ 19 callersMethodhttpConnectionManager
()
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:637
↓ 19 callersMethodisValid
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:813
↓ 19 callersMethodmakeAddress
Create a locality-labeled address.
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1081
↓ 19 callersMethodmatchRoute
Returns {@code true} iff the given {@link RouteMatch} matches the RPC's full method name and headers.
xds/src/main/java/io/grpc/xds/RoutingUtils.java:146
↓ 19 callersMethodname
Returns the field at {@code position} or null if that is out of range.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Headers.java:54
↓ 19 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/TestServiceGrpc.java:299
↓ 19 callersMethodnewBuilder
()
binder/src/main/java/io/grpc/binder/ServerSecurityPolicy.java:87
↓ 19 callersMethodnewCall
( MethodDescriptor<ReqT, RespT> method, CallOptions callOptions)
api/src/test/java/io/grpc/ClientInterceptorsTest.java:140
← previousnext →801–900 of 22,628, ranked by callers