Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Nepxion/Coroutine
/ functions
Functions
630 in github.com/Nepxion/Coroutine
⨍
Functions
630
◇
Types & classes
143
↓ 3 callers
Method
invokeSync
(final String chainName)
coroutine-test/src/test/java/com/nepxion/coroutine/test/CoroutineTest.java:93
↓ 3 callers
Method
loadDelegate
(Class<S> serviceClass)
coroutine-common/src/main/java/com/nepxion/coroutine/common/spi/SpiLoader.java:99
↓ 3 callers
Method
parse
(String categoryName, String ruleName, String ruleContent)
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineManager.java:102
↓ 3 callers
Method
parseRemote
(String categoryName, String ruleName)
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineManager.java:75
↓ 3 callers
Method
persistRule
(String categoryName, String ruleName, String ruleContent)
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryExecutor.java:31
↓ 3 callers
Method
put
(String key, String value)
coroutine-common/src/main/java/com/nepxion/coroutine/common/property/CoroutineProperties.java:77
↓ 3 callers
Method
register
(Object object)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventController.java:15
↓ 3 callers
Method
registerRule
(String categoryName, String ruleName)
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryExecutor.java:25
↓ 3 callers
Method
reject
(Exception exception)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseDeferred.java:17
↓ 3 callers
Method
run
()
coroutine-spring-boot-client-example/src/main/java/com/nepxion/coroutine/CoroutineClientApplication.java:66
↓ 3 callers
Method
setIndex
(int index)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ServiceId.java:26
↓ 3 callers
Method
start
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineManager.java:59
↓ 3 callers
Method
startSync
同步方法调用,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 callers
Method
toString
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/property/CoroutineProperties.java:349
↓ 3 callers
Method
validateClosedStatus
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:169
↓ 2 callers
Method
addListener
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:30
↓ 2 callers
Method
chain
(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 callers
Method
createBlockingQueue
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/ThreadPoolFactory.java:72
↓ 2 callers
Method
createInstance
(String className)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:109
↓ 2 callers
Method
createRejectedPolicy
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/ThreadPoolFactory.java:91
↓ 2 callers
Method
createResult
(MultipleResults results)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:147
↓ 2 callers
Method
doMerge
(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 callers
Method
doMerge
(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 callers
Method
doThen
(String value, String service)
coroutine-spring-boot-thunder-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:22
↓ 2 callers
Method
doThen
(String value, String service)
coroutine-spring-boot-dubbo-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:22
↓ 2 callers
Method
doWhen
(String value, String service)
coroutine-spring-boot-thunder-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:32
↓ 2 callers
Method
doWhen
(String value, String service)
coroutine-spring-boot-dubbo-server-example/src/main/java/com/nepxion/coroutine/service/impl/CoroutineInvoker.java:32
↓ 2 callers
Method
done
(Promise<T, F, P> promise)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/AbstractPromiseExecutor.java:74
↓ 2 callers
Method
enabled
()
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryLauncher.java:26
↓ 2 callers
Method
execute
执行异步调用,用在某调用链中间步 当when链结束后执行then链,或者then链结束后执行when链,上个链的返回的上下文对象需要缓存,以便被下个链所引用 对于异步来说,如果上个链正常调用,则缓存对象,如果上个链调用出现异常,则直接通过callback回调异常,并终止下个链调用 @param id
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/AbstractPromiseExecutor.java:34
↓ 2 callers
Method
fail
(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 callers
Method
finish
执行异步回调,用在调用链最后一步 @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 callers
Method
getApplicationContext
(String key)
coroutine-data/src/main/java/com/nepxion/coroutine/data/cache/ObjectCache.java:33
↓ 2 callers
Method
getApplicationContextPath
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ComponentEntity.java:32
↓ 2 callers
Method
getChainEntity
(String name)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/RuleEntity.java:84
↓ 2 callers
Method
getChildNameList
(String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:319
↓ 2 callers
Method
getClassEntityList
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ComponentEntity.java:56
↓ 2 callers
Method
getClazz
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ClassEntity.java:35
↓ 2 callers
Method
getClient
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:180
↓ 2 callers
Method
getController
(String identifier, boolean async)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventControllerFactory.java:47
↓ 2 callers
Method
getInputStream
(String path)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/IOUtil.java:17
↓ 2 callers
Method
getKeyName
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/MethodEntity.java:78
↓ 2 callers
Method
getMethodEntityList
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ClassEntity.java:43
↓ 2 callers
Method
getRules
(RuleKey ruleKey)
coroutine-data/src/main/java/com/nepxion/coroutine/data/cache/RuleCache.java:87
↓ 2 callers
Method
getSchema
(Class<T> clazz)
coroutine-serialization-protostuff/src/main/java/com/nepxion/coroutine/serialization/protostuff/ProtoStuffSerializer.java:57
↓ 2 callers
Method
getTimeout
()
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/DependencyEntity.java:50
↓ 2 callers
Method
getType
()
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryEntity.java:25
↓ 2 callers
Method
invokeAsync
()
coroutine-spring-boot-client-example/src/main/java/com/nepxion/coroutine/CoroutineClientApplication.java:63
↓ 2 callers
Method
invokeSync
()
coroutine-spring-boot-client-example/src/main/java/com/nepxion/coroutine/CoroutineClientApplication.java:86
↓ 2 callers
Method
isStarted
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:153
↓ 2 callers
Method
isTerminated
()
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimSerialExecutor.java:133
↓ 2 callers
Method
load
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineLoader.java:18
↓ 2 callers
Method
load
()
coroutine-serialization/src/main/java/com/nepxion/coroutine/serialization/SerializerLoader.java:17
↓ 2 callers
Method
pathExist
(String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:185
↓ 2 callers
Method
resolve
(R result)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromisePipe.java:38
↓ 2 callers
Method
send
发送邮件 @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 callers
Method
setApplicationContext
(ApplicationContext applicationContext)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ComponentEntity.java:48
↓ 2 callers
Method
setChainName
(String chainName)
coroutine-monitor/src/main/java/com/nepxion/coroutine/monitor/MonitorEntity.java:58
↓ 2 callers
Method
setCoroutineEntryList
(List<CoroutineEntry<T>> coroutineEntryList)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineList.java:29
↓ 2 callers
Method
setId
(CoroutineId id)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineEntry.java:30
↓ 2 callers
Method
setReferenceEntity
(ReferenceEntity referenceEntity)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineEntry.java:38
↓ 2 callers
Method
setResult
(T result)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineEntry.java:46
↓ 2 callers
Method
setStepType
(StepType stepType)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/StepEntity.java:37
↓ 2 callers
Method
startAsync
异步方法调用,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 callers
Method
stop
()
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryLauncher.java:23
↓ 2 callers
Method
then
(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 callers
Method
toExceptionString
(Exception exception)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ExceptionUtil.java:16
↓ 2 callers
Method
uuidRandom
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/RandomUtil.java:31
↓ 1 callers
Method
addListener
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperNodeCacheListener.java:28
↓ 1 callers
Method
addListener
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:29
↓ 1 callers
Method
calculate
(String value)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/MathsUtil.java:17
↓ 1 callers
Method
childAdded
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:71
↓ 1 callers
Method
childRemoved
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:75
↓ 1 callers
Method
childUpdated
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:73
↓ 1 callers
Method
connectionLost
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:81
↓ 1 callers
Method
connectionLost
(TreeCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:82
↓ 1 callers
Method
connectionReconnected
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:79
↓ 1 callers
Method
connectionReconnected
(TreeCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:80
↓ 1 callers
Method
connectionSuspended
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:77
↓ 1 callers
Method
connectionSuspended
(TreeCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:78
↓ 1 callers
Method
createApplicationContextPath
(String applicationContextPath)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:156
↓ 1 callers
Method
createAsyncController
(String identifier, Executor executor)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventControllerFactory.java:92
↓ 1 callers
Method
createAuthenticator
()
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpExecutor.java:51
↓ 1 callers
Method
createJarApplicationContextPath
(String className, String applicationContextPath)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:143
↓ 1 callers
Method
createListResult
(MultipleResults results)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:157
↓ 1 callers
Method
createListResult
(List<CoroutineEntry<Object>> value)
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimParallelExecutor.java:165
↓ 1 callers
Method
createMapResult
(MultipleResults results)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:181
↓ 1 callers
Method
createMapResult
(List<CoroutineEntry<Object>> entries)
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimParallelExecutor.java:185
↓ 1 callers
Method
createNamespacePath
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRegistryExecutor.java:138
↓ 1 callers
Method
createParameterTypes
(Class<?>[] parameterClasses)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:91
↓ 1 callers
Method
createParameters
(Object parameter)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:21
↓ 1 callers
Method
createPath
(String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:205
↓ 1 callers
Method
createProperties
()
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpExecutor.java:40
↓ 1 callers
Method
createResult
(List<CoroutineEntry<Object>> value)
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimParallelExecutor.java:155
↓ 1 callers
Method
createRetryNTimes
(int count, int sleepMsBetweenRetries)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:56
↓ 1 callers
Method
createSession
()
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpExecutor.java:60
↓ 1 callers
Method
createSyncController
()
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventControllerFactory.java:80
↓ 1 callers
Method
createThreadPoolExecutor
()
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseThreadPoolFactory.java:22
↓ 1 callers
Method
createThreadPoolExecutor
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/thread/CoroutineThreadPoolFactory.java:22
↓ 1 callers
Method
currentPromise
()
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseContext.java:16
← previous
next →
101–200 of 630, ranked by callers