MCPcopy Create free account

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

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

↓ 3 callersMethodhasPotentialHedging
(State state)
core/src/main/java/io/grpc/internal/RetriableStream.java:816
↓ 3 callersMethodhasSignatureSha256Hash
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 callersMethodhasValue
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 callersMethodhasX509ExtendedTrustManager
()
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:638
↓ 3 callersMethodhashCode
()
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:592
↓ 3 callersMethodhashInt
(int input)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:66
↓ 3 callersMethodhashLong
(long input)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:55
↓ 3 callersMethodhashShort
(short input)
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:74
↓ 3 callersMethodheader
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 callersMethodheaderRemove
(List<Header> header, ByteString key)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:503
↓ 3 callersMethodheaders
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/Request.java:39
↓ 3 callersMethodhost
()
rls/src/main/java/io/grpc/rls/RlsProtoData.java:242
↓ 3 callersMethodhost
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 callersMethodhostnameVerifier
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 callersMethodhttp2ProcessingFailed
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 callersMethodidleTimeout
(long value, TimeUnit unit)
binder/src/main/java/io/grpc/binder/BinderChannelBuilder.java:344
↓ 3 callersMethodignoreCase
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:229
↓ 3 callersMethodinboundHeaders
Headers has been received from the server.
api/src/main/java/io/grpc/ClientStreamTracer.java:69
↓ 3 callersMethodinboundMessage
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 callersMethodinboundMessageRead
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 callersMethodinboundUncompressedSize
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 callersMethodinboundUncompressedSize
(long bytes)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:234
↓ 3 callersMethodinboundWireSize
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 callersMethodincludePeerCertificate
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 callersMethodincrement
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 callersMethodinitialFlowControlWindow
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 callersMethodinstance
()
api/src/main/java/io/grpc/InternalChannelz.java:74
↓ 3 callersMethodinterceptors
Returns interceptors necessary for full service implementation.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:504
↓ 3 callersMethodinternalClose
Like {@link ServerCall#close(Status, Metadata)}, but thread-safe for internal use.
core/src/main/java/io/grpc/internal/ServerImpl.java:829
↓ 3 callersMethodintervalNanos
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:337
↓ 3 callersMethodintervalWithJitter
(long intervalNanos)
core/src/main/java/io/grpc/internal/RetriableStream.java:857
↓ 3 callersMethodisAndroid
Accessor for {@link ServiceProviders#isAndroid}.
api/src/main/java/io/grpc/InternalServiceProviders.java:76
↓ 3 callersMethodisCancelled
()
core/src/main/java/io/grpc/internal/RetriableStream.java:1613
↓ 3 callersMethodisComplete
Returns true if we've parsed a complete frame.
alts/src/main/java/io/grpc/alts/internal/AltsFraming.java:321
↓ 3 callersMethodisConnected
()
android/src/main/java/io/grpc/android/UdsSocket.java:213
↓ 3 callersMethodisCurrent
()
api/src/context/java/io/grpc/Context.java:797
↓ 3 callersMethodisDeviceOwner
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 callersMethodisInProgress
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 callersMethodisOutboundClosed
()
core/src/main/java/io/grpc/internal/AbstractClientStream.java:295
↓ 3 callersMethodisReleased
()
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:443
↓ 3 callersMethodisRequireClientCertificate
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:172
↓ 3 callersMethodisShutDown
Returns {@code true} if {@link #shutdown()} has been called.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:312
↓ 3 callersMethodisTerminal
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:241
↓ 3 callersMethoditerator
()
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:498
↓ 3 callersMethodkeepAliveTime
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 callersMethodkeepAliveTimeout
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 callersMethodkey
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 callersMethodlargeUnary
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:437
↓ 3 callersMethodlengthWithoutPadding
(int length, byte flags, short padding)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:656
↓ 3 callersMethodlistener
Override this method to provide a stream listener.
core/src/main/java/io/grpc/internal/AbstractStream.java:201
↓ 3 callersMethodlistener
()
netty/src/test/java/io/grpc/netty/NettyStreamTestBase.java:205
↓ 3 callersMethodloadClass
(String name, boolean resolve)
api/src/test/java/io/grpc/ServiceProvidersTestUtil.java:46
↓ 3 callersMethodlog
(ChannelLogLevel level, String message)
core/src/testFixtures/java/io/grpc/internal/TestUtils.java:161
↓ 3 callersMethodlogData
(Direction direction, int streamId, Buffer data, int length, boolean endStream)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:73
↓ 3 callersMethodlogGoAway
(Direction direction, int lastStreamId, ErrorCode errorCode, ByteString debugData)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:166
↓ 3 callersMethodlogHeaders
(Direction direction, int streamId, List<Header> headers, boolean endStream)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:89
↓ 3 callersMethodlogOnly
(InternalLogId logId, Level logLevel, String msg)
core/src/main/java/io/grpc/internal/ChannelTracer.java:123
↓ 3 callersMethodlogOnly
(InternalLogId logId, ChannelLogLevel level, String msg)
core/src/main/java/io/grpc/internal/ChannelLoggerImpl.java:55
↓ 3 callersMethodlogPing
(Direction direction, long data)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:139
↓ 3 callersMethodlogPushPromise
( Direction direction, int streamId, int promisedStreamId, List<Header> headers)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:151
↓ 3 callersMethodlogRstStream
(Direction direction, int streamId, ErrorCode errorCode)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:120
↓ 3 callersMethodlogSettings
(Direction direction, Settings settings)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:133
↓ 3 callersMethodlogTrailer
()
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:730
↓ 3 callersMethodlogWindowsUpdate
(Direction direction, int streamId, long windowSizeIncrement)
okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:182
↓ 3 callersMethodlookForCompleteMessage
()
binder/src/main/java/io/grpc/binder/internal/Inbound.java:449
↓ 3 callersMethodmakeCall
()
binder/src/test/java/io/grpc/binder/RobolectricBinderSecurityTest.java:178
↓ 3 callersMethodmakeServiceCall
(boolean populateUid, boolean includeInterceptor)
binder/src/test/java/io/grpc/binder/PeerUidsTest.java:83
↓ 3 callersMethodmakeServiceCall
(boolean includeInterceptor, boolean includeUidInHeader, int uid)
binder/src/test/java/io/grpc/binder/PeerUidTestHelperTest.java:66
↓ 3 callersMethodmaxDataLength
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 callersMethodmaxEjectionPercent
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:346
↓ 3 callersMethodmaxEjectionTimeNanos
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:343
↓ 3 callersMethodmaxHeaderListSize
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 callersMethodmaxInboundMetadataSize
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 callersMethodmayHaveCreatedStream
(int streamId)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:1260
↓ 3 callersMethodmaybeCloseSpan
(AtomicReference<Span> applicationSpan)
interop-testing/src/test/java/io/grpc/testing/integration/OpenTelemetryContextPropagationTest.java:135
↓ 3 callersMethodmessageAvailable
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:148
↓ 3 callersMethodmetadataSize
(Metadata metadata)
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:348
↓ 3 callersMethodmethod
()
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:383
↓ 3 callersMethodmethodName
()
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:82
↓ 3 callersMethodmin
Checks deadline for timeout.
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:446
↓ 3 callersMethodminimumHosts
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:430
↓ 3 callersMethodminimumHosts
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:455
↓ 3 callersMethodnames
Returns ordered list of names; the first non-empty value will be used.
rls/src/main/java/io/grpc/rls/RlsProtoData.java:179
↓ 3 callersMethodnegotiator
( ProtocolNegotiator.ClientFactory factory)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:280
↓ 3 callersMethodnegotiator
(ProtocolNegotiator.ServerFactory factory)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:311
↓ 3 callersMethodnewAttachMetadataServerInterceptor
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 callersMethodnewBinderChannelBuilder
()
binder/src/androidTest/java/io/grpc/binder/BinderChannelSmokeTest.java:156
↓ 3 callersMethodnewBuilder
()
alts/src/main/java/io/grpc/alts/AltsChannelCredentials.java:51
↓ 3 callersMethodnewBuilder
(String clusterName)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:640
↓ 3 callersMethodnewCall
( MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions)
core/src/main/java/io/grpc/internal/SubchannelChannel.java:85
↓ 3 callersMethodnewCall
(MethodDescriptor<ReqT, RespT> method, CallOptions callOptions)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:808
↓ 3 callersMethodnewChannelBuilder
(String target, ChannelCredentials creds)
netty/src/main/java/io/grpc/netty/NettyChannelProvider.java:48
↓ 3 callersMethodnewClientCall
( MethodDescriptor<ReqT, RespT> method, CallOptions callOptions)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1046
↓ 3 callersMethodnewClientStreamTracer
(StreamInfo info, Metadata headers)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:660
↓ 3 callersMethodnewClientStreamTracer
( ClientStreamTracer.StreamInfo info, Metadata headers)
grpclb/src/main/java/io/grpc/grpclb/TokenAttachingTracerFactory.java:43
↓ 3 callersMethodnewClientTransport
( SocketAddress serverAddress, ClientTransportOptions options, ChannelLogger channelLogger)
core/src/main/java/io/grpc/internal/CallCredentialsApplyingTransportFactory.java:56
↓ 3 callersMethodnewFakeCreateSubchannelArgs
()
util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:740
↓ 3 callersMethodnewFakeHandshakerServer
()
alts/src/test/java/io/grpc/alts/internal/FakeTsiHandshaker.java:93
↓ 3 callersMethodnewInProcessChannelBuilder
()
stub/src/test/java/io/grpc/stub/MetadataUtilsTest.java:172
↓ 3 callersMethodnewInProcessServerBuilder
()
stub/src/test/java/io/grpc/stub/MetadataUtilsTest.java:168
← previousnext →3,801–3,900 of 22,628, ranked by callers