dao

Documentation

Index

• func GetDBConn(c *conf.Config) *sql.DB
• func GetRedisClient(c *conf.Config) *redis.Client
• type Dao
  • func NEW(c *conf.Config) (dao *Dao)
  • func (d *Dao) AddFChainTx(f *model.FChainTx) (err error)
  • func (d *Dao) AddMChainTx(m *model.MChainTx) (err error)
  • func (d *Dao) AddMChainTxByFTx(m *model.MChainTx) (err error)
  • func (d *Dao) AddTChainTx(t *model.TChainTx) (err error)
  • func (d *Dao) AddTChainTxByMTx(t *model.TChainTx) (err error)
  • func (d *Dao) BeginTran() (*sql.Tx, error)
  • func (d *Dao) CacheFChainTx(txHash string) (f *model.FChainTx, err error)
  • func (d *Dao) CacheMChainTx(txHash string) (m *model.MChainTx, err error)
  • func (d *Dao) CacheMChainTxByFTx(fTxHash string) (m *model.MChainTx, err error)
  • func (d *Dao) CacheTChainTx(txHash string) (t *model.TChainTx, err error)
  • func (d *Dao) CacheTChainTxByMTx(mTxHash string) (m *model.TChainTx, err error)
  • func (d *Dao) Close()
  • func (d *Dao) FChainTx(txHash string, chain uint32) (res *model.FChainTx, err error)
  • func (d *Dao) InsertFChainTx(f *model.FChainTx) (err error)
  • func (d *Dao) InsertFChainTxAndCache(f *model.FChainTx) (err error)
  • func (d *Dao) InsertMChainTx(m *model.MChainTx) (err error)
  • func (d *Dao) InsertMChainTxAndCache(m *model.MChainTx) (err error)
  • func (d *Dao) InsertPolyValidator(height uint32, validators []string) (err error)
  • func (d *Dao) InsertTChainTx(t *model.TChainTx) (err error)
  • func (d *Dao) InsertTChainTxAndCache(t *model.TChainTx) (err error)
  • func (d *Dao) MChainTx(txHash string) (res *model.MChainTx, err error)
  • func (d *Dao) MChainTxByFTx(fTxHash string) (res *model.MChainTx, err error)
  • func (d *Dao) Ping() (err error)
  • func (d *Dao) SelectAddressTxList(chainId uint32, addr string, start uint32, end uint32) (res []*model.AddressTx, err error)
  • func (d *Dao) SelectAddressTxTotal(chainId uint32, addr string) (count *uint32, err error)
  • func (d *Dao) SelectAllChainInfos() (c []*model.ChainInfo, err error)
  • func (d *Dao) SelectAllianceTx(height uint32, chain uint32) (res []*model.MChainTx, err error)
  • func (d *Dao) SelectBitcoinTxUnConfirm(id uint32) (res []string, err error)
  • func (d *Dao) SelectChainAddresses(chainId uint32) (uint32, error)
  • func (d *Dao) SelectChainInfoById(id uint32) (res *model.ChainInfo, err error)
  • func (d *Dao) SelectContractById(id uint32) (c []*model.ChainContract, err error)
  • func (d *Dao) SelectFChainTxByHash(hash string, chain uint32) (res *model.FChainTx, err error)
  • func (d *Dao) SelectFChainTxByTime(chainId uint32, start uint32, end uint32) (res []*model.CrossChainTxStatus, err error)
  • func (d *Dao) SelectMChainTxByFHash(hash string) (res *model.MChainTx, err error)
  • func (d *Dao) SelectMChainTxByHash(hash string) (res *model.MChainTx, err error)
  • func (d *Dao) SelectMChainTxByLimit(start int, limit int) (res []*model.MChainTx, err error)
  • func (d *Dao) SelectMChainTxCount() (count *uint32, err error)
  • func (d *Dao) SelectPolyValidator() (validator []string, err error)
  • func (d *Dao) SelectTChainTxByHash(hash string) (res *model.TChainTx, err error)
  • func (d *Dao) SelectTChainTxByMHash(hash string) (res *model.TChainTx, err error)
  • func (d *Dao) SelectTChainTxByTime(chainId uint32, start uint32, end uint32) (res []*model.CrossChainTxStatus, err error)
  • func (d *Dao) SelectTokenById(id uint32) (c []*model.ChainToken, err error)
  • func (d *Dao) SelectTokenCount() (count *uint32, err error)
  • func (d *Dao) SelectTokenTxList(token string, start uint32, end uint32) (res []*model.TokenTx, err error)
  • func (d *Dao) SelectTokenTxTotal(token string) (count *uint32, err error)
  • func (d *Dao) TChainTx(txHash string) (res *model.TChainTx, err error)
  • func (d *Dao) TChainTxByMTx(txHash string) (res *model.TChainTx, err error)
  • func (d *Dao) TxInsertFChainTx(tx *sql.Tx, f *model.FChainTx) (err error)
  • func (d *Dao) TxInsertFChainTxAndCache(tx *sql.Tx, f *model.FChainTx) (err error)
  • func (d *Dao) TxInsertMChainTx(tx *sql.Tx, m *model.MChainTx) (err error)
  • func (d *Dao) TxInsertMChainTxAndCache(tx *sql.Tx, m *model.MChainTx) (err error)
  • func (d *Dao) TxInsertTChainTx(tx *sql.Tx, t *model.TChainTx) (err error)
  • func (d *Dao) TxInsertTChainTxAndCache(tx *sql.Tx, t *model.TChainTx) (err error)
  • func (d *Dao) TxUpdateChainInfoById(tx *sql.Tx, c *model.ChainInfo) (err error)
  • func (d *Dao) UpdateBitcoinTxConfirmed(txhash string, height uint32, tt uint32, gas uint64, toaddress string, ...) (err error)

