utils

Documentation

Index

• func CompactRange(dbHandle protocol.DBHandle, logger protocol.Logger)
• func ConcurrentWriteBatch(batches []protocol.StoreBatcher, writeFunc conCurfunc, blockHeight uint64) error
• func ConstructDBIndexInfo(blkIndex *storePb.StoreInfo, offset, byteLen uint64) []byte
• func DecodeValueToIndex(blockIndexByte []byte) (*storePb.StoreInfo, error)
• func ElapsedMillisSeconds(start time.Time) int64
• func PathExists(path string) (bool, error)

Functions

func CompactRange

func CompactRange(dbHandle protocol.DBHandle, logger protocol.Logger)

做一次compact

func ConcurrentWriteBatch

func ConcurrentWriteBatch(batches []protocol.StoreBatcher, writeFunc conCurfunc,
	blockHeight uint64) error

ConcurrentWriteBatch Concurrent write batch to db

func ConstructDBIndexInfo

func ConstructDBIndexInfo(blkIndex *storePb.StoreInfo, offset, byteLen uint64) []byte

索引序列化

func DecodeValueToIndex

func DecodeValueToIndex(blockIndexByte []byte) (*storePb.StoreInfo, error)

索引反序列化

func ElapsedMillisSeconds

func ElapsedMillisSeconds(start time.Time) int64

计算时间差

func PathExists

func PathExists(path string) (bool, error)

判断path是否存在