MCPcopy Create free account

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

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

↓ 1 callersMethodsendAndExpectUnexpectedMessage
Send a message and expect an IOException on unexpected message.
alts/src/test/java/io/grpc/alts/internal/AltsHandshakerStubTest.java:86
↓ 1 callersMethodsendBuffer
(Buffer buffer, boolean endOfStream, boolean flush)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java:380
↓ 1 callersMethodsendBuffer
(Buffer buffer, boolean flush)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java:247
↓ 1 callersMethodsendClose
(Status closeStatus, Metadata trailers)
binder/src/main/java/io/grpc/binder/internal/Outbound.java:460
↓ 1 callersMethodsendConnectionPrefaceAndSettings
Should only be called once when the transport is first established.
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:826
↓ 1 callersMethodsendGetTlsConfigResp
()
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:140
↓ 1 callersMethodsendGrpcFrame
Sends the given gRPC frame to the client.
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:775
↓ 1 callersMethodsendGrpcFrame
Sends the given GRPC frame for the stream.
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:836
↓ 1 callersMethodsendHalfClose
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:382
↓ 1 callersMethodsendHeaders
(Metadata headers)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1378
↓ 1 callersMethodsendHeaders
(Metadata headers)
gcp-csm-observability/src/main/java/io/grpc/gcp/csm/observability/MetadataExchanger.java:287
↓ 1 callersMethodsendHeaders
(Metadata responseHeaders)
examples/src/main/java/io/grpc/examples/header/HeaderServerInterceptor.java:46
↓ 1 callersMethodsendHeaders
(Metadata headers)
binder/src/main/java/io/grpc/binder/internal/Outbound.java:422
↓ 1 callersMethodsendHeaders
(final Metadata headers)
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:152
↓ 1 callersMethodsendHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/MetadataUtils.java:194
↓ 1 callersMethodsendHeaders
(Metadata responseHeaders)
xds/src/test/java/io/grpc/xds/DataPlaneRule.java:143
↓ 1 callersMethodsendHeadersInternal
(Metadata headers)
core/src/main/java/io/grpc/internal/ServerCallImpl.java:108
↓ 1 callersMethodsendInternal
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:220
↓ 1 callersMethodsendLoadReport
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:692
↓ 1 callersMethodsendLoadReport
()
xds/src/main/java/io/grpc/xds/client/LoadReportClient.java:250
↓ 1 callersMethodsendMessage
(View view)
examples/android/helloworld/app/src/main/java/io/grpc/helloworldexample/HelloworldActivity.java:67
↓ 1 callersMethodsendMessage
(final RespT message)
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:132
↓ 1 callersMethodsendMessageInternal
(ReqT message)
core/src/main/java/io/grpc/internal/ClientCallImpl.java:515
↓ 1 callersMethodsendMessageInternal
(RespT message)
core/src/main/java/io/grpc/internal/ServerCallImpl.java:156
↓ 1 callersMethodsendOutOfBandClose
(int callId, Status status)
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:427
↓ 1 callersMethodsendPing
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:236
↓ 1 callersMethodsendPingFrame
(ChannelHandlerContext ctx, SendPingCommand msg, ChannelPromise promise)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:847
↓ 1 callersMethodsendPingFrameTraced
Sends a PING frame. If a ping operation is already outstanding, the callback in the message is registered to be called when the existing operation com
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:859
↓ 1 callersMethodsendResponse
(RouteLookupResponse response, StreamObserver<io.grpc.lookup.v1.RouteLookupResponse> responseObserver)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:859
↓ 1 callersMethodsendResponseHeaders
Sends the response headers to the client.
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:799
↓ 1 callersMethodsendShutdownTransaction
()
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:362
↓ 1 callersMethodsendSingleMessageAndClose
( @Nullable Metadata pendingHeaders, @Nullable InputStream pendingSingleMessage, Statu
binder/src/main/java/io/grpc/binder/internal/Outbound.java:436
↓ 1 callersMethodsendSingleMessageAndHalfClose
(@Nullable InputStream singleMessage)
binder/src/main/java/io/grpc/binder/internal/Outbound.java:373
↓ 1 callersMethodsendSingleRequest
(ReqT request)
stub/src/main/java/io/grpc/stub/BlockingClientCall.java:238
↓ 1 callersMethodsendSuccessfulMessage
Send a message as in_bytes and expect same message as out_frames echo back.
alts/src/test/java/io/grpc/alts/internal/AltsHandshakerStubTest.java:52
↓ 1 callersMethodsendTrailers
(List<Header> responseTrailers)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java:263
↓ 1 callersMethodsendTrailersAfterFlowControlled
(List<Header> responseTrailers)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java:269
↓ 1 callersMethodsendUnexpectedResponse
Send a handshaker response to reader.
alts/src/test/java/io/grpc/alts/internal/AltsHandshakerStubTest.java:143
↓ 1 callersMethodserializeHeadersWithCommasInBin
(byte[][] http2Headers, int resumeFrom)
core/src/main/java/io/grpc/internal/TransportFrameUtil.java:121
↓ 1 callersMethodserverAddressesToString
(List<InetSocketAddress> addresses)
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:422
↓ 1 callersMethodserverAltsProtocolNegotiator
Creates a protocol negotiator for ALTS on the server side.
alts/src/main/java/io/grpc/alts/internal/AltsProtocolNegotiator.java:148
↓ 1 callersMethodserverCallMethodResolved
Notifies server tracers that a primary-registry method descriptor was resolved before {@link ServerStreamTracer#serverCallStarted(ServerCallInfo)}. <
core/src/main/java/io/grpc/internal/StatsTraceContext.java:162
↓ 1 callersMethodserverCallStarted
See {@link ServerStreamTracer#serverCallStarted}. For server-side only. <p>Called from {@link io.grpc.internal.ServerImpl}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:150
↓ 1 callersMethodserverCompressedStreaming
Tests server per-message compression in a streaming response. Ideally we would assert that the responses have the requested compression, but this is n
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:680
↓ 1 callersMethodserverCompressedUnary
Tests if the server can send a compressed unary response. Ideally we would assert that the responses have the requested compression, but this is not s
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:513
↓ 1 callersMethodserverFactory
()
binder/src/androidTest/java/io/grpc/binder/HostServices.java:70
↓ 1 callersMethodserverFilterContext
See {@link ServerStreamTracer#filterContext}. For server-side only. <p>Called from {@link io.grpc.internal.ServerImpl}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:135
↓ 1 callersMethodserverHostOverride
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:696
↓ 1 callersMethodserverPlaintext
Returns a {@link ProtocolNegotiator} for plaintext server channel.
netty/src/main/java/io/grpc/netty/InternalProtocolNegotiators.java:136
↓ 1 callersMethodserverProtocolNegotiatorFactory
( @Nullable InternalProtocolNegotiator.ServerFactory fallbackNegotiator)
xds/src/main/java/io/grpc/xds/internal/security/SecurityProtocolNegotiators.java:89
↓ 1 callersMethodserverRequested
Client requested more messages. @return whether onReady should be called on the server
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:754
↓ 1 callersMethodserverResponseHeaders
(byte[][] serializedMetadata)
netty/src/main/java/io/grpc/netty/GrpcHttp2OutboundHeaders.java:49
↓ 1 callersMethodserverResponseTrailers
(byte[][] serializedMetadata)
netty/src/main/java/io/grpc/netty/GrpcHttp2OutboundHeaders.java:57
↓ 1 callersMethodserverStreamingShouldBeFlowControlled
()
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:915
↓ 1 callersMethodserverTls
Returns a {@link ProtocolNegotiator} that ensures the pipeline is set up so that TLS will be negotiated, the server TLS {@code handler} is added and w
netty/src/main/java/io/grpc/netty/InternalProtocolNegotiators.java:88
↓ 1 callersMethodserviceAccountCreds
Sends a large unary rpc with service account credentials.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:793
↓ 1 callersMethodserviceUri
Generate a JWT-specific service URI. The URI is simply an identifier with enough information for a service to know that the JWT was intended for it. T
auth/src/main/java/io/grpc/auth/ClientAuthInterceptor.java:97
↓ 1 callersMethodserviceUri
Generate a JWT-specific service URI. The URI is simply an identifier with enough information for a service to know that the JWT was intended for it. T
auth/src/main/java/io/grpc/auth/GoogleAuthLibraryCallCredentials.java:165
↓ 1 callersMethodset
(CharSequence name, CharSequence value)
netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java:200
↓ 1 callersMethodsetAboveClient
Sets or clears the {@link android.content.Context#BIND_ABOVE_CLIENT} flag. <p>This flag has no additional meaning at the gRPC layer. See the Android
binder/src/main/java/io/grpc/binder/BindServiceFlags.java:91
↓ 1 callersMethodsetAdjustWithActivity
Sets or clears the {@link android.content.Context#BIND_ADJUST_WITH_ACTIVITY} flag. <p>This flag has no additional meaning at the gRPC layer. See the
binder/src/main/java/io/grpc/binder/BindServiceFlags.java:102
↓ 1 callersMethodsetAdvmss
(int advmss)
api/src/main/java/io/grpc/InternalChannelz.java:963
↓ 1 callersMethodsetAggregateCdsConfig
(XdsTestControlPlaneService service, String serverName, String clusterName
xds/src/test/java/io/grpc/xds/XdsTestUtils.java:175
↓ 1 callersMethodsetAll
(Headers<? extends CharSequence, ? extends CharSequence, ?> headers)
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:483
↓ 1 callersMethodsetAllowActivityStarts
Sets or clears the {@code android.content.Context#BIND_ALLOW_ACTIVITY_STARTS} flag. <p>This flag has no additional meaning at the gRPC layer. See the
binder/src/main/java/io/grpc/binder/BindServiceFlags.java:113
↓ 1 callersMethodsetAllowOomManagement
Sets or clears the {@link android.content.Context#BIND_ALLOW_OOM_MANAGEMENT} flag. <p>This flag has no additional meaning at the gRPC layer. See the
binder/src/main/java/io/grpc/binder/BindServiceFlags.java:125
↓ 1 callersMethodsetAto
(int ato)
api/src/main/java/io/grpc/InternalChannelz.java:873
↓ 1 callersMethodsetAttributes
(Attributes attributes)
binder/src/test/java/io/grpc/binder/internal/BinderServerTransportTest.java:147
↓ 1 callersMethodsetAuthority
(final String authority)
core/src/main/java/io/grpc/internal/DelayedStream.java:220
↓ 1 callersMethodsetBackoff
(int backoff)
api/src/main/java/io/grpc/InternalChannelz.java:848
↓ 1 callersMethodsetBindingAction
(String bindAction)
binder/src/test/java/io/grpc/binder/internal/ServiceBindingTest.java:504
↓ 1 callersMethodsetC2pId
(int c2pId)
googleapis/src/main/java/io/grpc/googleapis/GoogleCloudToProdNameResolver.java:400
↓ 1 callersMethodsetCaState
(int caState)
api/src/main/java/io/grpc/InternalChannelz.java:833
↓ 1 callersMethodsetChannelCredentials
(BinderChannelCredentials channelCredentials)
binder/src/main/java/io/grpc/binder/internal/BinderClientTransportFactory.java:152
↓ 1 callersMethodsetClientAuthValues
( SslContextBuilder sslContextBuilder, XdsTrustManagerFactory xdsTrustManagerFactory)
xds/src/main/java/io/grpc/xds/internal/security/SslContextProvider.java:77
↓ 1 callersMethodsetClientStub
(GreeterGrpc.GreeterBlockingStub clientStub)
examples/src/main/java/io/grpc/examples/deadline/DeadlineServer.java:97
↓ 1 callersMethodsetClientValue
(ClientConfiguration config, String value)
benchmarks/src/main/java/io/grpc/benchmarks/qps/ClientConfiguration.java:128
↓ 1 callersMethodsetClosedStatus
Stores the {@code Status} that the application used to close this stream.
core/src/main/java/io/grpc/internal/AbstractServerStream.java:363
↓ 1 callersMethodsetCompression
(final String compressor)
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:233
↓ 1 callersMethodsetCompressorRegistry
(CompressorRegistry compressorRegistry)
core/src/main/java/io/grpc/internal/ClientCallImpl.java:149
↓ 1 callersMethodsetConfig
(OutlierDetectionLoadBalancerConfig config)
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:521
↓ 1 callersMethodsetCurrentPicker
(SubchannelPicker newPicker)
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:322
↓ 1 callersMethodsetCurrentState
(ConnectivityState newState)
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:318
↓ 1 callersMethodsetDeadlineTicker
Sets a custom deadline ticker. This should only be called from InProcessServerBuilder.
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:252
↓ 1 callersMethodsetDecompressor
(Decompressor decompressor)
core/src/main/java/io/grpc/internal/AbstractStream.java:292
↓ 1 callersMethodsetDefaultBootstrapOverride
(Map<String, ?> rawBootstrap)
xds/src/main/java/io/grpc/xds/GrpcBootstrapperImpl.java:115
↓ 1 callersMethodsetDelayDispatchUntilContent
(HttpConfiguration httpConfiguration)
servlet/src/jettyTest/java/io/grpc/servlet/JettyTransportTest.java:139
↓ 1 callersMethodsetDueTimeNanos
(long dueTimeNanos)
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:102
↓ 1 callersMethodsetEnableClientStreamTracers
(boolean enableClientStreamTracers)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:301
↓ 1 callersMethodsetEnableTxt
(boolean enableTxt)
grpclb/src/main/java/io/grpc/grpclb/GrpclbNameResolver.java:151
↓ 1 callersMethodsetEnabledCipherSuites
(String[] suites)
okhttp/src/main/java/io/grpc/okhttp/NoopSslSocket.java:38
↓ 1 callersMethodsetEnabledProtocols
(String[] protocols)
okhttp/src/main/java/io/grpc/okhttp/NoopSslSocket.java:53
↓ 1 callersMethodsetEndpointTracker
If the {@link Subchannel} is considered for outlier detection the associated {@link EndpointTracker} should be set.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:365
↓ 1 callersMethodsetError
(Status error)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4630
↓ 1 callersMethodsetException
(Throwable throwable)
examples/src/main/java/io/grpc/examples/multiplex/SharingClient.java:233
↓ 1 callersMethodsetFackets
(int fackets)
api/src/main/java/io/grpc/InternalChannelz.java:908
↓ 1 callersMethodsetFlags
(int bindServiceFlags)
binder/src/test/java/io/grpc/binder/internal/ServiceBindingTest.java:509
↓ 1 callersMethodsetFullStreamDecompressor
(GzipInflatingBuffer fullStreamDecompressor)
core/src/main/java/io/grpc/internal/MessageDeframer.java:146
↓ 1 callersMethodsetFullStreamDecompressor
(GzipInflatingBuffer fullStreamDecompressor)
core/src/main/java/io/grpc/internal/AbstractStream.java:189
↓ 1 callersMethodsetGrpcHeaders
(BidirectionalStream.Builder builder)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:370
← previousnext →7,401–7,500 of 22,628, ranked by callers