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
↓ 15 callersMethodbuildBootstrapInfo
Build {@link Bootstrapper.BootstrapInfo} for certProviderInstance tests. Populates with temp file paths.
xds/src/test/java/io/grpc/xds/client/CommonBootstrapperTestUtils.java:101
↓ 15 callersMethodbuildClientListener
Builds a new client listener.
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:319
↓ 15 callersMethodcallEnded
(Status status, CallOptions callOptions)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:443
↓ 15 callersMethodclientChannel
(Server server, ChannelCredentials creds)
okhttp/src/test/java/io/grpc/okhttp/TlsTest.java:759
↓ 15 callersMethodclose
Closes the sink.
gcp-observability/src/main/java/io/grpc/gcp/observability/logging/Sink.java:36
↓ 15 callersMethodcreateManagedChannelServiceConfig
( Map<String, Object> rawServiceConfig, PolicySelection policySelection)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4745
↓ 15 callersMethoddecrypt
Decrypt ciphertext into plaintext buffer using the given nonce. @param plaintext the decrypted plaintext will be written into this buffer. @param cip
alts/src/main/java/io/grpc/alts/internal/AeadCrypter.java:61
↓ 15 callersMethoddefaultServiceConfig
(@Nullable Map<String, ?> serviceConfig)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:556
↓ 15 callersMethoddeliver
Delivers a previously queued transaction to its original destination. @throws IllegalStateException if transaction was already delivered once before
binder/src/testFixtures/java/io/grpc/binder/internal/OneWayBinderProxies.java:173
↓ 15 callersMethoddisallowAll
If true, disallows all header mutations. @see HeaderMutationRules#getDisallowAll()
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationRulesConfig.java:55
↓ 15 callersMethoddisallowIsError
If true, a disallowed header mutation will result in an error instead of being ignored. @see HeaderMutationRules#getDisallowIsError()
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderMutationRulesConfig.java:62
↓ 15 callersMethodfilterTransport
Called just before {@link #transportReady} to allow direct modification of transport Attributes.
core/src/main/java/io/grpc/internal/ManagedClientTransport.java:112
↓ 15 callersMethodforPort
Creates a server builder that will bind to the given port. @param port the port on which the server is to be bound. @return the server builder.
netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:128
↓ 15 callersMethodfromCodeValue
Return a {@link Status} given a canonical error {@link Code} value.
api/src/main/java/io/grpc/Status.java:304
↓ 15 callersMethodgetCandidatesViaServiceLoader
Accessor for method.
api/src/main/java/io/grpc/InternalServiceProviders.java:59
↓ 15 callersMethodgetDefaultFactory
()
core/src/main/java/io/grpc/internal/TransportTracer.java:172
↓ 15 callersMethodgetDelegate
()
core/src/main/java/io/grpc/internal/AutoConfiguredLoadBalancerFactory.java:146
↓ 15 callersMethodgetError
()
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:304
↓ 15 callersMethodgetKey
()
netty/src/main/java/io/grpc/netty/GrpcHttp2OutboundHeaders.java:132
↓ 15 callersMethodgetMessageEncoding
Returns the message encoding that this compressor uses. <p>This can be values such as "gzip", "deflate", "snappy", etc.
api/src/main/java/io/grpc/Compressor.java:32
↓ 15 callersMethodgetPrivateKey
Generates a {@link PrivateKey} from a PEM file. The key should be PKCS #8 formatted. The key algorithm should be "RSA" or "EC". The PEM file should co
util/src/main/java/io/grpc/util/CertificateUtils.java:65
↓ 15 callersMethodgetPrivateKey
(String resourceName)
xds/src/test/java/io/grpc/xds/internal/security/certprovider/CommonCertProviderTestUtils.java:33
↓ 15 callersMethodgetRequestMarshaller
Returns the marshaller for the request type. Allows introspection of the request marshaller. @since 1.1.0
api/src/main/java/io/grpc/MethodDescriptor.java:327
↓ 15 callersMethodgetResponseMarshaller
Returns the marshaller for the response type. Allows introspection of the response marshaller. @since 1.1.0
api/src/main/java/io/grpc/MethodDescriptor.java:336
↓ 15 callersMethodgetServiceName
If specified, it overrides the name of the service name to be sent to the balancer. if not, the target to be sent to the balancer will continue to be
grpclb/src/main/java/io/grpc/grpclb/GrpclbConfig.java:62
↓ 15 callersMethodgetServiceName
A convenience method for {@code extractFullServiceName(getFullMethodName())}. @since 1.21.0
api/src/main/java/io/grpc/MethodDescriptor.java:259
↓ 15 callersMethodgetText
()
opentelemetry/src/test/java/io/grpc/opentelemetry/MetadataGetterTest.java:83
↓ 15 callersMethodgetWriteQueue
()
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:709
↓ 15 callersMethodhasData
()
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:569
↓ 15 callersMethodinternalOnly
Creates a default {@link SecurityPolicy} that allows access only to callers with the same UID as the current process.
binder/src/main/java/io/grpc/binder/SecurityPolicies.java:62
↓ 15 callersMethodisInUse
()
core/src/main/java/io/grpc/internal/InUseStateAggregator.java:52
↓ 15 callersMethodisSourceContextCleared
()
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:380
↓ 15 callersMethodmatchingPolicyName
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:96
↓ 15 callersMethodoutboundWireSize
See {@link StreamTracer#outboundWireSize}. <p>Called from {@link io.grpc.internal.Framer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:244
↓ 15 callersMethodplaintext
Returns a {@link io.netty.channel.ChannelHandler} that ensures that the {@code handler} is added to the pipeline writes to the {@link io.netty.channel
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:936
↓ 15 callersMethodrunOnTransportThread
(Runnable r)
core/src/main/java/io/grpc/internal/ApplicationThreadDeframerListener.java:35
↓ 15 callersMethodserverShutdown
The server is shutting down. No new transports will be processed, but existing transports may continue. Shutdown is only caused by a call to {@link In
core/src/main/java/io/grpc/internal/ServerListener.java:38
↓ 15 callersMethodsetChannelLogger
See {@link Args#getChannelLogger}. @since 1.26.0
api/src/main/java/io/grpc/NameResolver.java:641
↓ 15 callersMethodsetPathFilter
Returns a new EquivalentAddressGroup by setting a path filter to the given EquivalentAddressGroup. This method does not modify the input address.
xds/src/main/java/io/grpc/xds/AddressFilter.java:42
↓ 15 callersMethodsetPermission
(String permissionName, int permissionFlag)
binder/src/test/java/io/grpc/binder/SecurityPoliciesTest.java:478
↓ 15 callersMethodsetSafe
Sets whether this method is safe. If true, calling this method any number of times doesn't have side effects. If {@code true}, method is also idempot
api/src/main/java/io/grpc/MethodDescriptor.java:577
↓ 15 callersMethodsettings
(boolean clearPrevious, io.grpc.okhttp.internal.framed.Settings settings)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:52
↓ 15 callersMethodskip
(long n)
core/src/main/java/io/grpc/internal/ReadableBuffers.java:357
↓ 15 callersMethodskipBytes
Increments the read position by the given length. @throws IndexOutOfBoundsException if required bytes are not readable
core/src/main/java/io/grpc/internal/ReadableBuffer.java:60
↓ 15 callersMethodtakeNextTransaction
( QueueingOneWayBinderProxy proxy)
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:679
↓ 15 callersMethodtransportHeadersReceived
Called by subclasses whenever {@code Headers} are received from the transport. @param headers the received headers
core/src/main/java/io/grpc/internal/Http2ClientStreamTransportState.java:88
↓ 15 callersMethodverifyNoMoreMeaningfulInteractions
(Helper helper)
util/src/testFixtures/java/io/grpc/util/AbstractTestHelper.java:187
↓ 15 callersMethodwriteKnownLength
(MessageFramer framer, byte[] bytes)
core/src/test/java/io/grpc/internal/MessageFramerTest.java:370
↓ 15 callersMethodxattr
(List<EquivalentAddressGroup> lbAddr)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2841
↓ 14 callersMethodacceptResolvedAddresses
Returns non-OK status if the delegate rejects the resolvedAddresses (e.g. if it does not support an empty list).
core/src/main/java/io/grpc/internal/AutoConfiguredLoadBalancerFactory.java:88
↓ 14 callersMethodaddOptionalLabel
Optional labels that provide context of how the pick was routed. Particularly helpful for per-RPC metrics. @throws NullPointerException if key or val
api/src/main/java/io/grpc/LoadBalancer.java:512
↓ 14 callersMethodapplyRequestMetadata
( RequestInfo info, Executor appExecutor, final MetadataApplier applier)
auth/src/main/java/io/grpc/auth/GoogleAuthLibraryCallCredentials.java:97
↓ 14 callersMethodassertClusterResolutionResult
(CallInfo call, String expectedCluster)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:1753
↓ 14 callersMethodbuffer
Returns a new buffer for every test case with at least 100 byte of capacity.
core/src/testFixtures/java/io/grpc/internal/WritableBufferTestBase.java:36
↓ 14 callersMethodbuffer
(byte[] bytes)
core/src/test/java/io/grpc/internal/MessageDeframerTest.java:550
↓ 14 callersMethodbuildClientInterceptor
(FilterConfig config, @Nullable FilterConfig overrideConfig, ScheduledExecutorService scheduler)
xds/src/main/java/io/grpc/xds/GcpAuthenticationFilter.java:130
↓ 14 callersMethodbuildClientTransportFactory
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:221
↓ 14 callersMethodbuildCluster
Builds a new default CDS configuration.
xds/src/test/java/io/grpc/xds/ControlPlaneRule.java:266
↓ 14 callersMethodbuildRouteConfiguration
(String authority, String rdsName, String clusterName)
xds/src/test/java/io/grpc/xds/XdsTestUtils.java:312
↓ 14 callersMethodcheckRpcProtocolVersions
Performs check between local and peer Rpc Protocol Versions. This function returns true and the highest common version if there exists a common Rpc Pr
alts/src/main/java/io/grpc/alts/internal/RpcProtocolVersionsUtil.java:67
↓ 14 callersMethodcheckStats
Verify stats were published through the tracer. @param transportStats the transport level stats counters @param clock the fakeClock to verify timesta
core/src/test/java/io/grpc/internal/MessageDeframerTest.java:503
↓ 14 callersMethodcluster
()
xds/src/main/java/io/grpc/xds/VirtualHost.java:157
↓ 14 callersMethodconfiguredChannelCredentials
()
xds/src/main/java/io/grpc/xds/client/AllowedGrpcServices.java:48
↓ 14 callersMethodcreate
( String clientListenerResourceNameTemplate, List<ServerInfo> xdsServers)
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:131
↓ 14 callersMethodcreate
( HeaderValue header, HeaderAppendAction appendAction, boolean keepEmptyValue)
xds/src/main/java/io/grpc/xds/internal/headermutations/HeaderValueOption.java:29
↓ 14 callersMethodcreateMetadataProto
(Metadata metadata, int maxHeaderBytes)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/LogHelper.java:346
↓ 14 callersMethodcreateMetadataProto
( Metadata metadata, int maxHeaderBytes)
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:832
↓ 14 callersMethodcreateOobChannel
(List<EquivalentAddressGroup> eag, String authority)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2919
↓ 14 callersMethodcreateSubchannel
(final int index, final Attributes attrs)
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1404
↓ 14 callersMethoddataFrame
(int streamId, boolean endStream, ByteBuf content)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:285
↓ 14 callersMethoddestroy
()
alts/src/main/java/io/grpc/alts/internal/AltsTsiFrameProtector.java:380
↓ 14 callersMethoddoPingPong
Helper that simply does an RPC. It can be used similar to a sleep for negative testing: to give time for actions _not_ to happen. Since it is based on
core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java:2097
↓ 14 callersMethodequals
(Object o)
xds/src/main/java/io/grpc/xds/internal/security/SslContextProviderSupplier.java:136
↓ 14 callersMethodforKeyValue
Creates a new key/value pair entry. <p>Both key and value can contain any character. They will be URL encoded for you if necessary.
api/src/main/java/io/grpc/QueryParams.java:210
↓ 14 callersMethodforServer
Creates an SslContextBuilder with ciphers and APN appropriate for gRPC. @see SslContextBuilder#forServer(File, File) @see #configure(SslContextBuilde
netty/src/main/java/io/grpc/netty/GrpcSslContexts.java:105
↓ 14 callersMethodfrom
Converts a Google Auth Library {@link Credentials} to {@link CallCredentials}. <p>Although this is a stable API, note that the returned instance's AP
auth/src/main/java/io/grpc/auth/MoreCallCredentials.java:34
↓ 14 callersMethodfromRawQuery
Parses a raw query string into a {@code QueryParams} instance. <p>The input is split on {@code '&'} and each parameter is parsed as either a key/valu
api/src/main/java/io/grpc/QueryParams.java:95
↓ 14 callersMethodfullDuplexCall
<pre> A sequence of requests with each request served by the server immediately. As one request could lead to multiple responses, this interface demon
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/TestServiceGrpc.java:395
↓ 14 callersMethodgenerateName
Generates a new server name that is unique each time.
inprocess/src/main/java/io/grpc/inprocess/InProcessServerBuilder.java:108
↓ 14 callersMethodgetAllAddresses
Returns the addresses that this Subchannel is bound to. The returned list will not be empty. <p>It should be called from the Synchronization Context.
api/src/main/java/io/grpc/LoadBalancer.java:1422
↓ 14 callersMethodgetDefault
()
netty/src/main/java/io/grpc/netty/InternalProtocolNegotiationEvent.java:31
↓ 14 callersMethodgetDefaultPort
()
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:241
↓ 14 callersMethodgetEps
()
services/src/main/java/io/grpc/services/MetricReport.java:81
↓ 14 callersMethodgetHeaders
Returns the custom HTTP headers to be sent during the HTTP CONNECT handshake.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:100
↓ 14 callersMethodgetLatencies
()
interop-testing/src/main/java/io/grpc/testing/integration/SoakClient.java:85
↓ 14 callersMethodgetLatitude
Gets the latitude for the given point.
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideUtil.java:37
↓ 14 callersMethodgetList
Gets a list from an object for the given key. If the key is not present, this returns null. If the value is not a List, throws an exception.
core/src/main/java/io/grpc/internal/JsonUtil.java:37
↓ 14 callersMethodgetLongitude
Gets the longitude for the given point.
examples/src/main/java/io/grpc/examples/routeguide/RouteGuideUtil.java:44
↓ 14 callersMethodgetMemoryUtilization
()
services/src/main/java/io/grpc/services/MetricReport.java:61
↓ 14 callersMethodgetObject
()
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:1052
↓ 14 callersMethodgetProviderForScheme
(String scheme)
api/src/main/java/io/grpc/NameResolverRegistry.java:66
↓ 14 callersMethodgetResult
()
alts/src/main/java/io/grpc/alts/internal/RpcProtocolVersionsUtil.java:102
↓ 14 callersMethodgetServiceAuthority
Returns the authority used to authenticate connections to servers. It <strong>must</strong> be from a trusted source, because if the authority is tam
api/src/main/java/io/grpc/NameResolver.java:74
↓ 14 callersMethodgetStatus
Returns the status code as a {@link Status} object. @since 1.0.0
api/src/main/java/io/grpc/StatusException.java:59
↓ 14 callersMethodgetStream
(int streamId)
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2233
↓ 14 callersMethodgetStreamTracerFactories
Returns an immutable list of {@code ClientStreamTracerFactory}s.
api/src/main/java/io/grpc/CallOptions.java:318
↓ 14 callersMethodgetSupportedSocketAddressTypes
Returns the {@link SocketAddress} types this transport supports.
core/src/main/java/io/grpc/internal/ClientTransportFactory.java:81
↓ 14 callersMethodgoAwayFrame
(int lastStreamId)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:303
↓ 14 callersMethodheader
(int bytes)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1522
↓ 14 callersMethodignoreResourceDeletion
Whether ignore_resource_deletion server feature is enabled for the given test.
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:417
← previousnext →1,101–1,200 of 22,628, ranked by callers