Functions — github.com/grpc/grpc-java

hub / github.com/grpc/grpc-java / functions

Functions22,628 in github.com/grpc/grpc-java

⨍ Functions 22,628◇ Types & classes 3,835

MethodClosedByNotFoundCompressor

()

core/src/main/java/io/grpc/internal/ClientCallImpl.java:222

MethodCloser

{@code closer} may be run multiple times.

xds/src/main/java/io/grpc/xds/FilterChainSelectorManager.java:85

MethodClusterDropStats

( String clusterName, @Nullable String edsServiceName, Stopwatch stopwatch)

xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:265

MethodClusterDropStatsSnapshot

( Map<String, Long> categorizedDrops, long uncategorizedDrops, long durationNano)

xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:319

MethodClusterImplConfig

(String cluster, @Nullable String edsServiceName, @Nullable ServerInfo lrsServerInfo, @Nullable Long m

xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancerProvider.java:105

MethodClusterImplLbHelper

(AtomicLong inFlights, @Nullable ServerInfo lrsServerInfo)

xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:214

MethodClusterImplLoadBalancer

(Helper helper)

xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:107

MethodClusterImplSubchannel

( Subchannel delegate, AtomicReference<ClusterLocality> localityAtomicReference)

xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:261

MethodClusterLocality

(ClusterLocalityStats localityStats, String localityName)

xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:555

MethodClusterLocalityStats

( String clusterName, @Nullable String edsServiceName, Locality locality, Stopwatch stopwatch,

xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:346

MethodClusterLocalityStatsSnapshot

( long callsSucceeded, long callsInProgress, long callsFailed, long callsIssued, long duration

xds/src/main/java/io/grpc/xds/client/LoadStatsManager2.java:460

MethodClusterManagerConfig

(Map<String, Object> childPolicies)

xds/src/main/java/io/grpc/xds/ClusterManagerLoadBalancerProvider.java:116

MethodClusterManagerLbState

(Object key, LoadBalancer.Factory policyFactory)

xds/src/main/java/io/grpc/xds/ClusterManagerLoadBalancer.java:189

MethodClusterManagerLoadBalancer

(Helper helper)

xds/src/main/java/io/grpc/xds/ClusterManagerLoadBalancer.java:62

MethodClusterManagerLoadBalancerProvider

()

xds/src/main/java/io/grpc/xds/ClusterManagerLoadBalancerProvider.java:47

MethodClusterNameMatcher

(List<String> expectedNames)

xds/src/test/java/io/grpc/xds/XdsDependencyManagerTest.java:1040

MethodClusterRefState

( AtomicInteger refCount, @Nullable String traditionalCluster, @Nullable RlsPluginConfig rlsPl

xds/src/main/java/io/grpc/xds/XdsNameResolver.java:1003

MethodClusterResolutionResult

(List<EquivalentAddressGroup> addresses, Map<String, PriorityChildConfig> configs, List<String> priori

xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:496

MethodClusterSpecifierPluginRegistry

()

xds/src/main/java/io/grpc/xds/ClusterSpecifierPluginRegistry.java:29

MethodClusterSubscription

(String clusterName)

xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:533

MethodCode

(int value)

api/src/main/java/io/grpc/Status.java:212

MethodCollisionLeaf

(K key1, V value1, K key2, V value2)

api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:112

MethodCombiningMetadataApplier

(MetadataApplier delegate, Metadata firstHeaders)

api/src/main/java/io/grpc/CompositeCallCredentials.java:79

MethodCommonTlsContextUtil

()

xds/src/main/java/io/grpc/xds/internal/security/CommonTlsContextUtil.java:25

MethodCompositeCallCredentials

(CallCredentials creds1, CallCredentials creds2)

api/src/main/java/io/grpc/CompositeCallCredentials.java:31

MethodCompositeChannelCredentials

(ChannelCredentials channelCreds, CallCredentials callCreds)

api/src/main/java/io/grpc/CompositeChannelCredentials.java:36

MethodCompositeReadableBuffer

(int initialCapacity)

core/src/main/java/io/grpc/internal/CompositeReadableBuffer.java:42

MethodCompressedIndex

(int bitmap, Node<K,V>[] values, int size)

api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:195

MethodCompressingHelloWorldClient

Construct client connecting to HelloWorld server at {@code host:port}.

examples/src/main/java/io/grpc/examples/experimental/CompressingHelloWorldClient.java:45

MethodCompressionTest

Auto called by test.

interop-testing/src/test/java/io/grpc/testing/integration/CompressionTest.java:117

MethodCompressorRegistry

(Compressor ...cs)

api/src/main/java/io/grpc/CompressorRegistry.java:54

MethodComputeEngineChannelBuilder

(String target)

alts/src/main/java/io/grpc/alts/ComputeEngineChannelBuilder.java:33

MethodComputeEngineChannelCredentials

()

alts/src/main/java/io/grpc/alts/ComputeEngineChannelCredentials.java:40

MethodConditionalClientInterceptor

(ClientInterceptor delegate, BiPredicate<MethodDescriptor<?, ?>, CallOptions> predicate)

gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/ConditionalClientInterceptor.java:38

MethodConfig

(Long randomSeed)

examples/src/main/java/io/grpc/examples/customloadbalance/ShufflingPickFirstLoadBalancer.java:56

MethodConfig

( OkHttpServerBuilder builder, List<? extends ServerStreamTracer.Factory> streamTracerFactorie

okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:540

MethodConfig

(LoadBalancer.Factory childFactory, @Nullable Object childConfig)

util/src/main/java/io/grpc/util/GracefulSwitchLoadBalancer.java:243

MethodConfig

(String config, String typeUrl)

xds/src/test/java/io/grpc/xds/StatefulFilter.java:149

MethodConfig

(Status resolvedAddressesResult, ConnectivityState state)

xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1139

MethodConfigFilterHelper

(ObservabilityConfig config)

gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/ConfigFilterHelper.java:38

MethodConfigOrError

(Object config)

api/src/main/java/io/grpc/NameResolver.java:976

MethodConfigOrError

(T config)

xds/src/main/java/io/grpc/xds/ConfigOrError.java:42

MethodConfigSelectingClientCall

( InternalConfigSelector configSelector, Channel channel, Executor channelExecutor, MethodDesc

core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1080

MethodConfigurableFakeWithTcpInfo

(FakeEpollTcpInfo infoToCopy)

netty/src/test/java/io/grpc/netty/TcpMetricsTest.java:333

MethodConfiguratorRegistry

()

api/src/main/java/io/grpc/ConfiguratorRegistry.java:40

MethodConnectionClosedException

(String errorMessage)

s2a/src/main/java/io/grpc/s2a/internal/handshaker/ConnectionClosedException.java:24

MethodConnectionSpec

(Builder builder)

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/ConnectionSpec.java:89

MethodConnectivityStateInfo

(ConnectivityState state, Status status)

api/src/main/java/io/grpc/ConnectivityStateInfo.java:93

MethodConstant

()

examples/example-oauth/src/main/java/io/grpc/examples/oauth/Constant.java:34

MethodConstant

()

examples/example-jwt-auth/src/main/java/io/grpc/examples/jwtauth/Constant.java:34

MethodContext

Construct a context that cannot be cancelled and will not cascade cancellation from its parent.

api/src/context/java/io/grpc/Context.java:187

MethodContextCloser

(Context.CancellableContext context, Throwable cause)

core/src/main/java/io/grpc/internal/ServerImpl.java:970

MethodContextRunnable

(Context context)

core/src/main/java/io/grpc/internal/ContextRunnable.java:29

MethodContextServerCallListener

(ServerCall.Listener<ReqT> delegate, Context context)

opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:360

MethodContexts

()

api/src/main/java/io/grpc/Contexts.java:27

MethodContextualizedServerCallListener

(ServerCall.Listener<ReqT> delegate, Context context)

api/src/main/java/io/grpc/Contexts.java:67

MethodContinuationSource

(BufferedSource source)

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:617

MethodControlPlaneClient

An entity that manages ADS RPCs over a single channel.

xds/src/main/java/io/grpc/xds/client/ControlPlaneClient.java:90

MethodControlPlaneRule

()

xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:94

MethodCounterReference

(AtomicLong counter, ReferenceQueue<AtomicLong> refQueue, String cluster, @Nullable String edsServiceN

xds/src/main/java/io/grpc/xds/SharedCallCounterMap.java:98

MethodCountingStreamTracerFactory

( ClusterLocalityStats stats, AtomicLong inFlights, @Nullable ClientStreamTracer.Factory deleg

xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:484

MethodCpcWithFallbackState

(ControlPlaneClient cpc, boolean didFallback)

xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:1085

MethodCreateStreamCommand

( Http2Headers headers, NettyClientStream.TransportState stream, boolean shouldBeCountedForI

netty/src/main/java/io/grpc/netty/CreateStreamCommand.java:32

MethodCreateSubchannelArgs

( List<EquivalentAddressGroup> addrs, Attributes attrs, Object[][] customOptions)

api/src/main/java/io/grpc/LoadBalancer.java:825

MethodCredentials

()

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Credentials.java:26

MethodCronetChannelBuilder

(String host, int port, CronetEngine cronetEngine)

cronet/src/main/java/io/grpc/cronet/CronetChannelBuilder.java:112

MethodCronetClientStream

( final String url, @Nullable String userAgent, Executor executor, final Metadata head

cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:97

MethodCronetClientTransport

( StreamBuilderFactory streamFactory, InetSocketAddress address, String authority, @Nu

cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java:85

MethodCronetTransportFactory

( StreamBuilderFactory streamFactory, Executor executor, @Nullable ScheduledExecutorSe

cronet/src/main/java/io/grpc/cronet/CronetChannelBuilder.java:250

MethodCronetWritableBuffer

(ByteBuffer buffer, int capacity)

cronet/src/main/java/io/grpc/cronet/CronetWritableBuffer.java:26

MethodCronetWritableBufferAllocator

Construct a new instance.

cronet/src/main/java/io/grpc/cronet/CronetWritableBufferAllocator.java:33

MethodCsdsService

(XdsClientPoolFactory xdsClientPoolFactory)

xds/src/main/java/io/grpc/xds/CsdsService.java:66

MethodCsmObservability

(Builder builder)

gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/CsmObservability.java:48

MethodCsmObservabilityClient

Construct client for accessing HelloWorld server using the existing channel.

examples/example-gcp-csm-observability/src/main/java/io/grpc/examples/csmobservability/CsmObservabilityClient.java:47

MethodCustomBackendMetricsClient

Construct client for accessing HelloWorld server using the existing channel.

examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsClient.java:45

MethodCustomBackendMetricsLoadBalancer

(Helper helper)

interop-testing/src/main/java/io/grpc/testing/integration/CustomBackendMetricsLoadBalancerProvider.java:66

MethodCustomBackendMetricsLoadBalancer

(LoadBalancer.Helper helper)

examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:63

MethodCustomBackendMetricsLoadBalancerHelper

(Helper helper)

interop-testing/src/main/java/io/grpc/testing/integration/CustomBackendMetricsLoadBalancerProvider.java:81

MethodCustomBackendMetricsLoadBalancerHelper

(LoadBalancer.Helper helper)

examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:78

MethodCustomHeaderClient

A custom client.

examples/src/main/java/io/grpc/examples/header/CustomHeaderClient.java:46

MethodCustomKnownLengthInputStream

(byte[] source)

protobuf-lite/src/test/java/io/grpc/protobuf/lite/ProtoLiteUtilsTest.java:321

MethodCustomLoadBalanceClient

(Channel channel)

examples/src/main/java/io/grpc/examples/customloadbalance/CustomLoadBalanceClient.java:47

MethodDataCacheEntry

(RouteLookupRequestKey routeLookupRequestKey, final RouteLookupResponse response)

rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:683

MethodDataPlaneRule

Creates a new {@link DataPlaneRule} that is connected to the given {@link ControlPlaneRule}.

xds/src/test/java/io/grpc/xds/DataPlaneRule.java:61

MethodDeadline

(Ticker ticker, long offset, boolean baseInstantAlreadyExpired)

api/src/context/java/io/grpc/Deadline.java:104

MethodDeadlineClient

Construct client for accessing HelloWorld server using the existing channel.

examples/src/main/java/io/grpc/examples/deadline/DeadlineClient.java:46

MethodDeadlineSubject

(FailureMetadata metadata, Deadline subject)

api/src/testFixtures/java/io/grpc/testing/DeadlineSubject.java:45

MethodDeadlineTest

(long epoch)

api/src/test/java/io/grpc/DeadlineTest.java:60

MethodDecompressorInfo

(Decompressor decompressor, boolean advertised)

api/src/main/java/io/grpc/DecompressorRegistry.java:147

MethodDecompressorRegistry

(Decompressor d, boolean advertised, DecompressorRegistry parent)

api/src/main/java/io/grpc/DecompressorRegistry.java:67

MethodDefaultEventLoopGroupResource

( int numEventLoops, String name, EventLoopGroupType eventLoopGroupType)

netty/src/main/java/io/grpc/netty/Utils.java:494

MethodDefaultListener

(String prefix)

xds/src/main/java/io/grpc/xds/XdsServerBuilder.java:180

MethodDelayInjectedCall

( long delayNanos, Executor callExecutor, ScheduledExecutorService scheduler, @Nullable Deadli

xds/src/main/java/io/grpc/xds/FaultFilter.java:411

MethodDelayedClientCall

( Executor callExecutor, ScheduledExecutorService scheduler, @Nullable Deadline deadline)

core/src/main/java/io/grpc/internal/DelayedClientCall.java:78

MethodDelayedClientTransport

Creates a new delayed transport. @param defaultAppExecutor pending streams will create real streams and run buffered operations in an applicat

core/src/main/java/io/grpc/internal/DelayedClientTransport.java:84

MethodDelayedListener

(DelayedClientCall<?, RespT> call, Listener<RespT> listener)

core/src/main/java/io/grpc/internal/DelayedClientCall.java:455

MethodDelayedStream

Create a delayed stream with debug context {@code bufferContext}. The context is what this stream is delayed by (e.g., "connecting", "call_credentials

core/src/main/java/io/grpc/internal/DelayedStream.java:72

MethodDelayedStreamListener

(ClientStreamListener listener)

core/src/main/java/io/grpc/internal/DelayedStream.java:461

MethodDelegatingTsiHandshaker

(TsiHandshaker delegate)

alts/src/test/java/io/grpc/alts/internal/AltsProtocolNegotiatorTest.java:468

MethodDelegatingTsiHandshakerFactory

(TsiHandshakerFactory delegate)

alts/src/test/java/io/grpc/alts/internal/AltsProtocolNegotiatorTest.java:454

← previous next →8,301–8,400 of 22,628, ranked by callers