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
↓ 8 callers
Method
assertCurrentPickerPicksSubchannel
(Subchannel expectedSubchannelToPick)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1033
↓ 8 callers
Method
assertLatestConnectivityState
(ConnectivityState expectedState)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1016
↓ 8 callers
Method
assertSuccess
(StreamRecorder<?> recorder)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1671
↓ 8 callers
Method
authority
The authority of the destination this channel connects to. Typically this is in the format {@code host:port}. @since 1.0.0
api/src/main/java/io/grpc/Channel.java:55
↓ 8 callers
Method
awaitTermination
Waits for the channel to become terminated, giving up if the timeout is reached. @return whether the channel is terminated, as would be done by {@lin
api/src/main/java/io/grpc/ManagedChannel.java:71
↓ 8 callers
Method
builder
()
rls/src/main/java/io/grpc/rls/RlsProtoData.java:141
↓ 8 callers
Method
channelInactive
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:678
↓ 8 callers
Method
checkBiosDataOnWindows
(BufferedReader reader)
alts/src/main/java/io/grpc/alts/InternalCheckGcpEnvironment.java:62
↓ 8 callers
Method
checkEndTags
( MetricsRecord record, String methodName, Status.Code status, boolean clientSide)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1879
↓ 8 callers
Method
checkStartTags
(MetricsRecord record, String methodName, boolean clientSide)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1868
↓ 8 callers
Method
clearTrustStoreSystemProperties
()
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:898
↓ 8 callers
Method
compare
(Closer c1, Closer c2)
xds/src/main/java/io/grpc/xds/FilterChainSelectorManager.java:91
↓ 8 callers
Method
copyWithSubchannel
Creates a new {@code PickResult} with the given {@code subchannel}, but retains all other properties from this {@code PickResult}. @since 1.80.0
api/src/main/java/io/grpc/LoadBalancer.java:678
↓ 8 callers
Method
create
( @Nullable String host, @Nullable String service, @Nullable String method)
rls/src/main/java/io/grpc/rls/RlsProtoData.java:248
↓ 8 callers
Method
create
Creates an instance using provided certificate chain and private key. Generally they should be PEM-encoded and the key is an unencrypted PKCS#8 key (f
api/src/main/java/io/grpc/TlsServerCredentials.java:46
↓ 8 callers
Method
create
( ChannelCredentials channelCreds, CallCredentials callCreds)
api/src/main/java/io/grpc/CompositeChannelCredentials.java:28
↓ 8 callers
Method
create
(int destinationPort, ImmutableList<CidrRange> prefixRanges, ImmutableList<String> application
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:254
↓ 8 callers
Method
create
(String name, @Nullable String exactValue, @Nullable Pattern safeRegEx, @Nullable Range range,
xds/src/main/java/io/grpc/xds/internal/Matchers.java:138
↓ 8 callers
Method
createX509TrustManager
( X509Certificate[] certs, CertificateValidationContext certContext, boolean autoSniSanValidation)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsTrustManagerFactory.java:129
↓ 8 callers
Method
decoderHeaderMutationRules
Rules for what modifications an ext_authz server may make to request headers. @see ExtAuthz#getDecoderHeaderMutationRules()
xds/src/main/java/io/grpc/xds/internal/extauthz/ExtAuthzConfig.java:119
↓ 8 callers
Method
defaultLoadBalancingPolicy
(String policy)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:444
↓ 8 callers
Method
deliverSubchannelState
(Subchannel subchannel, ConnectivityStateInfo newState)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1329
↓ 8 callers
Method
denominatorType
()
xds/src/main/java/io/grpc/xds/FaultConfig.java:106
↓ 8 callers
Method
disableAutoRequestWithInitial
Swaps to manual flow control where no message will be delivered to {@link StreamObserver#onNext(Object)} unless it is {@link #request request()}ed. Si
stub/src/main/java/io/grpc/stub/ClientCallStreamObserver.java:59
↓ 8 callers
Method
endOfStream
()
netty/src/main/java/io/grpc/netty/SendResponseHeadersCommand.java:56
↓ 8 callers
Method
execute
(Runnable command)
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:291
↓ 8 callers
Method
execute
(Runnable var1)
netty/src/test/java/io/grpc/netty/NettyTestUtil.java:69
↓ 8 callers
Method
executor
(@Nullable Executor executor)
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:130
↓ 8 callers
Method
exitIdleMode
Make the channel exit idle mode, if it's in it. <p>Must be called from syncContext
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:388
↓ 8 callers
Method
extract
(Context context, @Nullable C carrier, TextMapGetter<C> getter)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagator.java:95
↓ 8 callers
Method
filter
Returns the next level hierarchical addresses derived from the given hierarchical addresses with the given filter name (any non-hierarchical addresses
xds/src/main/java/io/grpc/xds/AddressFilter.java:69
↓ 8 callers
Method
filterChainMatch
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:275
↓ 8 callers
Method
filterStateTestStartServer
(FilterRegistry filterRegistry)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1859
↓ 8 callers
Method
finest
(String str, Object...params)
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:262
↓ 8 callers
Method
fireProtocolNegotiationEvent
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:1204
↓ 8 callers
Method
forCode
Looks up the HTTP/2 error code enum value for the specified code. @param code an HTTP/2 error code value. @return the HTTP/2 error code enum or {@cod
core/src/main/java/io/grpc/internal/GrpcUtil.java:405
↓ 8 callers
Method
forExact
The input string should exactly matches the specified string.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:232
↓ 8 callers
Method
forPrefix
The request header value should have this prefix.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:108
↓ 8 callers
Method
forTarget
Creates a channel with a target string, which can be either a valid {@link NameResolver}-compliant URI, or an authority string. <p>A {@code NameResol
api/src/main/java/io/grpc/ManagedChannelBuilder.java:85
↓ 8 callers
Method
fromPrefix
(String prefix, boolean caseSensitive)
xds/src/main/java/io/grpc/xds/VirtualHost.java:131
↓ 8 callers
Method
fromSpiffeId
Returns an {@link S2AIdentity} instance with SPIFFE ID set to {@code spiffeId}.
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AIdentity.java:33
↓ 8 callers
Method
generateUserHandle
Generate UserHandles the hard way.
binder/src/test/java/io/grpc/binder/internal/ServiceBindingTest.java:457
↓ 8 callers
Method
get
(K key, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:129
↓ 8 callers
Method
getArg
Returns the value of a custom arg named 'key', or {@code null} if it's not set. <p>While ordinary {@link Args} should be universally useful and meani
api/src/main/java/io/grpc/NameResolver.java:455
↓ 8 callers
Method
getAuthorityOverride
Returns the authority override if any.
api/src/main/java/io/grpc/LoadBalancer.java:729
↓ 8 callers
Method
getCacertFilePathForTestCa
()
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:438
↓ 8 callers
Method
getConfig
()
core/src/main/java/io/grpc/internal/ServiceConfigUtil.java:430
↓ 8 callers
Method
getCustomTags
Map of all custom tags used for logging, metrics and traces.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:50
↓ 8 callers
Method
getDefaultFactory
()
core/src/main/java/io/grpc/internal/CallTracer.java:78
↓ 8 callers
Method
getDelay
(TimeUnit unit)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:205
↓ 8 callers
Method
getDueTasks
Return all due tasks.
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:332
↓ 8 callers
Method
getEndpoint
(StatusOr<XdsClusterConfig> childConfigOr)
xds/src/test/java/io/grpc/xds/XdsDependencyManagerTest.java:254
↓ 8 callers
Method
getEndpoint
()
xds/src/main/java/io/grpc/xds/XdsConfig.java:179
↓ 8 callers
Method
getFilterContext
()
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:472
↓ 8 callers
Method
getHeaderTypeFieldBytes
()
alts/src/main/java/io/grpc/alts/internal/AltsTsiFrameProtector.java:57
↓ 8 callers
Method
getHelper
()
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:232
↓ 8 callers
Method
getId
()
core/src/main/java/io/grpc/internal/NoopSslSession.java:29
↓ 8 callers
Method
getInboundWireSize
Returns to sum of all sizes passed to {@link StreamTracer#inboundWireSize}.
testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java:53
↓ 8 callers
Method
getKey
Returns the resulting key of the handshake, if the handshake is completed. Note that the key data returned from the handshake may be more than the key
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerClient.java:137
↓ 8 callers
Method
getKeyLength
()
alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:49
↓ 8 callers
Method
getKeyManagers
Returns the key manager list which provides the server's identity. Entries are scanned checking for specific types, like {@link javax.net.ssl.X509KeyM
api/src/main/java/io/grpc/TlsServerCredentials.java:118
↓ 8 callers
Method
getList
(SubchannelPicker picker)
util/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java:562
↓ 8 callers
Method
getList
(SubchannelPicker picker)
xds/src/test/java/io/grpc/xds/LeastRequestLoadBalancerTest.java:625
↓ 8 callers
Method
getListOfStrings
Gets a list from an object for the given key, and verifies all entries are strings. If the key is not present, this returns null. If the value is no
core/src/main/java/io/grpc/internal/JsonUtil.java:70
↓ 8 callers
Method
getLogLevel
Accepts a throwable and returns the appropriate logging level. Uninteresting exceptions should not clutter the log.
netty/src/main/java/io/grpc/netty/NettyServerTransport.java:204
↓ 8 callers
Method
getNamedMetrics
()
services/src/main/java/io/grpc/services/MetricReport.java:73
↓ 8 callers
Method
getOutFrame
Returns a mock output frame.
alts/src/test/java/io/grpc/alts/internal/MockAltsHandshakerResp.java:60
↓ 8 callers
Method
getOutboundUncompressedSize
Returns to sum of al sizes passed to {@link StreamTracer#outboundUncompressedSize}.
testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java:68
↓ 8 callers
Method
getParcelable
Get the parcelable as if it had been serialized/de-serialized. <p>If the parcelable is immutable, or it was already de-serialized from a Parcel (I.e.
binder/src/main/java/io/grpc/binder/internal/ParcelableInputStream.java:183
↓ 8 callers
Method
getPath
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:292
↓ 8 callers
Method
getPolicyName
Returns the load-balancing policy name associated with this provider, which makes it selectable via {@link LoadBalancerRegistry#getProvider}. This is
api/src/main/java/io/grpc/LoadBalancerProvider.java:70
↓ 8 callers
Method
getProjectId
Get project ID - where logs will go.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:38
↓ 8 callers
Method
getRouteLookupConfig
()
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:63
↓ 8 callers
Method
getServerTracerFactory
Returns the server tracer factory.
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:137
↓ 8 callers
Method
getSession
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2526
↓ 8 callers
Method
getSocketFactory
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:1059
↓ 8 callers
Method
getSslContextProvider
Helper method to build CertProviderClientSslContextProvider.
xds/src/test/java/io/grpc/xds/internal/security/certprovider/CertProviderClientSslContextProviderTest.java:70
↓ 8 callers
Method
getSubscribedResourceTypesWithTypeUrl
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:487
↓ 8 callers
Method
getSuffixLength
Returns the length of the tag in bytes.
alts/src/main/java/io/grpc/alts/internal/ChannelCrypterNetty.java:72
↓ 8 callers
Method
getSynchronizationContext
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1529
↓ 8 callers
Method
getTargetAddress
Returns the address to the target server.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:93
↓ 8 callers
Method
getTracerFactories
()
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:266
↓ 8 callers
Method
getTrailers
Returns the received trailers. @since 1.0.0
api/src/main/java/io/grpc/StatusException.java:68
↓ 8 callers
Method
getTransportFromPickResult
Returns a transport out of a PickResult, or {@code null} if the result is "buffer".
core/src/main/java/io/grpc/internal/GrpcUtil.java:710
↓ 8 callers
Method
getTypedMock
()
xds/src/test/java/io/grpc/xds/internal/security/ReferenceCountingMapTest.java:69
↓ 8 callers
Method
getUnaryCallMethod
()
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/TestServiceGrpc.java:53
↓ 8 callers
Method
getVersion
The last successfully updated version of the resource.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:223
↓ 8 callers
Method
grpcDataFrame
(int streamId, boolean endStream, byte[] content)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:281
↓ 8 callers
Method
handleNameResolutionError
(Status error)
xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:197
↓ 8 callers
Method
inboundUncompressedSize
(long bytes)
census/src/main/java/io/grpc/census/CensusStatsModule.java:305
↓ 8 callers
Method
initialMetadata
()
xds/src/main/java/io/grpc/xds/internal/grpcservice/GrpcServiceConfig.java:43
↓ 8 callers
Method
interceptCall
Intercept {@link ServerCall} dispatch by the {@code next} {@link ServerCallHandler}. General semantics of {@link ServerCallHandler#startCall} apply an
api/src/main/java/io/grpc/ServerInterceptor.java:55
↓ 8 callers
Method
isCancelled
()
stub/src/test/java/io/grpc/stub/ServerCallsTest.java:710
↓ 8 callers
Method
isGreaterThanOrEqualTo
Returns true if first Rpc Protocol Version is greater than or equal to the second one. Returns false otherwise.
alts/src/main/java/io/grpc/alts/internal/RpcProtocolVersionsUtil.java:53
↓ 8 callers
Method
isPathAbsolute
Returns true iff this URI's path component starts with the '/' segment delimiter (rather than a path segment). <p>The path of an RFC 3986 URI is eith
api/src/main/java/io/grpc/Uri.java:538
↓ 8 callers
Method
isShutdown
Returns whether the server is shutdown. Shutdown servers reject any new calls, but may still have some calls being processed. @see #shutdown() @see #
api/src/main/java/io/grpc/Server.java:151
↓ 8 callers
Method
isValid
()
core/src/main/java/io/grpc/internal/NoopSslSession.java:60
↓ 8 callers
Method
keysForTest
()
api/src/main/java/io/grpc/Attributes.java:82
↓ 8 callers
Method
makeOptions
(String logConfigStr)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1547
↓ 8 callers
Method
maybeGetMockListener
()
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1233
← previous
next →
1,801–1,900 of 22,628, ranked by callers