MCPcopy Create free account

hub / github.com/Nepxion/Coroutine / functions

Functions630 in github.com/Nepxion/Coroutine

↓ 1 callersMethodsetNamespace
(String namespace)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRegistryExecutor.java:57
↓ 1 callersMethodsetObject
(Object object)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/MethodEntity.java:101
↓ 1 callersMethodsetParameterTypes
(Class<?>[] parameterTypes)
coroutine-common/src/main/java/com/nepxion/coroutine/common/invocation/MethodInvocation.java:32
↓ 1 callersMethodsetParameterTypes
(String parameterTypes)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/MethodEntity.java:59
↓ 1 callersMethodsetParameters
(Object[] parameters)
coroutine-common/src/main/java/com/nepxion/coroutine/common/invocation/MethodInvocation.java:40
↓ 1 callersMethodsetPromise
(PromiseDeferred<?> promise)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseContext.java:28
↓ 1 callersMethodsetReferenceEntity
(ReferenceEntity referenceEntity)
coroutine-monitor/src/main/java/com/nepxion/coroutine/monitor/MonitorEntity.java:50
↓ 1 callersMethodsetRegistryInitializer
(RegistryInitializer registryInitializer)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRegistryExecutor.java:46
↓ 1 callersMethodsetRegistryInitializer
(RegistryInitializer registryInitializer)
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryExecutor.java:19
↓ 1 callersMethodsetStepEntityList
(List<StepEntity> stepEntityList)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ChainEntity.java:38
↓ 1 callersMethodsetTimeout
(long timeout)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/DependencyEntity.java:54
↓ 1 callersMethodsetTimestamp
(long timestamp)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/CoroutineResult.java:40
↓ 1 callersMethodsetVersion
(int version)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/RuleEntity.java:34
↓ 1 callersMethodstart
(T result)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseSerialPortal.java:16
↓ 1 callersMethodstart
()
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimParallelExecutor.java:136
↓ 1 callersMethodstart
()
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimSerialExecutor.java:138
↓ 1 callersMethodstartAndBlock
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:107
↓ 1 callersMethodstartAsync
(String categoryName, String ruleName, String chainName, Object[] parameters, boolean last, CoroutineCallback<
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/AbstractCoroutineLauncher.java:37
↓ 1 callersMethodstartFailure
(MonitorEntity monitorEntity)
coroutine-monitor/src/main/java/com/nepxion/coroutine/monitor/MonitorLauncher.java:20
↓ 1 callersMethodstartSuccess
(MonitorEntity monitorEntity)
coroutine-monitor/src/main/java/com/nepxion/coroutine/monitor/MonitorLauncher.java:17
↓ 1 callersMethodstop
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineManager.java:67
↓ 1 callersMethodunregister
(Object object)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventController.java:17
MethodAbortPolicyWithReport
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/AbortPolicyWithReport.java:23
MethodBlockingPolicyWithReport
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/BlockingPolicyWithReport.java:24
MethodCallerRunsPolicyWithReport
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/CallerRunsPolicyWithReport.java:23
MethodCoroutineContent
(String path, String encoding)
coroutine-common/src/main/java/com/nepxion/coroutine/common/property/CoroutineContent.java:24
MethodCoroutineDelegateImpl
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/delegate/CoroutineDelegateImpl.java:18
MethodCoroutineException
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineException.java:15
MethodCoroutineManager
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineManager.java:98
MethodCoroutineProperties
(String path, String stringEncoding, String readerEncoding)
coroutine-common/src/main/java/com/nepxion/coroutine/common/property/CoroutineProperties.java:36
MethodCoroutineScan
(Map<CoroutineId, CoroutineResult<?>> resultMap, long scan)
coroutine-data/src/main/java/com/nepxion/coroutine/data/scan/CoroutineScan.java:30
MethodDiscardedPolicyWithReport
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/DiscardedPolicyWithReport.java:25
MethodEvent
()
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/Event.java:24
MethodEventControllerFactory
()
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventControllerFactory.java:27
MethodEventControllerImpl
(EventBus eventBus)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventControllerImpl.java:19
MethodEventType
(String value)
coroutine-event/src/main/java/com/nepxion/coroutine/event/eventbus/EventType.java:18
MethodExecutorType
(String value)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ExecutorType.java:18
MethodKilimParallelExecutor
(final CoroutineId coroutineId, RuleEntity ruleEntity, StepEntity stepEntity, final String chainName, final Co
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimParallelExecutor.java:58
MethodKilimSerialExecutor
(final CoroutineId coroutineId, RuleEntity ruleEntity, StepEntity stepEntity, final String chainName, final Co
coroutine-framework-kilim/src/main/java/com/nepxion/coroutine/framework/core/kilim/KilimSerialExecutor.java:44
MethodMonitorEntity
()
coroutine-monitor/src/main/java/com/nepxion/coroutine/monitor/MonitorEntity.java:26
MethodPromiseParallelExecutor
()
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:49
MethodPromiseParallelPortal
()
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelPortal.java:18
MethodPromiseSerialExecutor
()
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseSerialExecutor.java:32
MethodReferenceType
(String value)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/ReferenceType.java:18
MethodRegistryType
(String value)
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryType.java:17
MethodRejectedPolicyWithReport
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/RejectedPolicyWithReport.java:25
MethodRuleAddedEvent
(String categoryName, String ruleName, String ruleContent)
coroutine-event/src/main/java/com/nepxion/coroutine/event/RuleAddedEvent.java:17
MethodRuleEvent
(String categoryName, String ruleName)
coroutine-event/src/main/java/com/nepxion/coroutine/event/RuleEvent.java:22
MethodRuleParser
(RuleKey ruleKey)
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/parser/RuleParser.java:45
MethodRuleReconnectedEvent
(String categoryName, Map<String, String> ruleMap)
coroutine-event/src/main/java/com/nepxion/coroutine/event/RuleReconnectedEvent.java:23
MethodRuleRemovedEvent
(String categoryName, String ruleName)
coroutine-event/src/main/java/com/nepxion/coroutine/event/RuleRemovedEvent.java:15
MethodRuleUpdatedEvent
(String categoryName, String ruleName, String ruleContent)
coroutine-event/src/main/java/com/nepxion/coroutine/event/RuleUpdatedEvent.java:17
MethodSerializerException
()
coroutine-serialization/src/main/java/com/nepxion/coroutine/serialization/SerializerException.java:15
MethodSmtpExecutor
(String host, String user, String password)
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpExecutor.java:32
MethodSmtpSslExecutor
(String host, String user, String password)
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpSslExecutor.java:18
MethodStepType
(String value)
coroutine-data/src/main/java/com/nepxion/coroutine/data/entity/StepType.java:18
MethodThreadQueueType
(String value)
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/ThreadQueueType.java:19
MethodThreadRejectedPolicyType
(String value)
coroutine-common/src/main/java/com/nepxion/coroutine/common/thread/ThreadRejectedPolicyType.java:21
MethodZookeeperCacheListener
(CuratorFramework client, String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperCacheListener.java:21
MethodZookeeperCategoryListener
(ZookeeperInvoker invoker, String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperCategoryListener.java:37
MethodZookeeperException
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperException.java:15
MethodZookeeperNodeCacheListener
(CuratorFramework client, String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperNodeCacheListener.java:19
MethodZookeeperPathChildrenCacheListener
(CuratorFramework client, String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:20
MethodZookeeperRegistryExecutor
()
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRegistryExecutor.java:33
MethodZookeeperRuleListener
(ZookeeperInvoker invoker, String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRuleListener.java:29
MethodZookeeperTreeCacheListener
(CuratorFramework client, String path)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:20
MethodaddCategoryListener
(String categoryName)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRegistryExecutor.java:122
MethodaddCategoryListener
(String categoryName)
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryExecutor.java:40
MethodaddRuleListener
(String categoryName, String ruleName)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRegistryExecutor.java:130
Methodcall
()
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:70
Methodcall
(T result, Exception exception)
coroutine-common/src/main/java/com/nepxion/coroutine/common/callback/CoroutineCallback.java:13
Methodcall
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/AbstractCoroutineLauncher.java:74
Methodchain
(final CoroutineResult<Object> origin, RuleEntity ruleEntity, StepEntity stepEntity, final String chainName)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseParallelExecutor.java:53
Methodchain
(CoroutineResult<Object> origin, RuleEntity ruleEntity, StepEntity stepEntity, String chainName)
coroutine-framework-promise/src/main/java/com/nepxion/coroutine/framework/core/promise/PromiseSerialExecutor.java:36
MethodchildAdded
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperCategoryListener.java:48
MethodchildEvent
(CuratorFramework client, PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperPathChildrenCacheListener.java:41
MethodchildEvent
(CuratorFramework client, TreeCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/listener/ZookeeperTreeCacheListener.java:42
MethodchildRemoved
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperCategoryListener.java:78
MethodchildUpdated
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperCategoryListener.java:63
MethodclearExpiredRule
(RuleKey ruleKey)
coroutine-data/src/main/java/com/nepxion/coroutine/data/cache/RuleCache.java:48
MethodconnectionLost
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperCategoryListener.java:109
MethodconnectionReconnected
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperCategoryListener.java:97
MethodconnectionSuspended
(PathChildrenCacheEvent event)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperCategoryListener.java:92
MethodcreateBoundedExponentialBackoffRetry
(int baseSleepTimeMs, int maxSleepTimeMs, int maxRetries)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:49
MethodcreateConstructor
(String className, Class<?>... parameterTypes)
coroutine-common/src/main/java/com/nepxion/coroutine/common/util/ClassUtil.java:128
MethodcreateDelegate
(String delegateClassId)
coroutine-common/src/main/java/com/nepxion/coroutine/common/delegate/CoroutineDelegate.java:21
MethodcreateDelegate
(String delegateClassId)
coroutine-common/src/main/java/com/nepxion/coroutine/common/delegate/CoroutineDelegateImpl.java:32
MethodcreateDocument
()
coroutine-common/src/main/java/com/nepxion/coroutine/common/xml/Dom4JWriter.java:22
MethodcreateEmbeddedServletContainerFactory
()
coroutine-spring-boot-thunder-server-example/src/main/java/com/nepxion/coroutine/ThunderServerApplication.java:26
MethodcreateEmbeddedServletContainerFactory
()
coroutine-spring-boot-dubbo-server-example/src/main/java/com/nepxion/coroutine/DubboServerApplication.java:26
MethodcreateEmbeddedServletContainerFactory
()
coroutine-spring-boot-client-example/src/main/java/com/nepxion/coroutine/CoroutineClientApplication.java:105
MethodcreateExponentialBackoffRetry
(int baseSleepTimeMs, int maxRetries)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:42
MethodcreateProperties
()
coroutine-monitor-mail/src/main/java/com/nepxion/coroutine/monitor/mail/smtp/SmtpSslExecutor.java:22
MethodcreateRetryForever
(int retryIntervalMs)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:63
MethodcreateRetryUntilElapsed
(int maxElapsedTimeMs, int sleepMsBetweenRetries)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/common/ZookeeperInvoker.java:70
MethoddeleteRule
(String categoryName, String ruleName)
coroutine-registry-zookeeper/src/main/java/com/nepxion/coroutine/registry/zookeeper/ZookeeperRegistryExecutor.java:77
MethoddeleteRule
(String categoryName, String ruleName)
coroutine-registry/src/main/java/com/nepxion/coroutine/registry/RegistryExecutor.java:28
Methoddeserialize
(byte[] bytes, Class<T> clazz)
coroutine-serialization-protostuff/src/main/java/com/nepxion/coroutine/serialization/protostuff/ProtoStuffSerializer.java:48
Methoddestroy
()
coroutine-framework/src/main/java/com/nepxion/coroutine/framework/core/CoroutineDestroy.java:22
MethoddoMerge
(CoroutineList<Object> value)
coroutine-test/src/test/java/com/nepxion/coroutine/test/service/BService.java:19
← previousnext →301–400 of 630, ranked by callers