MCPcopy Create free account

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

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

⨍ Functions 22,628◇ Types & classes 3,835
↓ 56 callersMethodtoX509Certificates
Generates X509Certificate array from a file on disk. @param file a {@link File} containing the cert data
xds/src/main/java/io/grpc/xds/internal/security/trust/CertificateUtils.java:41
↓ 56 callersMethodwriteInt
(int value, int prefixMask, int bits)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Hpack.java:508
↓ 55 callersMethodnewChannelBuilder
Creates a channel builder with a target string and credentials. The target can be either a valid {@link NameResolver}-compliant URI, or an authority s
api/src/main/java/io/grpc/Grpc.java:106
↓ 55 callersMethodsetException
(Throwable throwable)
stub/src/main/java/io/grpc/stub/ClientCalls.java:666
↓ 55 callersMethodtransportInUse
Called whenever the transport's in-use state has changed. A transport is in-use when it has at least one stream.
core/src/main/java/io/grpc/internal/ManagedClientTransport.java:106
↓ 54 callersMethodconnection
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:335
↓ 54 callersMethodendsWith
(byte[] bytes, byte[] suffix)
netty/src/main/java/io/grpc/netty/Utils.java:231
↓ 54 callersMethodgetAddresses
(PickResult pickResult)
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:813
↓ 54 callersMethodinflateBytes
Attempts to inflate {@code length} bytes of data into {@code b}. <p>Any gzipped bytes consumed by this method will be added to the counter returned b
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:260
↓ 54 callersMethodnewInstance
Creates a new instance of the filter. <p>Returns a filter instance registered with the same typeUrls as the provider, capable of working with the sam
xds/src/main/java/io/grpc/xds/Filter.java:94
↓ 53 callersMethodcontext
Enables automatic monitoring of the device's network state.
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:153
↓ 53 callersMethodcreateMetricReport
(double cpuUtilization, double applicationUtilization, double memoryUtilization, double qps, double eps,
services/src/main/java/io/grpc/services/InternalCallMetricRecorder.java:48
↓ 53 callersMethodget
(Key key)
examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptor.java:95
↓ 53 callersMethodgetCurrent
Gets the current service config or error. @throws IllegalStateException if the service config has not yet been updated.
core/src/main/java/io/grpc/internal/ServiceConfigState.java:80
↓ 53 callersMethodnewBuilder
Creates a builder for changing default configuration.
api/src/main/java/io/grpc/TlsChannelCredentials.java:218
↓ 53 callersMethodnewServerBuilderForPort
Static factory for creating a new ServerBuilder. @param port the port to listen on @param creds the server identity
api/src/main/java/io/grpc/Grpc.java:139
↓ 53 callersMethodupdateBalancingState
(ConnectivityState newState, SubchannelPicker newPicker)
util/src/testFixtures/java/io/grpc/util/AbstractTestHelper.java:120
↓ 52 callersMethodcreate
(ServerTransport transport)
core/src/testFixtures/java/io/grpc/internal/MockServerListener.java:43
↓ 52 callersMethodfromError
Returns a {@link StructOrError} for the failure to convert the data object.
xds/src/main/java/io/grpc/xds/StructOrError.java:37
↓ 52 callersMethodgetSelectorToUpdateSelector
Only safe to be called by code that is responsible for updating the selector.
xds/src/main/java/io/grpc/xds/FilterChainSelectorManager.java:55
↓ 52 callersMethodhasNext
()
api/src/main/java/io/grpc/Metadata.java:272
↓ 52 callersMethodreadBytes
Reads {@code length} bytes from this buffer and writes them to the destination array. Increments the read position by {@code length}. @param dest the
core/src/main/java/io/grpc/internal/ReadableBuffer.java:72
↓ 52 callersMethodsetDescription
(String description)
api/src/main/java/io/grpc/InternalChannelz.java:586
↓ 52 callersMethodsetMessageCompression
Enables per-message compression, if an encoding type has been negotiated. If no message encoding has been negotiated, this is a no-op. By default per
core/src/main/java/io/grpc/internal/Stream.java:89
↓ 52 callersMethodwindowUpdate
Notifies that an additional {@code windowSizeIncrement} bytes can be sent on {@code streamId}, or the connection if {@code streamId} is zero.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:88
↓ 51 callersMethodcreateClientTransportOptions
Create ClientTransportOptions. Should not be reused if it may be mutated.
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:1466
↓ 51 callersMethoddetach
Detaches the underlying data source from this instance and transfers to an {@link InputStream}. Detaching data from an already-detached instance gives
api/src/main/java/io/grpc/Detachable.java:43
↓ 51 callersMethodforString
The request header value should match this stringMatcher.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:130
↓ 51 callersMethodfromConfig
Returns a {@link ConfigOrError} for the successfully parsed config.
api/src/main/java/io/grpc/NameResolver.java:960
↓ 51 callersMethodisDone
()
xds/src/test/java/io/grpc/xds/SharedCallCounterMapTest.java:57
↓ 51 callersMethodmakeLog
(String factoryConfigStr, String lookup)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1543
↓ 51 callersMethodstop
(io.grpc.testing.integration.EmptyProtos.Empty request, io.grpc.stub.StreamObserver<io.grpc.testing.in
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ReconnectServiceGrpc.java:155
↓ 50 callersMethodbuildTestInternalDownstreamTlsContext
( String certName, String validationContextName)
xds/src/test/java/io/grpc/xds/internal/security/CommonTlsContextTestsUtil.java:142
↓ 50 callersMethodcreate
()
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptor.java:59
↓ 50 callersMethodinitTransport
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1325
↓ 50 callersMethodlog
(ChannelLogLevel level, String msg)
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1284
↓ 50 callersMethodsslContextProviderSupplier
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:279
↓ 49 callersMethodasyncBidiStreamingCall
Executes a bidirectional-streaming call. The {@code call} should not be already started. After calling this method, {@code call} should no longer be
stub/src/main/java/io/grpc/stub/ClientCalls.java:127
↓ 49 callersMethodcheckAuthorization
(int uid)
binder/src/test/java/io/grpc/binder/SecurityPoliciesTest.java:551
↓ 49 callersMethodequals
(Object obj)
xds/src/main/java/io/grpc/xds/XdsConfig.java:59
↓ 49 callersMethodfail
(ChannelHandlerContext ctx, Throwable cause)
netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java:1417
↓ 49 callersMethodnewBuilder
Constructs a new builder of a name resolution result. @since 1.21.0
api/src/main/java/io/grpc/NameResolver.java:789
↓ 48 callersMethodallocate
Creates a log id. @param type the "Type" to be used when logging this id. The short name of this class will be used, or else a default if the c
api/src/main/java/io/grpc/InternalLogId.java:43
↓ 48 callersMethodassertSameLimits
(BinlogHelper a, BinlogHelper b)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1538
↓ 48 callersMethodforAction
(RouteMatch routeMatch, RouteAction routeAction, Map<String, FilterConfig> filterConfigOverrides)
xds/src/main/java/io/grpc/xds/VirtualHost.java:68
↓ 48 callersMethodgetObject
Get an object from the pool.
core/src/main/java/io/grpc/internal/ObjectPool.java:28
↓ 48 callersMethodgetStopwatchSupplier
Provides a stopwatch instance that uses the fake clock ticker.
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:278
↓ 48 callersMethodgetXdsClient
()
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:307
↓ 48 callersMethodhashCode
()
api/src/test/java/io/grpc/PersistentHashArrayMappedTrieTest.java:251
↓ 48 callersMethodmatches
Returns the matching result.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:149
↓ 48 callersMethodrstStream
(int streamId, io.grpc.okhttp.internal.framed.ErrorCode errorCode)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:51
↓ 48 callersMethodtoBuilder
(ChannelStats stats)
services/src/test/java/io/grpc/protobuf/services/ChannelzProtoUtilTest.java:941
↓ 47 callersMethodacceptResolvedAddresses
(final ResolvedAddresses resolvedAddresses)
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:208
↓ 47 callersMethodcreateFilterChain
(String name, HttpConnectionManager hcm)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1939
↓ 47 callersMethodgetScheme
Returns the scheme component of this URI, e.g. "http", "mailto" or "dns".
core/src/main/java/io/grpc/internal/UriWrapper.java:41
↓ 47 callersMethodgetString
Gets a string from an object for the given key. If the key is not present, this returns null. If the value is not a String, throws an exception.
core/src/main/java/io/grpc/internal/JsonUtil.java:217
↓ 47 callersMethodnewHandler
Creates a new handler to control the protocol negotiation. Once the negotiation has completed successfully, the provided handler is installed. Must ca
netty/src/main/java/io/grpc/netty/ProtocolNegotiator.java:40
↓ 47 callersMethodpickSubchannel
(PickSubchannelArgs args)
xds/src/test/java/io/grpc/xds/WeightedRandomPickerTest.java:58
↓ 46 callersMethodcreateSubchannelSafely
( final Helper helper, final EquivalentAddressGroup addressGroup, final Attributes attrs, final Su
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4651
↓ 46 callersMethodnewBlockingStub
Creates a new blocking-style stub that supports unary and streaming output calls on the service
services/src/generated/main/grpc/io/grpc/health/v1/HealthGrpc.java:109
↓ 46 callersMethodonUpdate
An updated XdsConfig or RPC-safe Status. The status code will be either UNAVAILABLE or INTERNAL.
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:526
↓ 46 callersMethodserverReflectionInfo
<pre> The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server. </pre>
services/src/generated/main/grpc/io/grpc/reflection/v1/ServerReflectionGrpc.java:115
↓ 46 callersMethodtoBuilder
()
xds/src/main/java/io/grpc/xds/client/EnvoyProtoData.java:217
↓ 45 callersMethodcreateConfig
( LoadBalancer.Factory childFactory, Object childConfig)
util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:727
↓ 45 callersMethoddeliverSubchannelState
( final Subchannel subchannel, final ConnectivityStateInfo newState)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2730
↓ 45 callersMethodfail
(Status status)
api/src/test/java/io/grpc/CompositeCallCredentialsTest.java:82
↓ 45 callersMethodgetInstance
()
xds/src/main/java/io/grpc/xds/XdsEndpointResource.java:65
↓ 45 callersMethodheaderEntries
(String... elements)
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java:37
↓ 45 callersMethodonResult2
(ResolutionResult resolutionResult)
core/src/main/java/io/grpc/internal/RetryingNameResolver.java:99
↓ 45 callersMethodstart
(io.grpc.testing.integration.Messages.ReconnectParams request, io.grpc.stub.StreamObserver<io.grpc.tes
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ReconnectServiceGrpc.java:148
↓ 45 callersMethodwaitUntilStreamClosed
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2427
↓ 44 callersMethodbuildEdsCluster
(String clusterName, @Nullable String edsServiceName, String lbPolicy, @Nullable Message ringHashLbCon
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5322
↓ 44 callersMethodfirstValue
Returns a {@link ListenableFuture} for the first value received from the stream. Useful for testing unary call patterns.
testing/src/main/java/io/grpc/testing/StreamRecorder.java:115
↓ 44 callersMethodhandshake
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1332
↓ 44 callersMethodlog
(ChannelLogLevel level, String message)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:1272
↓ 44 callersMethodnewCall
( MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOpti
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1006
↓ 44 callersMethodonError
Receives a terminating error from the stream. <p>May only be called once and if called it must be the last method called. In particular if an excepti
stub/src/main/java/io/grpc/stub/StreamObserver.java:79
↓ 44 callersMethodonError
(Status errorStatus)
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertificateProvider.java:51
↓ 44 callersMethodstartTransport
( ManagedClientTransport clientTransport, ManagedClientTransport.Listener listener)
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:2180
↓ 43 callersMethodaddShutdownHook
(final Server server)
examples/example-debug/src/main/java/io/grpc/examples/debug/HostnameDebuggableServer.java:70
↓ 43 callersMethodgetMetric
Returns the value of a metric, or {@code null} if not found.
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:82
↓ 43 callersMethodgetObject
Gets an object from an object for the given key. If the key is not present, this returns null. If the value is not a Map, throws an exception.
core/src/main/java/io/grpc/internal/JsonUtil.java:83
↓ 43 callersMethodgetServer
<pre> Returns a single Server, or else a NOT_FOUND code. </pre>
services/src/generated/main/grpc/io/grpc/channelz/v1/ChannelzGrpc.java:329
↓ 43 callersMethodheader
(String key, ByteString value)
xds/src/test/java/io/grpc/xds/internal/headermutations/HeaderMutationFilterTest.java:37
↓ 43 callersMethodmatches
Returns the matching result for this string.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:267
↓ 43 callersMethodnewBlockingStub
Creates a new blocking-style stub that supports unary and streaming output calls on the service
testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/SimpleServiceGrpc.java:174
↓ 43 callersMethodnewBuilder
()
benchmarks/src/main/java/io/grpc/benchmarks/qps/ServerConfiguration.java:49
↓ 43 callersMethodnewNameResolver
Uses the given factory and args to create a {@link NameResolver} for this URI.
core/src/main/java/io/grpc/internal/UriWrapper.java:38
↓ 43 callersMethodparse
Given an {@link InputStream} parse it into an instance of the declared type so that it can be passed to application code. @param stream of bytes for
api/src/main/java/io/grpc/MethodDescriptor.java:157
↓ 43 callersMethodread
()
core/src/main/java/io/grpc/internal/TransportTracer.java:156
↓ 43 callersMethodremaining
()
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:229
↓ 42 callersMethodasFactory
()
api/src/main/java/io/grpc/NameResolverRegistry.java:157
↓ 42 callersMethodcreate
(String target, @Nullable Object implSpecificConfig)
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:71
↓ 42 callersMethoddeliverResolvedAddresses
( final List<EquivalentAddressGroup> backendAddrs, List<EquivalentAddressGroup> balancerAddrs)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2744
↓ 42 callersMethoddeliverSubchannelState
(Subchannel subchannel, ConnectivityStateInfo state)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:1247
↓ 42 callersMethodgetTicker
Ticker of the FakeClock.
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:285
↓ 42 callersMethodnewClientTransport
Returns a new transport that when started will be able to connect to {@code server}.
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:133
↓ 42 callersMethodvoidMarshaller
Creates a new marshaller that does nothing. @since 1.1.0
testing/src/main/java/io/grpc/testing/TestMethodDescriptors.java:53
↓ 41 callersMethodaddOption
Add a custom option. Any existing value for the key is overwritten. <p>This is an <strong>optional</strong> property. @param key the option key @par
api/src/main/java/io/grpc/LoadBalancer.java:911
↓ 41 callersMethodbind
Attempt to bind with the remote service. <p>Calling this multiple times or after {@link #unbind()} has no effect.
binder/src/main/java/io/grpc/binder/internal/Bindable.java:71
← previousnext →301–400 of 22,628, ranked by callers