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

↓ 7 callersMethodassertPicker

(SubchannelPicker picker, Status expectedStatus, @Nullable Subchannel expectedSubchannel)

xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1065

↓ 7 callersMethodassertResourceInvalidExceptionThrown

(Cluster cluster, boolean enableLeastRequest, String expectedMessage)

xds/src/test/java/io/grpc/xds/LoadBalancerConfigFactoryTest.java:415

↓ 7 callersMethodassertRpcStartedRecorded

()

interop-testing/src/test/java/io/grpc/testing/integration/RetryTest.java:223

↓ 7 callersMethodauthConfig

()

xds/src/main/java/io/grpc/xds/RbacConfig.java:32

↓ 7 callersMethodawaitHalfClosed

(int timeout, TimeUnit unit)

core/src/testFixtures/java/io/grpc/internal/ServerStreamListenerBase.java:53

↓ 7 callersMethodawaitTermination

(long l, TimeUnit timeUnit)

binder/src/testFixtures/java/io/grpc/binder/internal/MainThreadScheduledExecutorService.java:130

↓ 7 callersMethodbuildDownstreamTlsContextForCertProviderInstance

Helper method to build DownstreamTlsContext for CertProvider tests.

xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:394

↓ 7 callersMethodbuildServer

(XdsServerBuilder.XdsServingStatusListener xdsServingStatusListener)

xds/src/test/java/io/grpc/xds/XdsServerBuilderTest.java:75

↓ 7 callersMethodbuildServletAdapter

Creates a {@link ServletAdapter}.

servlet/src/main/java/io/grpc/servlet/ServletServerBuilder.java:106

↓ 7 callersMethodbuildTransportFactory

(NettyChannelBuilder builder)

netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java:109

↓ 7 callersMethodbuildTransportFactory

()

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

↓ 7 callersMethodbytesEqual

(byte[] left, byte[] right)

api/src/main/java/io/grpc/Metadata.java:563

↓ 7 callersMethodcaptureWrite

(ChannelHandlerContext ctx)

netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:357

↓ 7 callersMethodcategory

()

xds/src/main/java/io/grpc/xds/client/Stats.java:87

↓ 7 callersMethodchannelBuilder

(ManagedChannelBuilder<?> builder)

api/src/main/java/io/grpc/ManagedChannelProvider.java:98

↓ 7 callersMethodcheckClientTrusted

(X509Certificate[] chain, String authType)

util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:74

↓ 7 callersMethodcheckSizeEnforcingInputStreamStats

( TestBaseStreamTracer tracer, long uncompressedSize)

core/src/test/java/io/grpc/internal/MessageDeframerTest.java:533

↓ 7 callersMethodclientOutboundHeaders

