common

type CacheProvider interface {
	Create(ledgerID string, lastCommittedBlockNum uint64) StoreExt
}

type CollElgProcSync struct {
	// contains filtered or unexported fields
}

type DBHandle interface {
	WriteBatch(batch *leveldbhelper.UpdateBatch, sync bool) error
	Delete(key []byte, sync bool) error
	Get(key []byte) ([]byte, error)
	GetIterator(startKey []byte, endKey []byte) (*leveldbhelper.Iterator, error)
	Put(key []byte, value []byte, sync bool) error
	NewUpdateBatch() *leveldbhelper.UpdateBatch
}

type DataAndExpiryEntries struct {
	DataEntries   map[DataKey]*rwset.CollectionPvtReadWriteSet
	ExpiryEntries map[ExpiryKey]*ExpiryData
}

type DataEntry struct {
	Key   *DataKey
	Value *rwset.CollectionPvtReadWriteSet
}

type DataKey struct {
	NsCollBlk
	TxNum uint64
}

type ExpiryData pvtdatastorage.ExpiryData

type ExpiryEntry struct {
	Key   *ExpiryKey
	Value *ExpiryData
}

type ExpiryKey struct {
	ExpiringBlk   uint64
	CommittingBlk uint64
}

type MissingDataKey struct {
	NsCollBlk
}

type NsCollBlk struct {
	Ns, Coll string
	BlkNum   uint64
}

type OldBlockDataProcessor struct {
	// contains filtered or unexported fields
}

type Provider interface {
	OpenStore(ledgerID string) (StoreExt, error)
	Close()
}

type StoreEntries struct {
	DataEntries             []*DataEntry
	ExpiryEntries           []*ExpiryEntry
	ElgMissingDataEntries   map[MissingDataKey]*bitset.BitSet
	InelgMissingDataEntries map[MissingDataKey]*bitset.BitSet
}

type StoreExt interface {
	xstorageapi.PrivateDataStore
	UpdateLastCommittedBlockNum(blockNum uint64)
}

type TxPvtdataAssembler struct {
	// contains filtered or unexported fields
}