MCPcopy Create free account

hub / github.com/Meituan-Dianping/octo-rpc / functions

Functions9,023 in github.com/Meituan-Dianping/octo-rpc

⨍ Functions 9,023◇ Types & classes 1,822
↓ 1 callersMethodaddRefCount
(ZookeeperClient zkClient)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/ZookeeperManager.java:65
↓ 1 callersMethodaddShutDownHook
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/http/AbstractHttpServer.java:99
↓ 1 callersMethodaddShutDownHook
()
dorado/dorado-core/src/main/java/com/meituan/dorado/config/service/ProviderConfig.java:106
↓ 1 callersMethodaddShutDownHook
()
dorado/dorado-core/src/main/java/com/meituan/dorado/config/service/ReferenceConfig.java:145
↓ 1 callersMethodadded
(List<Provider> providers)
dorado/dorado-core/src/main/java/com/meituan/dorado/registry/ProviderListener.java:26
↓ 1 callersMethodafterPropertiesSet
()
dorado/dorado-core/src/main/java/com/meituan/dorado/config/service/spring/ServiceBean.java:24
↓ 1 callersMethodafterPropertiesSet
()
dorado/dorado-core/src/main/java/com/meituan/dorado/config/service/spring/ReferenceBean.java:25
↓ 1 callersMethodalive
()
dorado/dorado-core/src/main/java/com/meituan/dorado/bootstrap/provider/meta/ServerInfo.java:47
↓ 1 callersMethodasyncClientRecv
(TraceParam traceParam, RpcInvocation invocation)
dorado/dorado-core/src/main/java/com/meituan/dorado/trace/AbstractInvokeTrace.java:55
↓ 1 callersMethodbuildActualInvokeHandler
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/support/ProviderChannelHandler.java:182
↓ 1 callersMethodbuildActualInvokeHandler
()
dorado/dorado-core/src/main/java/com/meituan/dorado/rpc/handler/invoker/AbstractInvoker.java:105
↓ 1 callersMethodbuildClientMethodCodec
(ThriftMethodMetadata methodMetadata, ThriftCodecManager codecManager)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/annotation/codec/ThriftMethodCodec.java:108
↓ 1 callersMethodbuildClusterHandler
(InvokerRepository<T> repository)
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/Cluster.java:23
↓ 1 callersMethodbuildClusterHandler
(InvokerRepository<T> repository)
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/tolerance/FailfastCluster.java:24
↓ 1 callersMethodbuildClusterHandler
(InvokerRepository<T> repository)
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/tolerance/FailoverCluster.java:24
↓ 1 callersMethodbuildClusterHandler
(InvokerRepository<T> repository)
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/tolerance/FailbackCluster.java:24
↓ 1 callersMethodbuildDirectConnInvokers
()
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/InvokerRepository.java:166
↓ 1 callersMethodbuildExceptionMap
(ThriftCatalog catalog, ThriftMethod thriftMethod)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/annotation/metadata/ThriftMethodMetadata.java:138
↓ 1 callersMethodbuildExpectInvokeChainStr
()
dorado/dorado-test/dorado-test-integration/src/test/java/com/meituan/dorado/test/thrift/filter/MultiClientTest.java:87
↓ 1 callersMethodbuildExpectInvokeChainStr
()
dorado/dorado-test/dorado-test-integration/src/test/java/com/meituan/dorado/test/thrift/filter/FilterTest.java:134
↓ 1 callersMethodbuildExpectInvokeChainStr
()
dorado/dorado-core/src/test/java/com/meituan/dorado/rpc/handler/filter/FilterTest.java:125
↓ 1 callersMethodbuildHttpServer
(RpcRole rpcRole)
dorado/dorado-transport/dorado-transport-httpnetty/src/main/java/com/meituan/dorado/transport/http/netty/NettyHttpServer.java:56
↓ 1 callersMethodbuildInvokeChain
(RpcRole role, FilterHandler actualHandler, List<Filter> cfgFilters)
dorado/dorado-core/src/main/java/com/meituan/dorado/rpc/handler/filter/InvokeChainBuilder.java:53
↓ 1 callersMethodbuildInvoker
(ClientConfig cfg, Provider provider)
dorado/dorado-core/src/main/java/com/meituan/dorado/rpc/handler/invoker/InvokerFactory.java:25
↓ 1 callersMethodbuildInvoker
(ClientConfig cfg, Provider provider)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/rpc/handler/invoker/DoradoInvokerFactory.java:23
↓ 1 callersMethodbuildResponse
(Request request)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/rpc/handler/provider/ScannerHeartBeatInvokeHandler.java:45
↓ 1 callersMethodbuildServer
(RpcRole rpcRole)
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/http/HttpServerFactory.java:24
↓ 1 callersMethodbuildServerMethodCodec
(ThriftMethodMetadata methodMetadata, ThriftCodecManager codecManager)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/annotation/codec/ThriftMethodCodec.java:81
↓ 1 callersMethodbytes2long
把byte数组中off开始的8个字节，转为long类型，高位在前 @param bytes @param off
dorado/dorado-core/src/main/java/com/meituan/dorado/util/BytesUtil.java:47
↓ 1 callersMethodcalculateWarmUpWeight
如果服务提供者启动时长小于预热时间，则需要降权 @param duration 秒 @param warmUpTime 秒 @param weight @return
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/loadbalance/AbstractLoadBalance.java:67
↓ 1 callersMethodcall
()
dorado/dorado-core/src/test/java/com/meituan/dorado/rpc/AsyncContextTest.java:33
↓ 1 callersMethodcancel
()
dorado/dorado-core/src/main/java/com/meituan/dorado/rpc/DefaultFuture.java:150
↓ 1 callersMethodchanged
(ProtocolRequest req, List<SGService> oldList, List<SGService>
dorado/dorado-registry/dorado-registry-mns/src/main/java/com/meituan/dorado/registry/mns/MnsChangeListener.java:41
↓ 1 callersMethodcheck
调用端相关参数检查
dorado/dorado-core/src/main/java/com/meituan/dorado/config/service/ReferenceConfig.java:155
↓ 1 callersMethodcheckData
(SGService sgService, String clientProtocol)
dorado/dorado-registry/dorado-registry-mns/src/main/java/com/meituan/dorado/registry/mns/MnsDiscoveryService.java:152
↓ 1 callersMethodcheckNodeData
(ChildNodeData nodeData, String clientProtocol)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/util/ZooKeeperNodeInfo.java:108
↓ 1 callersMethodchildNodeAdded
(String childPath, String childNodePath)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/NodeChangeListener.java:20
↓ 1 callersMethodchildNodeRemoved
(String childPath, String childNodePath)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/NodeChangeListener.java:24
↓ 1 callersMethodchildNodeUpdated
(String childPath, String childNodePath)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/NodeChangeListener.java:22
↓ 1 callersMethodclientAsyncRecv
(Throwable throwable, RpcInvocation invocation)
dorado/dorado-core/src/main/java/com/meituan/dorado/trace/InvokerAsyncTrace.java:30
↓ 1 callersMethodclientSend
(TraceParam traceParam, RpcInvocation invocation)
dorado/dorado-core/src/main/java/com/meituan/dorado/trace/InvokeTrace.java:29
↓ 1 callersMethodclose
()
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/ZookeeperClient.java:208
↓ 1 callersMethodclose
()
dorado/dorado-core/src/test/java/com/meituan/dorado/mock/MockHttpServerFactory.java:45
↓ 1 callersMethodclose
()
dorado/dorado-core/src/test/java/com/meituan/dorado/mock/MockServerFactory.java:54
↓ 1 callersMethodclose
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/Client.java:63
↓ 1 callersMethodclose
关闭连接
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/Channel.java:48
↓ 1 callersMethodclose
关闭server
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/http/HttpServer.java:38
↓ 1 callersMethodcloseZkServer
()
dorado/dorado-demo/src/test/java/com/meituan/dorado/demo/thrift/zkmock/ThriftProvider.java:49
↓ 1 callersMethodcompareCheckSum
(byte[] buffer, int readerIndex, int headerBodyLength)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/codec/octo/OctoCodec.java:371
↓ 1 callersMethodconfigLoadBalance
()
dorado/dorado-core/src/main/java/com/meituan/dorado/config/service/ReferenceConfig.java:129
↓ 1 callersMethodconfigRouter
()
dorado/dorado-core/src/main/java/com/meituan/dorado/config/service/ReferenceConfig.java:141
↓ 1 callersMethodcontainsAttachment
(String key)
dorado/dorado-core/src/main/java/com/meituan/dorado/rpc/meta/RpcInvocation.java:85
↓ 1 callersMethodconvertHeaderToRequest
(Header header)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/codec/octo/MetaUtil.java:71
↓ 1 callersMethodconvertReferenceCfg2SubscribeInfo
(ReferenceConfig cfg, Map<String, String> a
dorado/dorado-core/src/main/java/com/meituan/dorado/bootstrap/invoker/ServiceSubscriber.java:104
↓ 1 callersMethodconvertRequestToHeader
(DefaultRequest request)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/codec/octo/MetaUtil.java:36
↓ 1 callersMethodconvertRequestToOldProtocolHeader
(DefaultRequest request)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/codec/octo/MetaUtil.java:170
↓ 1 callersMethodcreateEphemeral
(String path, String nodeData)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/ZookeeperClient.java:113
↓ 1 callersMethodcreateHeartBeatInvocationHandler
()
dorado/dorado-core/src/main/java/com/meituan/dorado/rpc/handler/AbstractHandlerFactory.java:56
↓ 1 callersMethodcreateNode
(String path, String nodeData)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/ZookeeperClient.java:91
↓ 1 callersMethodcreatePersistent
(String path)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/ZookeeperClient.java:134
↓ 1 callersMethodcreateScannerHeartBeatInvocationHandler
()
dorado/dorado-core-default/src/main/java/com/meituan/dorado/rpc/handler/DoradoHandlerFactory.java:37
↓ 1 callersMethodcreateServiceInvocationHandler
(RpcRole role)
dorado/dorado-core/src/main/java/com/meituan/dorado/rpc/handler/AbstractHandlerFactory.java:63
↓ 1 callersMethoddecodeLength
从数据源中解析本次会话所需的数据size @param in 数据源 @return 所需数据长度，负值表示不合法的情况
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/LengthDecoder.java:31
↓ 1 callersMethoddecodeOctoHeader
(byte[] headerBytes)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/codec/octo/OctoCodec.java:247
↓ 1 callersMethoddecodeParams
(String str, Map<String, String> kvParams)
dorado/dorado-common/src/main/java/com/meituan/dorado/common/util/URLUtil.java:49
↓ 1 callersMethoddecodeReqBody
(byte serialize, byte[] buff, DefaultRequest request)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/codec/octo/OctoCodec.java:201
↓ 1 callersMethoddecodeReqBody
(byte[] buff, DefaultRequest request)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftCodecSerializer.java:45
↓ 1 callersMethoddecodeRspBody
(byte serialize, byte[] buff, DefaultResponse response)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/codec/octo/OctoCodec.java:212
↓ 1 callersMethoddecodeRspBody
(byte[] buff, DefaultResponse response)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftCodecSerializer.java:55
↓ 1 callersMethoddecodeThrift
(byte[] buffer, Map<String, Object> attachments)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/codec/octo/OctoCodec.java:381
↓ 1 callersMethoddecodeThrift
(byte[] buff, Map<String, Object> attachments)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftCodecSerializer.java:91
↓ 1 callersMethoddegrade
(double degradeWeight)
dorado/dorado-core/src/main/java/com/meituan/dorado/registry/meta/Provider.java:168
↓ 1 callersMethoddegradeRecover
()
dorado/dorado-core/src/main/java/com/meituan/dorado/registry/meta/Provider.java:173
↓ 1 callersMethoddelete
(String path)
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/curator/ZookeeperClient.java:148
↓ 1 callersMethoddeserialize
(byte[] bytes, Class<?> clz)
dorado/dorado-core/src/main/java/com/meituan/dorado/serialize/Serializer.java:24
↓ 1 callersMethoddeserialize4Thrift
(byte[] buff, Class<?> iface, Map<String, Object> attachments)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftMessageSerializer.java:41
↓ 1 callersMethoddeserializeArguments
(String ifaceName, String methodName, TProtocol protocol, List<Object> arguments, List<Class<?>> parameterType
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftIDLSerializer.java:266
↓ 1 callersMethoddeserializeResult
(TProtocol protocol, String ifaceName, String methodName)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftIDLSerializer.java:338
↓ 1 callersMethoddestroy
()
dorado/dorado-registry/dorado-registry-zookeeper/src/main/java/com/meituan/dorado/registry/zookeeper/ZookeeperDiscoveryService.java:103
↓ 1 callersMethoddestroy
()
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/InvokerRepository.java:121
↓ 1 callersMethoddestroyInvokers
()
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/InvokerRepository.java:206
↓ 1 callersMethoddisable
()
dorado/dorado-core/src/test/java/com/meituan/dorado/rpc/handler/filter/ServerQpsLimitFilter.java:60
↓ 1 callersMethoddoBind
(InetSocketAddress localAddress)
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/http/AbstractHttpServer.java:140
↓ 1 callersMethoddoClose
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/AbstractChannel.java:57
↓ 1 callersMethoddoClose
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/AbstractServer.java:76
↓ 1 callersMethoddoClose
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/AbstractClient.java:264
↓ 1 callersMethoddoClose
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/http/AbstractHttpServer.java:142
↓ 1 callersMethoddoGet
(String url, Map<String, String> params)
dorado/dorado-test/dorado-test-integration/src/test/java/com/meituan/dorado/check/http/HttpClientUtil.java:59
↓ 1 callersMethoddoInvoke
(final RpcInvocation invocation, List<Invoker<T>> invokers)
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/ClusterHandler.java:62
↓ 1 callersMethoddoReceived
(Channel channel, Response response)
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/support/InvokerChannelHandler.java:35
↓ 1 callersMethoddoRegister
(RegistryInfo info)
dorado/dorado-core/src/main/java/com/meituan/dorado/registry/support/FailbackRegistry.java:64
↓ 1 callersMethoddoSelect
(List<Invoker<T>> invokers)
dorado/dorado-core/src/main/java/com/meituan/dorado/cluster/loadbalance/AbstractLoadBalance.java:37
↓ 1 callersMethoddoSend
(Object message)
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/AbstractChannel.java:44
↓ 1 callersMethoddoSerializeRequest
(DefaultRequest request)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftIDLSerializer.java:127
↓ 1 callersMethoddoSerializeRequest
(DefaultRequest request, TBinaryProtocol protocol, TMemoryBuffer memoryBuffer)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftAnnotationSerializer.java:183
↓ 1 callersMethoddoSerializeResponse
(DefaultResponse response)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftIDLSerializer.java:174
↓ 1 callersMethoddoSerializeResponse
(DefaultResponse response, TBinaryProtocol protocol, TMemoryBuffer memoryBuffer)
dorado/dorado-core-default/src/main/java/com/meituan/dorado/serialize/thrift/ThriftAnnotationSerializer.java:214
↓ 1 callersMethoddoStart
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/AbstractServer.java:93
↓ 1 callersMethoddoStart
()
dorado/dorado-core/src/main/java/com/meituan/dorado/transport/http/AbstractHttpServer.java:138
↓ 1 callersMethoddoSubcribe
(SubscribeInfo info, ProviderListener listener)
dorado/dorado-core/src/main/java/com/meituan/dorado/registry/support/FailbackRegistry.java:98
← previousnext →1,401–1,500 of 9,023, ranked by callers