Versions in this module Expand all Collapse all v0 v0.1.0 Jun 24, 2021 Changes in this version + var DaemonAction = []string + var RedisFillAlreadyBlockNum = redisKeyPrefix() + "FillAlreadyBlockNum" + var RedisFillFinalizedBlockNum = redisKeyPrefix() + "FillFinalizedBlockNum" + var RedisMetadataKey = redisKeyPrefix() + "metadata" + func New() (dao *Dao, storage *DbStorage) + type Dao struct + func (d *Dao) AddIndex(blockNum int) + func (d *Dao) BlockAsJson(c context.Context, block *model.ChainBlock) *model.ChainBlockJson + func (d *Dao) BlocksReverseByNum(blockNums []int) map[int]model.ChainBlock + func (d *Dao) Close() + func (d *Dao) CreateBlock(txn *GormDB, cb *model.ChainBlock) (err error) + func (d *Dao) CreateEvent(txn *GormDB, event *model.ChainEvent) error + func (d *Dao) CreateExtrinsic(c context.Context, txn *GormDB, extrinsic *model.ChainExtrinsic) error + func (d *Dao) CreateLog(txn *GormDB, ce *model.ChainLog) error + func (d *Dao) CreateRuntimeVersion(name string, specVersion int) int64 + func (d *Dao) DaemonHeath(c context.Context) map[string]bool + func (d *Dao) DbBegin() *GormDB + func (d *Dao) DbCommit(c *GormDB) + func (d *Dao) DbRollback(c *GormDB) + func (d *Dao) DropEventNotFinalizedData(blockNum int, finalized bool) bool + func (d *Dao) DropExtrinsicNotFinalizedData(c context.Context, blockNum int, finalized bool) bool + func (d *Dao) DropLogsNotFinalizedData(blockNum int, finalized bool) bool + func (d *Dao) ExtrinsicsAsJson(e *model.ChainExtrinsic) *model.ChainExtrinsicJson + func (d *Dao) GetBestBlockNum(c context.Context) (uint64, error) + func (d *Dao) GetBlockByHash(c context.Context, hash string) *model.ChainBlock + func (d *Dao) GetBlockByNum(blockNum int) *model.ChainBlock + func (d *Dao) GetBlockList(page, row int) []model.ChainBlock + func (d *Dao) GetEventByBlockNum(blockNum int, where ...string) []model.ChainEventJson + func (d *Dao) GetEventByIdx(index string) *model.ChainEvent + func (d *Dao) GetEventList(page, row int, order string, where ...string) ([]model.ChainEvent, int) + func (d *Dao) GetEventsByIndex(extrinsicIndex string) []model.ChainEvent + func (d *Dao) GetExtrinsicList(c context.Context, page, row int, order string, queryWhere ...string) ([]model.ChainExtrinsic, int) + func (d *Dao) GetExtrinsicsByBlockNum(blockNum int) []model.ChainExtrinsicJson + func (d *Dao) GetExtrinsicsByHash(c context.Context, hash string) *model.ChainExtrinsic + func (d *Dao) GetExtrinsicsDetailByHash(c context.Context, hash string) *model.ExtrinsicDetail + func (d *Dao) GetExtrinsicsDetailByIndex(c context.Context, index string) *model.ExtrinsicDetail + func (d *Dao) GetFillBestBlockNum(c context.Context) (num int, err error) + func (d *Dao) GetFillFinalizedBlockNum(c context.Context) (num int, err error) + func (d *Dao) GetFinalizedBlockNum(c context.Context) (uint64, error) + func (d *Dao) GetLogByBlockNum(blockNum int) []model.ChainLogJson + func (d *Dao) GetLogsByIndex(index string) *model.ChainLogJson + func (d *Dao) GetMetadata(c context.Context) (ms map[string]string, err error) + func (d *Dao) GetNearBlock(blockNum int) *model.ChainBlock + func (d *Dao) IncrMetadata(c context.Context, filed string, incrNum int) (err error) + func (d *Dao) InternalTables(blockNum int) (models []interface{}) + func (d *Dao) Migration() + func (d *Dao) Ping(ctx context.Context) (err error) + func (d *Dao) RuntimeVersionList() []model.RuntimeVersion + func (d *Dao) RuntimeVersionRaw(spec int) *metadata.RuntimeRaw + func (d *Dao) RuntimeVersionRecent() *model.RuntimeVersion + func (d *Dao) SaveFillAlreadyBlockNum(c context.Context, blockNum int) (err error) + func (d *Dao) SaveFillAlreadyFinalizedBlockNum(c context.Context, blockNum int) (err error) + func (d *Dao) SetBlockFinalized(block *model.ChainBlock) + func (d *Dao) SetHeartBeatNow(c context.Context, action string) error + func (d *Dao) SetMetadata(c context.Context, metadata map[string]interface{}) (err error) + func (d *Dao) SetRuntimeData(specVersion int, modules string, rawData string) int64 + func (d *Dao) UpdateEventAndExtrinsic(txn *GormDB, block *model.ChainBlock, ...) error + type DbStorage struct + Prefix string + func (d *DbStorage) AddIndex(model interface{}, indexName string, columns ...string) error + func (d *DbStorage) AddUniqueIndex(model interface{}, indexName string, columns ...string) error + func (d *DbStorage) AutoMigration(model interface{}) error + func (d *DbStorage) Create(record interface{}) error + func (d *DbStorage) Delete(model interface{}, query interface{}) error + func (d *DbStorage) FindBy(record interface{}, query interface{}, option *storage.Option) (int, bool) + func (d *DbStorage) GetPrefix() string + func (d *DbStorage) RPCPool() *websocket.PoolConn + func (d *DbStorage) SetPrefix(prefix string) + func (d *DbStorage) SpecialMetadata(spec int) string + func (d *DbStorage) Update(model interface{}, query interface{}, attr map[string]interface{}) error + type GormDB struct + type IDao interface + BlockAsJson func(c context.Context, block *model.ChainBlock) *model.ChainBlockJson + BlocksReverseByNum func([]int) map[int]model.ChainBlock + Close func() + CreateBlock func(*GormDB, *model.ChainBlock) (err error) + CreateEvent func(txn *GormDB, event *model.ChainEvent) error + CreateExtrinsic func(c context.Context, txn *GormDB, extrinsic *model.ChainExtrinsic) error + CreateLog func(txn *GormDB, ce *model.ChainLog) error + CreateRuntimeVersion func(name string, specVersion int) int64 + DaemonHeath func(context.Context) map[string]bool + DbBegin func() *GormDB + DbCommit func(*GormDB) + DbRollback func(*GormDB) + ExtrinsicsAsJson func(e *model.ChainExtrinsic) *model.ChainExtrinsicJson + GetBestBlockNum func(c context.Context) (uint64, error) + GetBlockByHash func(context.Context, string) *model.ChainBlock + GetBlockByNum func(int) *model.ChainBlock + GetBlockList func(page, row int) []model.ChainBlock + GetEventByBlockNum func(blockNum int, where ...string) []model.ChainEventJson + GetEventByIdx func(index string) *model.ChainEvent + GetEventList func(page, row int, order string, where ...string) ([]model.ChainEvent, int) + GetEventsByIndex func(extrinsicIndex string) []model.ChainEvent + GetExtrinsicList func(c context.Context, page, row int, order string, queryWhere ...string) ([]model.ChainExtrinsic, int) + GetExtrinsicsByBlockNum func(blockNum int) []model.ChainExtrinsicJson + GetExtrinsicsByHash func(c context.Context, hash string) *model.ChainExtrinsic + GetExtrinsicsDetailByHash func(c context.Context, hash string) *model.ExtrinsicDetail + GetExtrinsicsDetailByIndex func(c context.Context, index string) *model.ExtrinsicDetail + GetFillBestBlockNum func(c context.Context) (num int, err error) + GetFillFinalizedBlockNum func(c context.Context) (num int, err error) + GetFinalizedBlockNum func(c context.Context) (uint64, error) + GetLogByBlockNum func(blockNum int) []model.ChainLogJson + GetLogsByIndex func(index string) *model.ChainLogJson + GetMetadata func(c context.Context) (ms map[string]string, err error) + GetNearBlock func(int) *model.ChainBlock + IncrMetadata func(c context.Context, filed string, incrNum int) (err error) + Ping func(ctx context.Context) (err error) + RuntimeVersionList func() []model.RuntimeVersion + RuntimeVersionRaw func(spec int) *metadata.RuntimeRaw + RuntimeVersionRecent func() *model.RuntimeVersion + SaveFillAlreadyBlockNum func(context.Context, int) error + SaveFillAlreadyFinalizedBlockNum func(c context.Context, blockNum int) (err error) + SetBlockFinalized func(*model.ChainBlock) + SetHeartBeatNow func(context.Context, string) error + SetMetadata func(c context.Context, metadata map[string]interface{}) (err error) + SetRuntimeData func(specVersion int, modules string, rawData string) int64 + UpdateEventAndExtrinsic func(*GormDB, *model.ChainBlock, int, int, int, string, bool, bool) error