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
↓ 19 callersMethodnewResolver
(String name, int defaultPort)
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:149
↓ 19 callersMethodnewServerContext
Factory method for the server-side.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:70
↓ 19 callersMethodopenStream
Creates a new {@link InputStream} backed by the given buffer. Any read taken on the stream will automatically increment the read position of this buff
core/src/main/java/io/grpc/internal/ReadableBuffers.java:109
↓ 19 callersMethodperMillion
(int numerator)
xds/src/main/java/io/grpc/xds/FaultConfig.java:116
↓ 19 callersMethodpickSubchannel
(PickSubchannelArgs args)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1196
↓ 19 callersMethodreadByte
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:339
↓ 19 callersMethodresolveTxt
(String host)
core/src/main/java/io/grpc/internal/DnsNameResolver.java:609
↓ 19 callersMethodsend
(HandshakerReq req)
alts/src/test/java/io/grpc/alts/internal/AltsTsiTest.java:161
↓ 19 callersMethodserver
(ServerCredentials creds)
okhttp/src/test/java/io/grpc/okhttp/TlsTest.java:744
↓ 19 callersMethodsetServiceConfig
Sets the Service Config parsed by {@link Args#getServiceConfigParser}. This field is optional. @since 1.21.0
api/src/main/java/io/grpc/NameResolver.java:932
↓ 19 callersMethodshouldUseJndi
( boolean jndiEnabled, boolean jndiLocalhostEnabled, String target)
core/src/main/java/io/grpc/internal/DnsNameResolver.java:685
↓ 19 callersMethodstatus
(CharSequence value)
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:543
↓ 19 callersMethodstream
()
netty/src/test/java/io/grpc/netty/NettyServerStreamTest.java:450
↓ 19 callersMethodvirtualHosts
()
xds/src/main/java/io/grpc/xds/HttpConnectionManager.java:40
↓ 19 callersMethodwaitForResponse
()
netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java:1263
↓ 18 callersMethodassertContainStream
(int streamId)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2237
↓ 18 callersMethodassertServiceConfigForLoadBalancingConfig
( List<String> clusters, ResolutionResult result)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:1842
↓ 18 callersMethodbytesRead
Called when the given number of bytes has been read from the input source of the deframer. This is typically used to indicate to the underlying transp
core/src/main/java/io/grpc/internal/MessageDeframer.java:61
↓ 18 callersMethodcleanUp
()
testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java:212
↓ 18 callersMethodcreateRds
(String name)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1965
↓ 18 callersMethodcurrentTimeNanos
Returns the current nano time.
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:384
↓ 18 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 {@link #regist
api/src/main/java/io/grpc/ServerRegistry.java:72
↓ 18 callersMethoddisallowExpression
If set, disallows any header that matches this regular expression. @see HeaderMutationRules#getDisallowExpression()
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationRulesConfig.java:48
↓ 18 callersMethoddroppedRequestsList
()
xds/src/main/java/io/grpc/xds/client/Stats.java:41
↓ 18 callersMethodempty
Returns an empty {@link ReadableBuffer} instance.
core/src/main/java/io/grpc/internal/ReadableBuffers.java:43
↓ 18 callersMethodfilterStateTestConfigs
(String... names)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1868
↓ 18 callersMethodforClient
Creates an SslContextBuilder with ciphers and APN appropriate for gRPC. @see SslContextBuilder#forClient() @see #configure(SslContextBuilder)
netty/src/main/java/io/grpc/netty/GrpcSslContexts.java:95
↓ 18 callersMethodforPort
Static factory for creating a new ServerBuilder. @param port the port to listen on @since 1.0.0
api/src/main/java/io/grpc/ServerBuilder.java:43
↓ 18 callersMethodgetChannelResource
Returns a {@link SharedResourceHolder.Resource} instance for managing channels to an S2A server running at {@code s2aAddress}. @param s2aAddress the
s2a/src/main/java/io/grpc/s2a/internal/channel/S2AHandshakerServiceChannel.java:60
↓ 18 callersMethodgetDefaultInstance
()
api/src/main/java/io/grpc/DecompressorRegistry.java:49
↓ 18 callersMethodgetDelay
(TimeUnit unit)
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:112
↓ 18 callersMethodgetInputStream
()
android/src/main/java/io/grpc/android/UdsSocket.java:101
↓ 18 callersMethodgetNegotiationLogger
Returns the channel logger for the given channel context.
netty/src/main/java/io/grpc/netty/GrpcHttp2ConnectionHandler.java:82
↓ 18 callersMethodgetOptionalLabelKeys
Returns a list of optional label keys for this metric instrument. @return a list of optional label keys.
api/src/main/java/io/grpc/MetricInstrument.java:66
↓ 18 callersMethodheader
(String key, String value, HeaderAppendAction action)
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutatorTest.java:75
↓ 18 callersMethodinitServerWithAuthzInterceptor
( ServerInterceptor authzInterceptor, ServerCredentials serverCredentials)
authz/src/test/java/io/grpc/authz/AuthorizationEnd2EndTest.java:83
↓ 18 callersMethodisAtBeginning
()
core/src/main/java/io/grpc/internal/InternalSubchannel.java:818
↓ 18 callersMethodloadClass
(String name, boolean resolve)
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:781
↓ 18 callersMethodmatches
Returns matching result for this address.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:306
↓ 18 callersMethodnewClientStreamTracer
( ClientStreamTracer.StreamInfo info, Metadata headers)
xds/src/test/java/io/grpc/xds/FakeControlPlaneXdsIntegrationTest.java:240
↓ 18 callersMethodnextDouble
()
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:110
↓ 18 callersMethodonServing
Callback invoked when server begins serving.
xds/src/main/java/io/grpc/xds/XdsServerBuilder.java:166
↓ 18 callersMethodoutboundMessage
(int seqNo)
census/src/main/java/io/grpc/census/CensusStatsModule.java:332
↓ 18 callersMethodparseConfig
(String json)
core/src/test/java/io/grpc/internal/AutoConfiguredLoadBalancerFactoryTest.java:684
↓ 18 callersMethodping
Pings a remote endpoint. When an acknowledgement is received, the given callback will be invoked using the given executor. <p>Pings are not necessari
core/src/main/java/io/grpc/internal/ClientTransport.java:72
↓ 18 callersMethodrequestConnection
()
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:569
↓ 18 callersMethodsetEagAttributes
Sets the non-null EquivalentAddressGroup's attributes.
core/src/main/java/io/grpc/internal/ClientTransportFactory.java:131
↓ 18 callersMethodsetFailure
Fail this object if it has not already been failed. <p>This method will NOT throw an {@link IllegalStateException} if called multiple times because t
alts/src/main/java/io/grpc/alts/internal/ProtectedPromise.java:109
↓ 18 callersMethodsetMetadata
(String metadataKey, String metadataValue)
xds/src/test/java/io/grpc/xds/MetadataLoadBalancerProvider.java:142
↓ 18 callersMethodstart
(Listener<RespT> observer, Metadata headers)
core/src/main/java/io/grpc/internal/ClientCallImpl.java:180
↓ 18 callersMethodstreamResponse
Serialize an outgoing response message. The returned InputStream should be closed by the caller. @param response the response message to serialize. @
api/src/main/java/io/grpc/MethodDescriptor.java:318
↓ 18 callersMethodtoRawQuery
Returns the "raw" query string representation of these parameters, suitable for passing to the {@link io.grpc.Uri.Builder#setRawQuery} method. @retur
api/src/main/java/io/grpc/QueryParams.java:127
↓ 17 callersMethodaddService
Registers a service. @return the previously registered service with the same service descriptor name if exists, otherwise {@code null}.
util/src/main/java/io/grpc/util/MutableHandlerRegistry.java:50
↓ 17 callersMethodallowExpression
If set, allows any header that matches this regular expression. @see HeaderMutationRules#getAllowExpression()
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationRulesConfig.java:41
↓ 17 callersMethodasciiName
()
api/src/main/java/io/grpc/Metadata.java:789
↓ 17 callersMethodassertResponse
( StreamingOutputCallResponse expected, StreamingOutputCallResponse actual)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:2003
↓ 17 callersMethodassertSameConfig
(ConfigOrError expected, ConfigOrError actual)
core/src/test/java/io/grpc/internal/ServiceConfigStateTest.java:449
↓ 17 callersMethodasyncUnaryCall
Creates a {@link ServerCallHandler} for a unary call method of the service. @param method an adaptor to the actual method on the service implementati
stub/src/main/java/io/grpc/stub/ServerCalls.java:49
↓ 17 callersMethodawaitCompletion
(long timeout, TimeUnit unit)
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:308
↓ 17 callersMethodbuffer
()
netty/src/test/java/io/grpc/netty/NettyWritableBufferTest.java:46
↓ 17 callersMethodcallback_ReportServerConnection
Invokes the callback, which will be called by {@link XdsClientMetricReporter} to record whether XdsClient has a working ADS stream.
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:659
↓ 17 callersMethodcaptureAttrHandler
( final SettableFuture<SslContextProviderSupplier> sslSet, final SettableFuture<AtomicRefe
xds/src/test/java/io/grpc/xds/FilterChainMatchingProtocolNegotiatorsTest.java:1242
↓ 17 callersMethodcheckAuthority
Verify {@code authority} is valid for use with gRPC. The syntax must be valid and it must not include userinfo. @return the {@code authority} provide
core/src/main/java/io/grpc/internal/GrpcUtil.java:534
↓ 17 callersMethodclose
Closes the stream for both reading and writing. A status code of {@link io.grpc.Status.Code#OK} implies normal termination of the stream. Any other va
core/src/main/java/io/grpc/internal/ServerStream.java:53
↓ 17 callersMethodclose
Unregister.
api/src/main/java/io/grpc/MetricRecorder.java:176
↓ 17 callersMethodcreateAndRegisterProviderProvider
( CertificateProviderRegistry certificateProviderRegistry, final CertificateProvider.DistributorWa
xds/src/test/java/io/grpc/xds/internal/security/ClientSslContextProviderFactoryTest.java:287
↓ 17 callersMethodcreateForClient
( S2AStub stub, String hostname, Optional<S2AIdentity> localIdentity)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2ATrustManager.java:46
↓ 17 callersMethodcreateSubchannel
(CreateSubchannelArgs args)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2937
↓ 17 callersMethodcurrent
()
contextstorage/src/main/java/io/grpc/override/ContextStorageOverride.java:42
↓ 17 callersMethoddelegate
Returns the underlying {@code ClientStreamTracer}.
core/src/main/java/io/grpc/internal/ForwardingClientStreamTracer.java:30
↓ 17 callersMethoddelegate
Returns the underlying {@code ClientStreamTracer}.
util/src/main/java/io/grpc/util/ForwardingClientStreamTracer.java:29
↓ 17 callersMethodfill
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:441
↓ 17 callersMethodforBindIntent
Creates a new address that uses the "filter matching" fields of <code>intent</code> as the binding {@link Intent}. <p><code>intent</code> must be "ex
binder/src/main/java/io/grpc/binder/AndroidComponentAddress.java:112
↓ 17 callersMethodfromMetricSpecs
Creates a BackendMetricPropagation from a list of metric specifications. @param metricSpecs list of metric specification strings from CDS resource @r
xds/src/main/java/io/grpc/xds/client/BackendMetricPropagation.java:59
↓ 17 callersMethodgetBootstrapInfo
Returns the config used to bootstrap this XdsClient {@link Bootstrapper.BootstrapInfo}.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:319
↓ 17 callersMethodgetChild
(WeightedRoundRobinPicker picker, int index)
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:437
↓ 17 callersMethodgetChildProvider
(Object config)
util/src/testFixtures/java/io/grpc/util/GracefulSwitchLoadBalancerAccessor.java:29
↓ 17 callersMethodgetInstance
()
opentelemetry/src/main/java/io/grpc/opentelemetry/BinaryFormat.java:89
↓ 17 callersMethodgetPolicyName
()
core/src/main/java/io/grpc/internal/ServiceConfigUtil.java:381
↓ 17 callersMethodgetRealStream
()
core/src/main/java/io/grpc/internal/DelayedStream.java:450
↓ 17 callersMethodgetRetriedNameResolver
Used to get the underlying {@link NameResolver} that is getting its failed attempts retried.
core/src/main/java/io/grpc/internal/RetryingNameResolver.java:74
↓ 17 callersMethodgetStatus
Returns the status code as a {@link Status} object. @since 1.0.0
api/src/main/java/io/grpc/StatusRuntimeException.java:60
↓ 17 callersMethodhashVoid
()
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:95
↓ 17 callersMethodisDone
()
core/src/test/java/io/grpc/internal/ManagedChannelOrphanWrapperTest.java:82
↓ 17 callersMethodisEnableCloudLogging
Is Cloud Logging enabled.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:29
↓ 17 callersMethodisEnableCloudTracing
Is Cloud Tracing enabled.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:35
↓ 17 callersMethodisInProgress
Returns true if and only if the handshake is still in progress. @return true, if the handshake is still in progress, false otherwise.
alts/src/main/java/io/grpc/alts/internal/TsiHandshaker.java:75
↓ 17 callersMethodisPending
()
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:602
↓ 17 callersMethodlog
(ChannelLogLevel level, String msg)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:165
↓ 17 callersMethodlookupMethod
Note: This does not actually honor the authority provided. It will, eventually in the future.
util/src/main/java/io/grpc/util/MutableHandlerRegistry.java:87
↓ 17 callersMethodname
(int i)
api/src/main/java/io/grpc/Metadata.java:154
↓ 17 callersMethodnewBuilder
()
binder/src/test/java/io/grpc/binder/internal/ServiceBindingTest.java:90
↓ 17 callersMethodnewLoadBalancer
(Helper helper)
core/src/test/java/io/grpc/internal/AutoConfiguredLoadBalancerFactoryTest.java:799
↓ 17 callersMethodonTransportTermination
Transport is being terminated. We no longer need to do keepalives.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:222
↓ 17 callersMethodparseConfig
(String json)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4740
↓ 17 callersMethodparseHttpConnectionManager
( HttpConnectionManager proto, FilterRegistry filterRegistry, boolean isForClient, XdsResourceType
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:494
↓ 17 callersMethodreaderHeaderTableLength
()
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java:1192
↓ 17 callersMethodrecordBackendLoadMetricStats
Records all custom named backend load metric stats for per-call load reporting. For each metric key {@code name}, creates a new {@link BackendLoadMetr
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:385
↓ 17 callersMethodrefreshNameResolution
()
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1252
↓ 17 callersMethodscheme
The HTTP/2 scheme to be used when sending {@code HEADERS}.
netty/src/main/java/io/grpc/netty/ProtocolNegotiator.java:32
← previousnext →901–1,000 of 22,628, ranked by callers