MCPcopy Create free account

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

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

MethodfilterTransport
(Attributes attributes)
core/src/main/java/io/grpc/internal/InternalSubchannel.java:583
MethodfilterTransport
(Attributes attributes)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:2009
MethodfilterTransport
(Attributes attributes)
netty/src/test/java/io/grpc/netty/NettyTransportTest.java:151
MethodfilterType_clientAndServer
()
xds/src/test/java/io/grpc/xds/RouterFilterTest.java:30
MethodfilterType_clientOnly
()
xds/src/test/java/io/grpc/xds/GcpAuthenticationFilterTest.java:105
MethodfilterType_clientOnly
()
xds/src/test/java/io/grpc/xds/FaultFilterTest.java:42
MethodfilterType_serverOnly
()
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:88
Methodfilter_mutationRules_disallowAll_dropsAll
()
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:115
Methodfilter_mutationRules_disallowAll_throws
()
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:129
Methodfilter_mutationRules_disallowExpression_dropsMatching
()
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:152
Methodfilter_mutationRules_disallowExpression_throws
()
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:169
Methodfilter_mutationRules_precedence
()
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:187
Methodfilter_mutationRules_precedence_throws
()
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:213
Methodfilter_validationRules_dropsInvalidHeaders
()
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:47
Methodfilter_validationRules_throwsOnInvalidHeaders
()
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:75
MethodfinalizeAndDump2
Returns all save metric values. No more metric values will be recorded after this method is called. Calling this method multiple times returns the sam
services/src/main/java/io/grpc/services/CallMetricRecorder.java:258
MethodfindClass
(String name)
okhttp/src/test/java/io/grpc/okhttp/OkHttpProtocolNegotiatorTest.java:58
MethodfindOrCreateClientSslContextProvider
( UpstreamTlsContext upstreamTlsContext)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1361
MethodfindOrCreateServerSslContextProvider
( DownstreamTlsContext downstreamTlsContext)
xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1376
MethodfindVirtualHostForHostName_asteriskMatchAnyDomain
()
xds/src/test/java/io/grpc/xds/RoutingUtilsTest.java:76
MethodfindVirtualHostForHostName_exactMatchFirst
()
xds/src/test/java/io/grpc/xds/RoutingUtilsTest.java:40
MethodfindVirtualHostForHostName_preferSuffixDomainOverPrefixDomain
()
xds/src/test/java/io/grpc/xds/RoutingUtilsTest.java:58
Methodfine
(String str, Object... params)
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:95
Methodfinest
(String str, Object... params)
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:102
MethodfinishStream
(CronetClientStream stream, Status status)
cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java:268
Methodfinished
(Description description)
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:134
MethodfinishedStreamRemovedFromInUseState
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2209
MethodfirstExecuteThrows
()
core/src/test/java/io/grpc/internal/SerializingExecutorTest.java:160
MethodfirstResolvedServerFailedToConnect
Verify that if the first resolved address points to a server that cannot be connected, the call will end up with the second address which works.
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:1344
MethodfirstSubchannelConnecting
()
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:758
MethodfirstSubchannelFailure
()
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:782
MethodfirstSubchannelIdle
()
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:736
MethodfirstValue
Returns a {@link ListenableFuture} for the first value received from the stream. Useful for testing unary call patterns.
testing/src/main/java/io/grpc/internal/testing/StreamRecorder.java:110
MethodfixedContextExecutor
()
api/src/test/java/io/grpc/ContextTest.java:572
MethodflowControl
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceV1Test.java:559
MethodflowControl
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java:559
MethodflowControlAbsent
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:3805
MethodflowControlDoesNotDeadlockLargeMessage
()
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:1484
MethodflowControlDoesNotDeadlockLargeMessage
()
servlet/src/jettyTest/java/io/grpc/servlet/JettyTransportTest.java:211
MethodflowControlDoesNotDeadlockLargeMessage
()
servlet/src/tomcatTest/java/io/grpc/servlet/TomcatTransportTest.java:228
MethodflowControlDoesNotDeadlockLargeMessage
()
servlet/src/undertowTest/java/io/grpc/servlet/UndertowTransportTest.java:272
MethodflowControlOnCompleteWithPendingRequest
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceV1Test.java:587
MethodflowControlOnCompleteWithPendingRequest
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java:587
MethodflowControlPushBack
()
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:1347
MethodflowControlPushBack
()
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:445
MethodflowControlPushBack
()
binder/src/androidTest/java/io/grpc/binder/internal/BinderTransportTest.java:117
MethodflowControlPushBack
()
servlet/src/jettyTest/java/io/grpc/servlet/JettyTransportTest.java:205
MethodflowControlPushBack
()
servlet/src/tomcatTest/java/io/grpc/servlet/TomcatTransportTest.java:222
MethodflowControlPushBack
()
servlet/src/undertowTest/java/io/grpc/servlet/UndertowTransportTest.java:266
MethodflowControlUnknownType
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:4031
MethodflowControlWindow
Sets the flow control window in bytes. If not called, the default value is {@link #DEFAULT_FLOW_CONTROL_WINDOW}).
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:360
Methodflush
()
gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/NettyClientInteropServlet.java:61
Methodflush
()
core/src/test/java/io/grpc/internal/ChannelLoggerImplTest.java:53
Methodflush
()
core/src/test/java/io/grpc/internal/ChannelTracerTest.java:50
Methodflush
Flush the buffered payload.
core/src/main/java/io/grpc/internal/Framer.java:32
Methodflush
()
core/src/main/java/io/grpc/internal/RetriableStream.java:616
Methodflush
()
core/src/main/java/io/grpc/internal/NoopClientStream.java:52
Methodflush
()
core/src/main/java/io/grpc/internal/ForwardingClientStream.java:40
Methodflush
()
core/src/main/java/io/grpc/internal/AbstractClientStream.java:504
Methodflush
()
core/src/main/java/io/grpc/internal/DelayedStream.java:299
Methodflush
()
core/src/main/java/io/grpc/internal/AbstractStream.java:77
Methodflush
Flushes any buffered data in the framer to the sink.
core/src/main/java/io/grpc/internal/MessageFramer.java:307
Methodflush
()
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:536
Methodflush
()
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:831
Methodflush
()
api/src/test/java/io/grpc/ThreadLocalContextStorageTest.java:66
Methodflush
()
api/src/test/java/io/grpc/ContextTest.java:181
Methodflush
()
api/src/test/java/io/grpc/ContextTest.java:1037
Methodflush
()
okhttp/src/test/java/io/grpc/okhttp/AsyncSinkTest.java:311
Methodflush
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:313
Methodflush
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2685
Methodflush
()
okhttp/src/test/java/io/grpc/okhttp/ExceptionHandlingFrameWriterTest.java:118
Methodflush
()
okhttp/src/main/java/io/grpc/okhttp/ForwardingFrameWriter.java:58
Methodflush
()
okhttp/src/main/java/io/grpc/okhttp/AsyncSink.java:154
Methodflush
()
okhttp/src/main/java/io/grpc/okhttp/ExceptionHandlingFrameWriter.java:88
Methodflush
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Http2.java:392
Methodflush
()
binder/src/main/java/io/grpc/binder/internal/SingleMessageClientStream.java:139
Methodflush
()
binder/src/main/java/io/grpc/binder/internal/SingleMessageServerStream.java:150
Methodflush
()
binder/src/main/java/io/grpc/binder/internal/MultiMessageServerStream.java:158
Methodflush
()
binder/src/main/java/io/grpc/binder/internal/MultiMessageClientStream.java:147
Methodflush
()
util/src/test/java/io/grpc/util/AdvancedTlsX509KeyManagerTest.java:196
Methodflush
()
util/src/test/java/io/grpc/util/AdvancedTlsX509TrustManagerTest.java:210
Methodflush
Called from application thread.
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:160
Methodflush
(@Param(name = "keepReady") boolean keepReady)
servlet/src/threadingTest/java/io/grpc/servlet/AsyncServletOutputStreamWriterConcurrencyTest.java:135
Methodflush
(ChannelHandlerContext ctx)
netty/src/test/java/io/grpc/netty/WriteBufferingAndExceptionHandlerTest.java:299
Methodflush
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:642
Methodflush
Calls to this method will not trigger an immediate flush. The flush will be deferred until {@link #writeBufferedAndRemove(ChannelHandlerContext)}.
netty/src/main/java/io/grpc/netty/WriteBufferingAndExceptionHandler.java:185
Methodflush
()
xds/src/test/java/io/grpc/xds/XdsClientMetricReporterImplTest.java:404
MethodflushAfterCloseShouldWork
()
alts/src/test/java/io/grpc/alts/internal/TsiFrameHandlerTest.java:92
MethodflushCoalescing_shouldMergeTwoQueuedFlushesAndWrites
()
okhttp/src/test/java/io/grpc/okhttp/AsyncSinkTest.java:96
MethodflushCoalescing_shouldMergeWrites
()
okhttp/src/test/java/io/grpc/okhttp/AsyncSinkTest.java:116
MethodflushCoalescing_shouldNotMergeTwoDistinctFlushes
()
okhttp/src/test/java/io/grpc/okhttp/AsyncSinkTest.java:74
MethodflushIsIdempotent
()
core/src/test/java/io/grpc/internal/MessageFramerTest.java:189
MethodflushShouldFailAllPromises
()
alts/src/test/java/io/grpc/alts/internal/AltsProtocolNegotiatorTest.java:284
Methodflush_beforeStart
()
core/src/test/java/io/grpc/internal/DelayedStreamTest.java:99
Methodflush_shouldThrowIfAlreadyClosed
()
okhttp/src/test/java/io/grpc/okhttp/AsyncSinkTest.java:196
MethodforAddress
(String name, int port)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:81
MethodforAddress
Creates a new builder with the given host and port.
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:106
MethodforAddress
"Overrides" the static method in {@link ManagedChannelBuilder}.
alts/src/main/java/io/grpc/alts/AltsChannelBuilder.java:46
MethodforAddress
"Overrides" the static method in {@link ManagedChannelBuilder}.
alts/src/main/java/io/grpc/alts/GoogleDefaultChannelBuilder.java:43
MethodforAddress
"Overrides" the static method in {@link ManagedChannelBuilder}.
alts/src/main/java/io/grpc/alts/ComputeEngineChannelBuilder.java:43
← previousnext →12,901–13,000 of 22,628, ranked by callers