rolling_window_cache

type ClockTurntable interface {
	// Get returns the value by given the time
	Get(t time.Time) uint64
	// GetLastSecond returns the sum of value of last n seconds
	GetLastSecond(n uint64) uint64
	// Add given n, that the value corresponding to the current moment, plus one n
	Add(n uint64)
}

type ClockTurntableInstrument struct {
	Status [60]*subStatus
}

type RollingWindowCache interface {

	// Has
	// @Description: 判断 key 在 start >r.startBlockHeight条件下，在 [start,r.endBlockHeight]区间内 是否存在
	// @param key
	// @param start
	// @return uint64 start在滑动窗口内的情况，0 小于左边，1 处于窗口内，2 大于右边 ;
	// @return bool key是否存在
	// @return error
	Has(key string, start uint64) (uint64, bool, error)

	// Consumer 消费 chan 中 数据到 RollingWindowCache
	// @Description:
	Consumer()

	// InitGenesis commit genesis block
	// @Description:
	// @param genesisBlock
	// @return error
	InitGenesis(genesisBlock *serialization.BlockWithSerializedInfo) error

	// CommitBlock  commits the txId and savepoint in an atomic operation
	// @Description:
	// @param blockWithRWSet
	// @param isCache
	// @return error
	CommitBlock(blockWithRWSet *serialization.BlockWithSerializedInfo, isCache bool) error

	// ResetRWCache set RollingWindowCache use blockInfo
	// @Description:
	// @param blockInfo
	// @return error
	ResetRWCache(blockInfo *serialization.BlockWithSerializedInfo) error
}

type RollingWindowCacher struct {
	Cache *cache.StoreCacheMgr

	sync.RWMutex

	CurrCache protocol.StoreBatcher
	// contains filtered or unexported fields
}