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
updateOobChannelAddresses
Updates the addresses used for connections in the {@code Channel} that was created by {@link #createOobChannel(EquivalentAddressGroup, String)}. This
api/src/main/java/io/grpc/LoadBalancer.java:1090
↓ 2 callers
Method
updateOverallBalancingState
Using the state of all children will calculate the current connectivity state, update fields, generate a picker and then call {@link Helper#updateBala
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:80
↓ 2 callers
Method
updateOverallBalancingState
()
xds/src/main/java/io/grpc/xds/WeightedTargetLoadBalancer.java:146
↓ 2 callers
Method
updateResolvedAddresses
Called either when the child is just created and in this case updated with the cached {@code resolvedAddresses}, or when priority lb receives a new re
xds/src/main/java/io/grpc/xds/PriorityLoadBalancer.java:301
↓ 2 callers
Method
updateRoutes
(List<VirtualHost> virtualHosts)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:449
↓ 2 callers
Method
updateServerList
Populate backend servers to be used based on the given list of addresses.
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:513
↓ 2 callers
Method
updateSslContextProviderSupplier
(@Nullable UpstreamTlsContext tlsContext)
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:366
↓ 2 callers
Method
updateState
(ConnectivityState newState)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:881
↓ 2 callers
Method
updateSubchannelAddressesSafely
( final Helper helper, final Subchannel subchannel, final EquivalentAddressGroup addrs)
core/src/test/java/io/grpc/internal/ManagedChannelImplIdlenessTest.java:648
↓ 2 callers
Method
updateSubchannelPicker
(SubchannelPicker newPicker)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:786
↓ 2 callers
Method
updateWeight
(WeightedRoundRobinPicker picker)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:248
↓ 2 callers
Method
updateWindow
()
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:195
↓ 2 callers
Method
usage
()
gcp-observability/interop/src/main/java/io/grpc/gcp/observability/interop/TestServiceInterop.java:52
↓ 2 callers
Method
useMarshalledMessages
Create a new {@code ServerServiceDefinition} whose {@link MethodDescriptor} serializes to and from T for all methods. The {@code ServerCallHandler} c
api/src/main/java/io/grpc/ServerInterceptors.java:183
↓ 2 callers
Method
useSystemDefaultTrustCerts
Uses the default trust certificates stored on user's local system. After this is used, functions that will provide new credential data(e.g. updateTrus
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:123
↓ 2 callers
Method
usingBuilder
Creates a new builder, which delegates to the given ManagedChannelBuilder. <p>The provided {@code builder} becomes "owned" by AndroidChannelBuilder.
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:134
↓ 2 callers
Method
usingPre4_1_111_Netty
()
netty/src/test/java/io/grpc/netty/NettyAdaptiveCumulatorTest.java:55
↓ 2 callers
Method
validateInitialMetadata
Inspect initial headers to make sure they conform to HTTP and gRPC, returning a {@code Status} on failure. @return status with description of failure
core/src/main/java/io/grpc/internal/Http2ClientStreamTransportState.java:218
↓ 2 callers
Method
validateName
(AsciiString str)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:264
↓ 2 callers
Method
validateSocketAddress
Validates the given address for this transport. @throws IllegalArgumentException if the given address is invalid for this transport.
benchmarks/src/main/java/io/grpc/benchmarks/qps/ServerConfiguration.java:123
↓ 2 callers
Method
validateUpstreamTlsContext
( io.envoyproxy.envoy.extensions.transport_sockets.tls.v3.UpstreamTlsContext upstreamTlsContext, S
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:435
↓ 2 callers
Method
validateWrappedMethod
(MethodDescriptor<?, ?> wMethod)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:195
↓ 2 callers
Method
verifyGoldenHcm
(HttpConnectionManager hcm)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:577
↓ 2 callers
Method
verifyPeerCertificate
Verifies the peer certificate chain. For more information, please refer to {@code X509ExtendedTrustManager}. @param peerCertChain the certificate c
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:411
↓ 2 callers
Method
verifyRequestInvalidResponseStatus
(Status status)
xds/src/test/java/io/grpc/xds/CsdsServiceTest.java:320
↓ 2 callers
Method
verifyRpcDelayedThenAborted
( ClientCall.Listener<Void> listener, long expectedDelayNanos, Status expectedStatus)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2483
↓ 2 callers
Method
verify_extract_map
(TraceFlags traceFlags, String goldenHeader)
opentelemetry/src/test/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagatorTest.java:176
↓ 2 callers
Method
verify_extract_metadata
(TraceFlags traceFlags, String hex)
opentelemetry/src/test/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagatorTest.java:256
↓ 2 callers
Method
verify_inject_map
(TraceFlags traceFlags, String goldenHeader)
opentelemetry/src/test/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagatorTest.java:146
↓ 2 callers
Method
verify_inject_metadata
(TraceFlags traceFlags, byte[] bytes)
opentelemetry/src/test/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagatorTest.java:219
↓ 2 callers
Method
veryLargeRequest
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:973
↓ 2 callers
Method
voidService
(Status status)
gcp-csm-observability/src/test/java/io/grpc/gcp/csm/observability/CsmObservabilityTest.java:524
↓ 2 callers
Method
waitAndDrain
Waits until there is a Runnable, then executes it and all queued Runnables after it.
benchmarks/src/jmh/java/io/grpc/benchmarks/ThreadlessExecutor.java:29
↓ 2 callers
Method
waitAndDrain
Waits until there is a Runnable, then executes it and all queued Runnables after it. Must only be called by one thread at a time.
stub/src/main/java/io/grpc/stub/ClientCalls.java:810
↓ 2 callers
Method
waitFor
(long duration, TimeUnit unit)
interop-testing/src/test/java/io/grpc/testing/integration/NettyFlowControlTest.java:234
↓ 2 callers
Method
waitForFallbackAndDoRpcs
(Deadline fallbackDeadline)
interop-testing/src/main/java/io/grpc/testing/integration/GrpclbFallbackTestClient.java:229
↓ 2 callers
Method
waitForFuture
(Future<?> future, long timeout, TimeUnit unit)
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:2162
↓ 2 callers
Method
waitForSyncContext
(XdsClient xdsClient)
xds/src/test/java/io/grpc/xds/XdsClientFederationTest.java:231
↓ 2 callers
Method
wantsHeaders
()
netty/src/main/java/io/grpc/netty/CancelServerStreamCommand.java:57
↓ 2 callers
Method
wasSetConfiguratorsCalled
()
api/src/main/java/io/grpc/InternalConfiguratorRegistry.java:48
↓ 2 callers
Method
window
()
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:233
↓ 2 callers
Method
withAdditionalAttributes
( List<EquivalentAddressGroup> addresses)
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:305
↓ 2 callers
Method
withDeadline
Returns a new {@code CallOptions} with the given absolute deadline. <p>This is mostly used for propagating an existing deadline. {@link #withDeadline
api/src/main/java/io/grpc/CallOptions.java:167
↓ 2 callers
Method
withExecutor
Returns a new stub with the given executor that is to be used instead of the default one specified with {@link ManagedChannelBuilder#executor}. Note t
stub/src/main/java/io/grpc/stub/AbstractStub.java:168
↓ 2 callers
Method
withReason
( NettyServerStream.TransportState stream, Status reason)
netty/src/main/java/io/grpc/netty/CancelServerStreamCommand.java:44
↓ 2 callers
Method
withServerCallHandler
Create a new method definition with a different call handler. @param handler to bind to a cloned instance of this. @return a cloned instance of this
api/src/main/java/io/grpc/ServerMethodDefinition.java:63
↓ 2 callers
Method
withStreamTracerFactory
()
api/src/test/java/io/grpc/CallOptionsTest.java:234
↓ 2 callers
Method
withTestTimeout
(ListenableFuture<V> future)
binder/src/androidTest/java/io/grpc/binder/BinderChannelSmokeTest.java:314
↓ 2 callers
Method
wrap
(T instance)
xds/src/main/java/io/grpc/xds/client/ReferenceCounted.java:40
↓ 2 callers
Method
wrapChannel
Wraps a channel to provide binary logging on {@link ClientCall}s as needed.
services/src/main/java/io/grpc/protobuf/services/BinaryLogProvider.java:54
↓ 2 callers
Method
wrapMethod
( final ServerMethodDefinition<OReqT, ORespT> definition, final MethodDescriptor<WReqT, WRespT> wr
api/src/main/java/io/grpc/ServerInterceptors.java:273
↓ 2 callers
Method
wrapMethodDefinition
Wraps a {@link ServerMethodDefinition} such that it performs binary logging if needed.
services/src/main/java/io/grpc/protobuf/services/BinaryLogProvider.java:67
↓ 2 callers
Method
write
Writes the frame and decrements the stream and connection window sizes. If the frame is in the pending queue, the written bytes are removed from this
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:315
↓ 2 callers
Method
writeBufferChain
Write a message that has been serialized to a sequence of buffers.
core/src/main/java/io/grpc/internal/MessageFramer.java:237
↓ 2 callers
Method
writeBufferedAndRemove
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/WriteBufferingAndExceptionHandler.java:209
↓ 2 callers
Method
writeBytes
Called from application thread.
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:155
↓ 2 callers
Method
writeContinuationFrames
(int streamId, long byteCount)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:469
↓ 2 callers
Method
writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:1170
↓ 2 callers
Method
writeHeadersToServletResponse
(Metadata metadata)
servlet/src/main/java/io/grpc/servlet/ServletServerStream.java:113
↓ 2 callers
Method
writeOrFlush
()
servlet/src/threadingTest/java/io/grpc/servlet/AsyncServletOutputStreamWriterConcurrencyTest.java:94
↓ 2 callers
Method
writeRaw
(byte[] b, int off, int len)
core/src/main/java/io/grpc/internal/MessageFramer.java:287
↓ 2 callers
Method
writeStatus
(Parcel parcel, Status status)
binder/src/main/java/io/grpc/binder/internal/TransactionUtils.java:90
↓ 2 callers
Method
writtenBytes
Bytes written to {@link #buffer()}.
core/src/testFixtures/java/io/grpc/internal/WritableBufferTestBase.java:41
↓ 2 callers
Method
xdsClientPoolFactory
(XdsClientPoolFactory xdsClientPoolFactory)
xds/src/main/java/io/grpc/xds/XdsServerBuilder.java:134
↓ 1 callers
Method
accept
(ServerCall.Listener<ReqT> listener)
binder/src/main/java/io/grpc/binder/internal/PendingAuthListener.java:96
↓ 1 callers
Method
acceptResolvedAddresses
(ResolvedAddresses resolvedAddresses)
rls/src/main/java/io/grpc/rls/RlsLoadBalancer.java:50
↓ 1 callers
Method
acceptResolvedAddresses
(ResolvedAddresses resolvedAddresses)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:92
↓ 1 callers
Method
acceptResolvedAddresses
Override to completely replace the default logic or to do additional activities.
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:112
↓ 1 callers
Method
acceptResolvedAddresses
(ResolvedAddresses resolvedAddresses)
xds/src/test/java/io/grpc/xds/ClusterManagerLoadBalancerTest.java:377
↓ 1 callers
Method
acceptResolvedAddresses
(ResolvedAddresses resolvedAddresses)
xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java:1235
↓ 1 callers
Method
acceptResolvedAddresses
(ResolvedAddresses resolvedAddresses)
xds/src/test/java/io/grpc/xds/CdsLoadBalancer2Test.java:703
↓ 1 callers
Method
acceptResolvedAddresses
(ResolvedAddresses resolvedAddresses)
xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:100
↓ 1 callers
Method
acceptResolvedAddresses
(ResolvedAddresses resolvedAddresses)
xds/src/main/java/io/grpc/xds/WeightedTargetLoadBalancer.java:65
↓ 1 callers
Method
acceptResolvedAddresses
(ResolvedAddresses resolvedAddresses)
xds/src/main/java/io/grpc/xds/PriorityLoadBalancer.java:89
↓ 1 callers
Method
acceptResolvedAddressesInternal
(ResolvedAddresses resolvedAddresses)
xds/src/main/java/io/grpc/xds/WeightedTargetLoadBalancer.java:75
↓ 1 callers
Method
acceptXSubchannels
(int num)
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3139
↓ 1 callers
Method
ackResponse
(XdsResourceType<?> type, String versionInfo, String nonce)
xds/src/main/java/io/grpc/xds/client/ControlPlaneClient.java:207
↓ 1 callers
Method
acquire
Increment refCount and acquire a reference to value.
xds/src/main/java/io/grpc/xds/internal/security/ReferenceCountingMap.java:114
↓ 1 callers
Method
action
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:109
↓ 1 callers
Method
activate
()
xds/src/main/java/io/grpc/xds/LazyLoadBalancer.java:58
↓ 1 callers
Method
add
(AsciiString name, AsciiString value)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:110
↓ 1 callers
Method
addAllMethods
Currently not exposed. Bulk adds methods to this builder. @param methods the methods to add. @return this builder.
api/src/main/java/io/grpc/ServiceDescriptor.java:175
↓ 1 callers
Method
addClusterDropStats
Adds drop stats for the specified cluster with edsServiceName by using the returned object to record dropped requests. Drop stats recorded with the re
xds/src/main/java/io/grpc/xds/client/XdsClient.java:375
↓ 1 callers
Method
addClusterLocalityStats
( ServerInfo lrsServerInfo, String clusterName, @Nullable String edsServiceName, Locality loca
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1341
↓ 1 callers
Method
addClusterLocalityStats
Adds load stats for the specified locality (in the specified cluster with edsServiceName) by using the returned object to record RPCs. Load stats reco
xds/src/main/java/io/grpc/xds/client/XdsClient.java:388
↓ 1 callers
Method
addCode
(int sym, int code, byte len)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Huffman.java:174
↓ 1 callers
Method
addCpcToAuthority
(String authority, ControlPlaneClient cpcToUse)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:333
↓ 1 callers
Method
addDnsWatcher
(String dnsHostName)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:438
↓ 1 callers
Method
addDoubleCounter
Adds a value for a double-precision counter metric instrument. @param metricInstrument The counter metric instrument to add the value against. @param
api/src/main/java/io/grpc/MetricRecorder.java:37
↓ 1 callers
Method
addEdsWatcher
(String edsServiceName)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:422
↓ 1 callers
Method
addFakeStatsData
()
xds/src/test/java/io/grpc/xds/LoadReportClientTest.java:198
↓ 1 callers
Method
addGzippedBytes
Adds more gzipped data, which will be consumed only when needed to fulfill requests made via {@link #inflateBytes}.
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:209
↓ 1 callers
Method
addInput
(ByteBufAllocator alloc, CompositeByteBuf composite, ByteBuf in)
netty/src/main/java/io/grpc/netty/NettyAdaptiveCumulator.java:110
↓ 1 callers
Method
addLenient
Add a field with the specified value without any validation. Only appropriate for headers from the remote peer or cache.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Headers.java:101
↓ 1 callers
Method
addLongCounter
Adds a value for a long valued counter metric instrument. @param metricInstrument The counter metric instrument to add the value against. @param valu
api/src/main/java/io/grpc/MetricRecorder.java:57
↓ 1 callers
Method
addLongUpDownCounter
Adds a value for a long valued up down counter metric instrument. @param metricInstrument The counter metric instrument to add the value against.
api/src/main/java/io/grpc/MetricRecorder.java:77
↓ 1 callers
Method
addMetricValueAndIncrementRequestsFinished
Adds the given {@code metricValue} and increments the number of requests finished counter for the existing {@link BackendLoadMetricStats}.
xds/src/main/java/io/grpc/xds/client/Stats.java:146
↓ 1 callers
Method
addNewCertificateValidationContext
( CommonTlsContext.Builder builder, String rootInstanceName, String rootCertName
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:310
↓ 1 callers
Method
addOtelResourceAttributes
(Attributes platformAttributes)
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:144
↓ 1 callers
Method
addRdsWatcher
(String resourceName)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:414
← previous
next →
5,401–5,500 of 22,628, ranked by callers