MCPcopy Create free account

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

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

↓ 2 callersMethodcreate
(Object childLbConfig)
rls/src/main/java/io/grpc/rls/ChildLbResolvedAddressFactory.java:39
↓ 2 callersMethodcreate
(ImmutableMap<String, String> keyMap)
rls/src/main/java/io/grpc/rls/RlsProtoData.java:38
↓ 2 callersMethodcreate
()
android/src/main/java/io/grpc/android/UdsSocketFactory.java:67
↓ 2 callersMethodcreate
()
alts/src/main/java/io/grpc/alts/AltsChannelCredentials.java:47
↓ 2 callersMethodcreate
()
alts/src/main/java/io/grpc/alts/AltsServerCredentials.java:41
↓ 2 callersMethodcreate
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 callersMethodcreate
(Channel channel, CallOptions callOptions)
stub/src/test/java/io/grpc/stub/AbstractStubTest.java:39
↓ 2 callersMethodcreate
( RouteMatch routeMatch, @Nullable RouteAction routeAction, Map<String, FilterConfig> filterCo
xds/src/main/java/io/grpc/xds/VirtualHost.java:78
↓ 2 callersMethodcreate
(Type type, boolean isTerminal, @Nullable String headerName, @Nullable Pattern regEx, @Nullable St
xds/src/main/java/io/grpc/xds/VirtualHost.java:268
↓ 2 callersMethodcreate
( String name, FilterChainMatch filterChainMatch, HttpConnectionManager httpConnection
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:282
↓ 2 callersMethodcreate
( @Nullable Long delayNanos, boolean headerDelay, FractionalPercent percent)
xds/src/main/java/io/grpc/xds/FaultConfig.java:67
↓ 2 callersMethodcreate
( @Nullable Status status, boolean headerAbort, FractionalPercent percent)
xds/src/main/java/io/grpc/xds/FaultConfig.java:92
↓ 2 callersMethodcreate
(long httpMaxStreamDurationNano, @Nullable String rdsName, @Nullable List<VirtualHost> virtualHosts,
xds/src/main/java/io/grpc/xds/HttpConnectionManager.java:60
↓ 2 callersMethodcreate
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 callersMethodcreate
(long start, long end)
xds/src/main/java/io/grpc/xds/internal/Matchers.java:188
↓ 2 callersMethodcreateAndStartXdsServer
()
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:172
↓ 2 callersMethodcreateBackOffEntry
(RouteLookupRequestKey routeLookupRequestKey, Status status, @Nullable BackoffPolicy backoffPolicy)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:472
↓ 2 callersMethodcreateByteBufAllocator
(boolean preferDirect)
netty/src/main/java/io/grpc/netty/Utils.java:166
↓ 2 callersMethodcreateChannel
()
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbFallbackTestClient.java:157
↓ 2 callersMethodcreateChannelBuilder
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:372
↓ 2 callersMethodcreateChannelBuilder
()
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:599
↓ 2 callersMethodcreateClusterLocalityFromAttributes
(Attributes addressAttributes)
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:321
↓ 2 callersMethodcreateConnection
(String url)
googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:433
↓ 2 callersMethodcreateContextAsUser
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 callersMethodcreateDefaultTrustManager
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 callersMethodcreateDelegateTrustManager
(KeyStore keyStore)
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:130
↓ 2 callersMethodcreateEvictingMap
(int size)
xds/src/main/java/io/grpc/xds/GcpAuthenticationFilter.java:287
↓ 2 callersMethodcreateHeaders
(StreamIdHolder stream, Http2Headers headers)
netty/src/main/java/io/grpc/netty/SendResponseHeadersCommand.java:38
↓ 2 callersMethodcreateJwtHelperOrNull
(ClassLoader loader)
auth/src/main/java/io/grpc/auth/GoogleAuthLibraryCallCredentials.java:215
↓ 2 callersMethodcreateLargeString
(int size)
binder/src/androidTest/java/io/grpc/binder/BinderChannelSmokeTest.java:305
↓ 2 callersMethodcreateMessageFrame
(String message)
okhttp/src/test/java/io/grpc/okhttp/ExceptionHandlingFrameWriterTest.java:93
↓ 2 callersMethodcreateMessageFrame
(byte[] bytes)
cronet/src/test/java/io/grpc/cronet/CronetClientStreamTest.java:220
↓ 2 callersMethodcreateMessageProto
( byte[] message, int maxMessageBytes)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:390
↓ 2 callersMethodcreateMessageProto
( byte[] message, int maxMessageBytes)
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:866
↓ 2 callersMethodcreatePathChain
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 callersMethodcreateProviderHelper
( String certName, String pluginName, Object config, Watcher watcher, boolean no
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProviderStore.java:177
↓ 2 callersMethodcreateReadyPicker
(Collection<ChildLbState> children)
util/src/main/java/io/grpc/util/RoundRobinLoadBalancer.java:88
↓ 2 callersMethodcreateReadyPicker
(Collection<ChildLbState> activeList)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:240
↓ 2 callersMethodcreateRequestHeaders
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 callersMethodcreateResolvingOobChannelBuilder
( String target, ChannelCredentials creds)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:727
↓ 2 callersMethodcreateResponseHeaders
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 callersMethodcreateResponseTrailers
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 callersMethodcreateServerAndRegister
(String target)
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:1101
↓ 2 callersMethodcreateSimplePolicyUsingLists
(int id)
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:445
↓ 2 callersMethodcreateSubchannel
(CreateSubchannelArgs args)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1347
↓ 2 callersMethodcreateSubchannel
(CreateSubchannelArgs args)
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1346
↓ 2 callersMethodcreateSubchannel
(CreateSubchannelArgs args)
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:233
↓ 2 callersMethodcreateSubchannel
(LoadBalancer.CreateSubchannelArgs args)
util/src/main/java/io/grpc/util/HealthProducerHelper.java:70
↓ 2 callersMethodcreateTrustManager
(byte[] rootCerts)
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:723
↓ 2 callersMethodcreateTrustManager
(X509Certificate[] certs)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsTrustManagerFactory.java:151
↓ 2 callersMethodcreateUnstartedSubchannel
( final Helper helper, final EquivalentAddressGroup addressGroup, final Attributes attrs)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4670
↓ 2 callersMethodcreateVirtualHost
(String name)
xds/src/test/java/io/grpc/xds/FilterChainMatchingProtocolNegotiatorsTest.java:1205
↓ 2 callersMethodcreateXdsClient
(String serverUri)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5126
↓ 2 callersMethodcurrent
()
contextstorage/src/main/java/io/grpc/override/OpenTelemetryContextStorage.java:63
↓ 2 callersMethodcurrent
()
api/src/context/java/io/grpc/ThreadLocalContextStorage.java:65
↓ 2 callersMethodcustomCredentialsType
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:711
↓ 2 callersMethoddata
(int len)
interop-testing/src/main/java/io/grpc/testing/integration/AltsHandshakerTestService.java:134
↓ 2 callersMethoddeactivate
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 callersMethoddeadlineExeedeed
(CallOptions callOptions, String descriptionSuffix)
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:781
↓ 2 callersMethoddecompress
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 callersMethoddecorate
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 callersMethoddecrypt
(ByteBuf out, ByteBuf tag, List<ByteBuf> ciphertextBufs)
alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:80
↓ 2 callersMethoddecryptAad
( ByteBuffer plaintext, ByteBuffer ciphertext, @Nullable ByteBuffer aad, byte[] nonce)
alts/src/main/java/io/grpc/alts/internal/AesGcmAeadCrypter.java:72
↓ 2 callersMethoddefaultBootstrapOverride
For test purpose, use boostrapOverride to programmatically provide bootstrap info.
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:187
↓ 2 callersMethoddefaultBootstrapOverride
()
xds/src/test/java/io/grpc/xds/XdsClientFallbackTest.java:586
↓ 2 callersMethoddeframe
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 callersMethoddelayNanos
()
xds/src/main/java/io/grpc/xds/FaultConfig.java:52
↓ 2 callersMethoddelayedVoidMethod
(int delayMillis, Thunk method)
stub/src/test/java/io/grpc/stub/BlockingClientCallTest.java:402
↓ 2 callersMethoddelegate
()
rls/src/test/java/io/grpc/rls/CachingRlsLbClientTest.java:1123
↓ 2 callersMethoddelegate
()
alts/src/main/java/io/grpc/alts/AltsChannelBuilder.java:78
↓ 2 callersMethoddelegate
()
alts/src/main/java/io/grpc/alts/HandshakerServiceChannel.java:108
↓ 2 callersMethoddelegate
()
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:390
↓ 2 callersMethoddelegate
()
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:183
↓ 2 callersMethoddelegate
Returns the delegated {@code ServerCall}.
api/src/main/java/io/grpc/ForwardingServerCall.java:27
↓ 2 callersMethoddelegate
Returns the delegated {@code ClientCall}.
api/src/main/java/io/grpc/ForwardingClientCall.java:27
↓ 2 callersMethoddelegate
()
api/src/main/java/io/grpc/ServerInterceptors.java:294
↓ 2 callersMethoddelegate
()
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:216
↓ 2 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:496
↓ 2 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:146
↓ 2 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:222
↓ 2 callersMethoddelegate
()
cronet/src/main/java/io/grpc/cronet/CronetChannelBuilder.java:128
↓ 2 callersMethoddeliver
Reads and delivers as many messages to the listener as possible.
core/src/main/java/io/grpc/internal/MessageDeframer.java:260
↓ 2 callersMethoddeliverEndpointAddresses
(List<EquivalentAddressGroup> addresses)
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1179
↓ 2 callersMethoddeliverErrorStatus
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2956
↓ 2 callersMethoddeliverHeaders
(Metadata headers)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:499
↓ 2 callersMethoddeliverLdsUpdate
(LdsUpdate ldsUpdate)
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:312
↓ 2 callersMethoddeliverMessage
(RespT message)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:524
↓ 2 callersMethoddeliverNameResolutionError
(final Status error)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2735
↓ 2 callersMethoddeliverOnReady
()
core/src/main/java/io/grpc/internal/DelayedClientCall.java:575
↓ 2 callersMethoddeliverResponseHeaders
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2948
↓ 2 callersMethoddeliverSubchannelState
(ConnectivityState state)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1448
↓ 2 callersMethoddepMap
( String group, String name, String version, String classifier)
buildSrc/src/main/java/io/grpc/gradle/CheckForUpdatesTask.java:103
↓ 2 callersMethoddestroyProtectorAndWrites
()
alts/src/main/java/io/grpc/alts/internal/TsiFrameHandler.java:182
↓ 2 callersMethoddetachAndCancel
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 callersMethoddetermineMetricsPickResult
(PickResult pickResult)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:1073
↓ 2 callersMethoddisableAutoRequest
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 callersMethoddisableCheckAuthority
(OkHttpChannelBuilder builder)
okhttp/src/main/java/io/grpc/okhttp/InternalOkHttpChannelBuilder.java:32
↓ 2 callersMethoddisableCheckAuthority
(NettyChannelBuilder builder)
netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java:35
↓ 2 callersMethoddisableMetrics
Disables the specified metrics from being collected and exported.
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java:422
↓ 2 callersMethoddisconnect
(ChannelHandlerContext ctx, ChannelPromise promise)
alts/src/main/java/io/grpc/alts/internal/TsiFrameHandler.java:89
← previousnext →4,401–4,500 of 22,628, ranked by callers