Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/grpc/grpc-java
/ functions
Functions
22,628 in github.com/grpc/grpc-java
⨍
Functions
22,628
◇
Types & classes
3,835
↓ 2 callers
Method
create
(Object childLbConfig)
rls/src/main/java/io/grpc/rls/ChildLbResolvedAddressFactory.java:39
↓ 2 callers
Method
create
(ImmutableMap<String, String> keyMap)
rls/src/main/java/io/grpc/rls/RlsProtoData.java:38
↓ 2 callers
Method
create
()
android/src/main/java/io/grpc/android/UdsSocketFactory.java:67
↓ 2 callers
Method
create
()
alts/src/main/java/io/grpc/alts/AltsChannelCredentials.java:47
↓ 2 callers
Method
create
()
alts/src/main/java/io/grpc/alts/AltsServerCredentials.java:41
↓ 2 callers
Method
create
Constructs a new transport instance. @param binderDecorator used to decorate 'callbackBinder', for fault injection.
binder/src/main/java/io/grpc/binder/internal/BinderServerTransport.java:59
↓ 2 callers
Method
create
(Channel channel, CallOptions callOptions)
stub/src/test/java/io/grpc/stub/AbstractStubTest.java:39
↓ 2 callers
Method
create
( RouteMatch routeMatch, @Nullable RouteAction routeAction, Map<String, FilterConfig> filterCo
xds/src/main/java/io/grpc/xds/VirtualHost.java:78
↓ 2 callers
Method
create
(Type type, boolean isTerminal, @Nullable String headerName, @Nullable Pattern regEx, @Nullable St
xds/src/main/java/io/grpc/xds/VirtualHost.java:268
↓ 2 callers
Method
create
( String name, FilterChainMatch filterChainMatch, HttpConnectionManager httpConnection
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:282
↓ 2 callers
Method
create
( @Nullable Long delayNanos, boolean headerDelay, FractionalPercent percent)
xds/src/main/java/io/grpc/xds/FaultConfig.java:67
↓ 2 callers
Method
create
( @Nullable Status status, boolean headerAbort, FractionalPercent percent)
xds/src/main/java/io/grpc/xds/FaultConfig.java:92
↓ 2 callers
Method
create
(long httpMaxStreamDurationNano, @Nullable String rdsName, @Nullable List<VirtualHost> virtualHosts,
xds/src/main/java/io/grpc/xds/HttpConnectionManager.java:60
↓ 2 callers
Method
create
Creates a new {@link OrcaMetricReportingServerInterceptor} instance with the given {@link MetricRecorder}. When both {@link CallMetricRecorder} and {@
xds/src/main/java/io/grpc/xds/orca/OrcaMetricReportingServerInterceptor.java:77
↓ 2 callers
Method
create
(long start, long end)
xds/src/main/java/io/grpc/xds/internal/Matchers.java:188
↓ 2 callers
Method
createAndStartXdsServer
()
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:172
↓ 2 callers
Method
createBackOffEntry
(RouteLookupRequestKey routeLookupRequestKey, Status status, @Nullable BackoffPolicy backoffPolicy)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:472
↓ 2 callers
Method
createByteBufAllocator
(boolean preferDirect)
netty/src/main/java/io/grpc/netty/Utils.java:166
↓ 2 callers
Method
createChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbFallbackTestClient.java:157
↓ 2 callers
Method
createChannelBuilder
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:372
↓ 2 callers
Method
createChannelBuilder
()
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:599
↓ 2 callers
Method
createClusterLocalityFromAttributes
(Attributes addressAttributes)
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:321
↓ 2 callers
Method
createConnection
(String url)
googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:433
↓ 2 callers
Method
createContextAsUser
Returns a new Context object whose methods act as if they were running in the given user. @throws ReflectiveOperationException if SDK_INT < R or host
binder/src/main/java/io/grpc/binder/internal/SystemApis.java:48
↓ 2 callers
Method
createDefaultTrustManager
Workaround the JDK's TrustManagerStore race. TrustManagerStore has a cache for the default certs based on the system properties. But updating the cach
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:913
↓ 2 callers
Method
createDelegateTrustManager
(KeyStore keyStore)
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:130
↓ 2 callers
Method
createEvictingMap
(int size)
xds/src/main/java/io/grpc/xds/GcpAuthenticationFilter.java:287
↓ 2 callers
Method
createHeaders
(StreamIdHolder stream, Http2Headers headers)
netty/src/main/java/io/grpc/netty/SendResponseHeadersCommand.java:38
↓ 2 callers
Method
createJwtHelperOrNull
(ClassLoader loader)
auth/src/main/java/io/grpc/auth/GoogleAuthLibraryCallCredentials.java:215
↓ 2 callers
Method
createLargeString
(int size)
binder/src/androidTest/java/io/grpc/binder/BinderChannelSmokeTest.java:305
↓ 2 callers
Method
createMessageFrame
(String message)
okhttp/src/test/java/io/grpc/okhttp/ExceptionHandlingFrameWriterTest.java:93
↓ 2 callers
Method
createMessageFrame
(byte[] bytes)
cronet/src/test/java/io/grpc/cronet/CronetClientStreamTest.java:220
↓ 2 callers
Method
createMessageProto
( byte[] message, int maxMessageBytes)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:390
↓ 2 callers
Method
createMessageProto
( byte[] message, int maxMessageBytes)
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:866
↓ 2 callers
Method
createPathChain
Creates a PathChain that can be set in an EquivalentAddressGroup's Attributes as a value of PATH_CHAIN_KEY.
xds/src/main/java/io/grpc/xds/AddressFilter.java:54
↓ 2 callers
Method
createProviderHelper
( String certName, String pluginName, Object config, Watcher watcher, boolean no
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProviderStore.java:177
↓ 2 callers
Method
createReadyPicker
(Collection<ChildLbState> children)
util/src/main/java/io/grpc/util/RoundRobinLoadBalancer.java:88
↓ 2 callers
Method
createReadyPicker
(Collection<ChildLbState> activeList)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:240
↓ 2 callers
Method
createRequestHeaders
Serializes the given headers and creates a list of OkHttp {@link Header}s to be used when creating a stream. Since this serializes the headers, this m
okhttp/src/main/java/io/grpc/okhttp/Headers.java:47
↓ 2 callers
Method
createResolvingOobChannelBuilder
( String target, ChannelCredentials creds)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:727
↓ 2 callers
Method
createResponseHeaders
Serializes the given headers and creates a list of OkHttp {@link Header}s to be used when starting a response. Since this serializes the headers, this
okhttp/src/main/java/io/grpc/okhttp/Headers.java:94
↓ 2 callers
Method
createResponseTrailers
Serializes the given headers and creates a list of OkHttp {@link Header}s to be used when finishing a response. Since this serializes the headers, thi
okhttp/src/main/java/io/grpc/okhttp/Headers.java:110
↓ 2 callers
Method
createServerAndRegister
(String target)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:1101
↓ 2 callers
Method
createSimplePolicyUsingLists
(int id)
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:445
↓ 2 callers
Method
createSubchannel
(CreateSubchannelArgs args)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1347
↓ 2 callers
Method
createSubchannel
(CreateSubchannelArgs args)
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1346
↓ 2 callers
Method
createSubchannel
(CreateSubchannelArgs args)
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:233
↓ 2 callers
Method
createSubchannel
(LoadBalancer.CreateSubchannelArgs args)
util/src/main/java/io/grpc/util/HealthProducerHelper.java:70
↓ 2 callers
Method
createTrustManager
(byte[] rootCerts)
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:723
↓ 2 callers
Method
createTrustManager
(X509Certificate[] certs)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsTrustManagerFactory.java:151
↓ 2 callers
Method
createUnstartedSubchannel
( final Helper helper, final EquivalentAddressGroup addressGroup, final Attributes attrs)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4670
↓ 2 callers
Method
createVirtualHost
(String name)
xds/src/test/java/io/grpc/xds/FilterChainMatchingProtocolNegotiatorsTest.java:1205
↓ 2 callers
Method
createXdsClient
(String serverUri)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5126
↓ 2 callers
Method
current
()
contextstorage/src/main/java/io/grpc/override/OpenTelemetryContextStorage.java:63
↓ 2 callers
Method
current
()
api/src/context/java/io/grpc/ThreadLocalContextStorage.java:65
↓ 2 callers
Method
customCredentialsType
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:711
↓ 2 callers
Method
data
(int len)
interop-testing/src/main/java/io/grpc/testing/integration/AltsHandshakerTestService.java:134
↓ 2 callers
Method
deactivate
Called when either the child is removed by config update, or a higher priority becomes READY.
xds/src/main/java/io/grpc/xds/PriorityLoadBalancer.java:268
↓ 2 callers
Method
deadlineExeedeed
(CallOptions callOptions, String descriptionSuffix)
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:781
↓ 2 callers
Method
decompress
Wraps an existing input stream with a decompressing input stream. @param is The input stream of uncompressed data @return An input stream that decompr
api/src/main/java/io/grpc/Decompressor.java:39
↓ 2 callers
Method
decorate
Returns an instance of {@link OneWayBinderProxy} that decorates {@code input} with some new behavior.
binder/src/main/java/io/grpc/binder/internal/OneWayBinderProxy.java:77
↓ 2 callers
Method
decrypt
(ByteBuf out, ByteBuf tag, List<ByteBuf> ciphertextBufs)
alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:80
↓ 2 callers
Method
decryptAad
( ByteBuffer plaintext, ByteBuffer ciphertext, @Nullable ByteBuffer aad, byte[] nonce)
alts/src/main/java/io/grpc/alts/internal/AesGcmAeadCrypter.java:72
↓ 2 callers
Method
defaultBootstrapOverride
For test purpose, use boostrapOverride to programmatically provide bootstrap info.
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:187
↓ 2 callers
Method
defaultBootstrapOverride
()
xds/src/test/java/io/grpc/xds/XdsClientFallbackTest.java:586
↓ 2 callers
Method
deframe
Called to parse a received frame and attempt delivery of any completed messages. Must be called from the transport thread.
core/src/main/java/io/grpc/internal/AbstractStream.java:245
↓ 2 callers
Method
delayNanos
()
xds/src/main/java/io/grpc/xds/FaultConfig.java:52
↓ 2 callers
Method
delayedVoidMethod
(int delayMillis, Thunk method)
stub/src/test/java/io/grpc/stub/BlockingClientCallTest.java:402
↓ 2 callers
Method
delegate
()
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:1123
↓ 2 callers
Method
delegate
()
alts/src/main/java/io/grpc/alts/AltsChannelBuilder.java:78
↓ 2 callers
Method
delegate
()
alts/src/main/java/io/grpc/alts/HandshakerServiceChannel.java:108
↓ 2 callers
Method
delegate
()
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:390
↓ 2 callers
Method
delegate
()
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:183
↓ 2 callers
Method
delegate
Returns the delegated {@code ServerCall}.
api/src/main/java/io/grpc/ForwardingServerCall.java:27
↓ 2 callers
Method
delegate
Returns the delegated {@code ClientCall}.
api/src/main/java/io/grpc/ForwardingClientCall.java:27
↓ 2 callers
Method
delegate
()
api/src/main/java/io/grpc/ServerInterceptors.java:294
↓ 2 callers
Method
delegate
()
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:216
↓ 2 callers
Method
delegate
()
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:496
↓ 2 callers
Method
delegate
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:146
↓ 2 callers
Method
delegate
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:222
↓ 2 callers
Method
delegate
()
cronet/src/main/java/io/grpc/cronet/CronetChannelBuilder.java:128
↓ 2 callers
Method
deliver
Reads and delivers as many messages to the listener as possible.
core/src/main/java/io/grpc/internal/MessageDeframer.java:260
↓ 2 callers
Method
deliverEndpointAddresses
(List<EquivalentAddressGroup> addresses)
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1179
↓ 2 callers
Method
deliverErrorStatus
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2956
↓ 2 callers
Method
deliverHeaders
(Metadata headers)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:499
↓ 2 callers
Method
deliverLdsUpdate
(LdsUpdate ldsUpdate)
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:312
↓ 2 callers
Method
deliverMessage
(RespT message)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:524
↓ 2 callers
Method
deliverNameResolutionError
(final Status error)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2735
↓ 2 callers
Method
deliverOnReady
()
core/src/main/java/io/grpc/internal/DelayedClientCall.java:575
↓ 2 callers
Method
deliverResponseHeaders
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2948
↓ 2 callers
Method
deliverSubchannelState
(ConnectivityState state)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1448
↓ 2 callers
Method
depMap
( String group, String name, String version, String classifier)
buildSrc/src/main/java/io/grpc/gradle/CheckForUpdatesTask.java:103
↓ 2 callers
Method
destroyProtectorAndWrites
()
alts/src/main/java/io/grpc/alts/internal/TsiFrameHandler.java:182
↓ 2 callers
Method
detachAndCancel
Cancel this context and detach it as the current context. @param toAttach context to make current. @param cause of cancellation, can be {@code null}.
api/src/context/java/io/grpc/Context.java:886
↓ 2 callers
Method
determineMetricsPickResult
(PickResult pickResult)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:1073
↓ 2 callers
Method
disableAutoRequest
Swaps to manual flow control where no message will be delivered to {@link StreamObserver#onNext(Object)} unless it is {@link #request request()}ed. <
stub/src/main/java/io/grpc/stub/ServerCallStreamObserver.java:112
↓ 2 callers
Method
disableCheckAuthority
(OkHttpChannelBuilder builder)
okhttp/src/main/java/io/grpc/okhttp/InternalOkHttpChannelBuilder.java:32
↓ 2 callers
Method
disableCheckAuthority
(NettyChannelBuilder builder)
netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java:35
↓ 2 callers
Method
disableMetrics
Disables the specified metrics from being collected and exported.
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:422
↓ 2 callers
Method
disconnect
(ChannelHandlerContext ctx, ChannelPromise promise)
alts/src/main/java/io/grpc/alts/internal/TsiFrameHandler.java:89
← previous
next →
4,401–4,500 of 22,628, ranked by callers