Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/annabergite/abg-rpc
/ functions
Functions
1,654 in github.com/annabergite/abg-rpc
⨍
Functions
1,654
◇
Types & classes
287
↓ 8 callers
Method
getUTF8Bytes
unsafe, do not change the return bytes @param str @return
abg-utils/src/main/java/rpc/abg/util/UnsafeStringUtils.java:101
↓ 8 callers
Method
parse
(String str)
abg-cloud/src/main/java/rpc/abg/config/HostPort.java:11
↓ 8 callers
Method
setWeightables
可多次重复设置 @param weightables
abg-cloud/src/main/java/rpc/abg/loadbalance/LoadBalance.java:21
↓ 8 callers
Method
writeString
(int fieldNumber, CharSequence value, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:152
↓ 8 callers
Method
writeTo
(final ByteBuf buffer)
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:113
↓ 8 callers
Method
writeVarInt
(int val, boolean optimizePositive)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:187
↓ 7 callers
Method
debug
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 callers
Method
get
通过服务id获取invoker @param serviceId @return
abg-cloud/src/main/java/rpc/abg/invoke/ServerInvokerFactory.java:80
↓ 7 callers
Method
getLatin1Bytes
unsafe, do not change the return bytes @param str @return
abg-utils/src/main/java/rpc/abg/util/UnsafeStringUtils.java:130
↓ 7 callers
Method
getRegisters
()
abg-cloud/src/main/java/rpc/abg/config/server/ServerConfig.java:85
↓ 7 callers
Method
getSerializer
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:50
↓ 7 callers
Method
getStatusCode
()
abg-cloud/src/main/java/rpc/abg/protocol/Response.java:32
↓ 7 callers
Method
hash2
(int h)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:677
↓ 7 callers
Method
hash3
(int h)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:682
↓ 7 callers
Method
hash4
(int h)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:687
↓ 7 callers
Method
next
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:865
↓ 7 callers
Method
next
Gets a new object id. @return the new id
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:86
↓ 7 callers
Method
readBytes
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:444
↓ 7 callers
Method
readVarLong
(ByteBuf byteBuf)
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:282
↓ 7 callers
Method
select
选出一个来 @return
abg-cloud/src/main/java/rpc/abg/loadbalance/LoadBalance.java:28
↓ 7 callers
Method
set
(int index, E element)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:58
↓ 7 callers
Method
setClientAddress
(HostPort clientAddress)
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:30
↓ 7 callers
Method
setRequestId
(int requestId)
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:29
↓ 7 callers
Method
setServerAddress
(HostPort serverAddress)
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:43
↓ 7 callers
Method
setStatusCode
(byte statusCode)
abg-cloud/src/main/java/rpc/abg/protocol/Response.java:36
↓ 7 callers
Method
typeClass
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Serializer.java:11
↓ 6 callers
Method
clear
Closes the underlying InputStream, if any.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:140
↓ 6 callers
Method
decode
(final byte[] bytes)
abg-utils/src/main/java/rpc/abg/util/URLEncodeUtils.java:52
↓ 6 callers
Method
getApp
()
abg-cloud/src/main/java/rpc/abg/remote/RemoteInterface.java:22
↓ 6 callers
Method
getMethod
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:47
↓ 6 callers
Method
getMethodParam
()
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:49
↓ 6 callers
Method
getMethodParamClass
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:59
↓ 6 callers
Method
getParameterNames
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:55
↓ 6 callers
Method
getRegister
()
abg-cloud/src/main/java/rpc/abg/config/server/RegisterConfig.java:21
↓ 6 callers
Method
getResult
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:52
↓ 6 callers
Method
idle
(final int idleCounter)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/WaitStrategy.java:7
↓ 6 callers
Method
isLatin1
(String str)
abg-utils/src/main/java/rpc/abg/util/UnsafeStringUtils.java:87
↓ 6 callers
Method
newMessage
()
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:754
↓ 6 callers
Method
put
@param index 通过 {@link #nextVarIndex()} 获得 @param value
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:187
↓ 6 callers
Method
release
(T t)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/LockObjectPool.java:57
↓ 6 callers
Method
remove
(int requestId)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer1.java:44
↓ 6 callers
Method
setTracer
(Tracer tracer)
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:45
↓ 6 callers
Method
values
Returns an iterator for the values in the map. Remove is supported.
abg-utils/src/main/java/rpc/abg/util/FastMap.java:728
↓ 6 callers
Method
writeClassAndObject
(ByteBuf buf, Object obj)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:144
↓ 5 callers
Method
addListener
添加一个服务变化回调 @param group @param app @param protocol @param listener
abg-cloud/src/main/java/rpc/abg/discover/Discover.java:29
↓ 5 callers
Method
advance
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:763
↓ 5 callers
Method
create
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ViberObjectPool.java:20
↓ 5 callers
Method
decode
(ChannelHandlerContext ctx, ByteBuf in)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/ResponseDecoder.java:26
↓ 5 callers
Method
existUser
会自动注册为失败回退方法,当远程调用失败时执行 @param email @return
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserService.java:18
↓ 5 callers
Method
gcd
最大公约数 @param a @param b @return
abg-utils/src/main/java/rpc/abg/util/MathUtils.java:16
↓ 5 callers
Method
get
获取EventLoopGroup, 使用完毕必须执行{@link #release(EventLoopGroup)} @return
abg-cloud/src/main/java/rpc/abg/common/EventLoopGroupHolder.java:43
↓ 5 callers
Method
getFuture
()
abg-cloud/src/main/java/rpc/abg/transport/client/future/RequestWithFuture.java:27
↓ 5 callers
Method
getGroup
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:34
↓ 5 callers
Method
getIntOrElse
(Config config, String path, int defaultValue)
abg-cloud/src/main/java/rpc/abg/config/ConfigUtils.java:25
↓ 5 callers
Method
getProtocol
()
abg-cloud/src/main/java/rpc/abg/config/server/RegisterConfig.java:29
↓ 5 callers
Method
getTracer
()
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:41
↓ 5 callers
Method
isSupport
(Class<?> clazz)
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:355
↓ 5 callers
Method
isTraceEnabled
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 callers
Method
kryoContext
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoSerializer.java:47
↓ 5 callers
Method
offset
(int index)
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:141
↓ 5 callers
Method
offset
(int index)
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:123
↓ 5 callers
Method
readInt32
Read an {@code int32} field value from the internal buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:284
↓ 5 callers
Method
readVarInt
(boolean optimizePositive)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:187
↓ 5 callers
Method
seconds
返回当前秒 @return
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:48
↓ 5 callers
Method
setParentId
(long parentId)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:58
↓ 5 callers
Method
setRequestId
(int requestId)
abg-cloud/src/main/java/rpc/abg/protocol/Response.java:28
↓ 5 callers
Method
setResult
(Object result)
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:56
↓ 5 callers
Method
setTraceId
(ObjectId traceId)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:50
↓ 5 callers
Method
toString
(FullHttpRequest httpRequest)
abg-cloud/src/main/java/rpc/abg/transport/server/rest/handler/NettyRestHandler.java:215
↓ 5 callers
Method
transferByteRangeTo
(Output output, boolean utf8String, int fieldNumber, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:551
↓ 5 callers
Method
writeRawInt32
(int value)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:37
↓ 5 callers
Method
writeRawString
(String value)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:128
↓ 5 callers
Method
writeTo
(Output output, int number, Tracer tracer, boolean repeated)
abg-protostuff/src/main/java/rpc/abg/serialization/protostuff/TracerDelegate.java:38
↓ 4 callers
Method
add
(T value)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:46
↓ 4 callers
Method
borrow
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/LockObjectPool.java:48
↓ 4 callers
Method
channelIndex
(int requestId)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:265
↓ 4 callers
Method
close
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:567
↓ 4 callers
Method
close
(ChannelHandlerContext ctx, ChannelPromise promise)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/RequestEncoder.java:67
↓ 4 callers
Method
close
()
abg-cloud/src/main/java/rpc/abg/transport/server/rpc/NettyRpcServer.java:73
↓ 4 callers
Method
createUser
(User user)
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserService.java:29
↓ 4 callers
Method
doResponseFilter
(Request request, Response response, Invoker<CompletableFuture<?>> invoker, Throwable throwable)
abg-cloud/src/main/java/rpc/abg/transport/server/rpc/handler/NettyRpcServerHandler.java:131
↓ 4 callers
Method
empty
()
abg-cloud/src/main/java/rpc/abg/param/EmptyMethodParam.java:7
↓ 4 callers
Method
get
获取线程变量 @param index 需要从 AttachmentThreadUtils.nextVarIndex()获取到 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:69
↓ 4 callers
Method
getDiscover
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:106
↓ 4 callers
Method
getMethodId
获取methodId @param method @return
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:365
↓ 4 callers
Method
getServiceClassName
@param group 不能包含# / @param app 不能包含# / @param clazz 不能为空 @return
abg-cloud/src/main/java/rpc/abg/invoke/InvokerUtils.java:24
↓ 4 callers
Method
getServiceMethodName
获取当前远程调用的服务名称, 可能为空 @return
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:65
↓ 4 callers
Method
getStash
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:400
↓ 4 callers
Method
getUserService
()
abg-jmh/src/main/java/rpc/abg/benchmark/client/AbstractClient.java:13
↓ 4 callers
Method
ignore
(Method method)
abg-cloud/src/main/java/rpc/abg/config/MethodConfig.java:86
↓ 4 callers
Method
incrementAndGet
递增并获取该位置的值 @param index @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:55
↓ 4 callers
Method
readBool
Read a {@code bool} field value from the internal buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:311
↓ 4 callers
Method
readBytes
Reads the specified number of bytes into a new byte[].
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:157
↓ 4 callers
Method
readRawLittleEndian32
Read a 32-bit little-endian integer from the internal buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:540
↓ 4 callers
Method
readRawLittleEndian64
Read a 64-bit little-endian integer from the internal byte buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:547
↓ 4 callers
Method
recycle
()
abg-cloud/src/main/java/rpc/abg/recycle/Recycleable.java:5
↓ 4 callers
Method
set
设置某位置的值 @param index @param value
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:122
↓ 4 callers
Method
setFailover
设置失败回退方法 @param clazz @param failover
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:171
↓ 4 callers
Method
setMethodParam
(MethodParam methodParam)
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:53
↓ 4 callers
Method
setResult
(List<T> result)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:44
← previous
next →
101–200 of 1,654, ranked by callers