# Multistore and Keepers
Look at the following sections before you begin:
Keepers are responsible for managing access to states defined by modules. Because states are accessed through keepers, they are an ideal place to ensure that invariants are enforced and security principles are always applied.
You can find a code example for your checkers blockchain at the end of the section that explores dealing with storage elements, message handling, and gas costs.
A Cosmos SDK application on an application-specific blockchain usually consists of several modules attending to separate concerns. Each module has a state that is a subset of the entire application state.
The Cosmos SDK adopts an object-capabilities-based approach to help developers better protect their application from unwanted inter-module interactions. Keepers are at the core of this approach.
A keeper is a Cosmos SDK abstraction that manages access to the subset of the state defined by a module. All access to the module's data must go through the module's keeper.
A keeper can be thought of as the literal gatekeeper of a module's stores. Each store defined within a module (typically an IAVL store) comes with a storeKey
which grants unlimited access. The module's keeper holds this storeKey
, which should otherwise remain unexposed, and defines methods for reading and writing to any store.
When a module needs to interact with the state defined in another module, it does so by interacting with the methods of the other module’s keeper. Developers control the interactions their module can have with other modules by defining methods and controlling access.
# Format
Keepers are generally defined in a /keeper/keeper.go
file located in the module’s folder. The type keeper of a module is named simply keeper.go
by convention. It usually follows the following structure:
# Parameters
The following parameters are of importance concerning the type definitions of keepers in modules:
- An expected
keeper
is a keeper external to a module that is required by the internal keeper of said module. External keepers are listed in the internal keeper's type definition as interfaces. These interfaces are themselves defined in anexpected_keepers.go
file in the root of the module's folder. Interfaces are used to reduce the number of dependencies and to facilitate the maintenance of the module in this context. storeKeys
grant access to any stores of the multistore managed by the module. They should always remain unexposed to external modules.cdc
is the codec used to marshal and unmarshal structs to and from []byte. Thecdc
can becodec.BinaryCodec
,codec.JSONCodec
, orcodec.Codec
based on your requirements. Note thatcode.Codec
includes the other interfaces. It can be either a proto or amino codec, as long as they implement these interfaces.
Each keeper has its own constructor function, which is called from the application's constructor function. This is where keepers are instantiated and where developers make sure to pass correct instances of the module's keepers to other modules that require them.
# Scope and best practices
Keepers primarily expose getter and setter methods for stores managed by their module. Methods should remain simple and strictly limited to getting or setting the requested value. Validity checks should already have been done with the ValidateBasic()
method of the message and the Msg
server before the keeper's methods are called.
The getter method will typically have the following signature:
The setter method will typically have the following signature:
Keepers also should implement an iterator method with the following signature when appropriate:
# Store types
The Cosmos SDK offers different store types to work with. It is important to gain a good overview of the different store types available for development.
# KVStore
and Multistore
in the interchain
Each Cosmos SDK application contains a state at its root, the Multistore
. It is subdivided into separate compartments managed by each module in the application. The Multistore
is a store of KVStore
s that follows the Multistore interface
(opens new window).
The base KVStore
and Multistore
implementations are wrapped in extensions that offer specialized behavior. A CommitMultistore
(opens new window) is a Multistore
with a committer. This is the main type of multistore used in the Cosmos SDK. The underlying KVStore
is used primarily to restrict access to the committer.
The rootMulti.Store
(opens new window) is the go-to implementation of the CommitMultiStore
interface. It is a base-layer multistore built around a database on top of which multiple KVStore
s can be mounted. It is the default multistore store used in BaseApp
.
# CacheMultistore
A cachemulti.Store
(opens new window) is used whenever the rootMulti.Store
needs to be branched. cachemulti.Store
branches all substores, creates a virtual store for each substore in its constructor, and holds them in Store.stores
. This is used primarily to create an isolated store, typically when it is necessary to mutate the state but it might be reverted later.
CacheMultistore
caches all read queries. Store.GetKVStore()
returns the store from Store.stores
, and Store.Write()
recursively calls CacheWrap.Write()
on all substores.
# Transient store
As the name suggests, Transient.Store
is a KVStore
that is discarded automatically at the end of each block. Transient.Store
is a dbadapter.Store
with a dbm.NewMemDB()
. All KVStore
methods are reused. A new dbadapter.Store
is assigned when Store.Commit()
is called, discarding the previous reference. Garbage collection is attended to automatically.
Take a closer look at the IAVL spec (opens new window) for when working with the IAVL store.
The default implementation of KVStore
and CommitKVStore
is the IAVL.Store
. The IAVL.Store
is a self-balancing binary search tree that ensures get and set operations are O(log n)
, where n
is the number of elements in the tree.
# Additional KVStore wrappers
In addition to the previous store types, there are a few others with more specific usage.
# GasKv store
Cosmos SDK applications use gas to track resource usage and prevent spam. The GasKv.Store
is a KVStore
wrapper that enables automatic gas consumption each time a read or write to the store is made. It is the solution of choice to track storage usage in Cosmos SDK applications.
GasKv.Store
automatically consumes the appropriate amount of gas depending on the Store.gasConfig
when methods of the parent KVStore
are called. All KVStores
are wrapped in GasKv.Stores
by default when retrieved. This is done in the KVStore()
method of the context. The default gas configuration is used in this case.
# TraceKv store
tracekv.Store
is a KVStore
wrapper which provides operation tracing functionalities over the underlying KVStore
. It is applied automatically by the Cosmos SDK on all KVStore
s if tracing is enabled on the parent MultiStore
.
When each of the KVStore
methods are called, tracekv.Store
automatically logs traceOperation
to the Store.writer
. traceOperation.Metadata
is filled with Store.context
when it is not nil. TraceContext
is a map[string]interface{}
.
# Prefix store
prefix.Store
is a KVStore
wrapper which provides automatic key-prefixing functionalities over the underlying KVStore
:
- When
Store.{Get, Set}()
is called, the store forwards the call to its parent with the key prefixed with theStore.prefix
. - When
Store.Iterator()
is called, it does not simply prefix theStore.prefix
since it does not work as intended. Some of the elements are traversed even when they are not starting with the prefix in this case.
# AnteHandler
The AnteHandler
is a special handler that implements the AnteHandler
interface. It is used to authenticate a transaction before the transaction's internal messages are processed.
The AnteHandler
is theoretically optional but still a very important component of public blockchain networks. It serves three primary purposes:
- It is a first line of defense against spam, and the second line of defense (after the mempool) against transaction replay with fees deduction and sequence checking.
- It performs preliminary stateful validity checks, like ensuring signatures are valid, or that a sender has enough funds to pay for fees.
- It plays a role in the incentivization of stakeholders via the collection of transaction fees.
BaseApp
holds an AnteHandler
as a parameter that is initialized in the application's constructor. The most widely used AnteHandler
is the auth module.
For more information on the subject, see the following resources:
# Code example
In the Accounts section, you were shown the elements of the stored game but not where this game is stored. This will now be explained.
Game object in storage
You need to decide under what structure you want to store a game in the storage. The Cosmos SDK partitions the global storage per module, with checkers
being its own module. You need to take care of how to store games in the checkers module's corner of the key/value pair storage.
The first idea is to attribute a unique ID to a game, and to store the game value at that ID. For the sake of clarity, and to differentiate between other stored elements in the future, you add a prefix to each ID. The storage structure looks like this:
This is pseudo-code because:
- Prefixes have to be
byte[]
instead ofstring
. This is easily handled with a cast such as[]byte("games-")
. - The Cosmos SDK prevents you from directly accessing any random module's store, such that
globalStore.getAtPrefix("checkers-")
is not allowed and instead has to be accessed via a secret key.
Define the ID of the StoredGame
. To return a single object, include Index
in the object's value:
The Cosmos SDK provides much support; you only need to define the required prefixes in your corner of the storage:
This assists you with accessing a game:
Keep in mind that these are examples and not the only way you can implement the desired outcome.
If you want to save a game:
In the same vein, if you want to delete a stored game, you call:
The KVStore
also allows you to obtain an iterator on a given prefix. You can list all stored games because they share the same prefix, which you do with:
Note the MustMarshalBinaryBare
and MustUnmarshalBinaryBare
functions in the previous codec
. They need to be instructed on how to proceed with the marshaling. Protobuf handled this for you.
See the previous section on Protobuf to explore how Protobuf deals with the marshaling.
Boilerplate, boilerplate everywhere!
Note how the v0.47 (or before) Set
, Get
, Remove
, and GetAll
functions shown previously look like boilerplate too. Do you have to redo these functions for every type? No - it was all created with this Ignite CLI command:
map
is the command that tells Ignite CLI to add an Index
and store all elements under a map-like structure.
With v0.50 or later, the boilerplate is already hidden away in the collections
library.
Other storage elements
If your users cannot choose a new game's index, how do you pick a value for the Index
in storedGame
? A viable idea is to keep a counter in storage for the next game. Unlike StoredGame
, which is saved as a map, this SystemInfo
object has to be at a unique location in the storage.
First define the object:
Then define the key where it resides:
Then define the functions to get and set:
Remember that SystemInfo
needs an initial value, which is the role of the genesis block definition:
Now initialize:
What about message handling
To see how messages are handled with the help of a message server and the keeper, head to one of the links at the bottom of the page.
More on game theory
Some players may drop out from games, especially if they know they are about to lose. As the blockchain designer, you need to protect your blockchain, and in particular to avoid bloat, or locked tokens.
A good first point is to introduce a game deadline. For details, head to one of the links at the bottom of the page.
How to expire games
How can you know what games should be removed? Should you load all games and filter for those that have expired? That would be extremely expensive, O(n) of the number of games in fact. This means the more successful your blockchain becomes, the slower it would run.
Better is to use a First-In-First-Out (FIFO) strategy, where fresh games are pushed back to the tail so that the head contains the next games to expire.
To see how this can be implemented in the context of the Cosmos SDK, head to one of the links at the bottom of the page.
When to expire games
See the next section about the BaseApp for a possible solution.
If you would like to get started on building your own checkers game, you can go straight to the main exercise in Run Your Own Cosmos Chain, either natively with SDK v0.50 or with Ignite CLI to start from scratch.
More precisely, you can jump to:
- Add a game in storage to see how to define a map storage natively in Cosmos SDK v0.50, and its usage in the keeper.
- Store Object - Make a Checkers Blockchain for general detail of how to handle your game in storage.
- Create and Save a Game Properly for how to handle the game when it is being created.
- Keep an Up-To-Date Game Deadline, where you add a small feature to your chain.
- Put Your Games in Order to see the implementation of the FIFO within the constraints of the store.
- Store leaderboard candidates in the context's transient store.
To summarize, this section has explored:
- How each keeper manages access to the subset of the blockchain state that is a given module's state, which is at the core of the Cosmos SDK's object-capabilities-based approach to protecting applications from unwanted inter-module interactions.
- How each keeper holds a
storeKey
granting unlimited access to its module's data and defines how to read and write to any store, so when one module needs to interact with another it must follow the methods of the other module's keeper. - How all Cosmos SDK applications contain a
Multistore
root state that is subdivided into compartments managed by each module and which stores all theKVStore
s of the application's modules. - How inclusion of the
AnteHandler
component is recommended to authenticate transactions before their internal messages are processed. It defends against spam and other wasteful transaction events, performs preliminary stateful validity checks, and is involved in collecting transaction fees.