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
↓ 82 callersMethodparse
Parses a json string, returning either a {@code Map<String, ?>}, {@code List<?>}, {@code String}, {@code Double}, {@code Boolean}, or {@code null}. Fa
core/src/main/java/io/grpc/internal/JsonParser.java:48
↓ 81 callersMethodgetXdsResourceTypeArgs
(boolean isTrustedServer)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplDataTest.java:3632
↓ 81 callersMethodrequestConnection
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:1145
↓ 80 callersMethodcreate
()
api/src/main/java/io/grpc/InsecureServerCredentials.java:21
↓ 79 callersMethodframeHandler
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2241
↓ 79 callersMethodlog
(ChannelLogLevel level, String message)
okhttp/src/test/java/io/grpc/okhttp/OkHttpChannelBuilderTest.java:530
↓ 79 callersMethodtimeout
()
okhttp/src/main/java/io/grpc/okhttp/AsyncSink.java:185
↓ 79 callersMethodwithOption
Sets a custom option. Any existing value for the key is overwritten. @param key The option key @param value The option value. @since 1.13.0
api/src/main/java/io/grpc/CallOptions.java:400
↓ 78 callersMethodgetMetricAsLongOrFail
Returns the value of a metric converted to long, or throw if not found.
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:101
↓ 78 callersMethodheaders
Create or update incoming headers, creating the corresponding streams if necessary. Frames that trigger this are SPDY SYN_STREAM, HEADERS, and SYN_REP
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:49
↓ 78 callersMethodstartResourceWatcher
( XdsResourceType<T> type, String name, ResourceWatcher<T> watcher, Executor executor)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5164
↓ 77 callersMethodassertExactCallbackInvokes
(String ... expectedInvokes)
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:1679
↓ 77 callersMethodenqueue
(WriteQueue.QueuedCommand command)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:341
↓ 77 callersMethodgetStats
(AbstractSubchannel subchannel)
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:4641
↓ 76 callersMethodisPresent
Returns {@code true} when the Conscrypt Java classes are available. Does not imply it actually works on this platform.
core/src/main/java/io/grpc/internal/ConscryptLoader.java:51
↓ 76 callersMethodrun
(boolean isDeframerOnTransportThread)
core/src/main/java/io/grpc/internal/MigratingThreadDeframer.java:37
↓ 76 callersMethodwithValue
Create a new context with the given key value set. The new context will cascade cancellation from its parent. <pre> Context withCredential = Cont
api/src/context/java/io/grpc/Context.java:342
↓ 75 callersMethodacceptResolvedAddresses
()
xds/src/test/java/io/grpc/xds/PriorityLoadBalancerTest.java:150
↓ 75 callersMethodmin
(@Nullable Deadline deadline0, @Nullable Deadline deadline1)
core/src/main/java/io/grpc/internal/ClientCallImpl.java:430
↓ 75 callersMethodsetListener
Sets the server stream listener.
core/src/main/java/io/grpc/internal/ServerStream.java:88
↓ 74 callersMethodkeyManager
Use the provided certificate chain and private key as the server's identity. Generally they should be PEM-encoded and the key is an unencrypted PKCS#8
api/src/main/java/io/grpc/TlsServerCredentials.java:267
↓ 73 callersMethodfutureUnaryCall
Executes a unary call and returns a {@link ListenableFuture} to the response. The {@code call} should not be already started. After calling this met
stub/src/main/java/io/grpc/stub/ClientCalls.java:321
↓ 73 callersMethodgetMethod
Look up a method by its fully qualified name. @param methodName the fully qualified name without leading slash. E.g., "com.foo.Foo/Bar"
api/src/main/java/io/grpc/ServerServiceDefinition.java:69
↓ 73 callersMethodtimeout
()
xds/src/main/java/io/grpc/xds/internal/grpcservice/GrpcServiceConfig.java:41
↓ 72 callersMethodgetDefaultRegistry
Returns the default registry that loads providers via the Java service loader mechanism.
api/src/main/java/io/grpc/LoadBalancerRegistry.java:100
↓ 72 callersMethodgetValue
()
netty/src/main/java/io/grpc/netty/GrpcHttp2OutboundHeaders.java:137
↓ 72 callersMethodnameResolverFactory
(NameResolver.Factory resolverFactory)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:419
↓ 72 callersMethodpostCommit
()
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:2971
↓ 72 callersMethodvalue
Returns the value of this counter.
core/src/main/java/io/grpc/internal/LongCounter.java:27
↓ 71 callersMethodcode
Gets the code for this error used on the wire.
core/src/main/java/io/grpc/internal/GrpcUtil.java:388
↓ 71 callersMethoddata
(boolean inFinished, int streamId, Buffer payload)
okhttp/src/test/java/io/grpc/okhttp/OkHttpServerTransportTest.java:1572
↓ 71 callersMethodgetAll
Returns all the metadata entries named 'name', in the order they were received, parsed as T, or null if there are none. The iterator is not guaranteed
api/src/main/java/io/grpc/Metadata.java:308
↓ 71 callersMethodonResult2
(final NameResolver.ResolutionResult resolutionResult)
xds/src/main/java/io/grpc/xds/XdsDependencyManager.java:893
↓ 70 callersMethodattach
Attach this context, thus enter a new scope within which this context is {@link #current}. The previously current context is returned. It is allowed
api/src/context/java/io/grpc/Context.java:426
↓ 70 callersMethodcontains
(CharSequence name)
netty/src/main/java/io/grpc/netty/AbstractHttp2Headers.java:258
↓ 70 callersMethodfromCode
Return a {@link Status} given a canonical error {@link Code} object.
api/src/main/java/io/grpc/Status.java:348
↓ 70 callersMethodgetAddress
(Subchannel subchannel)
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:640
↓ 69 callersMethodnewCall
()
core/src/test/java/io/grpc/internal/ForwardingManagedChannelTest.java:88
↓ 69 callersMethodsetStatus
Updates the status of the server. @param service the name of some aspect of the server that is associated with a health status. This name can have
services/src/main/java/io/grpc/services/HealthStatusManager.java:67
↓ 68 callersMethodgetErrorDetail
Returns error detail if exists, otherwise null.
xds/src/main/java/io/grpc/xds/StructOrError.java:66
↓ 68 callersMethodinterceptCall
Intercept {@link ClientCall} creation by the {@code next} {@link Channel}. <p>Many variations of interception are possible. Complex implementations m
api/src/main/java/io/grpc/ClientInterceptor.java:60
↓ 68 callersMethodupdateBalancingState
( @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker)
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:2959
↓ 67 callersMethodclose
Releases resources held by this negotiator. Called when the Channel transitions to terminated or when InternalServer is shutdown (depending on client
netty/src/main/java/io/grpc/netty/ProtocolNegotiator.java:48
↓ 67 callersMethodmessagesAvailable
Called to deliver the next complete message. @param producer single message producer wrapping the message.
core/src/main/java/io/grpc/internal/MessageDeframer.java:68
↓ 67 callersMethodwithError
A decision to report a connectivity error to the RPC. If the RPC is {@link CallOptions#withWaitForReady wait-for-ready}, it will stay buffered. Othe
api/src/main/java/io/grpc/LoadBalancer.java:702
↓ 66 callersMethodequals
(Object other)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Header.java:41
↓ 66 callersMethodexecute
(Runnable runnable)
api/src/test/java/io/grpc/ContextTest.java:365
↓ 65 callersMethodfromStatus
Construct from a non-Ok status.
api/src/main/java/io/grpc/StatusOr.java:42
↓ 65 callersMethodgetStats
Returns the stats object.
api/src/main/java/io/grpc/InternalInstrumented.java:33
↓ 65 callersMethodunaryCall
<pre> One request followed by one response. The server returns the client payload as-is. </pre>
benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java:239
↓ 64 callersMethodaddLongCounter
Adds a value for a long valued counter metric associated with specified metric instrument. @param metricInstrument The counter metric instrument iden
api/src/main/java/io/grpc/MetricSink.java:72
↓ 64 callersMethodname
()
xds/src/main/java/io/grpc/xds/internal/Matchers.java:40
↓ 64 callersMethodsetAuthority
Override the default authority with {@code authority}. May only be called before {@link #start}.
core/src/main/java/io/grpc/internal/ClientStream.java:55
↓ 63 callersMethodcreate
Creates a new recorder.
testing/src/main/java/io/grpc/testing/StreamRecorder.java:43
↓ 63 callersMethodheadersRead
Called upon receiving all header information from the remote end-point. Note that transports are not required to call this method if no header informa
core/src/main/java/io/grpc/internal/ClientStreamListener.java:34
↓ 63 callersMethodtypeUrl
()
xds/src/main/java/io/grpc/xds/Filter.java:44
↓ 62 callersMethoddeliverLdsUpdate
(long httpMaxStreamDurationNano, List<VirtualHost> virtualHosts)
xds/src/test/java/io/grpc/xds/XdsNameResolverTest.java:2631
↓ 62 callersMethodexecute
Runs the given runnable strictly after all Runnables that were submitted before it, and using the {@code executor} passed to the constructor. .
core/src/main/java/io/grpc/internal/SerializingExecutor.java:92
↓ 62 callersMethodnewCall
( MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions)
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:277
↓ 62 callersMethodnextBackoffNanos
Returns the number of nanoseconds to wait.
core/src/main/java/io/grpc/internal/BackoffPolicy.java:30
↓ 62 callersMethodnode
Returns the node identifier to be included in xDS requests.
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:149
↓ 61 callersMethodblockingV2UnaryCall
Executes a unary call and blocks on the response, throws a checked {@link StatusException}. @return the single response message. @throws StatusExcept
stub/src/main/java/io/grpc/stub/ClientCalls.java:192
↓ 61 callersMethodequal
Returns true if two possibly-null objects are equal.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Util.java:40
↓ 61 callersMethodgetKey
()
xds/src/main/java/io/grpc/xds/internal/MetricReportUtils.java:45
↓ 61 callersMethodhandler
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:220
↓ 61 callersMethodupdateBalancingState
Set a new state with a new picker to the channel. <p>When a new picker is provided via {@code updateBalancingState()}, the channel will apply the pic
api/src/main/java/io/grpc/LoadBalancer.java:1183
↓ 60 callersMethodaddListener
Add a listener that will be notified when the context becomes cancelled.
api/src/context/java/io/grpc/Context.java:499
↓ 60 callersMethodforName
Create a channel builder that will connect to the server with the given name. @param name the identity of the server to connect to @return a new buil
inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:61
↓ 60 callersMethodisShutdown
()
xds/src/test/java/io/grpc/xds/StatefulFilter.java:47
↓ 60 callersMethodmatches
(EvaluateArgs args)
xds/src/main/java/io/grpc/xds/internal/rbac/engine/GrpcAuthorizationEngine.java:419
↓ 60 callersMethodnextFrame
(Handler handler)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/FrameReader.java:32
↓ 60 callersMethodnextInt
(int bound)
xds/src/main/java/io/grpc/xds/ThreadSafeRandom.java:24
↓ 60 callersMethodtransportReportStatus
Must be holding 'lock' when calling.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:1166
↓ 60 callersMethodunaryRpc
<pre> Simple unary RPC. </pre>
testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/SimpleServiceGrpc.java:213
↓ 59 callersMethodget
()
rls/src/main/java/io/grpc/rls/RlsLoadBalancer.java:119
↓ 59 callersMethodgetMethodDescriptor
Returns method descriptor to the proto service method.
protobuf/src/main/java/io/grpc/protobuf/ProtoMethodDescriptorSupplier.java:31
↓ 59 callersMethodid
Returns the id.
netty/src/main/java/io/grpc/netty/StreamIdHolder.java:26
↓ 59 callersMethodloadMetricStatsMap
()
xds/src/main/java/io/grpc/xds/client/Stats.java:109
↓ 58 callersMethodallocate
Request a new {@link WritableBuffer} with the given {@code capacityHint}. The allocator is free to return a buffer with a greater or lesser capacity.
core/src/main/java/io/grpc/internal/WritableBufferAllocator.java:29
↓ 58 callersMethodexecute
(Runnable command)
core/src/test/java/io/grpc/internal/ReschedulerTest.java:117
↓ 58 callersMethodgetInstance
()
xds/src/main/java/io/grpc/xds/XdsRouteConfigureResource.java:90
↓ 58 callersMethodgetKey
Returns the key. <p>Any characters that needed URL encoding have already been decoded.
api/src/main/java/io/grpc/QueryParams.java:185
↓ 58 callersMethodgetLoadBalancingPolicyConfig
Gets the domain specific load balancing policy. This is the config produced by {@link LoadBalancerProvider#parseLoadBalancingPolicyConfig(Map)}. @si
api/src/main/java/io/grpc/LoadBalancer.java:279
↓ 58 callersMethodobtainActiveTransport
Returns a READY transport that will be used to create new streams. <p>Returns {@code null} if the state is not READY. Will try to connect if state i
core/src/main/java/io/grpc/internal/TransportProvider.java:32
↓ 58 callersMethodshutdownAndVerify
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2625
↓ 58 callersMethodupdate
(@Nullable ConfigOrError coe)
core/src/main/java/io/grpc/internal/ServiceConfigState.java:86
↓ 57 callersMethodinitTransport
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:204
↓ 57 callersMethodintercept
Adds a {@link ServerInterceptor} that is run for all services on the server. Interceptors added through this method always run before per-service int
api/src/main/java/io/grpc/ServerBuilder.java:144
↓ 57 callersMethodinvoke
(ReqT request, StreamObserver<RespT> responseObserver)
stub/src/main/java/io/grpc/stub/ServerCalls.java:88
↓ 57 callersMethodof
Returns companion enum value of passed internal enum equivalent.
stub/src/main/java/io/grpc/stub/InternalClientCalls.java:57
↓ 57 callersMethodpollRecord
()
testing/src/main/java/io/grpc/internal/testing/StatsTestUtils.java:142
↓ 57 callersMethodservers
Returns the list of xDS servers to be connected to. Must not be empty.
xds/src/main/java/io/grpc/xds/client/Bootstrapper.java:146
↓ 57 callersMethodsetHost
Specifies the "host" component of the new URI in its "registered name" form (usually DNS), e.g. "server.com". <p>The registered name can contain any
api/src/main/java/io/grpc/Uri.java:904
↓ 57 callersMethodtoString
{@inheritDoc} <p>If this URI was created by {@link #parse(String)} or {@link #create(String)}, then the returned string will match that original inpu
api/src/main/java/io/grpc/Uri.java:613
↓ 56 callersMethodcreate
Creates a URI from a string assumed to be valid. <p>Useful for defining URI constants in code. Not for user input. @throws IllegalArgumentException
api/src/main/java/io/grpc/Uri.java:214
↓ 56 callersMethodequals
(Object o)
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:5431
↓ 56 callersMethodisLoggable
(Level level)
servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:256
↓ 56 callersMethodisWithin
Prepares for a check that the subject is deadline within the given tolerance of an expected value that will be provided in the next call in the fluent
api/src/testFixtures/java/io/grpc/testing/DeadlineSubject.java:55
↓ 56 callersMethodmanualSetUp
()
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:190
↓ 56 callersMethodstream
()
netty/src/test/java/io/grpc/netty/NettyClientStreamTest.java:593
← previousnext →201–300 of 22,628, ranked by callers