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
↓ 3 callers
Method
newInstance
()
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionService.java:43
↓ 3 callers
Method
newProvider
Same as {@code Conscrypt.newProvider()}.
core/src/main/java/io/grpc/internal/ConscryptLoader.java:70
↓ 3 callers
Method
newReader
@param client true if this is the HTTP client's reader, reading frames from a server.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Variant.java:35
↓ 3 callers
Method
newRecursiveCallback
(final Executor executor)
core/src/test/java/io/grpc/internal/ConnectivityStateManagerTest.java:189
↓ 3 callers
Method
newResourceMetadataDoesNotExist
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:198
↓ 3 callers
Method
newResourceMetadataNacked
( ResourceMetadata metadata, String failedVersion, long failedUpdateTime, String failedDetails
xds/src/main/java/io/grpc/xds/client/XdsClient.java:213
↓ 3 callers
Method
newResourceMetadataRequested
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:194
↓ 3 callers
Method
newRoundRobinProvider
()
services/src/main/java/io/grpc/protobuf/services/internal/HealthCheckingRoundRobinLoadBalancerProvider.java:67
↓ 3 callers
Method
newServerBuilder
()
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:181
↓ 3 callers
Method
newServerBuilderForPort
(int port, ServerCredentials creds)
api/src/main/java/io/grpc/ServerRegistry.java:139
↓ 3 callers
Method
newSslSocketFactoryForCa
Creates an SSLSocketFactory which contains {@code certChainFile} as its only root certificate. @deprecated Not for public use
testing/src/main/java/io/grpc/testing/TestUtils.java:117
↓ 3 callers
Method
newStreamException
(int streamId, Throwable cause)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:934
↓ 3 callers
Method
newTransportProvider
(final ClientTransport transport)
core/src/test/java/io/grpc/internal/DelayedClientTransportTest.java:775
↓ 3 callers
Method
newWriter
@param client true if this is the HTTP client's writer, writing frames to a server.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Variant.java:40
↓ 3 callers
Method
next32
()
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:273
↓ 3 callers
Method
nextOutboundEvent
()
testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java:112
↓ 3 callers
Method
nioBuffers
Optimized accessor for obtaining the underlying NIO buffers for a Netty {@link ByteBuf}. Based on code from Netty's {@code SslHandler}. This method re
alts/src/main/java/io/grpc/alts/internal/BufUnwrapper.java:69
↓ 3 callers
Method
nodeInfo
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:456
↓ 3 callers
Method
notifyFailed
Notifies the given callback that the ping operation failed. @param callback the callback @param executor the executor used to invoke the callback @pa
core/src/main/java/io/grpc/internal/Http2Ping.java:171
↓ 3 callers
Method
notifyTerminated
()
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:334
↓ 3 callers
Method
notifyTerminated
(Status s, DisconnectError disconnectError)
netty/src/main/java/io/grpc/netty/ClientTransportLifecycleManager.java:86
↓ 3 callers
Method
onAmbientError
(Status error, @Nullable ProcessingTracker tracker)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:987
↓ 3 callers
Method
onCancel
()
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingServerInterceptor.java:244
↓ 3 callers
Method
onCancel
()
stub/src/main/java/io/grpc/stub/ServerCalls.java:192
↓ 3 callers
Method
onCanceled
(BidirectionalStream stream, UrlResponseInfo info)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:534
↓ 3 callers
Method
onClose
(Status status, Metadata trailers)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptor.java:185
↓ 3 callers
Method
onClose
(Status status, Metadata trailers)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:757
↓ 3 callers
Method
onCompleteCalled
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceV1Test.java:652
↓ 3 callers
Method
onCompleteCalled
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java:652
↓ 3 callers
Method
onHalfClose
()
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingServerInterceptor.java:226
↓ 3 callers
Method
onHalfClose
()
binder/src/main/java/io/grpc/binder/internal/PendingAuthListener.java:73
↓ 3 callers
Method
onHalfClose
()
util/src/test/java/io/grpc/util/UtilServerInterceptorsTest.java:88
↓ 3 callers
Method
onHeaders
(Metadata headers)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptor.java:164
↓ 3 callers
Method
onPingTimeout
Callback when Ping Ack was not received in KEEPALIVE_TIMEOUT. Should shutdown the transport.
core/src/main/java/io/grpc/internal/KeepAliveManager.java:258
↓ 3 callers
Method
onReady
()
core/src/main/java/io/grpc/internal/ServerCallImpl.java:388
↓ 3 callers
Method
onResult
(ResolutionResult resolutionResult)
api/src/main/java/io/grpc/NameResolver.java:97
↓ 3 callers
Method
onShutdown
(Status reason)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1276
↓ 3 callers
Method
onStreamDeallocated
Notify that the stream does not exist in a usable state any longer. This causes {@link AbstractStream#isReady()} to return {@code false} from this poi
core/src/main/java/io/grpc/internal/AbstractStream.java:324
↓ 3 callers
Method
originalName
Returns the original name used to create this key.
api/src/main/java/io/grpc/Metadata.java:770
↓ 3 callers
Method
outboundMessageSent
An outbound message has been serialized and sent to the transport. @param seqNo the sequential number of the message within the stream, starting from
api/src/main/java/io/grpc/StreamTracer.java:64
↓ 3 callers
Method
outboundUncompressedSize
The uncompressed size of some outbound data is revealed. This can only used to record the accumulative outbound uncompressed size. There is no guarant
api/src/main/java/io/grpc/StreamTracer.java:90
↓ 3 callers
Method
outboundWireSize
The wire size of some outbound data is revealed. This can only used to record the accumulative outbound wire size. There is no guarantee wrt timing or
api/src/main/java/io/grpc/StreamTracer.java:82
↓ 3 callers
Method
outlierDetection
(OutlierDetection outlierDetection)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:774
↓ 3 callers
Method
overrideAuthorityIsReadableHelper
(NettyChannelBuilder builder, String overrideAuthority)
netty/src/test/java/io/grpc/netty/NettyChannelBuilderTest.java:92
↓ 3 callers
Method
packToAny
(String typeName, MessageLite value)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:499
↓ 3 callers
Method
panic
(final Throwable t)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:761
↓ 3 callers
Method
parse
Parses the {@link io.envoyproxy.envoy.config.core.v3.GrpcService} proto to create a {@link GrpcServiceConfig} instance. @param grpcServiceProto The p
xds/src/main/java/io/grpc/xds/GrpcServiceConfigParser.java:84
↓ 3 callers
Method
parseFile
(String configFile)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:76
↓ 3 callers
Method
parseGoogleGrpcConfig
( GrpcService.GoogleGrpc googleGrpcProto, BootstrapInfo bootstrapInfo, ServerInfo serverInfo)
xds/src/test/java/io/grpc/xds/GrpcServiceConfigParserTest.java:95
↓ 3 callers
Method
parseJson
(String json)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:627
↓ 3 callers
Method
parseJsonObject
(String json)
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerProviderTest.java:135
↓ 3 callers
Method
parseLoadBalancingPolicyConfig
Parses the config for the Load Balancing policy unpacked from the service config. This will return a {@link ConfigOrError} which contains either the
api/src/main/java/io/grpc/LoadBalancerProvider.java:86
↓ 3 callers
Method
parseMetadata
Parses cluster metadata into a structured map. <p>Values in {@code typed_filter_metadata} take precedence over {@code filter_metadata} when keys over
xds/src/main/java/io/grpc/xds/MetadataRegistry.java:76
↓ 3 callers
Method
parsePlugin
(Message rawProtoMessage)
xds/src/main/java/io/grpc/xds/ClusterSpecifierPlugin.java:33
↓ 3 callers
Method
parseRecursive
(JsonReader jr)
core/src/main/java/io/grpc/internal/JsonParser.java:61
↓ 3 callers
Method
parseRouteMatch
( io.envoyproxy.envoy.config.route.v3.RouteMatch proto)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:324
↓ 3 callers
Method
parseServiceConfig
(Map<String, ?> rawServiceConfig)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:163
↓ 3 callers
Method
parsedValue
Creates a holder for a pre-parsed value read by the transport. @param marshaller The {@link Metadata.BinaryStreamMarshaller} associated with this val
api/src/main/java/io/grpc/InternalMetadata.java:108
↓ 3 callers
Method
path
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:111
↓ 3 callers
Method
perAttemptRecvTimeout
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:289
↓ 3 callers
Method
perHundred
(int numerator)
xds/src/main/java/io/grpc/xds/FaultConfig.java:108
↓ 3 callers
Method
performMtlsTestAndGetListenerWatcher
( UpstreamTlsContext upstreamTlsContext, String certInstanceName2, String privateKey2, String cert
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:669
↓ 3 callers
Method
permissionDenied
(String description)
binder/src/main/java/io/grpc/binder/SecurityPolicies.java:74
↓ 3 callers
Method
pickSubchannel
(PickSubchannelArgs args)
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:179
↓ 3 callers
Method
plaintext
Returns a {@link ProtocolNegotiator} for plaintext client channel.
netty/src/main/java/io/grpc/netty/InternalProtocolNegotiators.java:112
↓ 3 callers
Method
plaintextUpgrade
Returns a {@link ProtocolNegotiator} used for upgrading to HTTP/2 from HTTP/1.x.
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:834
↓ 3 callers
Method
port
Returns the explicitly-specified port if one was provided, or the default port for this URL's scheme. For example, this returns 8443 for {@code https:
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:83
↓ 3 callers
Method
prefix
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:213
↓ 3 callers
Method
preprocessArgs
Preprocess args, for: - merging duplicate flags. So "--grpc=8080 --grpc=9090" becomes "--grpc=8080,9090".
istio-interop-testing/src/main/java/io/grpc/testing/istio/EchoTestServer.java:111
↓ 3 callers
Method
prestart
()
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:2975
↓ 3 callers
Method
printUsage
Prints the command-line usage for the application based on the options supported by this builder.
benchmarks/src/main/java/io/grpc/benchmarks/qps/Configuration.java:38
↓ 3 callers
Method
prioritizedClusterNames
(List<String> prioritizedClusterNames)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:772
↓ 3 callers
Method
propagateError
(Status status)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:487
↓ 3 callers
Method
providers
Returns effective providers map from scheme to the highest priority XdsCredsProvider of that scheme.
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:138
↓ 3 callers
Method
put
(K key, V value, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:81
↓ 3 callers
Method
put
(K key, V value, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:139
↓ 3 callers
Method
readAndUpdate
Reads the private key and certificates specified in the path locations. Updates {@code key} and {@code cert} if both of their modified time changed si
util/src/main/java/io/grpc/util/AdvancedTlsX509KeyManager.java:322
↓ 3 callers
Method
readAndUpdate
Reads the trust certificates specified in the path location, and updates the key store if the modified time has changed since last read. @param trust
util/src/main/java/io/grpc/util/AdvancedTlsX509TrustManager.java:339
↓ 3 callers
Method
readArray
Reads an entire {@link ReadableBuffer} to a new array. After calling this method, the buffer will contain no readable bytes.
core/src/main/java/io/grpc/internal/ReadableBuffers.java:77
↓ 3 callers
Method
readAsStringUtf8
Reads the entire {@link ReadableBuffer} to a new {@link String} using UTF-8 decoding.
core/src/main/java/io/grpc/internal/ReadableBuffers.java:97
↓ 3 callers
Method
readInternal
(K key)
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:155
↓ 3 callers
Method
readMetadata
Read a Metadata instance from a Parcel. @param parcel The {@link Parcel} to read from.
binder/src/main/java/io/grpc/binder/internal/MetadataHelper.java:126
↓ 3 callers
Method
readUnsignedByte
Returns the next unsigned byte, adding it the CRC and incrementing {@code bytesConsumed}. <p>It is the responsibility of the caller to verify and res
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:66
↓ 3 callers
Method
recordFinishedAttempt
()
census/src/main/java/io/grpc/census/CensusStatsModule.java:368
↓ 3 callers
Method
recordMethodName
(boolean generatedMethod, String fullMethodName)
core/src/test/java/io/grpc/internal/ServerImplTest.java:198
↓ 3 callers
Method
recordMethodName
(String fullMethodName, boolean isGeneratedMethod)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:163
↓ 3 callers
Method
refreshInvokedAndUpdateBS
(InOrder inOrder, ConnectivityState state)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:317
↓ 3 callers
Method
refreshNameResolution
()
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:770
↓ 3 callers
Method
refreshNameResolution
Call {@link NameResolver#refresh} on the channel's resolver. <p>It should be called from the Synchronization Context. Currently will log a warning i
api/src/main/java/io/grpc/LoadBalancer.java:1195
↓ 3 callers
Method
refreshProviderMap
()
api/src/main/java/io/grpc/LoadBalancerRegistry.java:86
↓ 3 callers
Method
refreshProviders
()
api/src/main/java/io/grpc/ManagedChannelRegistry.java:84
↓ 3 callers
Method
refreshProviders
()
api/src/main/java/io/grpc/NameResolverRegistry.java:102
↓ 3 callers
Method
refreshProviders
()
api/src/main/java/io/grpc/ServerRegistry.java:77
↓ 3 callers
Method
refreshProviders
()
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:88
↓ 3 callers
Method
regExSubstitution
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:255
↓ 3 callers
Method
registerLongUpDownCounter
Registers a new Long Up Down Counter metric instrument. @param name the name of the metric @param description a description of the
api/src/main/java/io/grpc/MetricInstrumentRegistry.java:159
↓ 3 callers
Method
registerNewTransport
()
binder/src/test/java/io/grpc/binder/internal/ActiveTransportTrackerTest.java:110
↓ 3 callers
Method
registerServerWithRobolectric
(BinderServer server)
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:195
↓ 3 callers
Method
registerStackDriverExporter
(String projectId, Map<String, String> customTags)
gcp-observability/src/main/java/io/grpc/gcp/observability/GcpObservability.java:244
↓ 3 callers
Method
releaseCluster
(final String cluster)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:560
← previous
next →
3,901–4,000 of 22,628, ranked by callers