-
Notifications
You must be signed in to change notification settings - Fork 3.6k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
refactor(core): remove cosmos-db dependency (#18848)
- Loading branch information
1 parent
f9f9211
commit 6649bb7
Showing
16 changed files
with
215 additions
and
175 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,122 @@ | ||
| package testkv | ||
|
|
||
| import ( | ||
| dbm "github.com/cosmos/cosmos-db" | ||
|
|
||
| "cosmossdk.io/core/store" | ||
| ) | ||
|
|
||
| type TestStore struct { | ||
| Db dbm.DB | ||
| } | ||
|
|
||
| func (ts TestStore) Get(bz []byte) ([]byte, error) { | ||
| return ts.Db.Get(bz) | ||
| } | ||
|
|
||
| // // Has checks if a key exists. | ||
| func (ts TestStore) Has(key []byte) (bool, error) { | ||
| return ts.Db.Has(key) | ||
| } | ||
|
|
||
| func (ts TestStore) Set(k, v []byte) error { | ||
| return ts.Db.Set(k, v) | ||
| } | ||
|
|
||
| // // SetSync sets the value for the given key, and flushes it to storage before returning. | ||
| func (ts TestStore) SetSync(k, v []byte) error { | ||
| return ts.Db.SetSync(k, v) | ||
| } | ||
|
|
||
| // // Delete deletes the key, or does nothing if the key does not exist. | ||
| // // CONTRACT: key readonly []byte | ||
| func (ts TestStore) Delete(bz []byte) error { | ||
| return ts.Db.Delete(bz) | ||
| } | ||
|
|
||
| // // DeleteSync deletes the key, and flushes the delete to storage before returning. | ||
| func (ts TestStore) DeleteSync(bz []byte) error { | ||
| return ts.Db.DeleteSync(bz) | ||
| } | ||
|
|
||
| func (ts TestStore) Iterator(start, end []byte) (store.Iterator, error) { | ||
| itr, err := ts.Db.Iterator(start, end) | ||
| return IteratorWrapper{itr: itr}, err | ||
| } | ||
|
|
||
| func (ts TestStore) ReverseIterator(start, end []byte) (store.Iterator, error) { | ||
| itr, err := ts.Db.ReverseIterator(start, end) | ||
| return itr, err | ||
| } | ||
|
|
||
| // Close closes the database connection. | ||
| func (ts TestStore) Close() error { | ||
| return ts.Db.Close() | ||
| } | ||
|
|
||
| // NewBatch creates a batch for atomic updates. The caller must call Batch.Close. | ||
| func (ts TestStore) NewBatch() dbm.Batch { | ||
| return ts.Db.NewBatch() | ||
| } | ||
|
|
||
| // NewBatchWithSize create a new batch for atomic updates, but with pre-allocated size. | ||
| // This will does the same thing as NewBatch if the batch implementation doesn't support pre-allocation. | ||
| func (ts TestStore) NewBatchWithSize(i int) dbm.Batch { | ||
| return ts.Db.NewBatchWithSize(i) | ||
| } | ||
|
|
||
| // Print is used for debugging. | ||
| func (ts TestStore) Print() error { | ||
| return ts.Db.Print() | ||
| } | ||
|
|
||
| // Stats returns a map of property values for all keys and the size of the cache. | ||
| func (ts TestStore) Stats() map[string]string { | ||
| return ts.Db.Stats() | ||
| } | ||
|
|
||
| var _ store.Iterator = IteratorWrapper{} | ||
|
|
||
| type IteratorWrapper struct { | ||
| itr dbm.Iterator | ||
| } | ||
|
|
||
| // Domain returns the start (inclusive) and end (exclusive) limits of the iterator. | ||
| // CONTRACT: start, end readonly []byte | ||
| func (iw IteratorWrapper) Domain() (start, end []byte) { | ||
| return iw.itr.Domain() | ||
| } | ||
|
|
||
| // Valid returns whether the current iterator is valid. Once invalid, the Iterator remains | ||
| // invalid forever. | ||
| func (iw IteratorWrapper) Valid() bool { | ||
| return iw.itr.Valid() | ||
| } | ||
|
|
||
| // Next moves the iterator to the next key in the database, as defined by order of iteration. | ||
| // If Valid returns false, this method will panic. | ||
| func (iw IteratorWrapper) Next() { | ||
| iw.itr.Next() | ||
| } | ||
|
|
||
| // Key returns the key at the current position. Panics if the iterator is invalid. | ||
| // CONTRACT: key readonly []byte | ||
| func (iw IteratorWrapper) Key() (key []byte) { | ||
| return iw.itr.Key() | ||
| } | ||
|
|
||
| // Value returns the value at the current position. Panics if the iterator is invalid. | ||
| // CONTRACT: value readonly []byte | ||
| func (iw IteratorWrapper) Value() (value []byte) { | ||
| return iw.itr.Value() | ||
| } | ||
|
|
||
| // Error returns the last error encountered by the iterator, if any. | ||
| func (iw IteratorWrapper) Error() error { | ||
| return iw.itr.Error() | ||
| } | ||
|
|
||
| // Close closes the iterator, relasing any allocated resources. | ||
| func (iw IteratorWrapper) Close() error { | ||
| return iw.itr.Close() | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.