类的使用
dev.tinyflow.core.chain.runtime.Trigger

使用Trigger的程序包

程序包	说明
dev.tinyflow.core.chain	Chain 执行链
dev.tinyflow.core.chain.event
dev.tinyflow.core.chain.runtime

dev.tinyflow.core.chain中Trigger的使用

参数类型为Trigger的dev.tinyflow.core.chain中的方法

修饰符和类型	方法	说明
void	Chain.executeNode(Node node, Trigger trigger)

dev.tinyflow.core.chain.event中Trigger的使用

声明为Trigger的dev.tinyflow.core.chain.event中的字段

修饰符和类型	字段	说明
private final Trigger	EdgeTriggerEvent.trigger

返回Trigger的dev.tinyflow.core.chain.event中的方法

修饰符和类型	方法	说明
Trigger	EdgeTriggerEvent.getTrigger()

参数类型为Trigger的dev.tinyflow.core.chain.event中的构造器

限定符	构造器	说明
	EdgeTriggerEvent(Chain chain, Trigger trigger)

dev.tinyflow.core.chain.runtime中Trigger的使用

类型参数类型为Trigger的dev.tinyflow.core.chain.runtime中的字段

修饰符和类型	字段	说明
private static final ThreadLocal<Trigger>	TriggerContext.currentTrigger
private final ConcurrentHashMap<String,Trigger>	InMemoryTriggerStore.store

返回Trigger的dev.tinyflow.core.chain.runtime中的方法

修饰符和类型	方法	说明
Trigger	InMemoryTriggerStore.find(String triggerId)
Trigger	TriggerStore.find(String triggerId)
static Trigger	TriggerContext.getCurrentTrigger()
Trigger	InMemoryTriggerStore.save(Trigger trigger)
Trigger	TriggerStore.save(Trigger trigger)
Trigger	TriggerScheduler.schedule(Trigger trigger)	schedule a trigger: persist -> schedule (单机语义)

返回变量类型为Trigger的类型的dev.tinyflow.core.chain.runtime中的方法

修饰符和类型	方法	说明
List<Trigger>	InMemoryTriggerStore.findAllPending()
List<Trigger>	TriggerStore.findAllPending()
List<Trigger>	InMemoryTriggerStore.findDue(long uptoTimestamp)
List<Trigger>	TriggerStore.findDue(long uptoTimestamp)

参数类型为Trigger的dev.tinyflow.core.chain.runtime中的方法

修饰符和类型	方法	说明
private void	ChainExecutor.accept(Trigger trigger, ExecutorService worker)
void	TriggerScheduler.TriggerConsumer.accept(Trigger trigger, ExecutorService worker)
Trigger	InMemoryTriggerStore.save(Trigger trigger)
Trigger	TriggerStore.save(Trigger trigger)
Trigger	TriggerScheduler.schedule(Trigger trigger)	schedule a trigger: persist -> schedule (单机语义)
private void	TriggerScheduler.scheduleInternal(Trigger trigger)	internal scheduling for a trigger (单机 scheduled semantics)
static void	TriggerContext.setCurrentTrigger(Trigger trigger)