dao

package

v0.1.0 Latest Latest Go to latest Published: Jun 24, 2021 License: GPL-3.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/itering/subscan

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func New() (dao *Dao, storage *DbStorage)
type Dao
type DbStorage
type GormDB
type IDao

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	RedisMetadataKey           = redisKeyPrefix() + "metadata"
	RedisFillAlreadyBlockNum   = redisKeyPrefix() + "FillAlreadyBlockNum"
	RedisFillFinalizedBlockNum = redisKeyPrefix() + "FillFinalizedBlockNum"
)

View Source

var (
	DaemonAction = []string{"substrate"}
)

Functions ¶

func New ¶

func New() (dao *Dao, storage *DbStorage)

New new a dao and return.

Types ¶

type Dao ¶

type Dao struct {
	// contains filtered or unexported fields
}

dao

func (*Dao) AddIndex ¶

func (d *Dao) AddIndex(blockNum int)

func (*Dao) BlockAsJson ¶

func (d *Dao) BlockAsJson(c context.Context, block *model.ChainBlock) *model.ChainBlockJson

func (*Dao) BlocksReverseByNum ¶

func (d *Dao) BlocksReverseByNum(blockNums []int) map[int]model.ChainBlock

func (*Dao) Close ¶

func (d *Dao) Close()

Close close the resource.

func (*Dao) CreateBlock ¶

func (d *Dao) CreateBlock(txn *GormDB, cb *model.ChainBlock) (err error)

CreateBlock, mysql db transaction Check if you need to create a new table(block, extrinsic, event, log ) after created

func (*Dao) CreateEvent ¶

func (d *Dao) CreateEvent(txn *GormDB, event *model.ChainEvent) error

func (*Dao) CreateExtrinsic ¶

func (d *Dao) CreateExtrinsic(c context.Context, txn *GormDB, extrinsic *model.ChainExtrinsic) error

func (*Dao) CreateLog ¶

func (d *Dao) CreateLog(txn *GormDB, ce *model.ChainLog) error

func (*Dao) CreateRuntimeVersion ¶

func (d *Dao) CreateRuntimeVersion(name string, specVersion int) int64

func (*Dao) DaemonHeath ¶

func (d *Dao) DaemonHeath(c context.Context) map[string]bool

func (*Dao) DbBegin ¶

func (d *Dao) DbBegin() *GormDB

dao funcs

func (*Dao) DbCommit ¶

func (d *Dao) DbCommit(c *GormDB)

func (*Dao) DbRollback ¶

func (d *Dao) DbRollback(c *GormDB)

func (*Dao) DropEventNotFinalizedData ¶

func (d *Dao) DropEventNotFinalizedData(blockNum int, finalized bool) bool

func (*Dao) DropExtrinsicNotFinalizedData ¶

func (d *Dao) DropExtrinsicNotFinalizedData(c context.Context, blockNum int, finalized bool) bool

func (*Dao) DropLogsNotFinalizedData ¶

func (d *Dao) DropLogsNotFinalizedData(blockNum int, finalized bool) bool

func (*Dao) ExtrinsicsAsJson ¶

func (d *Dao) ExtrinsicsAsJson(e *model.ChainExtrinsic) *model.ChainExtrinsicJson

func (*Dao) GetBestBlockNum ¶

func (d *Dao) GetBestBlockNum(c context.Context) (uint64, error)

func (*Dao) GetBlockByHash ¶

func (d *Dao) GetBlockByHash(c context.Context, hash string) *model.ChainBlock

func (*Dao) GetBlockByNum ¶

func (d *Dao) GetBlockByNum(blockNum int) *model.ChainBlock

func (*Dao) GetBlockList ¶

func (d *Dao) GetBlockList(page, row int) []model.ChainBlock

func (*Dao) GetEventByBlockNum ¶

func (d *Dao) GetEventByBlockNum(blockNum int, where ...string) []model.ChainEventJson

func (*Dao) GetEventByIdx ¶

func (d *Dao) GetEventByIdx(index string) *model.ChainEvent

func (*Dao) GetEventList ¶

func (d *Dao) GetEventList(page, row int, order string, where ...string) ([]model.ChainEvent, int)

func (*Dao) GetEventsByIndex ¶

func (d *Dao) GetEventsByIndex(extrinsicIndex string) []model.ChainEvent

func (*Dao) GetExtrinsicList ¶