See {@link ClientStreamTracer#outboundHeaders}. For client-side only. <p>Transport-specific, thus should be called by transport implementations.

core/src/main/java/io/grpc/internal/StatsTraceContext.java:102

↓ 7 callersMethodclientStream

Gets the client stream associated to the given HTTP/2 stream object.

netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1036

↓ 7 callersMethodconnectionPreface

HTTP/2 only.

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameWriter.java:31

↓ 7 callersMethodcontentAsArray

()

netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:244

↓ 7 callersMethodconvertServerHeaders

(Metadata headers)

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

↓ 7 callersMethodcreate

()

core/src/jmh/java/io/grpc/internal/ChannelzBenchmark.java:133

↓ 7 callersMethodcreate

Constructs with the provided {@code creds} as options, with preferred credentials first. @throws IllegalArgumentException if no creds are provided

api/src/main/java/io/grpc/ChoiceChannelCredentials.java:35

↓ 7 callersMethodcreate

(Map<String, ?> config)

xds/src/main/java/io/grpc/xds/RouteLookupServiceClusterSpecifierPlugin.java:88

↓ 7 callersMethodcreate

Passing in null will match all authenticated user, i.e. SSL session is present. https://github.com/envoyproxy/envoy/blob/3975bf5dadb43421907bbc52df57c

xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:153

↓ 7 callersMethodcreate

Matches when all of the matchers match.

xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:455

↓ 7 callersMethodcreateOrGet

(String target)

rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:243

↓ 7 callersMethodcreateSubChannel

()

xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1204

↓ 7 callersMethodcreateSubchannel

(CreateSubchannelArgs args)

xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1235

↓ 7 callersMethoddelegate

Returns the delegated {@code ClientCall}.

api/src/main/java/io/grpc/PartialForwardingClientCall.java:30

↓ 7 callersMethoddelegate

()

okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:153

↓ 7 callersMethoddelegate

Returns the underlying balancer.

util/src/main/java/io/grpc/util/ForwardingLoadBalancer.java:30

↓ 7 callersMethodderegister

()

xds/src/test/java/io/grpc/xds/XdsCredentialsRegistryTest.java:53

↓ 7 callersMethoddrain

Run all tasks in the queue in the current thread, if no other thread is running this method. Otherwise do nothing. <p>Upon returning, it guarantees t

api/src/main/java/io/grpc/SynchronizationContext.java:87

↓ 7 callersMethodencodeAuthority

(String authority)

core/src/main/java/io/grpc/internal/GrpcUtil.java:934

↓ 7 callersMethodencrypt

(ByteBuf out, List<ByteBuf> plain)

alts/src/test/java/io/grpc/alts/internal/FakeChannelCrypter.java:37

↓ 7 callersMethodequals

(@Nullable Object o)

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

↓ 7 callersMethodequals

(Object o)

xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:228

↓ 7 callersMethoderror

(String error)

okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:511

↓ 7 callersMethodfallbackTestVerifyUseOfFallbackBackendLists

( InOrder inOrder, List<EquivalentAddressGroup> addrs)

grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:1678

↓ 7 callersMethodfaultDelay

()

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

↓ 7 callersMethodfilterConfigOverrides

()

xds/src/main/java/io/grpc/xds/VirtualHost.java:50

↓ 7 callersMethodfilterStateTestFilterRegistry

( StatefulFilter.Provider statefulFilterProvider)

xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1854

↓ 7 callersMethodfilterStateTestSetupResolver

()

xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:1698

↓ 7 callersMethodfindOrCreateServerSslContextProvider

Creates a SslContextProvider. Used for retrieving a server-side SslContext.

xds/src/main/java/io/grpc/xds/TlsContextManager.java:28

↓ 7 callersMethodflowControlWindow

Sets the flow control window in bytes. If not called, the default value is 64 KiB.

okhttp/src/main/java/io/grpc/okhttp/OkHttpServerBuilder.java:327

↓ 7 callersMethodforError

Creates a {@code Result} with the given error status.

api/src/main/java/io/grpc/InternalConfigSelector.java:57

↓ 7 callersMethodforLoneKey

Creates a new query parameter with a "lone" key. <p>'key' can contain any character. It will be URL encoded for you later, as necessary. @param key

api/src/main/java/io/grpc/QueryParams.java:224

↓ 7 callersMethodforPort

(int port)

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

↓ 7 callersMethodforSafeRegEx

The request header value should match the regular expression pattern.

xds/src/main/java/io/grpc/xds/internal/Matchers.java:86

↓ 7 callersMethodfork

Create a new context which propagates the values of this context but does not cascade its cancellation.

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

↓ 7 callersMethodframer

The framer to use for sending messages.

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

↓ 7 callersMethodfromByteArray

(byte[] bytes)

testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:202

↓ 7 callersMethodgenerateRandomSpan

Creates a MockableSpan with a random trace ID and span ID.

testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:338

↓ 7 callersMethodgenerateServiceConfigWithMethodConfig

( @Nullable Long timeoutNano, @Nullable RetryPolicy retryPolicy)

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

↓ 7 callersMethodget

()

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java:94

↓ 7 callersMethodgetActiveStreams

()

okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:208

↓ 7 callersMethodgetAllAddresses

()

core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3162

↓ 7 callersMethodgetBareMethodName

A convenience method for {@code extractBareMethodName(getFullMethodName())}. @since 1.33.0

api/src/main/java/io/grpc/MethodDescriptor.java:270

↓ 7 callersMethodgetBoolean

Gets a boolean from an object for the given key. If the key is not present, this returns null. If the value is not a Boolean, throws an exception.

core/src/main/java/io/grpc/internal/JsonUtil.java:252

↓ 7 callersMethodgetByteBufAllocator

(boolean forceHeapBuffer)

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

↓ 7 callersMethodgetCacheableUnaryCallMethod

()

interop-testing/src/generated/main/grpc/io/grpc/testing/integration/TestServiceGrpc.java:84

↓ 7 callersMethodgetCallOptions

()

core/src/main/java/io/grpc/internal/PickSubchannelArgsImpl.java:52

↓ 7 callersMethodgetCandidatesViaHardCoded

Load providers from a hard-coded list. This avoids using getResource(), which has performance problems on Android (see https://github.com/grpc/grpc-ja

api/src/main/java/io/grpc/ServiceProviders.java:125

↓ 7 callersMethodgetChannelBuilder

()

api/src/main/java/io/grpc/ManagedChannelProvider.java:106

↓ 7 callersMethodgetChildPicker

()

grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:1194

↓ 7 callersMethodgetDefaultPort

Returns the implicit port to use if no port was specified explicitly by the user.

netty/src/main/java/io/grpc/netty/ProtocolNegotiator.java:55

↓ 7 callersMethodgetDelay

(TimeUnit targetUnit)

core/src/test/java/io/grpc/internal/SharedResourceHolderTest.java:301

↓ 7 callersMethodgetExecutor

Returns the executor override to use for this specific call, or {@code null} if there is no override. The executor is only for servicing this one call

api/src/main/java/io/grpc/CallOptions.java:448

↓ 7 callersMethodgetIndexLocation

()

core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:848

↓ 7 callersMethodgetInstance

()

opentelemetry/src/main/java/io/grpc/opentelemetry/MetadataSetter.java:37

↓ 7 callersMethodgetInstance

()

opentelemetry/src/main/java/io/grpc/opentelemetry/MetadataGetter.java:38

↓ 7 callersMethodgetInstrumentedInternalSubchannel

Returns the InternalSubchannel as an {@code Instrumented<T>} for the sole purpose of channelz unit tests.

core/src/main/java/io/grpc/internal/AbstractSubchannel.java:34

↓ 7 callersMethodgetInternalSubchannel

()

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

↓ 7 callersMethodgetLb

()

util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:304

↓ 7 callersMethodgetListenAddress

()

interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:288

↓ 7 callersMethodgetListenSocketAddresses

()

netty/src/main/java/io/grpc/netty/NettyServer.java:193

↓ 7 callersMethodgetLogId

()

services/src/test/java/io/grpc/protobuf/services/ChannelzTestHelper.java:171

↓ 7 callersMethodgetOffloadExecutor

Returns the Executor on which this resolver should execute long-running or I/O bound work. Null if no Executor was set. @since 1.25.0

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

↓ 7 callersMethodgetOkResponse

Returns a mock normal handshaker response.

alts/src/test/java/io/grpc/alts/internal/MockAltsHandshakerResp.java:82

↓ 7 callersMethodgetOrCreate

( String target, MetricRecorder metricRecorder, CallCredentials transportCallCredentials)

xds/src/main/java/io/grpc/xds/SharedXdsClientPoolProvider.java:81

↓ 7 callersMethodgetOutboundWireSize

Returns to sum of all sizes passed to {@link StreamTracer#outboundWireSize}.

testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java:63

↓ 7 callersMethodgetPassword

Returns the password used to connect to the proxy. {@code null} if there is no password.

api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:70

↓ 7 callersMethodgetPickResultForCreate

(ArgumentCaptor<SubchannelPicker> pickerCaptor, Metadata headers)

rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:654

↓ 7 callersMethodgetPort

()

benchmarks/src/main/java/io/grpc/benchmarks/driver/LoadServer.java:161

↓ 7 callersMethodgetPorts

Turn ports from a string list to an int list.

istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:132

↓ 7 callersMethodgetPrivateKey

(String alias)

util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:69

↓ 7 callersMethodgetProvider

()

okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java:119

↓ 7 callersMethodgetRawConnectivityState

()

core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:649

↓ 7 callersMethodgetRoot

()

buildSrc/src/main/java/io/grpc/gradle/RequireUpperBoundDepsMatchTask.java:65

↓ 7 callersMethodgetRootChannel

(long id)

api/src/main/java/io/grpc/InternalChannelz.java:234

↓ 7 callersMethodgetServerLrsClientMap

()

xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1354

↓ 7 callersMethodgetServerReflectionInfoMethod

()

services/src/generated/main/grpc/io/grpc/reflection/v1/ServerReflectionGrpc.java:18

↓ 7 callersMethodgetServerStreamingRpcMethod

()

testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/SimpleServiceGrpc.java:83

↓ 7 callersMethodgetServiceConfigParser

Returns the {@link ServiceConfigParser}. @since 1.21.0

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

↓ 7 callersMethodgetServiceDescriptor

The descriptor for the service.

api/src/main/java/io/grpc/ServerServiceDefinition.java:53

↓ 7 callersMethodgetSoleMethod

( ServerServiceDefinition serviceDef)

util/src/test/java/io/grpc/util/UtilServerInterceptorsTest.java:65

↓ 7 callersMethodgetSslContextProviderSupplier

( FilterChainSelector selector)

xds/src/test/java/io/grpc/xds/XdsClientWrapperForServerSdsTestMisc.java:348

↓ 7 callersMethodgetStandardServices

Returns a list of gRPC's built-in admin services. @return list of standard admin services

services/src/main/java/io/grpc/services/AdminInterface.java:51

← previous next →2,001–2,100 of 22,628, ranked by callers