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
↓ 1 callersMethodcreateMinimalLbEndpointsMap
(String serverAddress)
xds/src/test/java/io/grpc/xds/XdsTestUtils.java:294
↓ 1 callersMethodcreateMtlsServer
()
s2a/src/test/java/io/grpc/s2a/internal/channel/S2AHandshakerServiceChannelTest.java:219
↓ 1 callersMethodcreateNameResolver
( String dnsHostName, NameResolver.Args nameResolverArgs)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:484
↓ 1 callersMethodcreateNewChannel
(ManagedChannel currentChannel)
interop-testing/src/main/java/io/grpc/testing/integration/XdsFederationTestClient.java:285
↓ 1 callersMethodcreateNewChannel
(ManagedChannel currentChannel)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:716
↓ 1 callersMethodcreateNewSubchannel
(SocketAddress addr, Attributes attrs)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:582
↓ 1 callersMethodcreateOobChannel
(EquivalentAddressGroup eag, String authority)
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:651
↓ 1 callersMethodcreatePadding
()
examples/src/main/java/io/grpc/examples/manualflowcontrol/BidiBlockingClient.java:170
↓ 1 callersMethodcreatePendingEntry
( RouteLookupRequestKey routeLookupRequestKey, ListenableFuture<RouteLookupResponse> pendingCall,
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:423
↓ 1 callersMethodcreatePendingStream
Caller must call {@code syncContext.drain()} outside of lock because this method may schedule tasks on syncContext.
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:174
↓ 1 callersMethodcreatePlaintextServer
()
s2a/src/test/java/io/grpc/s2a/internal/channel/S2AHandshakerServiceChannelTest.java:235
↓ 1 callersMethodcreatePolicyChecker
Creates a {@link BinderTransportSecurity.ServerPolicyChecker} from a {@link ServerSecurityPolicy}. This exposes to callers an interface to check secur
binder/src/main/java/io/grpc/binder/BinderInternal.java:37
↓ 1 callersMethodcreateRds
(String name)
xds/src/test/java/io/grpc/xds/FilterChainMatchingProtocolNegotiatorsTest.java:1200
↓ 1 callersMethodcreateRealStream
Runnable may be null.
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:372
↓ 1 callersMethodcreateRealSubchannel
(CreateSubchannelArgs args)
util/src/testFixtures/java/io/grpc/util/AbstractTestHelper.java:144
↓ 1 callersMethodcreateRepeatedServerAddrs
(long... weights)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:1278
↓ 1 callersMethodcreateRequestHeaders
( Metadata metadata, List<NameMatcher> keyBuilder)
rls/src/main/java/io/grpc/rls/RlsRequestFactory.java:95
↓ 1 callersMethodcreateResolvingOobChannelBuilder
Creates an out-of-band channel builder for LoadBalancer's own RPC needs, e.g., talking to an external load-balancer service, that is specified by a ta
api/src/main/java/io/grpc/LoadBalancer.java:1139
↓ 1 callersMethodcreateScheduledExecutor
()
core/src/main/java/io/grpc/internal/SharedResourceHolder.java:170
↓ 1 callersMethodcreateServer
(Service service, IBinderReceiver receiver)
binder/src/androidTest/java/io/grpc/binder/HostServices.java:59
↓ 1 callersMethodcreateServerCallHandler
( ServerServiceDefinition serverServiceDefinition)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionService.java:78
↓ 1 callersMethodcreateSocketAddress
Called by gRPC to pick local socket to bind to. This may be called multiple times. Subclasses are expected to override this method. @param remoteAdd
netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java:586
↓ 1 callersMethodcreateSslContext
()
netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java:1214
↓ 1 callersMethodcreateStatsTraceContext
(String methodName, Metadata headers)
binder/src/main/java/io/grpc/binder/internal/BinderServerTransport.java:106
↓ 1 callersMethodcreateStorage
( AtomicReference<? super ClassNotFoundException> deferredStorageFailure)
api/src/context/java/io/grpc/Context.java:126
↓ 1 callersMethodcreateStream
()
netty/src/test/java/io/grpc/netty/NettyStreamTestBase.java:201
↓ 1 callersMethodcreateStream
Attempts to create a new stream from the given command. If there are too many active streams, the creation request is queued.
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:615
↓ 1 callersMethodcreateStreamTraced
( final int streamId, final NettyClientStream.TransportState stream, final Http2Headers head
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:732
↓ 1 callersMethodcreateSubchannel
(LoadBalancer.CreateSubchannelArgs args)
examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:82
↓ 1 callersMethodcreateSubchannelAttrs
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:952
↓ 1 callersMethodcreateTls
()
xds/src/test/java/io/grpc/xds/FilterChainMatchingProtocolNegotiatorsTest.java:1218
↓ 1 callersMethodcreateTrailers
( StreamIdHolder stream, Http2Headers headers, Status status)
netty/src/main/java/io/grpc/netty/SendResponseHeadersCommand.java:42
↓ 1 callersMethodcreateUdsServer
(String name)
netty/src/test/java/io/grpc/netty/UdsNettyChannelProviderTest.java:143
↓ 1 callersMethodcreateWithDefault
Factory method for creating instances of {@link Key}. @param debugString a debug string that describes this key. @param defaultValue default value to
api/src/main/java/io/grpc/LoadBalancer.java:1009
↓ 1 callersMethodcreateWithResponse
(SessionResp response)
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AStub.java:217
↓ 1 callersMethodcreateWriterIfNull
Create a new writer if the writer is null.
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AStub.java:166
↓ 1 callersMethodcreateWriterIfNull
Create a new writer if the writer is null.
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerStub.java:82
↓ 1 callersMethodcurrent
()
api/src/test/java/io/grpc/ContextTest.java:913
↓ 1 callersMethodcurrentTimeNanos
()
core/src/main/java/io/grpc/internal/InstantTimeProvider.java:29
↓ 1 callersMethodcurrentTimeNanos
()
core/src/main/java/io/grpc/internal/ConcurrentTimeProvider.java:28
↓ 1 callersMethodcustomCensusModulePresent
Override this when custom census module presence is different from {@link #metricsExpected()}.
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:414
↓ 1 callersMethodcustomMetadata
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1420
↓ 1 callersMethoddataEntry
(DataCacheEntry dataEntry)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:565
↓ 1 callersMethoddataFrame
(int streamId, byte flags, Buffer buffer, int byteCount)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:503
↓ 1 callersMethoddeDupAddresses
(List<EquivalentAddressGroup> groups)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:212
↓ 1 callersMethoddeactivateChild
()
xds/src/main/java/io/grpc/xds/ClusterManagerLoadBalancer.java:214
↓ 1 callersMethoddeadlineExceeded
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1094
↓ 1 callersMethoddeadlineExceededServerStreaming
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1135
↓ 1 callersMethoddeadlineNotExceeded
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1082
↓ 1 callersMethoddecode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
alts/src/main/java/io/grpc/alts/internal/TsiHandshakeHandler.java:122
↓ 1 callersMethoddecodeFrame
(ByteBufAllocator alloc, List<Object> out)
alts/src/main/java/io/grpc/alts/internal/AltsTsiFrameProtector.java:227
↓ 1 callersMethoddecodeIpv4Suffix
Decodes an IPv4 address suffix of an IPv6 address, like 1111::5555:6666:192.168.0.1.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:284
↓ 1 callersMethoddecodeIpv6
Decodes an IPv6 address like 1111:2222:3333:4444:5555:6666:7777:8888 or ::1.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:213
↓ 1 callersMethoddecrementEjectionTimeMultiplier
()
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:590
↓ 1 callersMethoddecrypt
(ByteBuffer plaintext, ByteBuffer ciphertext, byte[] nonce)
alts/src/main/java/io/grpc/alts/internal/AesGcmHkdfAeadCrypter.java:73
↓ 1 callersMethoddefaultBootstrapOverride
()
xds/src/test/java/io/grpc/xds/XdsClientFederationTest.java:238
↓ 1 callersMethoddefaultSslProvider
Returns OpenSSL if available, otherwise returns the JDK provider.
netty/src/main/java/io/grpc/netty/GrpcSslContexts.java:229
↓ 1 callersMethoddeframe
(ReadableBuffer data)
core/src/main/java/io/grpc/internal/MessageDeframer.java:165
↓ 1 callersMethoddelayedCancel
(BlockingClientCall<Integer, Integer> biDiStream, String message)
stub/src/test/java/io/grpc/stub/BlockingClientCallTest.java:420
↓ 1 callersMethoddelegate
()
grpclb/src/main/java/io/grpc/grpclb/TokenAttachingTracerFactory.java:51
↓ 1 callersMethoddelegate
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:158
↓ 1 callersMethoddelegate
()
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:59
↓ 1 callersMethoddelegate
()
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:208
↓ 1 callersMethoddelegate
()
api/src/test/java/io/grpc/ForwardingServerCallTest.java:47
↓ 1 callersMethoddelegate
Returns the delegated {@code ClientCall.Listener}.
api/src/main/java/io/grpc/ForwardingClientCallListener.java:28
↓ 1 callersMethoddelegate
()
api/src/main/java/io/grpc/ClientInterceptors.java:121
↓ 1 callersMethoddelegate
Returns the delegated {@code ServerCall.Listener}.
api/src/main/java/io/grpc/ForwardingServerCallListener.java:28
↓ 1 callersMethoddelegate
()
interop-testing/src/main/java/io/grpc/testing/integration/CustomBackendMetricsLoadBalancerProvider.java:106
↓ 1 callersMethoddelegate
()
examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:69
↓ 1 callersMethoddelegate
()
examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:107
↓ 1 callersMethoddelegate
()
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:228
↓ 1 callersMethoddelegate
()
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:480
↓ 1 callersMethoddelegate
()
util/src/main/java/io/grpc/util/HealthProducerHelper.java:83
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/PriorityLoadBalancer.java:362
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:507
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/orca/OrcaPerRequestUtil.java:236
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:238
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:555
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:180
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:194
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:208
↓ 1 callersMethoddelegate
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:268
↓ 1 callersMethoddeliverCdsUpdate
(String clusterName, CdsUpdate update)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2854
↓ 1 callersMethoddeliverCloseAbnormal
(Status status)
binder/src/main/java/io/grpc/binder/internal/Inbound.java:303
↓ 1 callersMethoddeliverCompleted
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2952
↓ 1 callersMethoddeliverEdsUpdate
(String name, EdsUpdate update)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2865
↓ 1 callersMethoddeliverError
(Status error)
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1187
↓ 1 callersMethoddeliverInternal
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:239
↓ 1 callersMethoddeliverLdsResourceDeletion
()
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2750
↓ 1 callersMethoddeliverLdsUpdateForRdsNameWithFaultInjection
( final String rdsName, @Nullable FaultConfig httpFilterFaultConfig)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2720
↓ 1 callersMethoddeliverLdsUpdateOnly
(long httpMaxStreamDurationNano, List<VirtualHost> virtualHosts)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2623
↓ 1 callersMethoddeliverLdsUpdateWithApiListener
(long httpMaxStreamDurationNano, List<VirtualHost> virtualHosts)
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:303
↓ 1 callersMethoddeliverRdsAmbientError
(String resourceName, Status status)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2612
↓ 1 callersMethoddeliverRdsUpdateWithFaultInjection
( String resourceName, @Nullable FaultConfig virtualHostFaultConfig, @Nullable FaultConfig rou
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2791
↓ 1 callersMethoddeliverSuffix
Deliver the suffix to gRPC.
binder/src/main/java/io/grpc/binder/internal/Inbound.java:267
↓ 1 callersMethoddeltaAggregatedResources
( io.grpc.stub.StreamObserver<io.envoyproxy.envoy.service.discovery.v3.DeltaDiscoveryResponse> respons
xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/discovery/v3/AggregatedDiscoveryServiceGrpc.java:168
↓ 1 callersMethoddemonstrateCancellation
()
examples/src/main/java/io/grpc/examples/cancellation/CancellationClient.java:48
↓ 1 callersMethodderegister
Deregisters a provider. No-op if the provider is not in the registry. @param provider the provider that was added to the register via {@link #regist
api/src/main/java/io/grpc/ManagedChannelRegistry.java:79
↓ 1 callersMethoddescribeContents
()
binder/src/test/java/io/grpc/binder/internal/TestParcelable.java:36
↓ 1 callersMethoddeserializeHeader
(String headerName)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:369
← previousnext →5,901–6,000 of 22,628, ranked by callers