Functions

func GetDBConn

func GetDBConn(c *conf.Config) *sql.DB

func GetRedisClient

func GetRedisClient(c *conf.Config) *redis.Client

Types

type Dao

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

func NEW

func NEW(c *conf.Config) (dao *Dao)

func (*Dao) AddFChainTx

func (d *Dao) AddFChainTx(f *model.FChainTx) (err error)

func (*Dao) AddMChainTx

func (d *Dao) AddMChainTx(m *model.MChainTx) (err error)

func (*Dao) AddMChainTxByFTx

func (d *Dao) AddMChainTxByFTx(m *model.MChainTx) (err error)

func (*Dao) AddTChainTx

func (d *Dao) AddTChainTx(t *model.TChainTx) (err error)

func (*Dao) AddTChainTxByMTx

func (d *Dao) AddTChainTxByMTx(t *model.TChainTx) (err error)

func (*Dao) BeginTran

func (d *Dao) BeginTran() (*sql.Tx, error)

func (*Dao) CacheFChainTx

func (d *Dao) CacheFChainTx(txHash string) (f *model.FChainTx, err error)

func (*Dao) CacheMChainTx

func (d *Dao) CacheMChainTx(txHash string) (m *model.MChainTx, err error)

func (*Dao) CacheMChainTxByFTx

func (d *Dao) CacheMChainTxByFTx(fTxHash string) (m *model.MChainTx, err error)

func (*Dao) CacheTChainTx

func (d *Dao) CacheTChainTx(txHash string) (t *model.TChainTx, err error)

func (*Dao) CacheTChainTxByMTx

func (d *Dao) CacheTChainTxByMTx(mTxHash string) (m *model.TChainTx, err error)

func (*Dao) Close

func (d *Dao) Close()

func (*Dao) FChainTx

func (d *Dao) FChainTx(txHash string, chain uint32) (res *model.FChainTx, err error)

func (*Dao) InsertFChainTx

func (d *Dao) InsertFChainTx(f *model.FChainTx) (err error)

func (*Dao) InsertFChainTxAndCache

func (d *Dao) InsertFChainTxAndCache(f *model.FChainTx) (err error)

func (*Dao) InsertMChainTx

func (d *Dao) InsertMChainTx(m *model.MChainTx) (err error)

func (*Dao) InsertMChainTxAndCache

func (d *Dao) InsertMChainTxAndCache(m *model.MChainTx) (err error)

func (*Dao) InsertPolyValidator

func (d *Dao) InsertPolyValidator(height uint32, validators []string) (err error)

func (*Dao) InsertTChainTx

func (d *Dao) InsertTChainTx(t *model.TChainTx) (err error)

func (*Dao) InsertTChainTxAndCache

func (d *Dao) InsertTChainTxAndCache(t *model.TChainTx) (err error)

func (*Dao) MChainTx

func (d *Dao) MChainTx(txHash string) (res *model.MChainTx, err error)

func (*Dao) MChainTxByFTx

func (d *Dao) MChainTxByFTx(fTxHash string) (res *model.MChainTx, err error)

func (*Dao) Ping

func (d *Dao) Ping() (err error)

func (*Dao) SelectAddressTxList

func (d *Dao) SelectAddressTxList(chainId uint32, addr string, start uint32, end uint32) (res []*model.AddressTx, err error)

func (*Dao) SelectAddressTxTotal

