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
↓ 24 callersMethodforAddress
Creates a new builder for the given server host and port.
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:159
↓ 24 callersMethodgetAll
(CharSequence csName)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:436
↓ 24 callersMethodgetDefaultPickSubchannelArgs
(long rpcHash)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:614
↓ 24 callersMethodgetMeasuresSize
Returns size of metric measures used to record metric values. These measures are created based on registered metrics (via MetricInstrumentRegistry) an
api/src/main/java/io/grpc/MetricSink.java:50
↓ 24 callersMethodgetPort
()
interop-testing/src/test/java/io/grpc/testing/integration/TrafficControlProxy.java:106
↓ 24 callersMethodgetRequestMetadata
(URI uri)
auth/src/main/java/io/grpc/auth/ClientAuthInterceptor.java:131
↓ 24 callersMethodgotoState
(final ConnectivityStateInfo newState)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:357
↓ 24 callersMethodmatchHostName
Returns {@code true} iff {@code hostName} matches the domain name {@code pattern} with case-insensitive. <p>Wildcard pattern rules: <ol> <li>A single
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:361
↓ 24 callersMethodnewClientStreamTracer
(StreamInfo info, Metadata metadata)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:376
↓ 24 callersMethodnewCreateStreamCommand
( Http2Headers headers, NettyClientStream.TransportState stream)
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:1183
↓ 24 callersMethodparseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
xds/src/test/java/io/grpc/xds/MetadataLoadBalancerProvider.java:42
↓ 24 callersMethodrecord
(TagContext tags)
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:246
↓ 24 callersMethodregisterBatchCallback
Registers a callback to produce metric values for only the listed instruments. The returned registration must be closed when no longer needed, which w
api/src/main/java/io/grpc/MetricSink.java:134
↓ 24 callersMethodreprocess
Called when it's ready to create a real call and reprocess the pending call.
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:999
↓ 24 callersMethodsetEdsConfig
(ClusterLoadAssignment clusterLoadAssignment)
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:229
↓ 24 callersMethodsetMaxInboundMessageSize
(int messageSize)
core/src/main/java/io/grpc/internal/Deframer.java:24
↓ 24 callersMethodsetPort
Specifies the "port" component of the new URI, e.g. "8080". <p>The port can be any non-negative integer. A negative value represents "no port". <p>T
api/src/main/java/io/grpc/Uri.java:972
↓ 24 callersMethodtransportState
()
core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java:412
↓ 24 callersMethodupdateMeasures
(List<MetricInstrument> instruments)
api/src/main/java/io/grpc/MetricSink.java:141
↓ 24 callersMethodwithAad
(String aad)
alts/src/test/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypterTest.java:90
↓ 24 callersMethodwithCiphertext
(String ciphertext)
alts/src/test/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypterTest.java:100
↓ 24 callersMethodwithComment
(String comment)
alts/src/test/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypterTest.java:75
↓ 24 callersMethodwithKey
(String key)
alts/src/test/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypterTest.java:80
↓ 24 callersMethodwithNonce
(String nonce)
alts/src/test/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypterTest.java:85
↓ 24 callersMethodwithPlaintext
(String plaintext)
alts/src/test/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypterTest.java:95
↓ 23 callersMethodbuildOpaqueVirtualHosts
(int num)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5313
↓ 23 callersMethodcheckAndReloadCertificates
()
xds/src/main/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProvider.java:112
↓ 23 callersMethodcloseQuietly
Quietly closes all messages in MessageProducer.
core/src/main/java/io/grpc/internal/GrpcUtil.java:788
↓ 23 callersMethoddeliverSubchannelState
(Subchannel subchannel, ConnectivityStateInfo newState)
xds/src/test/java/io/grpc/xds/LeastRequestLoadBalancerTest.java:635
↓ 23 callersMethodequals
(Object that)
netty/src/main/java/io/grpc/netty/SendGrpcFrameCommand.java:62
↓ 23 callersMethodgetAllAddresses
()
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:887
↓ 23 callersMethodgetAndResetHeaderList
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:238
↓ 23 callersMethodgetExecutor
Returns an executor to handle the server call. It should never throw. It should return null to fallback to the default executor.
api/src/main/java/io/grpc/ServerCallExecutorSupplier.java:32
↓ 23 callersMethodgetMetricInstruments
Returns a list of registered metric instruments.
api/src/main/java/io/grpc/MetricInstrumentRegistry.java:63
↓ 23 callersMethodgetPath
Returns the (possibly empty) percent-decoded "path" component of this URI. <p>NB: This method assumes the path was encoded as UTF-8, although RFC 398
api/src/main/java/io/grpc/Uri.java:476
↓ 23 callersMethodgetServiceRegistry
Returns the service registry for this service. The registry is used to add service instances (e.g. {@link BindableService} or {@link ServerServiceDefi
testing/src/main/java/io/grpc/testing/GrpcServerRule.java:93
↓ 23 callersMethodgetStub
()
authz/src/test/java/io/grpc/authz/AuthorizationEnd2EndTest.java:102
↓ 23 callersMethodgetSynchronizationContext
()
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:666
↓ 23 callersMethodisEnabledNewPickFirst
()
core/src/main/java/io/grpc/internal/PickFirstLoadBalancerProvider.java:92
↓ 23 callersMethodloadX509Cert
Loads an X.509 certificate from the classpath resources in src/main/resources/certs. @param fileName name of a file in src/main/resources/certs. @d
testing/src/main/java/io/grpc/testing/TestUtils.java:99
↓ 23 callersMethodparse
( GrpcService grpcServiceProto, BootstrapInfo bootstrapInfo, ServerInfo serverInfo)
xds/src/test/java/io/grpc/xds/GrpcServiceConfigParserTest.java:88
↓ 23 callersMethodpriority
Called when reading a headers or priority frame. This may be used to change the stream's weight from the default (16) to a new value. @param streamId
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:100
↓ 23 callersMethodrecordDoubleHistogram
Records a value for a double-precision histogram metric associated with specified metric instrument. @param metricInstrument The histogram metric ins
api/src/main/java/io/grpc/MetricSink.java:99
↓ 23 callersMethodsetStream
(ClientStream stream)
core/src/main/java/io/grpc/internal/DelayedStream.java:136
↓ 23 callersMethodsetSynchronizationContext
See {@link Args#getSynchronizationContext}. This is a required field. @since 1.21.0
api/src/main/java/io/grpc/NameResolver.java:611
↓ 23 callersMethodtoString
()
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:215
↓ 23 callersMethodusePlaintext
Use of a plaintext connection to the server. By default a secure connection mechanism such as TLS will be used. <p>Should only be used for testing or
api/src/main/java/io/grpc/ManagedChannelBuilder.java:230
↓ 23 callersMethodwithCallCredentials
Returns a new {@code CallOptions} with the given call credentials.
api/src/main/java/io/grpc/CallOptions.java:139
↓ 22 callersMethodaccept
Records instrument values into {@code recorder}.
api/src/main/java/io/grpc/MetricRecorder.java:147
↓ 22 callersMethodactiveStreamCount
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2229
↓ 22 callersMethodaddAndGet
(long newBytesUsed)
core/src/main/java/io/grpc/internal/RetriableStream.java:1460
↓ 22 callersMethodarray
Gets the backing array for this buffer. This is an optional method, so callers should first check {@link #hasArray}. @throws UnsupportedOperationExce
core/src/main/java/io/grpc/internal/ReadableBuffer.java:108
↓ 22 callersMethodasyncServerStreamingCall
Executes a server-streaming call with a response {@link StreamObserver}. The {@code call} should not be already started. After calling this method,
stub/src/main/java/io/grpc/stub/ClientCalls.java:95
↓ 22 callersMethodaugmentDescription
Create a derived instance of {@link Status} augmenting the current description with additional detail. Leading and trailing whitespace may be removed
api/src/main/java/io/grpc/Status.java:478
↓ 22 callersMethodbuildClusterLoadAssignment
(String cluster, List<Message> localityLbEndpoints, List<Message> dropOverloads)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5348
↓ 22 callersMethodcreate
( @Nullable FaultDelay faultDelay, @Nullable FaultAbort faultAbort, @Nullable Integer maxActiveFau
xds/src/main/java/io/grpc/xds/FaultConfig.java:43
↓ 22 callersMethodcreateOrGetProvider
Creates or retrieves a {@link CertificateProvider} instance, increments its ref-count and registers the watcher passed. Returns a {@link Handle} that
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProviderStore.java:159
↓ 22 callersMethodcreateSubchannel
(CreateSubchannelArgs args)
util/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java:471
↓ 22 callersMethoddelegate
Returns the underlying helper.
util/src/main/java/io/grpc/util/ForwardingLoadBalancerHelper.java:43
↓ 22 callersMethoddeliverSubchannelState
(final int index, final ConnectivityStateInfo newState)
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1428
↓ 22 callersMethoddeliverSubchannelState
(Subchannel subchannel, ConnectivityStateInfo newState)
util/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java:575
↓ 22 callersMethoddeliverSubchannelState
(final int index, final ConnectivityStateInfo newState)
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:763
↓ 22 callersMethodforAddress
Creates a server builder configured with the given {@link SocketAddress}. @param address the socket address on which the server is to be bound. @retu
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:148
↓ 22 callersMethodforTarget
Creates a new builder with the given target string that will be resolved by {@link io.grpc.NameResolver}.
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:170
↓ 22 callersMethodgetCurrentState
()
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:314
↓ 22 callersMethodgetDefault
Returns the user supplied default value for this key.
api/src/main/java/io/grpc/CallOptions.java:338
↓ 22 callersMethodgetDefaultRegistry
Returns the default registry that loads providers via the Java service loader mechanism.
api/src/main/java/io/grpc/NameResolverRegistry.java:125
↓ 22 callersMethodgetState
Returns the current state. The state instance's value does not change of time.
core/src/main/java/io/grpc/internal/AtomicBackoff.java:43
↓ 22 callersMethodgetX509Certificates
Generates X509Certificate array from a PEM file. The PEM file should contain one or more items in Base64 encoding, each with plain-text headers and fo
util/src/main/java/io/grpc/util/CertificateUtils.java:50
↓ 22 callersMethodinterceptors
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:945
↓ 22 callersMethodisEmpty
()
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:38
↓ 22 callersMethodisFinished
Returns true if the handshake is complete.
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerClient.java:110
↓ 22 callersMethodlog
(ChannelLogLevel level, String msg)
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:853
↓ 22 callersMethodnewLoadBalancer
(Helper helper)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:255
↓ 22 callersMethodnewNegotiator
()
netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java:1079
↓ 22 callersMethodonQualifiedFailureThenCheckIsAboveThreshold
Counts down the token on qualified failure and checks if it is above the threshold atomically. Qualified failure is a failure with a retryable or non-
core/src/main/java/io/grpc/internal/RetriableStream.java:1510
↓ 22 callersMethodparseLoadBalancingPolicyConfig
( Map<String, ?> rawLoadBalancingPolicyConfig)
core/src/test/java/io/grpc/internal/AutoConfiguredLoadBalancerFactoryTest.java:804
↓ 22 callersMethodregisterLongCounter
Registers a new Long Counter metric instrument. @param name the name of the metric @param description a description of the metric @param unit the uni
api/src/main/java/io/grpc/MetricInstrumentRegistry.java:121
↓ 22 callersMethodsetDefaultPort
See {@link Args#getDefaultPort}. This is a required field. @since 1.21.0
api/src/main/java/io/grpc/NameResolver.java:591
↓ 22 callersMethodsetProxyDetector
See {@link Args#getProxyDetector}. This is required field. @since 1.21.0
api/src/main/java/io/grpc/NameResolver.java:601
↓ 22 callersMethodsetServiceConfigParser
See {@link Args#getServiceConfigParser}. This is a required field. @since 1.21.0
api/src/main/java/io/grpc/NameResolver.java:631
↓ 22 callersMethodsetSignatures
(Signature... signatures)
binder/src/test/java/io/grpc/binder/SecurityPoliciesTest.java:483
↓ 22 callersMethodtoString
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpServer.java:181
↓ 22 callersMethodtotalDroppedRequests
()
xds/src/main/java/io/grpc/xds/client/Stats.java:43
↓ 22 callersMethodunwrapLoadBalancingConfig
Unwrap a LoadBalancingConfig JSON object into a {@link LbConfig}. The input is a JSON object (map) with exactly one entry, where the key is the polic
core/src/main/java/io/grpc/internal/ServiceConfigUtil.java:311
↓ 22 callersMethodupdateBalancingState
( @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:764
↓ 22 callersMethodupdateState
(ConnectivityStateInfo newState)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1304
↓ 22 callersMethodverifyResourceValidInvalidCount
Verifies that the {@link XdsClientMetricReporter#reportResourceUpdates} method has been called the expected number of times with the expected values f
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:639
↓ 21 callersMethodaddLongUpDownCounter
Adds a value for a long valued up down counter metric associated with specified metric instrument. @param metricInstrument The counter metric inst
api/src/main/java/io/grpc/MetricSink.java:85
↓ 21 callersMethodas
(String string)
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:1179
↓ 21 callersMethodawaitTrailers
Returns response trailers from the server or throws {@link java.util.concurrent.TimeoutException} if they aren't delivered before the timeout. <p>Cal
core/src/testFixtures/java/io/grpc/internal/ClientStreamListenerBase.java:69
↓ 21 callersMethodbuildUpstreamTlsContext
Helper method to build UpstreamTlsContext for above tests. Called from other classes as well.
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:155
↓ 21 callersMethodempty
()
xds/src/main/java/io/grpc/xds/client/AllowedGrpcServices.java:38
↓ 21 callersMethodencode
(String s)
api/src/main/java/io/grpc/QueryParams.java:281
↓ 21 callersMethodexecute
(Runnable command)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:2082
↓ 21 callersMethodfromServiceConfig
Parses the Channel level config values (e.g. excludes load balancing)
core/src/main/java/io/grpc/internal/ManagedChannelServiceConfig.java:89
↓ 21 callersMethodgetAddresses
Gets the server addresses. @since 1.21.0
api/src/main/java/io/grpc/LoadBalancer.java:258
↓ 21 callersMethodgetBytesToSendToPeer
Gets bytes that need to be sent to the peer. @param bytes The buffer to put handshake bytes.
alts/src/main/java/io/grpc/alts/internal/TsiHandshaker.java:59
↓ 21 callersMethodgetCredentials
Returns the call credentials.
api/src/main/java/io/grpc/CallOptions.java:283
↓ 21 callersMethodgetData
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:613
← previousnext →701–800 of 22,628, ranked by callers