sequencer

May 23, 2024

Changes in this version

+ type GetQueryCtxFn func(height int64, prove bool) (sdk.Context, error)

type Option

+ func WithRouterKey(key string) Option

type Sequencer

+ func New(shardKeeper *keeper.Keeper, queryCtxGetter GetQueryCtxFn, opts ...Option) *Sequencer

+ func (s *Sequencer) QueryTransactions(_ context.Context, request *shard.QueryTransactionsRequest) (*shard.QueryTransactionsResponse, error)

+ func (s *Sequencer) RegisterGameShard(_ context.Context, req *shard.RegisterGameShardRequest) (*shard.RegisterGameShardResponse, error)

type TxQueue

+ func (tc *TxQueue) AddInitMsg(namespace, routerAddr string)

+ func (tc *TxQueue) FlushInitQueue() []*namespacetypes.UpdateNamespaceRequest

+ func (tc *TxQueue) FlushTxQueue() []*types.SubmitShardTxRequest

Feb 8, 2024

Changes in this version

+ var Name = "shard_sequencer"

+ type Option func(*Sequencer)

+ func WithCredentials(certPath, keyPath string) Option

+ type Sequencer struct

+ func NewShardSequencer(opts ...Option) *Sequencer

+ func (s *Sequencer) FlushMessages() []*types.SubmitShardTxRequest

+ func (s *Sequencer) Serve()

+ func (s *Sequencer) Submit(_ context.Context, req *shard.SubmitTransactionsRequest) (*shard.SubmitTransactionsResponse, error)

+ type TxQueue struct

+ func NewTxQueue(moduleAddr string) *TxQueue

+ func (tc *TxQueue) AddTx(namespace string, epoch, unixTimestamp, txID uint64, payload []byte)

+ func (tc *TxQueue) GetTxs() []*types.SubmitShardTxRequest