Versions in this module Expand all Collapse all v3 v3.0.1 Dec 28, 2023 v3.0.0 Dec 23, 2022 Changes in this version + var SHARD_COUNT = 32 + func NewUpdateBatch() protocol.StoreBatcher + type BlockGetter interface + GetTxInfoOnly func(txId string) (*storePb.TransactionStoreInfo, error) + type ConcurrentMap []*ConcurrentMapShared + func New() ConcurrentMap + func (m ConcurrentMap) Clear() + func (m ConcurrentMap) Count() int + func (m ConcurrentMap) Get(key string) (interface{}, bool) + func (m ConcurrentMap) GetShard(key string) *ConcurrentMapShared + func (m ConcurrentMap) Has(key string) bool + func (m ConcurrentMap) IsEmpty() bool + func (m ConcurrentMap) Items() map[string]interface{} + func (m ConcurrentMap) Iter() <-chan Tuple + func (m ConcurrentMap) IterBuffered() <-chan Tuple + func (m ConcurrentMap) IterCb(fn IterCb) + func (m ConcurrentMap) Keys() []string + func (m ConcurrentMap) MSet(data map[string]interface{}) + func (m ConcurrentMap) MarshalJSON() ([]byte, error) + func (m ConcurrentMap) Pop(key string) (v interface{}, exists bool) + func (m ConcurrentMap) Remove(key string) + func (m ConcurrentMap) RemoveCb(key string, cb RemoveCb) bool + func (m ConcurrentMap) Set(key string, value interface{}) + func (m ConcurrentMap) SetIfAbsent(key string, value interface{}) bool + func (m ConcurrentMap) Upsert(key string, value interface{}, cb UpsertCb) (res interface{}) + type ConcurrentMapShared struct + type ConnectionPoolDBHandle struct + func NewConnectionPoolDBHandle(size int, log protocol.Logger) *ConnectionPoolDBHandle + func (c *ConnectionPoolDBHandle) Clear() + func (c *ConnectionPoolDBHandle) GetDBHandle(contractName string) (protocol.SqlDBHandle, bool) + func (c *ConnectionPoolDBHandle) SetDBHandle(contractName string, handle protocol.SqlDBHandle) + type EngineType int32 + const BadgerDb + const LevelDb + const MySQL + const Sqlite + const TikvDb + const UnknownDb + func (t EngineType) LowerString() string + func (t EngineType) String() string + type HistoryIteratorImpl struct + func NewHistoryIterator(contractName string, key []byte, dbItr historydb.HistoryIterator, ...) *HistoryIteratorImpl + func (hs *HistoryIteratorImpl) Next() bool + func (hs *HistoryIteratorImpl) Release() + func (hs *HistoryIteratorImpl) Value() (*storePb.KeyModification, error) + type IterCb func(key string, v interface{}) + type RemoveCb func(key string, v interface{}, exists bool) bool + type SavePoint struct + BlockHeight uint64 + func (b *SavePoint) GetCountSql() (string, []interface{}) + func (b *SavePoint) GetCreateTableSql(dbType string) string + func (b *SavePoint) GetInsertSql(dbType string) (string, []interface{}) + func (b *SavePoint) GetTableName() string + func (b *SavePoint) GetUpdateSql() (string, []interface{}) + type SqlVerifyPass struct + func (s *SqlVerifyPass) VerifyDDLSql(sql string) error + func (s *SqlVerifyPass) VerifyDMLSql(sql string) error + func (s *SqlVerifyPass) VerifyDQLSql(sql string) error + type StandardSqlVerify struct + func (s *StandardSqlVerify) VerifyDDLSql(sql string) error + func (s *StandardSqlVerify) VerifyDMLSql(sql string) error + func (s *StandardSqlVerify) VerifyDQLSql(sql string) error + type Tuple struct + Key string + Val interface{} + type TxHistoryIteratorImpl struct + func NewTxHistoryIterator(dbItr historydb.HistoryIterator, blockStore BlockGetter) *TxHistoryIteratorImpl + func (hs *TxHistoryIteratorImpl) Next() bool + func (hs *TxHistoryIteratorImpl) Release() + func (hs *TxHistoryIteratorImpl) Value() (*storePb.TxHistory, error) + type UpdateBatch struct + func (batch *UpdateBatch) Delete(key []byte) + func (batch *UpdateBatch) Get(key []byte) ([]byte, error) + func (batch *UpdateBatch) Has(key []byte) bool + func (batch *UpdateBatch) KVs() map[string][]byte + func (batch *UpdateBatch) Keys() []string + func (batch *UpdateBatch) Len() int + func (batch *UpdateBatch) Merge(u protocol.StoreBatcher) + func (batch *UpdateBatch) Put(key []byte, value []byte) + func (batch *UpdateBatch) ReSet() + func (batch *UpdateBatch) Remove(key []byte) + func (batch *UpdateBatch) SplitBatch(batchCnt uint64) []protocol.StoreBatcher + type UpsertCb func(exist bool, valueInMap interface{}, newValue interface{}) interface