timerstore

README

x/timerstore

Abstract

This document specifies the timerstore module of Lava Protocol.

This module primarily serves as a utility for other modules in the Lava Protocol. It's not designed for direct user interaction, except for a limited set of queries intended for debugging. As such, it functions as an essential support utility within the protocol's ecosystem.

The timerstore allows other modules to create timers, that triggers callback functions.
A timer defined in this module can be one of two types: BlockHeight or BlockTime.
The BlockHeight timers operate based on block counts, while BlockTime timers are measured in seconds. The callback function can be triggered either at BeginBlock or EndBlock.

Contents

• Concepts
  • Creating the TimerStore
    • TimerStore Object
    • Initialization Methods
    • Setting Callbacks
  • Using the TimerStore
    • Overview of Timer Usage
    • Timer Types
    • Adding Timers to TimerStore
    • Timer Lifecycle
• Parameters
• Queries
• Transactions
• Proposals

Concepts

Creating the TimerStore

TimerStore Object

The core of this module is the TimerStore object, encapsulating all essential logic:

type Keeper struct {
	timerStoresBegin []*timerstoretypes.TimerStore
	timerStoresEnd   []*timerstoretypes.TimerStore
	cdc              codec.BinaryCodec
}

This structure reflects the dual nature of timer triggers: at the beginning or end of a block.

Initialization Methods

To initialize a TimerStore, use NewTimerStoreBeginBlock or NewTimerStoreEndBlock. These methods set up the store to trigger timers at either the start or end of a block, respectively.

Setting Callbacks

Callbacks are set using WithCallbackByBlockHeight for block-height-based timers or WithCallbackByBlockTime for time-based timers. These methods link the specified callback function to the timer, ensuring it's executed at the right moment.

Note: The following code snippet demonstrates a common pattern used in the initialization of a timer in the codebase. This approach typically involves creating a TimerStore instance and immediately configuring its callback function, streamlining the setup process:

callbackFunction := func(ctx sdk.Context, key, data []byte) {
	// callback logic here
}

timerStore := timerStoreKeeper.NewTimerStoreBeginBlock(storeKey, timerPrefix).
	WithCallbackByBlockTime(callbackFunction)

Note on Timer Keys and Data:

• Subkey as Timer Identifier: The key argument in the callback function refers to the timer's subkey. It's important to note that this subkey does not need to be unique across all timers. The timerstore module internally manages a unique primary key for each timer, ensuring distinct identification.
• Data Attachment: The data argument allows for attaching relevant information to the timer. This data is then accessible when the callback function is triggered, enabling context-specific actions based on the timer's purpose.

Using the TimerStore

Overview of Timer Usage

After establishing the TimerStore, it's used to create and manage individual timers. This section delves into the operational aspect of the TimerStore.

Timer Types

There are two types of timers:

• BlockHeight timers trigger based on the count of blocks.
• BlockTime timers operate based on elapsed time in seconds.

Each type serves different use cases, offering flexibility in scheduling tasks.

Adding Timers to TimerStore

Timers are added to the TimerStore via AddTimerByBlockHeight and AddTimerByBlockTime. These functions create timers that will trigger either at a specified block height or after a set time:

// Add a BlockHeight timer
AddTimerByBlockHeight(ctx sdk.Context, block uint64, key, data []byte)

// Add a BlockTime timer
AddTimerByBlockTime(ctx sdk.Context, timestamp uint64, key, data []byte)

When using AddTimerByBlockHeight and AddTimerByBlockTime, it's important to understand the key argument is the timer's subkey, which doesn't need to be unique. The unique primary key of each timer is internally managed by the timerstore. The data argument is for attaching additional information to the timer, available when the callback is triggered.

Timer Lifecycle

Once set, a timer remains active until triggered, after which it's automatically deleted. For recurring events, it's necessary to create a new timer each time.

Parameters

The timerstore module does not contain parameters.

Queries

The timerstore module supports the following queries:

Query	Arguments	What it does
all-timers	store-key (string), prefix (string)	Shows all timers of a specific timer store
next	store-key (string), prefix (string)	Shows the next timeout of a specific timer store
store-keys	none	Shows all timer store keys and prefixes

Transactions

The timerstore module does not support any transaction.

Proposals

The timerstore module does not support any proposals.

Documentation

Index

• Constants
• type AppModule
  • func NewAppModule(k *timerstorekeeper.Keeper) AppModule
  • func (a AppModule) BeginBlock(context sdk.Context, _ abci.RequestBeginBlock)
  • func (a AppModule) ConsensusVersion() uint64
  • func (a AppModule) EndBlock(context sdk.Context, _ abci.RequestEndBlock) []abci.ValidatorUpdate
  • func (am AppModule) RegisterServices(cfg module.Configurator)
• type AppModuleBasic
  • func (a AppModuleBasic) GetQueryCmd() *cobra.Command
  • func (a AppModuleBasic) GetTxCmd() *cobra.Command
  • func (a AppModuleBasic) Name() string
  • func (a AppModuleBasic) RegisterGRPCGatewayRoutes(_ client.Context, _ *runtime.ServeMux)
  • func (a AppModuleBasic) RegisterInterfaces(_ cdctypes.InterfaceRegistry)
  • func (a AppModuleBasic) RegisterLegacyAminoCodec(_ *codec.LegacyAmino)

Constants

const (
	ConsensusVersion = 1
)

Types

type AppModule

type AppModule struct {
	AppModuleBasic
	// contains filtered or unexported fields
}

func NewAppModule

func NewAppModule(k *timerstorekeeper.Keeper) AppModule

func (AppModule) BeginBlock

func (a AppModule) BeginBlock(context sdk.Context, _ abci.RequestBeginBlock)

func (AppModule) ConsensusVersion

func (a AppModule) ConsensusVersion() uint64

func (AppModule) EndBlock

func (a AppModule) EndBlock(context sdk.Context, _ abci.RequestEndBlock) []abci.ValidatorUpdate

EndBlock executes all ABCI EndBlock logic respective to the capability module. It returns no validator updates.

func (AppModule) RegisterServices

func (am AppModule) RegisterServices(cfg module.Configurator)

RegisterServices registers a GRPC query service to respond to the module-specific GRPC queries.

type AppModuleBasic

type AppModuleBasic struct{}

AppModuleBasic implements the module.AppModuleBasic interface for the downtime module.

func (AppModuleBasic) GetQueryCmd

func (a AppModuleBasic) GetQueryCmd() *cobra.Command

func (AppModuleBasic) GetTxCmd

func (a AppModuleBasic) GetTxCmd() *cobra.Command

func (AppModuleBasic) Name

func (a AppModuleBasic) Name() string

func (AppModuleBasic) RegisterGRPCGatewayRoutes

func (a AppModuleBasic) RegisterGRPCGatewayRoutes(_ client.Context, _ *runtime.ServeMux)

func (AppModuleBasic) RegisterInterfaces

func (a AppModuleBasic) RegisterInterfaces(_ cdctypes.InterfaceRegistry)

func (AppModuleBasic) RegisterLegacyAminoCodec

func (a AppModuleBasic) RegisterLegacyAminoCodec(_ *codec.LegacyAmino)