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
↓ 3 callers
Method
hasPotentialHedging
(State state)
core/src/main/java/io/grpc/internal/RetriableStream.java:816
↓ 3 callers
Method
hasSignatureSha256Hash
Creates {@link SecurityPolicy} which checks if the SHA-256 hash of the package signature matches {@code requiredSignatureSha256Hash}. @param packageN
binder/src/main/java/io/grpc/binder/SecurityPolicies.java:108
↓ 3 callers
Method
hasValue
Returns {@code true} if this entry has a value, {@code false} if it is a "lone" key.
api/src/main/java/io/grpc/QueryParams.java:200
↓ 3 callers
Method
hasX509ExtendedTrustManager
()
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:638
↓ 3 callers
Method
hashCode
()
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:592
↓ 3 callers
Method
hashInt
(int input)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:66
↓ 3 callers
Method
hashLong
(long input)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:55
↓ 3 callers
Method
hashShort
(short input)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:74
↓ 3 callers
Method
header
Sets the header named {@code name} to {@code value}. If this request already has any headers with that name, they are all replaced.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/Request.java:72
↓ 3 callers
Method
headerRemove
(List<Header> header, ByteString key)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:503
↓ 3 callers
Method
headers
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/Request.java:39
↓ 3 callers
Method
host
()
rls/src/main/java/io/grpc/rls/RlsProtoData.java:242
↓ 3 callers
Method
host
Returns the host address suitable for use with {@link InetAddress#getAllByName(String)}. May be: <ul> <li>A regular host name, like {@code android.c
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:74
↓ 3 callers
Method
hostnameVerifier
Set the hostname verifier to use when using TLS negotiation. The hostnameVerifier is only used if using TLS negotiation. If the hostname verifier is n
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:409
↓ 3 callers
Method
http2ProcessingFailed
Called to process a failure in HTTP/2 processing. It should notify the transport to cancel the stream and call {@code transportReportStatus()}.
core/src/main/java/io/grpc/internal/Http2ClientStreamTransportState.java:80
↓ 3 callers
Method
idleTimeout
(long value, TimeUnit unit)
binder/src/main/java/io/grpc/binder/BinderChannelBuilder.java:344
↓ 3 callers
Method
ignoreCase
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:229
↓ 3 callers
Method
inboundHeaders
Headers has been received from the server.
api/src/main/java/io/grpc/ClientStreamTracer.java:69
↓ 3 callers
Method
inboundMessage
An inbound message has been received by the stream. This is called as soon as the stream knows about the message, but doesn't have further guarantee
api/src/main/java/io/grpc/StreamTracer.java:53
↓ 3 callers
Method
inboundMessageRead
An inbound message has been fully read from the transport. @param seqNo the sequential number of the message within the stream, starting from 0. It
api/src/main/java/io/grpc/StreamTracer.java:75
↓ 3 callers
Method
inboundUncompressedSize
The uncompressed size of some inbound data is revealed. This can only used to record the accumulative received uncompressed size. There is no guarante
api/src/main/java/io/grpc/StreamTracer.java:106
↓ 3 callers
Method
inboundUncompressedSize
(long bytes)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:234
↓ 3 callers
Method
inboundWireSize
The wire size of some inbound data is revealed. This can only be used to record the accumulative received wire size. There is no guarantee wrt timing
api/src/main/java/io/grpc/StreamTracer.java:98
↓ 3 callers
Method
includePeerCertificate
Specifies if the peer certificate is sent to the external authorization service. @see ExtAuthz#getIncludePeerCertificate()
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:73
↓ 3 callers
Method
increment
Move to next address in group. If last address in group move to first address of next group. @return false if went off end of the list, otherwise tru
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:702
↓ 3 callers
Method
initialFlowControlWindow
Sets the initial flow control window in bytes. Setting initial flow control window enables auto flow control tuning using bandwidth-delay product algo
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:420
↓ 3 callers
Method
instance
()
api/src/main/java/io/grpc/InternalChannelz.java:74
↓ 3 callers
Method
interceptors
Returns interceptors necessary for full service implementation.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:504
↓ 3 callers
Method
internalClose
Like {@link ServerCall#close(Status, Metadata)}, but thread-safe for internal use.
core/src/main/java/io/grpc/internal/ServerImpl.java:829
↓ 3 callers
Method
intervalNanos
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:337
↓ 3 callers
Method
intervalWithJitter
(long intervalNanos)
core/src/main/java/io/grpc/internal/RetriableStream.java:857
↓ 3 callers
Method
isAndroid
Accessor for {@link ServiceProviders#isAndroid}.
api/src/main/java/io/grpc/InternalServiceProviders.java:76
↓ 3 callers
Method
isCancelled
()
core/src/main/java/io/grpc/internal/RetriableStream.java:1613
↓ 3 callers
Method
isComplete
Returns true if we've parsed a complete frame.
alts/src/main/java/io/grpc/alts/internal/AltsFraming.java:321
↓ 3 callers
Method
isConnected
()
android/src/main/java/io/grpc/android/UdsSocket.java:213
↓ 3 callers
Method
isCurrent
()
api/src/context/java/io/grpc/Context.java:797
↓ 3 callers
Method
isDeviceOwner
Creates {@link SecurityPolicy} which checks if the app is a device owner app. See {@link DevicePolicyManager}.
binder/src/main/java/io/grpc/binder/SecurityPolicies.java:187
↓ 3 callers
Method
isInProgress
Returns true if and only if the handshake is still in progress. @return true, if the handshake is still in progress, false otherwise.
alts/src/main/java/io/grpc/alts/internal/AltsTsiHandshaker.java:176
↓ 3 callers
Method
isOutboundClosed
()
core/src/main/java/io/grpc/internal/AbstractClientStream.java:295
↓ 3 callers
Method
isReleased
()
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:443
↓ 3 callers
Method
isRequireClientCertificate
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:172
↓ 3 callers
Method
isShutDown
Returns {@code true} if {@link #shutdown()} has been called.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:312
↓ 3 callers
Method
isTerminal
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:241
↓ 3 callers
Method
iterator
()
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:498
↓ 3 callers
Method
keepAliveTime
Sets the time without read activity before sending a keepalive ping. An unreasonably small value might be increased, and {@code Long.MAX_VALUE} nano s
api/src/main/java/io/grpc/ServerBuilder.java:257
↓ 3 callers
Method
keepAliveTimeout
Sets a time waiting for read activity after sending a keepalive ping. If the time expires without any read activity on the connection, the connection
api/src/main/java/io/grpc/ServerBuilder.java:275
↓ 3 callers
Method
key
The name that will be used in the RLS key_map to refer to this value.
rls/src/main/java/io/grpc/rls/RlsProtoData.java:176
↓ 3 callers
Method
largeUnary
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:437
↓ 3 callers
Method
lengthWithoutPadding
(int length, byte flags, short padding)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:656
↓ 3 callers
Method
listener
Override this method to provide a stream listener.
core/src/main/java/io/grpc/internal/AbstractStream.java:201
↓ 3 callers
Method
listener
()
netty/src/test/java/io/grpc/netty/NettyStreamTestBase.java:205
↓ 3 callers
Method
loadClass
(String name, boolean resolve)
api/src/test/java/io/grpc/ServiceProvidersTestUtil.java:46
↓ 3 callers
Method
log
(ChannelLogLevel level, String message)
core/src/testFixtures/java/io/grpc/internal/TestUtils.java:161
↓ 3 callers
Method
logData
(Direction direction, int streamId, Buffer data, int length, boolean endStream)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:73
↓ 3 callers
Method
logGoAway
(Direction direction, int lastStreamId, ErrorCode errorCode, ByteString debugData)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:166
↓ 3 callers
Method
logHeaders
(Direction direction, int streamId, List<Header> headers, boolean endStream)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:89
↓ 3 callers
Method
logOnly
(InternalLogId logId, Level logLevel, String msg)
core/src/main/java/io/grpc/internal/ChannelTracer.java:123
↓ 3 callers
Method
logOnly
(InternalLogId logId, ChannelLogLevel level, String msg)
core/src/main/java/io/grpc/internal/ChannelLoggerImpl.java:55
↓ 3 callers
Method
logPing
(Direction direction, long data)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:139
↓ 3 callers
Method
logPushPromise
( Direction direction, int streamId, int promisedStreamId, List<Header> headers)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:151
↓ 3 callers
Method
logRstStream
(Direction direction, int streamId, ErrorCode errorCode)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:120
↓ 3 callers
Method
logSettings
(Direction direction, Settings settings)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:133
↓ 3 callers
Method
logTrailer
()
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:730
↓ 3 callers
Method
logWindowsUpdate
(Direction direction, int streamId, long windowSizeIncrement)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:182
↓ 3 callers
Method
lookForCompleteMessage
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:449
↓ 3 callers
Method
makeCall
()
binder/src/test/java/io/grpc/binder/RobolectricBinderSecurityTest.java:178
↓ 3 callers
Method
makeServiceCall
(boolean populateUid, boolean includeInterceptor)
binder/src/test/java/io/grpc/binder/PeerUidsTest.java:83
↓ 3 callers
Method
makeServiceCall
(boolean includeInterceptor, boolean includeUidInHeader, int uid)
binder/src/test/java/io/grpc/binder/PeerUidTestHelperTest.java:66
↓ 3 callers
Method
maxDataLength
The maximum size of bytes that may be sent in a single call to {@link #data}.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameWriter.java:63
↓ 3 callers
Method
maxEjectionPercent
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:346
↓ 3 callers
Method
maxEjectionTimeNanos
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:343
↓ 3 callers
Method
maxHeaderListSize
Sets the maximum size of header list allowed to be received. This is cumulative size of the headers with some overhead, as defined for <a href="http:/
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:476
↓ 3 callers
Method
maxInboundMetadataSize
Sets the maximum size of metadata allowed to be received. {@code Integer.MAX_VALUE} disables the enforcement. Defaults to no limit ({@code Integer.MAX
inprocess/src/main/java/io/grpc/inprocess/InProcessServerBuilder.java:195
↓ 3 callers
Method
mayHaveCreatedStream
(int streamId)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:1260
↓ 3 callers
Method
maybeCloseSpan
(AtomicReference<Span> applicationSpan)
interop-testing/src/test/java/io/grpc/testing/integration/OpenTelemetryContextPropagationTest.java:135
↓ 3 callers
Method
messageAvailable
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:148
↓ 3 callers
Method
metadataSize
(Metadata metadata)
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:348
↓ 3 callers
Method
method
()
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:383
↓ 3 callers
Method
methodName
()
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:82
↓ 3 callers
Method
min
Checks deadline for timeout.
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:446
↓ 3 callers
Method
minimumHosts
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:430
↓ 3 callers
Method
minimumHosts
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:455
↓ 3 callers
Method
names
Returns ordered list of names; the first non-empty value will be used.
rls/src/main/java/io/grpc/rls/RlsProtoData.java:179
↓ 3 callers
Method
negotiator
( ProtocolNegotiator.ClientFactory factory)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:280
↓ 3 callers
Method
negotiator
(ProtocolNegotiator.ServerFactory factory)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:311
↓ 3 callers
Method
newAttachMetadataServerInterceptor
Returns a ServerInterceptor that adds the specified Metadata to every response stream, one way or another. <p>If, absent this interceptor, a stream w
stub/src/main/java/io/grpc/stub/MetadataUtils.java:167
↓ 3 callers
Method
newBinderChannelBuilder
()
binder/src/androidTest/java/io/grpc/binder/BinderChannelSmokeTest.java:156
↓ 3 callers
Method
newBuilder
()
alts/src/main/java/io/grpc/alts/AltsChannelCredentials.java:51
↓ 3 callers
Method
newBuilder
(String clusterName)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:640
↓ 3 callers
Method
newCall
( MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions)
core/src/main/java/io/grpc/internal/SubchannelChannel.java:85
↓ 3 callers
Method
newCall
(MethodDescriptor<ReqT, RespT> method, CallOptions callOptions)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:808
↓ 3 callers
Method
newChannelBuilder
(String target, ChannelCredentials creds)
netty/src/main/java/io/grpc/netty/NettyChannelProvider.java:48
↓ 3 callers
Method
newClientCall
( MethodDescriptor<ReqT, RespT> method, CallOptions callOptions)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1046
↓ 3 callers
Method
newClientStreamTracer
(StreamInfo info, Metadata headers)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:660
↓ 3 callers
Method
newClientStreamTracer
( ClientStreamTracer.StreamInfo info, Metadata headers)
grpclb/src/main/java/io/grpc/grpclb/TokenAttachingTracerFactory.java:43
↓ 3 callers
Method
newClientTransport
( SocketAddress serverAddress, ClientTransportOptions options, ChannelLogger channelLogger)
core/src/main/java/io/grpc/internal/CallCredentialsApplyingTransportFactory.java:56
↓ 3 callers
Method
newFakeCreateSubchannelArgs
()
util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:740
↓ 3 callers
Method
newFakeHandshakerServer
()
alts/src/test/java/io/grpc/alts/internal/FakeTsiHandshaker.java:93
↓ 3 callers
Method
newInProcessChannelBuilder
()
stub/src/test/java/io/grpc/stub/MetadataUtilsTest.java:172
↓ 3 callers
Method
newInProcessServerBuilder
()
stub/src/test/java/io/grpc/stub/MetadataUtilsTest.java:168
← previous
next →
3,801–3,900 of 22,628, ranked by callers