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
↓ 4 callersMethodtoString
()
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:127
↓ 4 callersMethodtoString
()
grpclb/src/test/java/io/grpc/grpclb/FakeSocketAddress.java:28
↓ 4 callersMethodtoString
()
api/src/testFixtures/java/io/grpc/StatusMatcher.java:79
↓ 4 callersMethodtoString
()
api/src/test/java/io/grpc/MetadataTest.java:501
↓ 4 callersMethodtoString
()
api/src/main/java/io/grpc/LoadBalancer.java:149
↓ 4 callersMethodtoString
Returns the string used to identify this protocol for ALPN, like "http/1.1", "spdy/3.1" or "h2".
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Protocol.java:98
↓ 4 callersMethodtoString
()
binder/src/main/java/io/grpc/binder/PeerUid.java:74
↓ 4 callersMethodtoString
()
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1111
↓ 4 callersMethodtransact
(int code, ParcelHolder wrappedParcel)
binder/src/main/java/io/grpc/binder/internal/OneWayBinderProxy.java:137
↓ 4 callersMethodtriggerPendingRpcProcessing
()
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:526
↓ 4 callersMethodunbindInternal
(Status reason)
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:255
↓ 4 callersMethodunwrap
(Subchannel s)
xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:144
↓ 4 callersMethodupdateActiveFilters
(@Nullable List<NamedFilterConfig> filterConfigs)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:733
↓ 4 callersMethodupdateAddresses
(List<EquivalentAddressGroup> addressGroups)
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:317
↓ 4 callersMethodupdateBalancingState
( @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1228
↓ 4 callersMethodupdateGroups
Update to new groups, resetting the current index.
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:744
↓ 4 callersMethodupdateSelector
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:525
↓ 4 callersMethodupstreamTlsContext
(UpstreamTlsContext upstreamTlsContext)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:769
↓ 4 callersMethoduserEventTriggered
(ChannelHandlerContext ctx, Object evt)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:450
↓ 4 callersMethodvalidateDownstreamTlsContext
( DownstreamTlsContext downstreamTlsContext, Set<String> certProviderInstances)
xds/src/main/java/io/grpc/xds/XdsListenerResource.java:295
↓ 4 callersMethodvalueAsT
(int i, Key<T> key)
api/src/main/java/io/grpc/Metadata.java:196
↓ 4 callersMethodverifyCallListenerClosed
( ClientCall.Listener<Integer> listener, Status.Code code, Throwable cause)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:2609
↓ 4 callersMethodverifyClientConfigNode
Assuming {@link EnvoyProtoDataTest#convertNode} passes, perform a minimal check, just verify the node itself is the one we expect.
xds/src/test/java/io/grpc/xds/CsdsServiceTest.java:442
↓ 4 callersMethodverifyEdsPriorityNames
(List<String> want, List<LocalityLbEndpoints>... updates)
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:616
↓ 4 callersMethodverifyErrorReply
(Throwable t)
examples/src/main/java/io/grpc/examples/errorhandling/DetailErrorSample.java:102
↓ 4 callersMethodverifyErrorReply
(Throwable t)
examples/src/main/java/io/grpc/examples/errordetails/ErrorDetailsExample.java:124
↓ 4 callersMethodverifyExecutorsAcquired
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1784
↓ 4 callersMethodverifyExecutorsNotReturned
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1789
↓ 4 callersMethodverifyExecutorsReturned
()
core/src/test/java/io/grpc/internal/ServerImplTest.java:1793
↓ 4 callersMethodverifyNextReportClusters
Verifies a LRS request has been sent with ClusterStats of the given list of clusters.
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5269
↓ 4 callersMethodverifyPanicMode
(Throwable cause)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:2592
↓ 4 callersMethodverifyResourceCount
( Map<String, XdsResourceType<?>> subscribedTypeUrls, Map<XdsResourceType<?>, Map<String, Resource
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:454
↓ 4 callersMethodverifyResourceMetadata
( XdsResourceType<?> type, String resourceName, Any rawResource, ResourceMetadataStatus status, St
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:527
↓ 4 callersMethodverifyRetryAfterNanos
( InOrder inOrder, SubchannelStateListener listener, HealthImpl impl, long nanos)
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:651
↓ 4 callersMethodverifyRpcMethodAnnotation
( MethodDescriptor<SimpleRequest, SimpleResponse> descriptor, RpcMethod annotation)
testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java:93
↓ 4 callersMethodwatchXdsResource
Registers a data watcher for the given Xds resource.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:346
↓ 4 callersMethodweight
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:221
↓ 4 callersMethodwithReset
( NettyServerStream.TransportState stream, Status reason)
netty/src/main/java/io/grpc/netty/CancelServerStreamCommand.java:39
↓ 4 callersMethodwrap
Returns a new instance of {@link OneWayBinderProxy} that wraps {@code iBinder}. @param iBinder the binder to wrap @param inProcessThreadHopExecutor a
binder/src/main/java/io/grpc/binder/internal/OneWayBinderProxy.java:61
↓ 4 callersMethodwritableWindow
Returns the maximum writable window (minimum of the stream and connection windows).
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:269
↓ 4 callersMethodwriteBufferingAndRemove
(Channel channel)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:555
↓ 4 callersMethodwriteData
( ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, Chann
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1176
↓ 4 callersMethodwriteDataDirectly
(BufferedSink sink, int flag, int streamId, String message, int paddingLength
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1360
↓ 4 callersMethodwriteQueue
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:216
↓ 3 callersMethodacquireBlock
Acquire a block of standard size.
binder/src/main/java/io/grpc/binder/internal/BlockPool.java:58
↓ 3 callersMethodaddAggregateToExistingConfig
(XdsTestControlPlaneService service, String rootName, List<String>
xds/src/test/java/io/grpc/xds/XdsTestUtils.java:206
↓ 3 callersMethodaddClusterDropStats
( ServerInfo lrsServerInfo, String clusterName, @Nullable String edsServiceName)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1335
↓ 3 callersMethodaddClusterWatcher
(String clusterName)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:430
↓ 3 callersMethodaddMetadata
(Metadata toMetadata)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryPlugin.java:47
↓ 3 callersMethodaddMetricSink
( ManagedChannelBuilder<T> builder, MetricSink metricSink)
api/src/main/java/io/grpc/InternalManagedChannelBuilder.java:31
↓ 3 callersMethodaddProvider
(ServerProvider provider)
api/src/main/java/io/grpc/ServerRegistry.java:62
↓ 3 callersMethodaddServerSocket
()
core/src/jmh/java/io/grpc/internal/ChannelzBenchmark.java:105
↓ 3 callersMethodaddServerSocket
Adds a server socket.
api/src/main/java/io/grpc/InternalChannelz.java:105
↓ 3 callersMethodaddSubchannel
Adds a subchannel.
api/src/main/java/io/grpc/InternalChannelz.java:86
↓ 3 callersMethodaddSubchannel
Adds a subchannel to the tracker, while assuring that the subchannel ejection status is updated to match the tracker's if needed.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:529
↓ 3 callersMethodaddTransportFilter
(ServerTransportFilter filter)
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:153
↓ 3 callersMethodaddress
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:305
↓ 3 callersMethodallResolved
()
core/src/test/java/io/grpc/internal/ServiceConfigErrorHandlingTest.java:583
↓ 3 callersMethodallocator
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpWritableBufferAllocatorTest.java:38
↓ 3 callersMethodanyPackageWithUidSatisfies
( Context applicationContext, Predicate<String> condition, String errorMessageForNoPackages,
binder/src/main/java/io/grpc/binder/SecurityPolicies.java:477
↓ 3 callersMethodapplicationProtocol
()
netty/src/test/java/io/grpc/netty/ProtocolNegotiatorsTest.java:753
↓ 3 callersMethodapplyRequestMetadata
( CallCredentials.RequestInfo requestInfo, Executor appExecutor, CallCredentials.MetadataAppli
api/src/test/java/io/grpc/CompositeCallCredentialsTest.java:103
↓ 3 callersMethodapplyRequestMetadata
Pass the credential data to the given {@link CallCredentials.MetadataApplier}, which will propagate it to the request metadata. <p>It is called for e
api/src/main/java/io/grpc/CallCredentials.java:55
↓ 3 callersMethodargThatTypeUrlIs
(String typeUrl)
xds/src/test/java/io/grpc/xds/client/ControlPlaneClientTest.java:276
↓ 3 callersMethodasChannel
(Internal use only) returns a {@link Channel} that is backed by this Subchannel. This allows a LoadBalancer to issue its own RPCs for auxiliary purpo
api/src/main/java/io/grpc/LoadBalancer.java:1459
↓ 3 callersMethodassertAddressesEqual
Asserts two list of EAGs contains same addresses, regardless of attributes.
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1092
↓ 3 callersMethodassertRecursionLimitNotExceeded
(Marshaller<SimpleRecursiveMessage> marshaller, SimpleRecursiveMessage message)
protobuf-lite/src/test/java/io/grpc/protobuf/lite/ProtoLiteUtilsTest.java:296
↓ 3 callersMethodassertResolverCreated
(String uriPath)
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1058
↓ 3 callersMethodassertRstStreamReceived
(Status status)
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:333
↓ 3 callersMethodassertTailExpanded
(String expectedTailReadableData, int expectedNewTailCapacity)
netty/src/test/java/io/grpc/netty/NettyAdaptiveCumulatorTest.java:390
↓ 3 callersMethodassertTailReplaced
()
netty/src/test/java/io/grpc/netty/NettyAdaptiveCumulatorTest.java:460
↓ 3 callersMethodauthority
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:814
↓ 3 callersMethodawaitCompletion
Waits for the stream to terminate.
testing/src/main/java/io/grpc/testing/StreamRecorder.java:86
↓ 3 callersMethodawaitReady
()
binder/src/androidTest/java/io/grpc/binder/internal/BinderClientTransportTest.java:561
↓ 3 callersMethodbaseEjectionTimeNanos
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:340
↓ 3 callersMethodbasicExchangeHelper
( MethodDescriptor<String, Integer> method, String request, int firstResponse, Integer
core/src/test/java/io/grpc/internal/ServerImplTest.java:842
↓ 3 callersMethodbitSetOfRange
(char from, char to)
api/src/test/java/io/grpc/UriTest.java:805
↓ 3 callersMethodbossEventLoopGroupPool
( ObjectPool<? extends EventLoopGroup> bossEventLoopGroupPool)
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:302
↓ 3 callersMethodbuffer
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpReadableBufferTest.java:59
↓ 3 callersMethodbuild
()
core/src/main/java/io/grpc/internal/InternalHandlerRegistry.java:67
↓ 3 callersMethodbuild
Builds a new instance of {@link Uri} as specified by the setters.
api/src/main/java/io/grpc/Uri.java:1037
↓ 3 callersMethodbuild
()
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:467
↓ 3 callersMethodbuild
()
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:206
↓ 3 callersMethodbuildCommonTlsContextForCertProviderInstance
( String certInstanceName, String certName, String rootInstanceName, String rootCertNa
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:211
↓ 3 callersMethodbuildComplexRbac
( List<Integer> ids, boolean listsFirst)
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:420
↓ 3 callersMethodbuildConfig
()
interop-testing/src/test/java/io/grpc/testing/integration/RpcBehaviorLoadBalancerProviderTest.java:121
↓ 3 callersMethodbuildHttpFaultTypedConfig
( @Nullable Long delayNanos, @Nullable Integer delayRate, String upstreamCluster, List<String>
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5303
↓ 3 callersMethodbuildHttpFilter
( String name, @Nullable Any typedConfig, boolean isOptional)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5300
↓ 3 callersMethodbuildInlineClientListener
(String rdsName, String clusterName)
xds/src/test/java/io/grpc/xds/XdsDependencyManagerTest.java:1008
↓ 3 callersMethodbuildProtocolNegotiatorFactory
()
alts/src/main/java/io/grpc/alts/AltsChannelCredentials.java:95
↓ 3 callersMethodbuildRbac
( List<Permission> permissionList, List<Principal> principalList)
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:404
↓ 3 callersMethodbuildTestListener
( String name, String address, ImmutableList<Integer> sourcePorts, EnvoyServerProtoData.Downstream
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:108
↓ 3 callersMethodbuildTransportServers
( List<? extends ServerStreamTracer.Factory> streamTracerFactories)
inprocess/src/main/java/io/grpc/inprocess/InProcessServerBuilder.java:202
↓ 3 callersMethodbuildTrustManagerAndGetSslSocket
()
xds/src/test/java/io/grpc/xds/internal/security/trust/XdsX509TrustManagerTest.java:767
↓ 3 callersMethodbuildUnmatchedVirtualHosts
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:700
↓ 3 callersMethodbuildVirtualHost
( List<? extends Message> routes, Map<String, Any> typedConfigMap)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5315
↓ 3 callersMethodbuildWrrLocalityConfig
Builds a service config JSON wrr_locality by wrapping another policy config.
xds/src/main/java/io/grpc/xds/LoadBalancerConfigFactory.java:183
↓ 3 callersMethodbuilder
()
xds/src/main/java/io/grpc/xds/client/AllowedGrpcServices.java:52
↓ 3 callersMethodcacheableUnaryCall
<pre> One request followed by one response. Response has cache control headers set such that a caching HTTP proxy (such as GFE) can satisfy subsequent
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/TestServiceGrpc.java:361
↓ 3 callersMethodcall
()
api/src/test/java/io/grpc/ContextTest.java:524
← previousnext →3,401–3,500 of 22,628, ranked by callers