func (d *Dao) GetExtrinsicList(c context.Context, page, row int, order string, queryWhere ...string) ([]model.ChainExtrinsic, int)

func (*Dao) GetExtrinsicsByBlockNum ¶

func (d *Dao) GetExtrinsicsByBlockNum(blockNum int) []model.ChainExtrinsicJson

func (*Dao) GetExtrinsicsByHash ¶

func (d *Dao) GetExtrinsicsByHash(c context.Context, hash string) *model.ChainExtrinsic

func (*Dao) GetExtrinsicsDetailByHash ¶

func (d *Dao) GetExtrinsicsDetailByHash(c context.Context, hash string) *model.ExtrinsicDetail

func (*Dao) GetExtrinsicsDetailByIndex ¶

func (d *Dao) GetExtrinsicsDetailByIndex(c context.Context, index string) *model.ExtrinsicDetail

func (*Dao) GetFillBestBlockNum ¶

func (d *Dao) GetFillBestBlockNum(c context.Context) (num int, err error)

func (*Dao) GetFillFinalizedBlockNum ¶

func (d *Dao) GetFillFinalizedBlockNum(c context.Context) (num int, err error)

func (*Dao) GetFinalizedBlockNum ¶

func (d *Dao) GetFinalizedBlockNum(c context.Context) (uint64, error)

func (*Dao) GetLogByBlockNum ¶

func (d *Dao) GetLogByBlockNum(blockNum int) []model.ChainLogJson

func (*Dao) GetLogsByIndex ¶

func (d *Dao) GetLogsByIndex(index string) *model.ChainLogJson

func (*Dao) GetMetadata ¶

func (d *Dao) GetMetadata(c context.Context) (ms map[string]string, err error)

func (*Dao) GetNearBlock ¶

func (d *Dao) GetNearBlock(blockNum int) *model.ChainBlock

func (*Dao) IncrMetadata ¶

func (d *Dao) IncrMetadata(c context.Context, filed string, incrNum int) (err error)

func (*Dao) InternalTables ¶

func (d *Dao) InternalTables(blockNum int) (models []interface{})

func (*Dao) Migration ¶

func (d *Dao) Migration()

func (*Dao) Ping ¶

func (d *Dao) Ping(ctx context.Context) (err error)

Ping ping the resource.

func (*Dao) RuntimeVersionList ¶

func (d *Dao) RuntimeVersionList() []model.RuntimeVersion

func (*Dao) RuntimeVersionRaw ¶

func (d *Dao) RuntimeVersionRaw(spec int) *metadata.RuntimeRaw

func (*Dao) RuntimeVersionRecent ¶

func (d *Dao) RuntimeVersionRecent() *model.RuntimeVersion

func (*Dao) SaveFillAlreadyBlockNum ¶

func (d *Dao) SaveFillAlreadyBlockNum(c context.Context, blockNum int) (err error)

func (*Dao) SaveFillAlreadyFinalizedBlockNum ¶

func (d *Dao) SaveFillAlreadyFinalizedBlockNum(c context.Context, blockNum int) (err error)

func (*Dao) SetBlockFinalized ¶

func (d *Dao) SetBlockFinalized(block *model.ChainBlock)

func (*Dao) SetHeartBeatNow ¶

func (d *Dao) SetHeartBeatNow(c context.Context, action string) error

func (*Dao) SetMetadata ¶

func (d *Dao) SetMetadata(c context.Context, metadata map[string]interface{}) (err error)

func (*Dao) SetRuntimeData ¶

func (d *Dao) SetRuntimeData(specVersion int, modules string, rawData string) int64

func (*Dao) UpdateEventAndExtrinsic ¶

func (d *Dao) UpdateEventAndExtrinsic(txn *GormDB, block *model.ChainBlock, eventCount, extrinsicsCount, blockTimestamp int, validator string, codecError bool, finalized bool) error

type DbStorage ¶

type DbStorage struct {
	Prefix string
	// contains filtered or unexported fields
}

func (*DbStorage) AddIndex ¶

func (d *DbStorage) AddIndex(model interface{}, indexName string, columns ...string) error

func (*DbStorage) AddUniqueIndex ¶

func (d *DbStorage) AddUniqueIndex(model interface{}, indexName string, columns ...string) error

func (*DbStorage) AutoMigration ¶

func (d *DbStorage) AutoMigration(model interface{}) error

