MCPcopy Create free account

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

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

↓ 3 callersMethodnewInstance
()
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionService.java:43
↓ 3 callersMethodnewProvider
Same as {@code Conscrypt.newProvider()}.
core/src/main/java/io/grpc/internal/ConscryptLoader.java:70
↓ 3 callersMethodnewReader
@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 callersMethodnewRecursiveCallback
(final Executor executor)
core/src/test/java/io/grpc/internal/ConnectivityStateManagerTest.java:189
↓ 3 callersMethodnewResourceMetadataDoesNotExist
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:198
↓ 3 callersMethodnewResourceMetadataNacked
( ResourceMetadata metadata, String failedVersion, long failedUpdateTime, String failedDetails
xds/src/main/java/io/grpc/xds/client/XdsClient.java:213
↓ 3 callersMethodnewResourceMetadataRequested
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:194
↓ 3 callersMethodnewRoundRobinProvider
()
services/src/main/java/io/grpc/protobuf/services/internal/HealthCheckingRoundRobinLoadBalancerProvider.java:67
↓ 3 callersMethodnewServerBuilder
()
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:181
↓ 3 callersMethodnewServerBuilderForPort
(int port, ServerCredentials creds)
api/src/main/java/io/grpc/ServerRegistry.java:139
↓ 3 callersMethodnewSslSocketFactoryForCa
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 callersMethodnewStreamException
(int streamId, Throwable cause)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:934
↓ 3 callersMethodnewTransportProvider
(final ClientTransport transport)
core/src/test/java/io/grpc/internal/DelayedClientTransportTest.java:775
↓ 3 callersMethodnewWriter
@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 callersMethodnext32
()
xds/third_party/zero-allocation-hashing/main/java/io/grpc/xds/XxHash64.java:273
↓ 3 callersMethodnextOutboundEvent
()
testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java:112
↓ 3 callersMethodnioBuffers
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 callersMethodnodeInfo
()
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:456
↓ 3 callersMethodnotifyFailed
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 callersMethodnotifyTerminated
()
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:334
↓ 3 callersMethodnotifyTerminated
(Status s, DisconnectError disconnectError)
netty/src/main/java/io/grpc/netty/ClientTransportLifecycleManager.java:86
↓ 3 callersMethodonAmbientError
(Status error, @Nullable ProcessingTracker tracker)
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:987
↓ 3 callersMethodonCancel
()
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingServerInterceptor.java:244
↓ 3 callersMethodonCancel
()
stub/src/main/java/io/grpc/stub/ServerCalls.java:192
↓ 3 callersMethodonCanceled
(BidirectionalStream stream, UrlResponseInfo info)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:534
↓ 3 callersMethodonClose
(Status status, Metadata trailers)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptor.java:185
↓ 3 callersMethodonClose
(Status status, Metadata trailers)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:757
↓ 3 callersMethodonCompleteCalled
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceV1Test.java:652
↓ 3 callersMethodonCompleteCalled
()
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java:652
↓ 3 callersMethodonHalfClose
()
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingServerInterceptor.java:226
↓ 3 callersMethodonHalfClose
()
binder/src/main/java/io/grpc/binder/internal/PendingAuthListener.java:73
↓ 3 callersMethodonHalfClose
()
util/src/test/java/io/grpc/util/UtilServerInterceptorsTest.java:88
↓ 3 callersMethodonHeaders
(Metadata headers)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptor.java:164
↓ 3 callersMethodonPingTimeout
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 callersMethodonReady
()
core/src/main/java/io/grpc/internal/ServerCallImpl.java:388
↓ 3 callersMethodonResult
(ResolutionResult resolutionResult)
api/src/main/java/io/grpc/NameResolver.java:97
↓ 3 callersMethodonShutdown
(Status reason)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1276
↓ 3 callersMethodonStreamDeallocated
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 callersMethodoriginalName
Returns the original name used to create this key.
api/src/main/java/io/grpc/Metadata.java:770
↓ 3 callersMethodoutboundMessageSent
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 callersMethodoutboundUncompressedSize
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 callersMethodoutboundWireSize
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 callersMethodoutlierDetection
(OutlierDetection outlierDetection)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:774
↓ 3 callersMethodoverrideAuthorityIsReadableHelper
(NettyChannelBuilder builder, String overrideAuthority)
netty/src/test/java/io/grpc/netty/NettyChannelBuilderTest.java:92
↓ 3 callersMethodpackToAny
(String typeName, MessageLite value)
services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:499
↓ 3 callersMethodpanic
(final Throwable t)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:761
↓ 3 callersMethodparse
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 callersMethodparseFile
(String configFile)
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfigImpl.java:76
↓ 3 callersMethodparseGoogleGrpcConfig
( GrpcService.GoogleGrpc googleGrpcProto, BootstrapInfo bootstrapInfo, ServerInfo serverInfo)
xds/src/test/java/io/grpc/xds/GrpcServiceConfigParserTest.java:95
↓ 3 callersMethodparseJson
(String json)
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:627
↓ 3 callersMethodparseJsonObject
(String json)
xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerProviderTest.java:135
↓ 3 callersMethodparseLoadBalancingPolicyConfig
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 callersMethodparseMetadata
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 callersMethodparsePlugin
(Message rawProtoMessage)
xds/src/main/java/io/grpc/xds/ClusterSpecifierPlugin.java:33
↓ 3 callersMethodparseRecursive
(JsonReader jr)
core/src/main/java/io/grpc/internal/JsonParser.java:61
↓ 3 callersMethodparseRouteMatch
( io.envoyproxy.envoy.config.route.v3.RouteMatch proto)
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:324
↓ 3 callersMethodparseServiceConfig
(Map<String, ?> rawServiceConfig)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:163
↓ 3 callersMethodparsedValue
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 callersMethodpath
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:111
↓ 3 callersMethodperAttemptRecvTimeout
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:289
↓ 3 callersMethodperHundred
(int numerator)
xds/src/main/java/io/grpc/xds/FaultConfig.java:108
↓ 3 callersMethodperformMtlsTestAndGetListenerWatcher
( UpstreamTlsContext upstreamTlsContext, String certInstanceName2, String privateKey2, String cert
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:669
↓ 3 callersMethodpermissionDenied
(String description)
binder/src/main/java/io/grpc/binder/SecurityPolicies.java:74
↓ 3 callersMethodpickSubchannel
(PickSubchannelArgs args)
xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:179
↓ 3 callersMethodplaintext
Returns a {@link ProtocolNegotiator} for plaintext client channel.
netty/src/main/java/io/grpc/netty/InternalProtocolNegotiators.java:112
↓ 3 callersMethodplaintextUpgrade
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 callersMethodport
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 callersMethodprefix
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:213
↓ 3 callersMethodpreprocessArgs
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 callersMethodprestart
()
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:2975
↓ 3 callersMethodprintUsage
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 callersMethodprioritizedClusterNames
(List<String> prioritizedClusterNames)
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:772
↓ 3 callersMethodpropagateError
(Status status)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:487
↓ 3 callersMethodproviders
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 callersMethodput
(K key, V value, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:81
↓ 3 callersMethodput
(K key, V value, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:139
↓ 3 callersMethodreadAndUpdate
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 callersMethodreadAndUpdate
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 callersMethodreadArray
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 callersMethodreadAsStringUtf8
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 callersMethodreadInternal
(K key)
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:155
↓ 3 callersMethodreadMetadata
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 callersMethodreadUnsignedByte
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 callersMethodrecordFinishedAttempt
()
census/src/main/java/io/grpc/census/CensusStatsModule.java:368
↓ 3 callersMethodrecordMethodName
(boolean generatedMethod, String fullMethodName)
core/src/test/java/io/grpc/internal/ServerImplTest.java:198
↓ 3 callersMethodrecordMethodName
(String fullMethodName, boolean isGeneratedMethod)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:163
↓ 3 callersMethodrefreshInvokedAndUpdateBS
(InOrder inOrder, ConnectivityState state)
xds/src/test/java/io/grpc/xds/RingHashLoadBalancerTest.java:317
↓ 3 callersMethodrefreshNameResolution
()
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:770
↓ 3 callersMethodrefreshNameResolution
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 callersMethodrefreshProviderMap
()
api/src/main/java/io/grpc/LoadBalancerRegistry.java:86
↓ 3 callersMethodrefreshProviders
()
api/src/main/java/io/grpc/ManagedChannelRegistry.java:84
↓ 3 callersMethodrefreshProviders
()
api/src/main/java/io/grpc/NameResolverRegistry.java:102
↓ 3 callersMethodrefreshProviders
()
api/src/main/java/io/grpc/ServerRegistry.java:77
↓ 3 callersMethodrefreshProviders
()
xds/src/main/java/io/grpc/xds/XdsCredentialsRegistry.java:88
↓ 3 callersMethodregExSubstitution
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:255
↓ 3 callersMethodregisterLongUpDownCounter
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 callersMethodregisterNewTransport
()
binder/src/test/java/io/grpc/binder/internal/ActiveTransportTrackerTest.java:110
↓ 3 callersMethodregisterServerWithRobolectric
(BinderServer server)
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:195
↓ 3 callersMethodregisterStackDriverExporter
(String projectId, Map<String, String> customTags)
gcp-observability/src/main/java/io/grpc/gcp/observability/GcpObservability.java:244
↓ 3 callersMethodreleaseCluster
(final String cluster)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:560
← previousnext →3,901–4,000 of 22,628, ranked by callers