MCPcopy Create free account

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

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

↓ 1 callersMethodgetClassRegisterList
获取已注册的RPC类,classString @return
abg-cloud/src/main/java/rpc/abg/common/TurboConnectService.java:49
↓ 1 callersMethodgetClazz
()
abg-utils/src/main/java/rpc/abg/util/SingleClassLoader.java:18
↓ 1 callersMethodgetConnectPerServer
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:74
↓ 1 callersMethodgetDirectUserAge
(long userId)
abg-jmh/src/main/java/rpc/abg/benchmark/reflect/ReflectTestBean.java:8
↓ 1 callersMethodgetEmail
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:56
↓ 1 callersMethodgetEnumIO
(String className, boolean load)
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:231
↓ 1 callersMethodgetExpireTime
()
abg-cloud/src/main/java/rpc/abg/transport/client/future/RequestWithFuture.java:35
↓ 1 callersMethodgetGlobalTimeout
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:58
↓ 1 callersMethodgetGroup
()
abg-cloud/src/main/java/rpc/abg/config/server/ServerConfig.java:37
↓ 1 callersMethodgetIcon
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:80
↓ 1 callersMethodgetInvoker
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:28
↓ 1 callersMethodgetJsonMapper
()
abg-cloud/src/main/java/rpc/abg/config/server/ServerConfig.java:77
↓ 1 callersMethodgetLoadBalanceFactory
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:98
↓ 1 callersMethodgetMethod
()
abg-cloud/src/main/java/rpc/abg/transport/client/MethodRouter.java:46
↓ 1 callersMethodgetMethodRegisterMap
获取已注册的RPC方法,key:serviceId, value:methodString @return
abg-cloud/src/main/java/rpc/abg/common/TurboConnectService.java:57
↓ 1 callersMethodgetMobile
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:64
↓ 1 callersMethodgetOrUpdate
(int index, Supplier<T> producer)
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:88
↓ 1 callersMethodgetPageNo
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:24
↓ 1 callersMethodgetPipeSchema
()
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:799
↓ 1 callersMethodgetRequest
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:36
↓ 1 callersMethodgetRestRegisterList
获取已注册的rest服务列表 @return
abg-cloud/src/main/java/rpc/abg/common/TurboConnectService.java:65
↓ 1 callersMethodgetSchema
()
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:865
↓ 1 callersMethodgetServerErrorThreshold
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:82
↓ 1 callersMethodgetServerWeight
()
abg-cloud/src/main/java/rpc/abg/config/server/RegisterConfig.java:45
↓ 1 callersMethodgetServiceId
获取远程服务id @param context @param methodId @return -1为找不到
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:649
↓ 1 callersMethodgetSex
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:40
↓ 1 callersMethodgetSleepTimeMs
(int retryCount, long elapsedTimeMs)
abg-register-zk/src/main/java/rpc/abg/zk/common/ForeverRetryPolicy.java:35
↓ 1 callersMethodgetSourceClassName
()
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:639
↓ 1 callersMethodgetSourceMethodName
()
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:653
↓ 1 callersMethodgetStatus
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:96
↓ 1 callersMethodgetTotal
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:32
↓ 1 callersMethodgetTypeByName
(final String className)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:208
↓ 1 callersMethodgetUpdateTime
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:112
↓ 1 callersMethodgetUser
(long id)
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserServiceServerImpl.java:33
↓ 1 callersMethodgetValue0
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/AllIntBean.java:38
↓ 1 callersMethodgetValue1
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/AllIntBean.java:46
↓ 1 callersMethodgetValue30
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/AllIntBean.java:278
↓ 1 callersMethodgetValue31
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/AllIntBean.java:286
↓ 1 callersMethodheartbeat
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:132
↓ 1 callersMethodheartbeat
()
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:542
↓ 1 callersMethodhello
(String msg)
abg-jmh/src/main/java/rpc/abg/benchmark/service/HelloService.java:10
↓ 1 callersMethodid
(Class<?> clazz)
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Register.java:41
↓ 1 callersMethodinit
@param hostPorts 注册中心地址
abg-cloud/src/main/java/rpc/abg/registry/Register.java:22
↓ 1 callersMethodinit
注册中心地址
abg-cloud/src/main/java/rpc/abg/discover/Discover.java:19
↓ 1 callersMethodinsertIndex
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:113
↓ 1 callersMethodipToInt
@param ip ipv4 only @return 找不到返回0,需要用户自己特殊处理0.0.0.0的情况
abg-utils/src/main/java/rpc/abg/util/IPUtils.java:68
↓ 1 callersMethodisClosed
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:563
↓ 1 callersMethodisCurrentFieldPacked
Return true if currently reading packed field
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:90
↓ 1 callersMethodisErrorEnabled
()
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:331
↓ 1 callersMethodisErrorEnabled
()
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:537
↓ 1 callersMethodisNumber
(String str)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:290
↓ 1 callersMethodkeys
Returns an iterator for the keys in the map. Remove is supported.
abg-utils/src/main/java/rpc/abg/util/FastMap.java:733
↓ 1 callersMethodkill
干掉有问题的连接 @param connectorContext
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:510
↓ 1 callersMethodlastIndexOf
(Object o)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:148
↓ 1 callersMethodlistUser
(int pageNo)
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserServiceServerImpl.java:55
↓ 1 callersMethodlz4Compress
()
abg-jmh/src/main/java/rpc/abg/benchmark/compress/CompressBenchmark.java:86
↓ 1 callersMethodmergeObjectEncodedAsGroup
(T value, final Schema<T> schema)
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:512
↓ 1 callersMethodmethodHandleInvoke
()
abg-jmh/src/main/java/rpc/abg/benchmark/invoke/InvokerBenchmark.java:82
↓ 1 callersMethodnewLoadBalance
创建一个新的LoadBalance @return
abg-cloud/src/main/java/rpc/abg/loadbalance/LoadBalanceFactory.java:17
↓ 1 callersMethodnext
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntegerSequencer.java:52
↓ 1 callersMethodnext
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentLongSequencer.java:52
↓ 1 callersMethodnextId
63年内有效 @return
abg-utils/src/main/java/rpc/abg/util/uuid/LongId.java:42
↓ 1 callersMethodnextTracer
如果有parent,会自动设置上 @return
abg-cloud/src/main/java/rpc/abg/trace/TracerContext.java:35
↓ 1 callersMethodnotifyResponse
(Response response)
abg-cloud/src/main/java/rpc/abg/transport/client/future/FutureContainer.java:51
↓ 1 callersMethodonError
发生错误时执行 @param request 可能为空 @param response 可能为空 @param throwable 不为空
abg-cloud/src/main/java/rpc/abg/filter/RestServerFilter.java:44
↓ 1 callersMethodonError
发生错误时执行 @param request 可能为空 @param response 可能为空 @param throwable 不为空
abg-cloud/src/main/java/rpc/abg/filter/RpcServerFilter.java:44
↓ 1 callersMethodonError
发生错误时执行 @param request 不为空 @param response 可能为空 @param throwable 不为空
abg-cloud/src/main/java/rpc/abg/filter/RpcClientFilter.java:43
↓ 1 callersMethodonRecive
服务端收到请求后执行 @param request 不为空 @return true表示允许发送,false表示不允许发送,<br> 不允许发送的情况将返回"rest server filter deny this request"给客户端
abg-cloud/src/main/java/rpc/abg/filter/RestServerFilter.java:19
↓ 1 callersMethodonRecive
服务端收到请求后执行 @param request 不为空,为空的情况会调用{@link #onError(Request, Response, Throwable)} @return true表示允许发送,false表示不允许发送,<br> 不允许发送的情
abg-cloud/src/main/java/rpc/abg/filter/RpcServerFilter.java:19
↓ 1 callersMethodonRecive
客户端收到后执行 @param request 不为空 @param response 不为空,为空的情况会调用{@link #onError(Request, Response, Throwable)}
abg-cloud/src/main/java/rpc/abg/filter/RpcClientFilter.java:29
↓ 1 callersMethodonSend
服务端发送请求前执行 @param request 不为空 @param response 不为空
abg-cloud/src/main/java/rpc/abg/filter/RestServerFilter.java:30
↓ 1 callersMethodonSend
服务端发送请求前执行 @param request 不为空,为空的情况会调用{@link #onError(Request, Response, Throwable)} @param response 不为空,为空的情况会调用{@link #onErr
abg-cloud/src/main/java/rpc/abg/filter/RpcServerFilter.java:30
↓ 1 callersMethodparse
从配置文件读取配置 @param appConfigList @return
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:135
↓ 1 callersMethodparse
(String resourceName)
abg-cloud/src/main/java/rpc/abg/config/server/ServerConfig.java:106
↓ 1 callersMethodparse
(Config config)
abg-cloud/src/main/java/rpc/abg/config/server/RegisterConfig.java:63
↓ 1 callersMethodputResize
Skips checks for existing keys.
abg-utils/src/main/java/rpc/abg/util/FastMap.java:218
↓ 1 callersMethodputRestInvoker
(List<JavassistInvoker<?>> invokers)
abg-cloud/src/main/java/rpc/abg/invoke/ServerInvokerFactory.java:159
↓ 1 callersMethodputServiceId
(String serviceMethodName, int methodId)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:506
↓ 1 callersMethodputStash
(K key, V value)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:364
↓ 1 callersMethodread
(ByteBuf buffer)
abg-cloud/src/main/java/rpc/abg/serialization/TracerSerializer.java:76
↓ 1 callersMethodreadByProtostuff
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/TracerSerializerBenchmark.java:92
↓ 1 callersMethodreadByTracerSerializer
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/TracerSerializerBenchmark.java:134
↓ 1 callersMethodreadClass
(Input input)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:150
↓ 1 callersMethodreadName
(Input input)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:172
↓ 1 callersMethodreadRequest
(ByteBuf byteBuf)
abg-protostuff/src/main/java/rpc/abg/serialization/protostuff/ProtostuffSerializer.java:118
↓ 1 callersMethodreadRequest
反序列化request @param byteBuf @return @throws IOException
abg-cloud/src/main/java/rpc/abg/serialization/Serializer.java:59
↓ 1 callersMethodreadResponse
(ByteBuf byteBuf)
abg-protostuff/src/main/java/rpc/abg/serialization/protostuff/ProtostuffSerializer.java:171
↓ 1 callersMethodreadResponse
反序列化response @param byteBuf @return @throws IOException
abg-cloud/src/main/java/rpc/abg/serialization/Serializer.java:77
↓ 1 callersMethodreadString
Reads the length and string of UTF8 characters, or null. This can read strings written by {@link Output#writeString(String)} , {@link Output#writeStri
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:254
↓ 1 callersMethodreadStringFast
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:395
↓ 1 callersMethodreadTag
Attempt to read a field tag, returning zero if we have reached EOF. Protocol message parsers use this to read tags, since a protocol message may legal
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:106
↓ 1 callersMethodreadVarLong
{@inheritDoc}
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:303
↓ 1 callersMethodregister
(Registration registration)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:72
↓ 1 callersMethodregisterAbgService
(Class<?> abgClass)
abg-spring-boot-starter/src/main/java/rpc/abg/boot/TurboClientStarter.java:122
↓ 1 callersMethodregisterClassId
(Method method)
abg-cloud/src/main/java/rpc/abg/invoke/ServerInvokerFactory.java:327
↓ 1 callersMethodregisterClassIds
(Map<Class<?>, Integer> classIds)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:112
↓ 1 callersMethodregisterDelegate
Registers a delegate. Returns true if registration is successful.
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:126
↓ 1 callersMethodrelease
(T t)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:85
↓ 1 callersMethodrelease
(final T t)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:78
↓ 1 callersMethodrelease
(T t)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool.java:78
← previousnext →501–600 of 1,654, ranked by callers