func (*DbStorage) Create ¶

func (d *DbStorage) Create(record interface{}) error

func (*DbStorage) Delete ¶

func (d *DbStorage) Delete(model interface{}, query interface{}) error

func (*DbStorage) FindBy ¶

func (d *DbStorage) FindBy(record interface{}, query interface{}, option *storage.Option) (int, bool)

func (*DbStorage) GetPrefix ¶

func (d *DbStorage) GetPrefix() string

func (*DbStorage) RPCPool ¶

func (d *DbStorage) RPCPool() *websocket.PoolConn

func (*DbStorage) SetPrefix ¶

func (d *DbStorage) SetPrefix(prefix string)

func (*DbStorage) SpecialMetadata ¶

func (d *DbStorage) SpecialMetadata(spec int) string

func (*DbStorage) Update ¶

func (d *DbStorage) Update(model interface{}, query interface{}, attr map[string]interface{}) error

type GormDB ¶

type GormDB struct {
	*gorm.DB
	// contains filtered or unexported fields
}

db

type IDao ¶

type IDao interface {
	Close()
	Ping(ctx context.Context) (err error)
	SetHeartBeatNow(context.Context, string) error
	DaemonHeath(context.Context) map[string]bool
	DbBegin() *GormDB
	DbCommit(*GormDB)
	DbRollback(*GormDB)
	CreateBlock(*GormDB, *model.ChainBlock) (err error)
	UpdateEventAndExtrinsic(*GormDB, *model.ChainBlock, int, int, int, string, bool, bool) error
	GetNearBlock(int) *model.ChainBlock
	SetBlockFinalized(*model.ChainBlock)
	BlocksReverseByNum([]int) map[int]model.ChainBlock
	GetBlockByHash(context.Context, string) *model.ChainBlock
	GetBlockByNum(int) *model.ChainBlock
	SaveFillAlreadyBlockNum(context.Context, int) error
	SaveFillAlreadyFinalizedBlockNum(c context.Context, blockNum int) (err error)
	GetFillBestBlockNum(c context.Context) (num int, err error)
	GetFillFinalizedBlockNum(c context.Context) (num int, err error)
	GetBlockList(page, row int) []model.ChainBlock
	BlockAsJson(c context.Context, block *model.ChainBlock) *model.ChainBlockJson
	CreateEvent(txn *GormDB, event *model.ChainEvent) error
	GetEventByBlockNum(blockNum int, where ...string) []model.ChainEventJson
	GetEventList(page, row int, order string, where ...string) ([]model.ChainEvent, int)
	GetEventsByIndex(extrinsicIndex string) []model.ChainEvent
	GetEventByIdx(index string) *model.ChainEvent
	CreateExtrinsic(c context.Context, txn *GormDB, extrinsic *model.ChainExtrinsic) error
	GetExtrinsicsByBlockNum(blockNum int) []model.ChainExtrinsicJson
	GetExtrinsicList(c context.Context, page, row int, order string, queryWhere ...string) ([]model.ChainExtrinsic, int)
	GetExtrinsicsByHash(c context.Context, hash string) *model.ChainExtrinsic
	GetExtrinsicsDetailByHash(c context.Context, hash string) *model.ExtrinsicDetail
	GetExtrinsicsDetailByIndex(c context.Context, index string) *model.ExtrinsicDetail
	ExtrinsicsAsJson(e *model.ChainExtrinsic) *model.ChainExtrinsicJson
	CreateLog(txn *GormDB, ce *model.ChainLog) error
	GetLogsByIndex(index string) *model.ChainLogJson
	GetLogByBlockNum(blockNum int) []model.ChainLogJson
	SetMetadata(c context.Context, metadata map[string]interface{}) (err error)
	IncrMetadata(c context.Context, filed string, incrNum int) (err error)
	GetMetadata(c context.Context) (ms map[string]string, err error)
	GetBestBlockNum(c context.Context) (uint64, error)
	GetFinalizedBlockNum(c context.Context) (uint64, error)
	CreateRuntimeVersion(name string, specVersion int) int64
	SetRuntimeData(specVersion int, modules string, rawData string) int64
	RuntimeVersionList() []model.RuntimeVersion
	RuntimeVersionRaw(spec int) *metadata.RuntimeRaw
	RuntimeVersionRecent() *model.RuntimeVersion
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL