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
↓ 4 callers
Method
setServiceId
(int serviceId)
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:37
↓ 4 callers
Method
setSpanId
(long spanId)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:66
↓ 4 callers
Method
tableSizeFor
(int cap)
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:132
↓ 4 callers
Method
toString
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:172
↓ 4 callers
Method
toString
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:196
↓ 4 callers
Method
writeByteRange
(boolean utf8String, int fieldNumber, byte[] value, int offset, int length, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:198
↓ 4 callers
Method
writeBytes
Writes the bytes. Note the byte[] length is not written.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:163
↓ 3 callers
Method
addFuture
(int requestId, CompletableFuture<Response> future)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer1.java:26
↓ 3 callers
Method
box
(Class<?> clazz, String value)
abg-utils/src/main/java/rpc/abg/util/SourceCodeUtils.java:87
↓ 3 callers
Method
castToInteger
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:238
↓ 3 callers
Method
checkLastTagWas
Verifies that the last call to readTag() returned the given tag value. This is used to verify that a nested group ended with the correct end tag. @th
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:128
↓ 3 callers
Method
createClass
方法参数封装,用于序列化传输参数数据,其实现类会自动根据方法名称生成get/set方法,<br> 必须开启"Store information about method parameters (usable via reflection)"<br> 参考:https://www.concretepa
abg-cloud/src/main/java/rpc/abg/param/MethodParamClassFactory.java:72
↓ 3 callers
Method
doExpireJob
删除过期任务 @param maxTime 毫秒,超时则跳出
abg-cloud/src/main/java/rpc/abg/transport/client/future/FutureContainer.java:75
↓ 3 callers
Method
doRequestFilter
(FullHttpRequest request, Invoker<CompletableFuture<?>> invoker)
abg-cloud/src/main/java/rpc/abg/transport/server/rest/handler/NettyRestHandler.java:188
↓ 3 callers
Method
encode
(final byte[] bytes)
abg-utils/src/main/java/rpc/abg/util/URLEncodeUtils.java:102
↓ 3 callers
Method
encode
(ChannelHandlerContext ctx, RequestWithFuture requestWithFuture, ByteBuf buffer)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/RequestEncoder.java:30
↓ 3 callers
Method
ensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:120
↓ 3 callers
Method
entries
Returns an iterator for the entries in the map. Remove is supported.
abg-utils/src/main/java/rpc/abg/util/FastMap.java:723
↓ 3 callers
Method
flush
Writes the buffered bytes to the underlying OutputStream, if any.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:114
↓ 3 callers
Method
futureMap
(int requestId)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer3.java:38
↓ 3 callers
Method
get
(final int key)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:71
↓ 3 callers
Method
get
(int index)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:73
↓ 3 callers
Method
get
某个位置的值 @param index @return
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:76
↓ 3 callers
Method
getCreateTime
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:104
↓ 3 callers
Method
getRequest
()
abg-cloud/src/main/java/rpc/abg/transport/client/future/RequestWithFuture.java:19
↓ 3 callers
Method
getSpanId
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:62
↓ 3 callers
Method
getTraceId
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:46
↓ 3 callers
Method
handleResult
处理返回值,无失败回退 @param request @param future @return
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:280
↓ 3 callers
Method
loadClass
添加时调用一次就行了 @throws Exception
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:688
↓ 3 callers
Method
newInstance
()
abg-cloud/src/main/java/rpc/abg/protocol/recycle/RecycleResponse.java:20
↓ 3 callers
Method
next
Gets a new object id. @return the new id
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:84
↓ 3 callers
Method
next
Gets a new object id. @return the new id
abg-utils/src/main/java/rpc/abg/util/uuid/RandomId128.java:67
↓ 3 callers
Method
next
Gets a new object id. @return the new id
abg-utils/src/main/java/rpc/abg/util/uuid/RandomId.java:69
↓ 3 callers
Method
nextPowerOfTwo
(int value)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:887
↓ 3 callers
Method
notifyResponse
(Response response)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer1.java:48
↓ 3 callers
Method
offset
(int key)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:155
↓ 3 callers
Method
offset
(int key)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool.java:141
↓ 3 callers
Method
put
@param key 大于零,小于256k @param value
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:117
↓ 3 callers
Method
put
@param key 大于零,小于512k @param value 大于零
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:114
↓ 3 callers
Method
put
@param key 大于零,小于512k @param value
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToObjectArrayMap.java:133
↓ 3 callers
Method
readClassAndObject
(ByteBuf buf)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:154
↓ 3 callers
Method
readRawVarint64
Reads a var int 64 from the internal byte buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:533
↓ 3 callers
Method
readVarInt
(ByteBuf byteBuf)
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:48
↓ 3 callers
Method
reset
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:757
↓ 3 callers
Method
selectConnector
()
abg-cloud/src/main/java/rpc/abg/transport/client/MethodRouter.java:42
↓ 3 callers
Method
send
(RequestWithFuture request)
abg-cloud/src/main/java/rpc/abg/transport/client/sender/Sender.java:9
↓ 3 callers
Method
set
设置某位置的值 @param index @param value
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:119
↓ 3 callers
Method
setAddress
(String address)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:76
↓ 3 callers
Method
setBirthday
(LocalDate birthday)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:52
↓ 3 callers
Method
setConnectors
(Collection<ConnectorContext> connectors)
abg-cloud/src/main/java/rpc/abg/transport/client/MethodRouter.java:29
↓ 3 callers
Method
setCreateTime
(LocalDateTime createTime)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:108
↓ 3 callers
Method
setEmail
(String email)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:60
↓ 3 callers
Method
setIcon
(String icon)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:84
↓ 3 callers
Method
setId
(long id)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:28
↓ 3 callers
Method
setMobile
(String mobile)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:68
↓ 3 callers
Method
setName
(String name)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:36
↓ 3 callers
Method
setPermissions
(List<Integer> permissions)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:92
↓ 3 callers
Method
setResult
(Object result)
abg-cloud/src/main/java/rpc/abg/protocol/Response.java:52
↓ 3 callers
Method
setSex
(int sex)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:44
↓ 3 callers
Method
setStatus
(int status)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:100
↓ 3 callers
Method
setTracer
设置tracer上下文,后续请求将会作为parent使用 @param tracer
abg-cloud/src/main/java/rpc/abg/trace/TracerContext.java:26
↓ 3 callers
Method
setUpdateTime
(LocalDateTime updateTime)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:116
↓ 3 callers
Method
sum
所有位置的和 @return
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:94
↓ 3 callers
Method
tableSizeFor
成倍扩容 @param cap @return
abg-utils/src/main/java/rpc/abg/util/TableUtils.java:12
↓ 3 callers
Method
toString
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:692
↓ 3 callers
Method
tuple
(T1 _1)
abg-utils/src/main/java/rpc/abg/util/tuple/Tuple.java:6
↓ 3 callers
Method
writeBoolean
Writes a 1 byte boolean.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:458
↓ 3 callers
Method
writeObject
(ByteBuf buf, Object obj)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:124
↓ 3 callers
Method
writeStringFast
(String value)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:191
↓ 2 callers
Method
_newBytes
()
abg-jmh/src/main/java/rpc/abg/benchmark/array/ArrayBenchmark.java:45
↓ 2 callers
Method
addAll
(Collection<? extends E> c)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:113
↓ 2 callers
Method
addFirst
添加过滤器到最前面,最前面的会被最先执行 @param filter
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:204
↓ 2 callers
Method
appendReadFieldCode
(StringBuilder builder, Field field)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:416
↓ 2 callers
Method
binarySearch
(int[] values, int key)
abg-cloud/src/main/java/rpc/abg/loadbalance/WeightableGroup.java:145
↓ 2 callers
Method
castTo
(String str, Class<?> clazz)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:115
↓ 2 callers
Method
castToBoolean
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:246
↓ 2 callers
Method
castToByte
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:266
↓ 2 callers
Method
castToCharacter
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:270
↓ 2 callers
Method
castToDouble
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:254
↓ 2 callers
Method
castToFloat
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:258
↓ 2 callers
Method
castToLong
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:242
↓ 2 callers
Method
castToShort
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:262
↓ 2 callers
Method
close
()
abg-jmh/src/main/java/rpc/abg/benchmark/client/RpcClientBenchmark.java:75
↓ 2 callers
Method
close
(ChannelHandlerContext ctx, ChannelPromise promise)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/RequestListEncoder.java:82
↓ 2 callers
Method
close
()
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:251
↓ 2 callers
Method
close
()
abg-cloud/src/main/java/rpc/abg/common/EventLoopGroupHolder.java:63
↓ 2 callers
Method
connect
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:553
↓ 2 callers
Method
contains
@param key @return
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:52
↓ 2 callers
Method
containsKeyStash
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:599
↓ 2 callers
Method
createLocationAwareLog
(String name)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:173
↓ 2 callers
Method
createLog
(String name)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:179
↓ 2 callers
Method
createSerializer
创建一个 Serializer @param className @return
abg-cloud/src/main/java/rpc/abg/serialization/SerializerFactory.java:17
↓ 2 callers
Method
current
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ThreadLocalHeapByteBuffer.java:16
↓ 2 callers
Method
doEncode
(ByteBuf buffer, RequestWithFuture request)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/RequestListEncoder.java:46
↓ 2 callers
Method
doRequestFilter
(Request request)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:435
↓ 2 callers
Method
doResponseFilter
(Request request, Response response, Method method, String serviceMethodName, Throwable throwable)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:477
↓ 2 callers
Method
ensureCapacity
Increases the size of the backing array to acommodate the specified number of additional items. Useful before adding many items to avoid multiple back
abg-utils/src/main/java/rpc/abg/util/FastMap.java:640
↓ 2 callers
Method
ensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:139
↓ 2 callers
Method
ensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:182
↓ 2 callers
Method
ensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToObjectArrayMap.java:196
← previous
next →
201–300 of 1,654, ranked by callers