mysql

Documentation

Index

• Variables
• func FromAddress(addr *types.Address) *mysqlAddress
• func FromMessage(srcMsg *types.Message) *mysqlMessage
• func FromNode(node *types.Node) *mysqlNode
• func FromSharedParams(sp types.SharedParams) *mysqlSharedParams
• func FromWallet(msg types.Wallet) *mysqlWallet
• func FromWalletAddress(walletAddr types.WalletAddress) *mysqlWalletAddress
• func OpenMysql(cfg *config.MySqlConfig) (repo.Repo, error)
• type MsgMeta
  • func FromMeta(srcMeta *types.MsgMeta) *MsgMeta
  • func (meta *MsgMeta) Meta() *types.MsgMeta
• type MysqlRepo
  • func (d MysqlRepo) AddressRepo() repo.AddressRepo
  • func (d MysqlRepo) AutoMigrate() error
  • func (d MysqlRepo) DbClose() error
  • func (d MysqlRepo) GetDb() *gorm.DB
  • func (d MysqlRepo) MessageRepo() repo.MessageRepo
  • func (d MysqlRepo) NodeRepo() repo.NodeRepo
  • func (d MysqlRepo) SharedParamsRepo() repo.SharedParamsRepo
  • func (d MysqlRepo) Transaction(cb func(txRepo repo.TxRepo) error) error
  • func (d MysqlRepo) WalletAddressRepo() repo.WalletAddressRepo
  • func (d MysqlRepo) WalletRepo() repo.WalletRepo
• type TxMysqlRepo
  • func (t *TxMysqlRepo) AddressRepo() repo.AddressRepo
  • func (t *TxMysqlRepo) MessageRepo() repo.MessageRepo
  • func (t *TxMysqlRepo) WalletAddressRepo() repo.WalletAddressRepo
  • func (t *TxMysqlRepo) WalletRepo() repo.WalletRepo

Variables

var TAddress = reflect.TypeOf(&types.Address{})

var TMessage = reflect.TypeOf(&types.Message{})

var TMysqlAddress = reflect.TypeOf(&mysqlAddress{})

var TMysqlMessage = reflect.TypeOf(&mysqlMessage{})

var TMysqlNode = reflect.TypeOf(&mysqlNode{})

var TMysqlSharedParams = reflect.TypeOf(&mysqlSharedParams{})

var TMysqlWallet = reflect.TypeOf(&mysqlWallet{})

var TMysqlWalletAddress = reflect.TypeOf(&mysqlWalletAddress{})

var TNode = reflect.TypeOf(&types.Node{})

var TSharedParams = reflect.TypeOf(&types.SharedParams{})

var TWallet = reflect.TypeOf(&types.Wallet{})

var TWalletAddress = reflect.TypeOf(&types.WalletAddress{})

Functions

func FromAddress

func FromAddress(addr *types.Address) *mysqlAddress

func FromMessage

func FromMessage(srcMsg *types.Message) *mysqlMessage

func FromNode

func FromNode(node *types.Node) *mysqlNode

func FromSharedParams

func FromSharedParams(sp types.SharedParams) *mysqlSharedParams

func FromWallet

func FromWallet(msg types.Wallet) *mysqlWallet

func FromWalletAddress

func FromWalletAddress(walletAddr types.WalletAddress) *mysqlWalletAddress

func OpenMysql

func OpenMysql(cfg *config.MySqlConfig) (repo.Repo, error)

Types

type MsgMeta

type MsgMeta struct {
	ExpireEpoch       abi.ChainEpoch `gorm:"column:expire_epoch;type:bigint;"`
	GasOverEstimation float64        `gorm:"column:gas_over_estimation;type:decimal(10,2);"`
	MaxFee            types.Int      `gorm:"column:max_fee;type:varchar(256);"`
	MaxFeeCap         types.Int      `gorm:"column:max_fee_cap;type:varchar(256);"`
}

func FromMeta

func FromMeta(srcMeta *types.MsgMeta) *MsgMeta

func (*MsgMeta) Meta

func (meta *MsgMeta) Meta() *types.MsgMeta

type MysqlRepo

type MysqlRepo struct {
	*gorm.DB
}

func (MysqlRepo) AddressRepo

func (d MysqlRepo) AddressRepo() repo.AddressRepo

func (MysqlRepo) AutoMigrate

func (d MysqlRepo) AutoMigrate() error

func (MysqlRepo) DbClose

func (d MysqlRepo) DbClose() error

func (MysqlRepo) GetDb

func (d MysqlRepo) GetDb() *gorm.DB

func (MysqlRepo) MessageRepo

func (d MysqlRepo) MessageRepo() repo.MessageRepo

func (MysqlRepo) NodeRepo

func (d MysqlRepo) NodeRepo() repo.NodeRepo

func (MysqlRepo) SharedParamsRepo

func (d MysqlRepo) SharedParamsRepo() repo.SharedParamsRepo

func (MysqlRepo) Transaction

func (d MysqlRepo) Transaction(cb func(txRepo repo.TxRepo) error) error

func (MysqlRepo) WalletAddressRepo

func (d MysqlRepo) WalletAddressRepo() repo.WalletAddressRepo

func (MysqlRepo) WalletRepo

func (d MysqlRepo) WalletRepo() repo.WalletRepo

type TxMysqlRepo

type TxMysqlRepo struct {
	*gorm.DB
}

func (*TxMysqlRepo) AddressRepo

func (t *TxMysqlRepo) AddressRepo() repo.AddressRepo

func (*TxMysqlRepo) MessageRepo

func (t *TxMysqlRepo) MessageRepo() repo.MessageRepo

func (*TxMysqlRepo) WalletAddressRepo

func (t *TxMysqlRepo) WalletAddressRepo() repo.WalletAddressRepo

func (*TxMysqlRepo) WalletRepo

func (t *TxMysqlRepo) WalletRepo() repo.WalletRepo