MCPcopy Create free account

hub / github.com/annabergite/abg-rpc / functions

Functions1,654 in github.com/annabergite/abg-rpc

↓ 8 callersMethodgetUTF8Bytes
unsafe, do not change the return bytes @param str @return
abg-utils/src/main/java/rpc/abg/util/UnsafeStringUtils.java:101
↓ 8 callersMethodparse
(String str)
abg-cloud/src/main/java/rpc/abg/config/HostPort.java:11
↓ 8 callersMethodsetWeightables
可多次重复设置 @param weightables
abg-cloud/src/main/java/rpc/abg/loadbalance/LoadBalance.java:21
↓ 8 callersMethodwriteString
(int fieldNumber, CharSequence value, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:152
↓ 8 callersMethodwriteTo
(final ByteBuf buffer)
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:113
↓ 8 callersMethodwriteVarInt
(int val, boolean optimizePositive)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:187
↓ 7 callersMethoddebug
Logs a message with debug log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:174
↓ 7 callersMethodget
通过服务id获取invoker @param serviceId @return
abg-cloud/src/main/java/rpc/abg/invoke/ServerInvokerFactory.java:80
↓ 7 callersMethodgetLatin1Bytes
unsafe, do not change the return bytes @param str @return
abg-utils/src/main/java/rpc/abg/util/UnsafeStringUtils.java:130
↓ 7 callersMethodgetRegisters
()
abg-cloud/src/main/java/rpc/abg/config/server/ServerConfig.java:85
↓ 7 callersMethodgetSerializer
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:50
↓ 7 callersMethodgetStatusCode
()
abg-cloud/src/main/java/rpc/abg/protocol/Response.java:32
↓ 7 callersMethodhash2
(int h)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:677
↓ 7 callersMethodhash3
(int h)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:682
↓ 7 callersMethodhash4
(int h)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:687
↓ 7 callersMethodnext
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:865
↓ 7 callersMethodnext
Gets a new object id. @return the new id
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:86
↓ 7 callersMethodreadBytes
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:444
↓ 7 callersMethodreadVarLong
(ByteBuf byteBuf)
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:282
↓ 7 callersMethodselect
选出一个来 @return
abg-cloud/src/main/java/rpc/abg/loadbalance/LoadBalance.java:28
↓ 7 callersMethodset
(int index, E element)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:58
↓ 7 callersMethodsetClientAddress
(HostPort clientAddress)
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:30
↓ 7 callersMethodsetRequestId
(int requestId)
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:29
↓ 7 callersMethodsetServerAddress
(HostPort serverAddress)
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:43
↓ 7 callersMethodsetStatusCode
(byte statusCode)
abg-cloud/src/main/java/rpc/abg/protocol/Response.java:36
↓ 7 callersMethodtypeClass
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Serializer.java:11
↓ 6 callersMethodclear
Closes the underlying InputStream, if any.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:140
↓ 6 callersMethoddecode
(final byte[] bytes)
abg-utils/src/main/java/rpc/abg/util/URLEncodeUtils.java:52
↓ 6 callersMethodgetApp
()
abg-cloud/src/main/java/rpc/abg/remote/RemoteInterface.java:22
↓ 6 callersMethodgetMethod
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:47
↓ 6 callersMethodgetMethodParam
()
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:49
↓ 6 callersMethodgetMethodParamClass
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:59
↓ 6 callersMethodgetParameterNames
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:55
↓ 6 callersMethodgetRegister
()
abg-cloud/src/main/java/rpc/abg/config/server/RegisterConfig.java:21
↓ 6 callersMethodgetResult
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:52
↓ 6 callersMethodidle
(final int idleCounter)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/WaitStrategy.java:7
↓ 6 callersMethodisLatin1
(String str)
abg-utils/src/main/java/rpc/abg/util/UnsafeStringUtils.java:87
↓ 6 callersMethodnewMessage
()
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:754
↓ 6 callersMethodput
@param index 通过 {@link #nextVarIndex()} 获得 @param value
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:187
↓ 6 callersMethodrelease
(T t)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/LockObjectPool.java:57
↓ 6 callersMethodremove
(int requestId)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer1.java:44
↓ 6 callersMethodsetTracer
(Tracer tracer)
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:45
↓ 6 callersMethodvalues
Returns an iterator for the values in the map. Remove is supported.
abg-utils/src/main/java/rpc/abg/util/FastMap.java:728
↓ 6 callersMethodwriteClassAndObject
(ByteBuf buf, Object obj)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:144
↓ 5 callersMethodaddListener
添加一个服务变化回调 @param group @param app @param protocol @param listener
abg-cloud/src/main/java/rpc/abg/discover/Discover.java:29
↓ 5 callersMethodadvance
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:763
↓ 5 callersMethodcreate
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ViberObjectPool.java:20
↓ 5 callersMethoddecode
(ChannelHandlerContext ctx, ByteBuf in)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/ResponseDecoder.java:26
↓ 5 callersMethodexistUser
会自动注册为失败回退方法,当远程调用失败时执行 @param email @return
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserService.java:18
↓ 5 callersMethodgcd
最大公约数 @param a @param b @return
abg-utils/src/main/java/rpc/abg/util/MathUtils.java:16
↓ 5 callersMethodget
获取EventLoopGroup, 使用完毕必须执行{@link #release(EventLoopGroup)} @return
abg-cloud/src/main/java/rpc/abg/common/EventLoopGroupHolder.java:43
↓ 5 callersMethodgetFuture
()
abg-cloud/src/main/java/rpc/abg/transport/client/future/RequestWithFuture.java:27
↓ 5 callersMethodgetGroup
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:34
↓ 5 callersMethodgetIntOrElse
(Config config, String path, int defaultValue)
abg-cloud/src/main/java/rpc/abg/config/ConfigUtils.java:25
↓ 5 callersMethodgetProtocol
()
abg-cloud/src/main/java/rpc/abg/config/server/RegisterConfig.java:29
↓ 5 callersMethodgetTracer
()
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:41
↓ 5 callersMethodisSupport
(Class<?> clazz)
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:355
↓ 5 callersMethodisTraceEnabled
Is trace logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenat
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:115
↓ 5 callersMethodkryoContext
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoSerializer.java:47
↓ 5 callersMethodoffset
(int index)
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:141
↓ 5 callersMethodoffset
(int index)
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:123
↓ 5 callersMethodreadInt32
Read an {@code int32} field value from the internal buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:284
↓ 5 callersMethodreadVarInt
(boolean optimizePositive)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:187
↓ 5 callersMethodseconds
返回当前秒 @return
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:48
↓ 5 callersMethodsetParentId
(long parentId)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:58
↓ 5 callersMethodsetRequestId
(int requestId)
abg-cloud/src/main/java/rpc/abg/protocol/Response.java:28
↓ 5 callersMethodsetResult
(Object result)
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:56
↓ 5 callersMethodsetTraceId
(ObjectId traceId)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:50
↓ 5 callersMethodtoString
(FullHttpRequest httpRequest)
abg-cloud/src/main/java/rpc/abg/transport/server/rest/handler/NettyRestHandler.java:215
↓ 5 callersMethodtransferByteRangeTo
(Output output, boolean utf8String, int fieldNumber, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:551
↓ 5 callersMethodwriteRawInt32
(int value)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:37
↓ 5 callersMethodwriteRawString
(String value)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:128
↓ 5 callersMethodwriteTo
(Output output, int number, Tracer tracer, boolean repeated)
abg-protostuff/src/main/java/rpc/abg/serialization/protostuff/TracerDelegate.java:38
↓ 4 callersMethodadd
(T value)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:46
↓ 4 callersMethodborrow
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/LockObjectPool.java:48
↓ 4 callersMethodchannelIndex
(int requestId)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:265
↓ 4 callersMethodclose
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:567
↓ 4 callersMethodclose
(ChannelHandlerContext ctx, ChannelPromise promise)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/RequestEncoder.java:67
↓ 4 callersMethodclose
()
abg-cloud/src/main/java/rpc/abg/transport/server/rpc/NettyRpcServer.java:73
↓ 4 callersMethodcreateUser
(User user)
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserService.java:29
↓ 4 callersMethoddoResponseFilter
(Request request, Response response, Invoker<CompletableFuture<?>> invoker, Throwable throwable)
abg-cloud/src/main/java/rpc/abg/transport/server/rpc/handler/NettyRpcServerHandler.java:131
↓ 4 callersMethodempty
()
abg-cloud/src/main/java/rpc/abg/param/EmptyMethodParam.java:7
↓ 4 callersMethodget
获取线程变量 @param index 需要从 AttachmentThreadUtils.nextVarIndex()获取到 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:69
↓ 4 callersMethodgetDiscover
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:106
↓ 4 callersMethodgetMethodId
获取methodId @param method @return
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:365
↓ 4 callersMethodgetServiceClassName
@param group 不能包含# / @param app 不能包含# / @param clazz 不能为空 @return
abg-cloud/src/main/java/rpc/abg/invoke/InvokerUtils.java:24
↓ 4 callersMethodgetServiceMethodName
获取当前远程调用的服务名称, 可能为空 @return
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:65
↓ 4 callersMethodgetStash
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:400
↓ 4 callersMethodgetUserService
()
abg-jmh/src/main/java/rpc/abg/benchmark/client/AbstractClient.java:13
↓ 4 callersMethodignore
(Method method)
abg-cloud/src/main/java/rpc/abg/config/MethodConfig.java:86
↓ 4 callersMethodincrementAndGet
递增并获取该位置的值 @param index @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:55
↓ 4 callersMethodreadBool
Read a {@code bool} field value from the internal buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:311
↓ 4 callersMethodreadBytes
Reads the specified number of bytes into a new byte[].
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:157
↓ 4 callersMethodreadRawLittleEndian32
Read a 32-bit little-endian integer from the internal buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:540
↓ 4 callersMethodreadRawLittleEndian64
Read a 64-bit little-endian integer from the internal byte buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:547
↓ 4 callersMethodrecycle
()
abg-cloud/src/main/java/rpc/abg/recycle/Recycleable.java:5
↓ 4 callersMethodset
设置某位置的值 @param index @param value
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:122
↓ 4 callersMethodsetFailover
设置失败回退方法 @param clazz @param failover
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:171
↓ 4 callersMethodsetMethodParam
(MethodParam methodParam)
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:53
↓ 4 callersMethodsetResult
(List<T> result)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:44
← previousnext →101–200 of 1,654, ranked by callers