程序包 dev.tinyflow.core.chain.runtime

类 InMemoryTriggerStore

java.lang.Object

dev.tinyflow.core.chain.runtime.InMemoryTriggerStore

所有已实现的接口:

TriggerStore

public class InMemoryTriggerStore
extends Object
implements TriggerStore

字段概要

字段

修饰符和类型	字段	说明
private final ConcurrentHashMap<String,Trigger>	store

构造器概要

构造器

构造器	说明
InMemoryTriggerStore()

方法概要

修饰符和类型	方法	说明
Trigger	find(String triggerId)
List<Trigger>	findAllPending()
List<Trigger>	findDue(long uptoTimestamp)
boolean	remove(String triggerId)
Trigger	save(Trigger trigger)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

store

private final ConcurrentHashMap<String,Trigger> store

构造器详细资料

InMemoryTriggerStore

public InMemoryTriggerStore()

方法详细资料

save

public Trigger save(Trigger trigger)

指定者:

save 在接口中 TriggerStore

remove

public boolean remove(String triggerId)

指定者:

remove 在接口中 TriggerStore

find

public Trigger find(String triggerId)

指定者:

find 在接口中 TriggerStore

findDue

public List<Trigger> findDue(long uptoTimestamp)

指定者:

findDue 在接口中 TriggerStore

findAllPending

public List<Trigger> findAllPending()

指定者:

findAllPending 在接口中 TriggerStore