MCPcopy Create free account

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

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

⨍ Functions 1,654◇ Types & classes 287
↓ 2 callersMethodtoHexString
()
abg-utils/src/main/java/rpc/abg/util/uuid/RandomId128.java:96
↓ 2 callersMethodtoHexString
()
abg-utils/src/main/java/rpc/abg/util/uuid/RandomId.java:98
↓ 2 callersMethodunbox
(Class<?> clazz)
abg-utils/src/main/java/rpc/abg/util/SourceCodeUtils.java:123
↓ 2 callersMethodwaitUntilShutdown
()
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:189
↓ 2 callersMethodweight
()
abg-cloud/src/main/java/rpc/abg/loadbalance/Weightable.java:4
↓ 2 callersMethodwriteByteArray
(int fieldNumber, byte[] bytes, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:193
↓ 2 callersMethodwriteClass
(Output output, Class type)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:110
↓ 2 callersMethodwriteIntS
(int value, boolean optimizePositive)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:409
↓ 2 callersMethodwriteLongS
Writes a 1-9 byte long. @param optimizePositive If true, small positive numbers will be more efficient (1 byte) and small negat
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:299
↓ 2 callersMethodwriteName
(Output output, Class type, Registration registration)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:128
↓ 2 callersMethodwriteRequest
序列化request @param byteBuf @param request @throws IOException
abg-cloud/src/main/java/rpc/abg/serialization/Serializer.java:50
↓ 1 callersMethodaddConnect
(AppConfig appConfig)
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:56
↓ 1 callersMethodaddConnect
(ConnectorContext context)
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:288
↓ 1 callersMethodaddRegisterWatcher
当断掉连接又重新连接上时起作用 @param group @param app @param protocol @param serverAddress @param serverWeight
abg-register-zk/src/main/java/rpc/abg/zk/registry/ZooKeeperRegister.java:98
↓ 1 callersMethodalignSize
(int cap)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:75
↓ 1 callersMethodallocateByteBuffer
()
abg-jmh/src/main/java/rpc/abg/benchmark/array/ArrayBenchmark.java:52
↓ 1 callersMethodallocateDirectByteBuffer
()
abg-jmh/src/main/java/rpc/abg/benchmark/array/ArrayBenchmark.java:59
↓ 1 callersMethodappendSetFieldValue
(StringBuilder builder, Field field)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:395
↓ 1 callersMethodappendWriteField
(StringBuilder builder, Field field)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:223
↓ 1 callersMethodborrow
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:51
↓ 1 callersMethodborrow
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:50
↓ 1 callersMethodborrow
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool.java:50
↓ 1 callersMethodbyteToHex
(byte b)
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:65
↓ 1 callersMethodcancelExchange
(final Object value)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:118
↓ 1 callersMethodcastToBigDecimal
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:286
↓ 1 callersMethodcastToBigInteger
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:282
↓ 1 callersMethodcastToCharSequence
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:278
↓ 1 callersMethodcastToLocalDate
(String str)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:213
↓ 1 callersMethodcastToLocalDateTime
(String str)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:223
↓ 1 callersMethodcastToString
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:274
↓ 1 callersMethodcheckExchange
(final Object value)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:122
↓ 1 callersMethodclear
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:98
↓ 1 callersMethodclear
Sets the position and total to zero.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:105
↓ 1 callersMethodclose
Closes the underlying InputStream, if any.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:136
↓ 1 callersMethodclose
()
abg-register-zk/src/main/java/rpc/abg/zk/registry/ZooKeeperRegister.java:182
↓ 1 callersMethodclose
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:118
↓ 1 callersMethodclose
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:138
↓ 1 callersMethodclose
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ViberObjectPool.java:63
↓ 1 callersMethodclose
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool.java:104
↓ 1 callersMethodclose
()
abg-cloud/src/main/java/rpc/abg/transport/client/NettyClientConnector.java:127
↓ 1 callersMethodclose
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/NettyRestServer.java:72
↓ 1 callersMethodconnectCount
()
abg-cloud/src/main/java/rpc/abg/transport/client/NettyClientConnector.java:59
↓ 1 callersMethodconvertToInvokerStream
(Class<?> clazz, Object service, AtomicInteger serviceIdCounter)
abg-cloud/src/main/java/rpc/abg/invoke/ServerInvokerFactory.java:178
↓ 1 callersMethodconvertToInvokerStream
(Class<?> clazz, Object failover)
abg-cloud/src/main/java/rpc/abg/invoke/FailoverInvokerFactory.java:55
↓ 1 callersMethodcreateHttpClient
(int concurrency)
abg-jmh/src/main/java/rpc/abg/benchmark/service/HttpClientUtils.java:22
↓ 1 callersMethodcreateLog
(String name)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:165
↓ 1 callersMethodcreateLog
(String name)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:187
↓ 1 callersMethodcreateMachineIdentifier
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:192
↓ 1 callersMethodcreateMachineIdentifier
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:216
↓ 1 callersMethodcreateProcessIdentifier
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:227
↓ 1 callersMethodcreateProcessIdentifier
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:251
↓ 1 callersMethodcreateUser
()
abg-jmh/src/main/java/rpc/abg/benchmark/client/RpcClientBenchmark.java:88
↓ 1 callersMethodcurrent
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ThreadLocalStringBuilder.java:15
↓ 1 callersMethodcurrentSeconds
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:271
↓ 1 callersMethodcurrentSeconds
()
abg-utils/src/main/java/rpc/abg/util/uuid/RandomId.java:182
↓ 1 callersMethoddeserializeUser
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/ProtostuffBenchmark.java:107
↓ 1 callersMethoddeserializeUser
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/JacksonBenchmark.java:102
↓ 1 callersMethoddeserializeUser
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/ManualBenchmark.java:73
↓ 1 callersMethoddeserializeUser
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/KryoBenchmark.java:93
↓ 1 callersMethoddeserializeUserPage
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/ProtostuffBenchmark.java:129
↓ 1 callersMethoddeserializeUserPage
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/ManualBenchmark.java:89
↓ 1 callersMethoddeserializeUserPage
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/KryoBenchmark.java:112
↓ 1 callersMethoddirectByteBufferPage
()
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/FastSerializerBenchmark.java:157
↓ 1 callersMethoddirectByteBufferPage
()
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/DefaultBenchmark.java:152
↓ 1 callersMethoddoBatchSend
()
abg-cloud/src/main/java/rpc/abg/transport/client/sender/BatchSender.java:46
↓ 1 callersMethoddoCreateClass
(Method method)
abg-cloud/src/main/java/rpc/abg/param/MethodParamClassFactory.java:98
↓ 1 callersMethoddoExpire
(long requestId, FutureWithExpire<Response> futureWithExpire)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer1.java:75
↓ 1 callersMethoddoExpire
(int requestId, FutureWithExpire<Response> futureWithExpire)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer2.java:74
↓ 1 callersMethoddoExpireJob
外部线程周期性调用
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer1.java:65
↓ 1 callersMethoddoExpireJob
外部线程周期性调用
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer2.java:64
↓ 1 callersMethoddoExpireJob
外部线程周期性调用
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer3.java:79
↓ 1 callersMethoddoRequestFilter
(Request request, Invoker<CompletableFuture<?>> invoker)
abg-cloud/src/main/java/rpc/abg/transport/server/rpc/handler/NettyRpcServerHandler.java:110
↓ 1 callersMethoddoResponse
(ChannelHandlerContext ctx, ChannelPromise promise, RestHttpResponse restHttpResponse)
abg-cloud/src/main/java/rpc/abg/transport/server/rest/codec/RestHttResponseEncoder.java:73
↓ 1 callersMethoddoResponseFilter
(ChannelHandlerContext ctx, FullHttpRequest request, FullHttpResponse response, Invoker<CompletableFuture<?
abg-cloud/src/main/java/rpc/abg/transport/server/rest/codec/RestHttResponseEncoder.java:117
↓ 1 callersMethodensureCapacity
(int minCapacity)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:35
↓ 1 callersMethodensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:111
↓ 1 callersMethodequals
(Object obj)
abg-cloud/src/main/java/rpc/abg/invoke/JavassistInvoker.java:377
↓ 1 callersMethodequals
(Object obj)
abg-cloud/src/main/java/rpc/abg/invoke/MethodHandleInvoker.java:170
↓ 1 callersMethodextractAbgServiceClass
(Set<Class<?>> AbgServiceSet, String beanClassName)
abg-spring-boot-starter/src/main/java/rpc/abg/boot/TurboClientStarter.java:206
↓ 1 callersMethodextractAbgServiceClassList
(ConfigurableListableBeanFactory beanFactory)
abg-spring-boot-starter/src/main/java/rpc/abg/boot/TurboClientStarter.java:177
↓ 1 callersMethodextractFromBody
(Invoker<?> invoker, JsonMapper jsonMapper, ByteBuf byteBuf)
abg-cloud/src/main/java/rpc/abg/param/HttpParamExtractor.java:19
↓ 1 callersMethodextractFromBodyByForm
(Invoker<?> invoker, ByteBuf byteBuf)
abg-cloud/src/main/java/rpc/abg/param/HttpParamExtractor.java:108
↓ 1 callersMethodextractFromBodyByJson
(Invoker<?> invoker, JsonMapper jsonMapper, ByteBuf byteBuf)
abg-cloud/src/main/java/rpc/abg/param/HttpParamExtractor.java:35
↓ 1 callersMethodextractFromQueryPath
(Invoker<?> invoker, String uri, int offset)
abg-cloud/src/main/java/rpc/abg/param/HttpParamExtractor.java:186
↓ 1 callersMethodgcdMerge
两两合并 @param numbers @param length @return 新的长度
abg-utils/src/main/java/rpc/abg/util/MathUtils.java:60
↓ 1 callersMethodgenerateDefaultImplObject
(Class<?> clazz)
abg-cloud/src/main/java/rpc/abg/invoke/FailoverInvokerFactory.java:136
↓ 1 callersMethodgenerateReadMethod
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:374
↓ 1 callersMethodgenerateRealInvoker
()
abg-cloud/src/main/java/rpc/abg/invoke/JavassistInvoker.java:215
↓ 1 callersMethodgenerateRealSerializer
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:120
↓ 1 callersMethodgenerateRemoteObject
(App app, Class<?> clazz, Collection<MethodConfig> configs)
abg-cloud/src/main/java/rpc/abg/remote/RemoteServiceFactory.java:232
↓ 1 callersMethodgenerateWriteMethod
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:202
↓ 1 callersMethodget
(Method method)
abg-cloud/src/main/java/rpc/abg/invoke/FailoverInvokerFactory.java:34
↓ 1 callersMethodgetAbgService
(Object bean)
abg-spring-boot-starter/src/main/java/rpc/abg/boot/TurboServerStarter.java:154
↓ 1 callersMethodgetAbgServiceList
()
abg-spring-boot-starter/src/main/java/rpc/abg/boot/TurboServerStarter.java:106
↓ 1 callersMethodgetAllDependClass
获取所有依赖的类，包括字段、方法返回值 @param target @param filter 过滤器 @return
abg-utils/src/main/java/rpc/abg/util/ReflectUtils.java:115
↓ 1 callersMethodgetAllFields
(Class<T> type)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:75
↓ 1 callersMethodgetAndAddCounte
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:194
↓ 1 callersMethodgetApp
()
abg-cloud/src/main/java/rpc/abg/config/server/ServerConfig.java:45
↓ 1 callersMethodgetBirthday
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:48
↓ 1 callersMethodgetChildMethods
(Class<?> clazz)
abg-cloud/src/main/java/rpc/abg/invoke/ServerInvokerFactory.java:408
← previousnext →401–500 of 1,654, ranked by callers