func (d *Dao) SelectAddressTxTotal(chainId uint32, addr string) (count *uint32, err error)

func (*Dao) SelectAllChainInfos

func (d *Dao) SelectAllChainInfos() (c []*model.ChainInfo, err error)

func (*Dao) SelectAllianceTx

func (d *Dao) SelectAllianceTx(height uint32, chain uint32) (res []*model.MChainTx, err error)

func (*Dao) SelectBitcoinTxUnConfirm

func (d *Dao) SelectBitcoinTxUnConfirm(id uint32) (res []string, err error)

func (*Dao) SelectChainAddresses

func (d *Dao) SelectChainAddresses(chainId uint32) (uint32, error)

func (*Dao) SelectChainInfoById

func (d *Dao) SelectChainInfoById(id uint32) (res *model.ChainInfo, err error)

func (*Dao) SelectContractById

func (d *Dao) SelectContractById(id uint32) (c []*model.ChainContract, err error)

func (*Dao) SelectFChainTxByHash

func (d *Dao) SelectFChainTxByHash(hash string, chain uint32) (res *model.FChainTx, err error)

func (*Dao) SelectFChainTxByTime

func (d *Dao) SelectFChainTxByTime(chainId uint32, start uint32, end uint32) (res []*model.CrossChainTxStatus, err error)

func (*Dao) SelectMChainTxByFHash

func (d *Dao) SelectMChainTxByFHash(hash string) (res *model.MChainTx, err error)

func (*Dao) SelectMChainTxByHash

func (d *Dao) SelectMChainTxByHash(hash string) (res *model.MChainTx, err error)

func (*Dao) SelectMChainTxByLimit

func (d *Dao) SelectMChainTxByLimit(start int, limit int) (res []*model.MChainTx, err error)

func (*Dao) SelectMChainTxCount

func (d *Dao) SelectMChainTxCount() (count *uint32, err error)

func (*Dao) SelectPolyValidator

func (d *Dao) SelectPolyValidator() (validator []string, err error)

func (*Dao) SelectTChainTxByHash

func (d *Dao) SelectTChainTxByHash(hash string) (res *model.TChainTx, err error)

func (*Dao) SelectTChainTxByMHash

func (d *Dao) SelectTChainTxByMHash(hash string) (res *model.TChainTx, err error)

func (*Dao) SelectTChainTxByTime

func (d *Dao) SelectTChainTxByTime(chainId uint32, start uint32, end uint32) (res []*model.CrossChainTxStatus, err error)

func (*Dao) SelectTokenById

func (d *Dao) SelectTokenById(id uint32) (c []*model.ChainToken, err error)

func (*Dao) SelectTokenCount

func (d *Dao) SelectTokenCount() (count *uint32, err error)

func (*Dao) SelectTokenTxList

func (d *Dao) SelectTokenTxList(token string, start uint32, end uint32) (res []*model.TokenTx, err error)

func (*Dao) SelectTokenTxTotal

func (d *Dao) SelectTokenTxTotal(token string) (count *uint32, err error)

func (*Dao) TChainTx

func (d *Dao) TChainTx(txHash string) (res *model.TChainTx, err error)

func (*Dao) TChainTxByMTx

func (d *Dao) TChainTxByMTx(txHash string) (res *model.TChainTx, err error)

func (*Dao) TxInsertFChainTx

func (d *Dao) TxInsertFChainTx(tx *sql.Tx, f *model.FChainTx) (err error)

func (*Dao) TxInsertFChainTxAndCache

func (d *Dao) TxInsertFChainTxAndCache(tx *sql.Tx, f *model.FChainTx) (err error)

func (*Dao) TxInsertMChainTx

func (d *Dao) TxInsertMChainTx(tx *sql.Tx, m *model.MChainTx) (err error)

func (*Dao) TxInsertMChainTxAndCache

func (d *Dao) TxInsertMChainTxAndCache(tx *sql.Tx, m *model.MChainTx) (err error)

func (*Dao) TxInsertTChainTx

func (d *Dao) TxInsertTChainTx(tx *sql.Tx, t *model.TChainTx) (err error)

func (*Dao) TxInsertTChainTxAndCache

func (d *Dao) TxInsertTChainTxAndCache(tx *sql.Tx, t *model.TChainTx) (err error)

func (*Dao) TxUpdateChainInfoById

func (d *Dao) TxUpdateChainInfoById(tx *sql.Tx, c *model.ChainInfo) (err error)

func (*Dao) UpdateBitcoinTxConfirmed

func (d *Dao) UpdateBitcoinTxConfirmed(txhash string, height uint32, tt uint32, gas uint64, toaddress string, amount uint64) (err error)