MCPcopy Create free account

hub / github.com/Nepxion/Coroutine / functions

Functions630 in github.com/Nepxion/Coroutine

↓ 3 callersMethodinvokeSync
(final String chainName)
coroutine-test/src/test/java/com/nepxion/coroutine/test/CoroutineTest.java:93
↓ 3 callersMethodloadDelegate
(Class<S> serviceClass)
coroutine-common/src/main/java/com/nepxion/coroutine/common/spi/SpiLoader.java:99
↓ 3 callersMethodparse
(String categoryName, String ruleName, String ruleContent)
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineManager.java:102
↓ 3 callersMethodparseRemote
(String categoryName, String ruleName)
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineManager.java:75
↓ 3 callersMethodpersistRule
(String categoryName, String ruleName, String ruleContent)
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryExecutor.java:31
↓ 3 callersMethodput
(String key, String value)
coroutine-common/src/main/java/com/nepxion/coroutine/common/property/CoroutineProperties.java:77
↓ 3 callersMethodregister
(Object object)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventController.java:15
↓ 3 callersMethodregisterRule
(String categoryName, String ruleName)
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryExecutor.java:25
↓ 3 callersMethodreject
(Exception exception)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseDeferred.java:17
↓ 3 callersMethodrun
()
coroutine-spring-boot-client-example/src/main/java/com/nepxion/coroutine/CoroutineClientApplication.java:66
↓ 3 callersMethodsetIndex
(int index)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ServiceId.java:26
↓ 3 callersMethodstart
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineManager.java:59
↓ 3 callersMethodstartSync
同步方法调用,id由系统自动生成(UUID) @param categoryName 规则的目录名,跟注册中心相对应 @param ruleName 规则名,跟注册中心相对应 @param chainName 链式调用名 @param parameters 初始传入的参数数组 @p
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineLauncher.java:81
↓ 3 callersMethodtoString
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/property/CoroutineProperties.java:349
↓ 3 callersMethodvalidateClosedStatus
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:169
↓ 2 callersMethodaddListener
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:30
↓ 2 callersMethodchain
(CoroutineResult<Object> origin, RuleEntity ruleEntity, StepEntity stepEntity, String chainName)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/AbstractPromiseExecutor.java:71
↓ 2 callersMethodcreateBlockingQueue
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/ThreadPoolFactory.java:72
↓ 2 callersMethodcreateInstance
(String className)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:109
↓ 2 callersMethodcreateRejectedPolicy
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/ThreadPoolFactory.java:91
↓ 2 callersMethodcreateResult
(MultipleResults results)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:147
↓ 2 callersMethoddoMerge
(List<Map<String, Object>> value, String service)
coroutine-spring-boot-thunder-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:42
↓ 2 callersMethoddoMerge
(List<Map<String, Object>> value, String service)
coroutine-spring-boot-dubbo-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:42
↓ 2 callersMethoddoThen
(String value, String service)
coroutine-spring-boot-thunder-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:22
↓ 2 callersMethoddoThen
(String value, String service)
coroutine-spring-boot-dubbo-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:22
↓ 2 callersMethoddoWhen
(String value, String service)
coroutine-spring-boot-thunder-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:32
↓ 2 callersMethoddoWhen
(String value, String service)
coroutine-spring-boot-dubbo-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:32
↓ 2 callersMethoddone
(Promise<T, F, P> promise)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/AbstractPromiseExecutor.java:74
↓ 2 callersMethodenabled
()
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryLauncher.java:26
↓ 2 callersMethodexecute
执行异步调用,用在某调用链中间步 当when链结束后执行then链,或者then链结束后执行when链,上个链的返回的上下文对象需要缓存,以便被下个链所引用 对于异步来说,如果上个链正常调用,则缓存对象,如果上个链调用出现异常,则直接通过callback回调异常,并终止下个链调用 @param id
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/AbstractPromiseExecutor.java:34
↓ 2 callersMethodfail
(Promise<T, F, P> promise, CoroutineCallback<CoroutineResult<Object>> callback)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/AbstractPromiseExecutor.java:80
↓ 2 callersMethodfinish
执行异步回调,用在调用链最后一步 @param id 全局唯一的ID,可以用UUID来实现,也可以外部传入唯一交易号/流水号 @param ruleEntity 规则实体 @param stepEntity 步骤实体 @param chainName 链式调用名称 @param c
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/AbstractPromiseExecutor.java:57
↓ 2 callersMethodgetApplicationContext
(String key)
coroutine-data/src/main/java/com/nepxion/coroutine/data/cache/ObjectCache.java:33
↓ 2 callersMethodgetApplicationContextPath
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ComponentEntity.java:32
↓ 2 callersMethodgetChainEntity
(String name)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/RuleEntity.java:84
↓ 2 callersMethodgetChildNameList
(String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:319
↓ 2 callersMethodgetClassEntityList
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ComponentEntity.java:56
↓ 2 callersMethodgetClazz
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ClassEntity.java:35
↓ 2 callersMethodgetClient
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:180
↓ 2 callersMethodgetController
(String identifier, boolean async)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventControllerFactory.java:47
↓ 2 callersMethodgetInputStream
(String path)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/IOUtil.java:17
↓ 2 callersMethodgetKeyName
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/MethodEntity.java:78
↓ 2 callersMethodgetMethodEntityList
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ClassEntity.java:43
↓ 2 callersMethodgetRules
(RuleKey ruleKey)
coroutine-data/src/main/java/com/nepxion/coroutine/data/cache/RuleCache.java:87
↓ 2 callersMethodgetSchema
(Class<T> clazz)
coroutine-serialization-protostuff/src/main/java/com/nepxion/coroutine/serialization/protostuff/ProtoStuffSerializer.java:57
↓ 2 callersMethodgetTimeout
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/DependencyEntity.java:50
↓ 2 callersMethodgetType
()
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryEntity.java:25
↓ 2 callersMethodinvokeAsync
()
coroutine-spring-boot-client-example/src/main/java/com/nepxion/coroutine/CoroutineClientApplication.java:63
↓ 2 callersMethodinvokeSync
()
coroutine-spring-boot-client-example/src/main/java/com/nepxion/coroutine/CoroutineClientApplication.java:86
↓ 2 callersMethodisStarted
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:153
↓ 2 callersMethodisTerminated
()
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimSerialExecutor.java:133
↓ 2 callersMethodload
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineLoader.java:18
↓ 2 callersMethodload
()
coroutine-serialization/src/main/java/com/nepxion/coroutine/serialization/SerializerLoader.java:17
↓ 2 callersMethodpathExist
(String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:185
↓ 2 callersMethodresolve
(R result)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromisePipe.java:38
↓ 2 callersMethodsend
发送邮件 @param from 发送者地址 @param to 接受者地址,可以多个,用逗号隔开 @param cc 抄送者地址,可以多个,用逗号隔开 @param bcc 暗抄送者地址,可以多个,用逗号隔开 @param subject 邮件
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpExecutor.java:89
↓ 2 callersMethodsetApplicationContext
(ApplicationContext applicationContext)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ComponentEntity.java:48
↓ 2 callersMethodsetChainName
(String chainName)
coroutine-monitor/src/main/java/com/nepxion/coroutine/monitor/MonitorEntity.java:58
↓ 2 callersMethodsetCoroutineEntryList
(List<CoroutineEntry<T>> coroutineEntryList)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineList.java:29
↓ 2 callersMethodsetId
(CoroutineId id)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineEntry.java:30
↓ 2 callersMethodsetReferenceEntity
(ReferenceEntity referenceEntity)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineEntry.java:38
↓ 2 callersMethodsetResult
(T result)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineEntry.java:46
↓ 2 callersMethodsetStepType
(StepType stepType)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/StepEntity.java:37
↓ 2 callersMethodstartAsync
异步方法调用,id由系统自动生成(UUID) @param categoryName 规则的目录名,跟注册中心相对应 @param ruleName 规则名,跟注册中心相对应 @param chainName 链式调用名 @param parameters 初始传入的参数数组 @p
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineLauncher.java:55
↓ 2 callersMethodstop
()
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryLauncher.java:23
↓ 2 callersMethodthen
(Promise<CoroutineResult<Object>, Exception, Void> promise, final ReferenceEntity referenceEntity, final Strin
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseSerialExecutor.java:97
↓ 2 callersMethodtoExceptionString
(Exception exception)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ExceptionUtil.java:16
↓ 2 callersMethoduuidRandom
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/RandomUtil.java:31
↓ 1 callersMethodaddListener
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperNodeCacheListener.java:28
↓ 1 callersMethodaddListener
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:29
↓ 1 callersMethodcalculate
(String value)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/MathsUtil.java:17
↓ 1 callersMethodchildAdded
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:71
↓ 1 callersMethodchildRemoved
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:75
↓ 1 callersMethodchildUpdated
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:73
↓ 1 callersMethodconnectionLost
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:81
↓ 1 callersMethodconnectionLost
(TreeCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:82
↓ 1 callersMethodconnectionReconnected
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:79
↓ 1 callersMethodconnectionReconnected
(TreeCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:80
↓ 1 callersMethodconnectionSuspended
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:77
↓ 1 callersMethodconnectionSuspended
(TreeCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:78
↓ 1 callersMethodcreateApplicationContextPath
(String applicationContextPath)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:156
↓ 1 callersMethodcreateAsyncController
(String identifier, Executor executor)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventControllerFactory.java:92
↓ 1 callersMethodcreateAuthenticator
()
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpExecutor.java:51
↓ 1 callersMethodcreateJarApplicationContextPath
(String className, String applicationContextPath)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:143
↓ 1 callersMethodcreateListResult
(MultipleResults results)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:157
↓ 1 callersMethodcreateListResult
(List<CoroutineEntry<Object>> value)
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimParallelExecutor.java:165
↓ 1 callersMethodcreateMapResult
(MultipleResults results)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:181
↓ 1 callersMethodcreateMapResult
(List<CoroutineEntry<Object>> entries)
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimParallelExecutor.java:185
↓ 1 callersMethodcreateNamespacePath
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRegistryExecutor.java:138
↓ 1 callersMethodcreateParameterTypes
(Class<?>[] parameterClasses)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:91
↓ 1 callersMethodcreateParameters
(Object parameter)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:21
↓ 1 callersMethodcreatePath
(String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:205
↓ 1 callersMethodcreateProperties
()
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpExecutor.java:40
↓ 1 callersMethodcreateResult
(List<CoroutineEntry<Object>> value)
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimParallelExecutor.java:155
↓ 1 callersMethodcreateRetryNTimes
(int count, int sleepMsBetweenRetries)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:56
↓ 1 callersMethodcreateSession
()
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpExecutor.java:60
↓ 1 callersMethodcreateSyncController
()
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventControllerFactory.java:80
↓ 1 callersMethodcreateThreadPoolExecutor
()
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseThreadPoolFactory.java:22
↓ 1 callersMethodcreateThreadPoolExecutor
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/thread/CoroutineThreadPoolFactory.java:22
↓ 1 callersMethodcurrentPromise
()
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseContext.java:16
← previousnext →101–200 of 630, ranked by callers