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
↓ 13 callersMethodtotalRequestsInProgress
()
xds/src/main/java/io/grpc/xds/client/Stats.java:107
↓ 13 callersMethodtransportState
()
netty/src/main/java/io/grpc/netty/NettyClientStream.java:97
↓ 13 callersMethodupdateState
Registers and updates state for given subchannel. {@link ConnectivityState#SHUTDOWN} unregisters the subchannel.
rls/src/main/java/io/grpc/rls/SubchannelStateManager.java:32
↓ 13 callersMethodverifyLongCounterAdd
(String name, int times, long value, String dataPlaneTargetLabel, String pickResult)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:685
↓ 13 callersMethodwithLogId
(InternalLogId logId)
xds/src/main/java/io/grpc/xds/client/XdsLogger.java:37
↓ 12 callersMethodacceptAddresses
(List<EquivalentAddressGroup> eagList, Attributes attrs)
util/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java:124
↓ 12 callersMethodaddAnnotation
(String description, Map<String, AttributeValue> attributes)
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:351
↓ 12 callersMethodaddClientFeatures
(String clientFeature)
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:200
↓ 12 callersMethodaddCluster
(String name, StatusOr<XdsClusterConfig> clusterConfig)
xds/src/main/java/io/grpc/xds/XdsConfig.java:236
↓ 12 callersMethodaddHeader
(AsciiString value, byte[] nameBytes, byte[] valueBytes)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:131
↓ 12 callersMethodaddRootChannel
Adds a root channel.
api/src/main/java/io/grpc/InternalChannelz.java:91
↓ 12 callersMethodaddService
(ServerServiceDefinition service)
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:142
↓ 12 callersMethodarrayOffset
Gets the offset in the backing array of the current read position. This is an optional method, so callers should first check {@link #hasArray} @throw
core/src/main/java/io/grpc/internal/ReadableBuffer.java:116
↓ 12 callersMethodassertCallSelectClusterResult
( CallInfo call, InternalConfigSelector configSelector, String expectedCluster, @Nullable Double e
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:1760
↓ 12 callersMethodassertCodeEquals
Only assert that the Status.Code matches, but provide the entire actual result in case the assertion fails.
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:2125
↓ 12 callersMethodassertCurrentPickerIsBufferPicker
()
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1037
↓ 12 callersMethodbecomeConnected
Sets the actual sink. It is allowed to call write / flush operations on the sink iff calling this method is scheduled in the executor. The socket is n
okhttp/src/main/java/io/grpc/okhttp/AsyncSink.java:88
↓ 12 callersMethodbuild
Returns a new stub with the given channel for the provided method configurations. @since 1.0.0 @param channel the channel that this stub will use to
stub/src/main/java/io/grpc/stub/AbstractStub.java:105
↓ 12 callersMethodbuildWeightedTargetConfig
(Map<Locality, Integer> localityWeights)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1067
↓ 12 callersMethodbyteStream
(int... bytes)
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java:1168
↓ 12 callersMethodcancelXdsResourceWatch
(XdsResourceType<T> type, String resourceNam
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2577
↓ 12 callersMethodcheckReadable
(int length)
core/src/main/java/io/grpc/internal/AbstractReadableBuffer.java:76
↓ 12 callersMethodcheckServerTrusted
(X509Certificate[] chain, String authType, Socket socket)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsX509TrustManager.java:259
↓ 12 callersMethodclosed
Called when the stream is fully closed. {@link io.grpc.Status.Code#OK} is the only status code that is guaranteed to have been sent from the remote se
core/src/main/java/io/grpc/internal/ClientStreamListener.java:49
↓ 12 callersMethodclusterType
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:583
↓ 12 callersMethodcreate
Create a new instance. @param method the {@link MethodDescriptor} for this method. @param handler to dispatch calls to. @return a new instance.
api/src/main/java/io/grpc/ServerMethodDefinition.java:41
↓ 12 callersMethodcreate
( String name, long weight, Map<String, FilterConfig> filterConfigOverrides)
xds/src/main/java/io/grpc/xds/VirtualHost.java:225
↓ 12 callersMethodcreate
(Matcher matcher)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:495
↓ 12 callersMethodcreateWithDefault
Factory method for creating instances of {@link Key}. @param debugString a debug string that describes this key. @param defaultValue default value to
api/src/main/java/io/grpc/CallOptions.java:387
↓ 12 callersMethoddeframerClosed
Called when the deframer closes. @param hasPartialMessage whether the deframer contained an incomplete message at closing.
core/src/main/java/io/grpc/internal/MessageDeframer.java:75
↓ 12 callersMethoddelegate
Returns the delegated {@code ServerCall}.
api/src/main/java/io/grpc/PartialForwardingServerCall.java:29
↓ 12 callersMethodeagAttrsWithToken
(String token)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2347
↓ 12 callersMethodequals
(Object other)
core/src/main/java/io/grpc/internal/RetryPolicy.java:71
↓ 12 callersMethodequals
(Object o)
api/src/test/java/io/grpc/MetadataTest.java:481
↓ 12 callersMethodfilterStateTestVhost
()
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1883
↓ 12 callersMethodforAddress
Creates a channel with the target's address and port number. <p>Note that there is an open JDK bug on {@link java.net.URI} class parsing an ipv6 scop
api/src/main/java/io/grpc/ManagedChannelBuilder.java:43
↓ 12 callersMethodfromThrowable
Extract a {@link com.google.rpc.Status} instance from the causal chain of a {@link Throwable}. @return the extracted {@link com.google.rpc.Status} in
protobuf/src/main/java/io/grpc/protobuf/StatusProto.java:152
↓ 12 callersMethodget
(CharSequence csName)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:374
↓ 12 callersMethodgetAddressesOrThrow
(ResolutionResult result)
binder/src/test/java/io/grpc/binder/internal/IntentNameResolverTest.java:477
↓ 12 callersMethodgetChildPolicyWrapper
()
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:573
↓ 12 callersMethodgetClient
()
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:53
↓ 12 callersMethodgetClusterLocalityStats
Gets or creates the stats object for recording loads for the specified locality (in the specified cluster with edsServiceName) with the specified back
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:109
↓ 12 callersMethodgetCurrentPicker
()
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:309
↓ 12 callersMethodgetDefaultRegistry
Returns the default metric instrument registry.
api/src/main/java/io/grpc/MetricInstrumentRegistry.java:53
↓ 12 callersMethodgetEagAttributes
()
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:650
↓ 12 callersMethodgetError
()
core/src/main/java/io/grpc/internal/FailingClientStream.java:64
↓ 12 callersMethodgetMeasure
()
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricSink.java:333
↓ 12 callersMethodgetNumFilteredPendingTasks
()
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:1624
↓ 12 callersMethodgetNumber
()
core/src/test/java/io/grpc/internal/JsonUtilTest.java:32
↓ 12 callersMethodgetNumberAsFloat
Gets a number from an object for the given key. If the key is not present, this returns null. If the value does not represent a float, throws an exce
core/src/main/java/io/grpc/internal/JsonUtil.java:128
↓ 12 callersMethodgetPeerCertificates
()
core/src/main/java/io/grpc/internal/NoopSslSession.java:83
↓ 12 callersMethodgetResult
Returns the result data of the handshake, if the handshake is completed.
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerClient.java:128
↓ 12 callersMethodgetSchemaDescriptor
Returns the schema descriptor for this method. A schema descriptor is an object that is not used by gRPC core but includes information related to the
api/src/main/java/io/grpc/MethodDescriptor.java:350
↓ 12 callersMethodgetServerCallInfo
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:188
↓ 12 callersMethodgetServers
<pre> Gets all servers that exist in the process. </pre>
services/src/generated/main/grpc/io/grpc/channelz/v1/ChannelzGrpc.java:319
↓ 12 callersMethodgetSocket
<pre> Returns a single Socket or else a NOT_FOUND code. </pre>
services/src/generated/main/grpc/io/grpc/channelz/v1/ChannelzGrpc.java:369
↓ 12 callersMethodgetStatus
Returns the status of the config selection operation. If status is not {@link Status#OK}, this result should not be used.
api/src/main/java/io/grpc/InternalConfigSelector.java:66
↓ 12 callersMethodgetStreamCoreMetricsMethod
()
xds/src/generated/thirdparty/grpc/com/github/xds/service/orca/v3/OpenRcaServiceGrpc.java:28
↓ 12 callersMethodgetSubscribedResources
( ServerInfo serverInfo, XdsResourceType<? extends ResourceUpdate> type)
xds/src/main/java/io/grpc/xds/client/XdsClient.java:483
↓ 12 callersMethodgetSubscribedResourcesMetadataSnapshot
()
xds/src/test/java/io/grpc/xds/CsdsServiceTest.java:139
↓ 12 callersMethodgetSynchronizationContext
()
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:797
↓ 12 callersMethodgrpcInit
Initialize grpc-observability. @throws ProviderNotFoundException if no underlying channel/server provider is available.
gcp-observability/src/main/java/io/grpc/gcp/observability/GcpObservability.java:95
↓ 12 callersMethodgrpcResponseHeaders
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2294
↓ 12 callersMethodhttpFilterConfigs
()
xds/src/main/java/io/grpc/xds/HttpConnectionManager.java:44
↓ 12 callersMethodinState
(TransportState transportState)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:265
↓ 12 callersMethodinject
(Context context, @Nullable C carrier, TextMapSetter<C> setter)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagator.java:74
↓ 12 callersMethodintercept
(ServerInterceptor interceptor)
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:159
↓ 12 callersMethodisIdempotent
Returns whether this method is idempotent. @since 1.0.0
api/src/main/java/io/grpc/MethodDescriptor.java:359
↓ 12 callersMethodkeys
Returns set of all keys in store. @return unmodifiable Set of keys
api/src/main/java/io/grpc/Metadata.java:323
↓ 12 callersMethodlbAuthority
(int unused)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2791
↓ 12 callersMethodlistener
()
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:641
↓ 12 callersMethodmarkSupported
Indicates whether or not {@link #mark} operation is supported for this buffer.
core/src/main/java/io/grpc/internal/ReadableBuffer.java:129
↓ 12 callersMethodnewHandshakers
()
alts/src/test/java/io/grpc/alts/internal/FakeTsiTest.java:60
↓ 12 callersMethodnewHandshakers
()
alts/src/test/java/io/grpc/alts/internal/AltsTsiTest.java:80
↓ 12 callersMethodnewNameResolver
( NameResolver.Factory factory, String uriString, NameResolver.Args args)
xds/src/test/java/io/grpc/xds/XdsNameResolverProviderTest.java:185
↓ 12 callersMethodnewPriorityChildConfig
( LoadBalancerProvider provider, Object config, boolean ignoreRefresh)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1051
↓ 12 callersMethodnewStub
Creates a new async stub that supports all call types for the service
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/TestServiceGrpc.java:270
↓ 12 callersMethodnumerator
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:197
↓ 12 callersMethodonTransportIdle
Transport has finished all streams.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:207
↓ 12 callersMethodparse
Parses the given {@link Any} object into a specific metadata value. @param any the {@link Any} object to parse. @return the parsed metadata value. @t
xds/src/main/java/io/grpc/xds/MetadataRegistry.java:123
↓ 12 callersMethodparseJsonObject
(String json)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerProviderTest.java:225
↓ 12 callersMethodparseServerSideListener
( Listener proto, TlsContextManager tlsContextManager, FilterRegistry filterRegistry, Set<String>
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:144
↓ 12 callersMethodpercent
()
xds/src/main/java/io/grpc/xds/FaultConfig.java:57
↓ 12 callersMethodperformHandshake
Performs a handshake between the client handshaker and server handshaker using a transport of length transportBufferSize.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:80
↓ 12 callersMethodputNextResult
Provides the next value to return from {@link #decorate}.
binder/src/testFixtures/java/io/grpc/binder/internal/OneWayBinderProxies.java:59
↓ 12 callersMethodrecordDroppedRequest
Records a dropped request with the specified category.
xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:276
↓ 12 callersMethodregister
Register a provider. <p>If the provider's {@link XdsCredentialsProvider#isAvailable isAvailable()} returns {@code false}, this method will throw {@li
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:67
↓ 12 callersMethodrequestConnection
()
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:882
↓ 12 callersMethodsendMessage
Sends a message between the sender and receiver.
alts/src/test/java/io/grpc/alts/internal/TsiTest.java:119
↓ 12 callersMethodsetCallOptions
Sets the effective CallOptions of the call. This field is optional.
api/src/main/java/io/grpc/ClientStreamTracer.java:230
↓ 12 callersMethodsetException
(Exception e)
binder/src/testFixtures/java/io/grpc/binder/internal/MainThreadScheduledExecutorService.java:190
↓ 12 callersMethodsetHeaders
Sets custom HTTP headers to be sent during the HTTP CONNECT handshake. This is an optional field. The headers will be sent in addition to any authenti
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:179
↓ 12 callersMethodsetOnReadyThreshold
A hint to the stream that specifies how many bytes must be queued before {@link #isReady()} will return false. A stream may ignore this property if un
core/src/main/java/io/grpc/internal/ServerStream.java:109
↓ 12 callersMethodsetResolvedAtStart
(boolean resolvedAtStart)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4625
↓ 12 callersMethodsetUsername
Sets the username used to connect to the proxy. This is an optional field and can be {@code null}.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:190
↓ 12 callersMethodsetVirtualHost
(VirtualHost virtualHost)
xds/src/main/java/io/grpc/xds/XdsConfig.java:243
↓ 12 callersMethodstartXdsDepManager
()
xds/src/test/java/io/grpc/xds/CdsLoadBalancer2Test.java:614
↓ 12 callersMethodstreamError
Respond with RST_STREAM, making sure to kill the associated stream if it exists. Reason will rarely be seen. RFC7540 §5.4.2.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:1053
↓ 12 callersMethodtoAsciiString
(Long timeoutNanosObject)
core/src/main/java/io/grpc/internal/GrpcUtil.java:659
↓ 12 callersMethodtransportState
()
servlet/src/main/java/io/grpc/servlet/ServletServerStream.java:88
← previousnext →1,301–1,400 of 22,628, ranked by callers