MCPcopy Create free account

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

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

↓ 8 callersMethodassertCurrentPickerPicksSubchannel
(Subchannel expectedSubchannelToPick)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1033
↓ 8 callersMethodassertLatestConnectivityState
(ConnectivityState expectedState)
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:1016
↓ 8 callersMethodassertSuccess
(StreamRecorder<?> recorder)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1671
↓ 8 callersMethodauthority
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 callersMethodawaitTermination
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 callersMethodbuilder
()
rls/src/main/java/io/grpc/rls/RlsProtoData.java:141
↓ 8 callersMethodchannelInactive
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:678
↓ 8 callersMethodcheckBiosDataOnWindows
(BufferedReader reader)
alts/src/main/java/io/grpc/alts/InternalCheckGcpEnvironment.java:62
↓ 8 callersMethodcheckEndTags
( MetricsRecord record, String methodName, Status.Code status, boolean clientSide)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1879
↓ 8 callersMethodcheckStartTags
(MetricsRecord record, String methodName, boolean clientSide)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1868
↓ 8 callersMethodclearTrustStoreSystemProperties
()
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:898
↓ 8 callersMethodcompare
(Closer c1, Closer c2)
xds/src/main/java/io/grpc/xds/FilterChainSelectorManager.java:91
↓ 8 callersMethodcopyWithSubchannel
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 callersMethodcreate
( @Nullable String host, @Nullable String service, @Nullable String method)
rls/src/main/java/io/grpc/rls/RlsProtoData.java:248
↓ 8 callersMethodcreate
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 callersMethodcreate
( ChannelCredentials channelCreds, CallCredentials callCreds)
api/src/main/java/io/grpc/CompositeChannelCredentials.java:28
↓ 8 callersMethodcreate
(int destinationPort, ImmutableList<CidrRange> prefixRanges, ImmutableList<String> application
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:254
↓ 8 callersMethodcreate
(String name, @Nullable String exactValue, @Nullable Pattern safeRegEx, @Nullable Range range,
xds/src/main/java/io/grpc/xds/internal/Matchers.java:138
↓ 8 callersMethodcreateX509TrustManager
( X509Certificate[] certs, CertificateValidationContext certContext, boolean autoSniSanValidation)
xds/src/main/java/io/grpc/xds/internal/security/trust/XdsTrustManagerFactory.java:129
↓ 8 callersMethoddecoderHeaderMutationRules
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 callersMethoddefaultLoadBalancingPolicy
(String policy)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:444
↓ 8 callersMethoddeliverSubchannelState
(Subchannel subchannel, ConnectivityStateInfo newState)
util/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java:1329
↓ 8 callersMethoddenominatorType
()
xds/src/main/java/io/grpc/xds/FaultConfig.java:106
↓ 8 callersMethoddisableAutoRequestWithInitial
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 callersMethodendOfStream
()
netty/src/main/java/io/grpc/netty/SendResponseHeadersCommand.java:56
↓ 8 callersMethodexecute
(Runnable command)
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:291
↓ 8 callersMethodexecute
(Runnable var1)
netty/src/test/java/io/grpc/netty/NettyTestUtil.java:69
↓ 8 callersMethodexecutor
(@Nullable Executor executor)
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:130
↓ 8 callersMethodexitIdleMode
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 callersMethodextract
(Context context, @Nullable C carrier, TextMapGetter<C> getter)
opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcTraceBinContextPropagator.java:95
↓ 8 callersMethodfilter
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 callersMethodfilterChainMatch
()
xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:275
↓ 8 callersMethodfilterStateTestStartServer
(FilterRegistry filterRegistry)
xds/src/test/java/io/grpc/xds/XdsServerWrapperTest.java:1859
↓ 8 callersMethodfinest
(String str, Object...params)
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:262
↓ 8 callersMethodfireProtocolNegotiationEvent
(ChannelHandlerContext ctx)
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:1204
↓ 8 callersMethodforCode
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 callersMethodforExact
The input string should exactly matches the specified string.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:232
↓ 8 callersMethodforPrefix
The request header value should have this prefix.
xds/src/main/java/io/grpc/xds/internal/Matchers.java:108
↓ 8 callersMethodforTarget
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 callersMethodfromPrefix
(String prefix, boolean caseSensitive)
xds/src/main/java/io/grpc/xds/VirtualHost.java:131
↓ 8 callersMethodfromSpiffeId
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 callersMethodgenerateUserHandle
Generate UserHandles the hard way.
binder/src/test/java/io/grpc/binder/internal/ServiceBindingTest.java:457
↓ 8 callersMethodget
(K key, int hash, int bitsConsumed)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:129
↓ 8 callersMethodgetArg
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 callersMethodgetAuthorityOverride
Returns the authority override if any.
api/src/main/java/io/grpc/LoadBalancer.java:729
↓ 8 callersMethodgetCacertFilePathForTestCa
()
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:438
↓ 8 callersMethodgetConfig
()
core/src/main/java/io/grpc/internal/ServiceConfigUtil.java:430
↓ 8 callersMethodgetCustomTags
Map of all custom tags used for logging, metrics and traces.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:50
↓ 8 callersMethodgetDefaultFactory
()
core/src/main/java/io/grpc/internal/CallTracer.java:78
↓ 8 callersMethodgetDelay
(TimeUnit unit)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:205
↓ 8 callersMethodgetDueTasks
Return all due tasks.
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:332
↓ 8 callersMethodgetEndpoint
(StatusOr<XdsClusterConfig> childConfigOr)
xds/src/test/java/io/grpc/xds/XdsDependencyManagerTest.java:254
↓ 8 callersMethodgetEndpoint
()
xds/src/main/java/io/grpc/xds/XdsConfig.java:179
↓ 8 callersMethodgetFilterContext
()
xds/src/test/java/io/grpc/xds/RbacFilterTest.java:472
↓ 8 callersMethodgetHeaderTypeFieldBytes
()
alts/src/main/java/io/grpc/alts/internal/AltsTsiFrameProtector.java:57
↓ 8 callersMethodgetHelper
()
util/src/main/java/io/grpc/util/MultiChildLoadBalancer.java:232
↓ 8 callersMethodgetId
()
core/src/main/java/io/grpc/internal/NoopSslSession.java:29
↓ 8 callersMethodgetInboundWireSize
Returns to sum of all sizes passed to {@link StreamTracer#inboundWireSize}.
testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java:53
↓ 8 callersMethodgetKey
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 callersMethodgetKeyLength
()
alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:49
↓ 8 callersMethodgetKeyManagers
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 callersMethodgetList
(SubchannelPicker picker)
util/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java:562
↓ 8 callersMethodgetList
(SubchannelPicker picker)
xds/src/test/java/io/grpc/xds/LeastRequestLoadBalancerTest.java:625
↓ 8 callersMethodgetListOfStrings
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 callersMethodgetLogLevel
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 callersMethodgetNamedMetrics
()
services/src/main/java/io/grpc/services/MetricReport.java:73
↓ 8 callersMethodgetOutFrame
Returns a mock output frame.
alts/src/test/java/io/grpc/alts/internal/MockAltsHandshakerResp.java:60
↓ 8 callersMethodgetOutboundUncompressedSize
Returns to sum of al sizes passed to {@link StreamTracer#outboundUncompressedSize}.
testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java:68
↓ 8 callersMethodgetParcelable
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 callersMethodgetPath
()
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:292
↓ 8 callersMethodgetPolicyName
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 callersMethodgetProjectId
Get project ID - where logs will go.
gcp-observability/src/main/java/io/grpc/gcp/observability/ObservabilityConfig.java:38
↓ 8 callersMethodgetRouteLookupConfig
()
rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:63
↓ 8 callersMethodgetServerTracerFactory
Returns the server tracer factory.
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryMetricsModule.java:137
↓ 8 callersMethodgetSession
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2526
↓ 8 callersMethodgetSocketFactory
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:1059
↓ 8 callersMethodgetSslContextProvider
Helper method to build CertProviderClientSslContextProvider.
xds/src/test/java/io/grpc/xds/internal/security/certprovider/CertProviderClientSslContextProviderTest.java:70
↓ 8 callersMethodgetSubscribedResourceTypesWithTypeUrl
()
xds/src/main/java/io/grpc/xds/client/XdsClient.java:487
↓ 8 callersMethodgetSuffixLength
Returns the length of the tag in bytes.
alts/src/main/java/io/grpc/alts/internal/ChannelCrypterNetty.java:72
↓ 8 callersMethodgetSynchronizationContext
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1529
↓ 8 callersMethodgetTargetAddress
Returns the address to the target server.
api/src/main/java/io/grpc/HttpConnectProxiedSocketAddress.java:93
↓ 8 callersMethodgetTracerFactories
()
core/src/main/java/io/grpc/internal/ServerImplBuilder.java:266
↓ 8 callersMethodgetTrailers
Returns the received trailers. @since 1.0.0
api/src/main/java/io/grpc/StatusException.java:68
↓ 8 callersMethodgetTransportFromPickResult
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 callersMethodgetTypedMock
()
xds/src/test/java/io/grpc/xds/internal/security/ReferenceCountingMapTest.java:69
↓ 8 callersMethodgetUnaryCallMethod
()
interop-testing/src/generated/main/grpc/io/grpc/testing/integration/TestServiceGrpc.java:53
↓ 8 callersMethodgetVersion
The last successfully updated version of the resource.
xds/src/main/java/io/grpc/xds/client/XdsClient.java:223
↓ 8 callersMethodgrpcDataFrame
(int streamId, boolean endStream, byte[] content)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:281
↓ 8 callersMethodhandleNameResolutionError
(Status error)
xds/src/main/java/io/grpc/xds/CdsLoadBalancer2.java:197
↓ 8 callersMethodinboundUncompressedSize
(long bytes)
census/src/main/java/io/grpc/census/CensusStatsModule.java:305
↓ 8 callersMethodinitialMetadata
()
xds/src/main/java/io/grpc/xds/internal/grpcservice/GrpcServiceConfig.java:43
↓ 8 callersMethodinterceptCall
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 callersMethodisCancelled
()
stub/src/test/java/io/grpc/stub/ServerCallsTest.java:710
↓ 8 callersMethodisGreaterThanOrEqualTo
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 callersMethodisPathAbsolute
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 callersMethodisShutdown
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 callersMethodisValid
()
core/src/main/java/io/grpc/internal/NoopSslSession.java:60
↓ 8 callersMethodkeysForTest
()
api/src/main/java/io/grpc/Attributes.java:82
↓ 8 callersMethodmakeOptions
(String logConfigStr)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1547
↓ 8 callersMethodmaybeGetMockListener
()
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1233
← previousnext →1,801–1,900 of 22,628, ranked by callers