mysql

Documentation

Index

• Variables
• type Database
  • func New(connection, tablePrefix string, multiStatements bool, maxPacket uint32) (*Database, error)
  • func (d *Database) Available() bool
  • func (d *Database) DuplicateError(err error) bool
  • func (d *Database) GetDeposit(id uint64) (*types.Deposit, error)
  • func (d *Database) GetEnqueuedDeposits(max uint16) ([]*types.Deposit, error)
  • func (d *Database) GetSetting(k, def string) (string, error)
  • func (d *Database) GetWallet(user mint.PublicKey) (*types.Wallet, error)
  • func (d *Database) MaxPacketError(err error) bool
  • func (d *Database) PutDeposit(v *types.Deposit) (dup bool, err error)
  • func (d *Database) PutSetting(k, v string) error
  • func (d *Database) PutWallet(v *types.Wallet) (dup bool, err error)
  • func (d *Database) UpdateDeposit(v *types.Deposit) error
  • func (d *Database) UpdateWallet(v *types.Wallet) error

Variables

var Migrations = []*gormigrate.Migration{

	&gormigrate.Migration{
		ID: "2019-09-02T11:39:31.802Z",
		Migrate: func(tx *gorm.DB) error {
			return tx.
				CreateTable(&model.Setting{}).
				CreateTable(&model.Wallet{}).
				CreateTable(&model.Deposit{}).
				AddIndex("ix_deposit_status", "status").
				AddIndex("ix_deposit_nextcheckat", "next_check_at").
				AddUniqueIndex("ux_deposit_src_tx", "src", "tx").
				Error
		},
		Rollback: func(tx *gorm.DB) error {
			return tx.
				DropTable(&model.Setting{}).
				DropTable(&model.Wallet{}).
				DropTable(&model.Deposit{}).
				Error
		},
	},
}

Migrations array

Types

type Database

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

Database data

func New

func New(connection, tablePrefix string, multiStatements bool, maxPacket uint32) (*Database, error)

New instance

func (*Database) Available

func (d *Database) Available() bool

Available impl.

func (*Database) DuplicateError

func (d *Database) DuplicateError(err error) bool

DuplicateError impl.

func (*Database) GetDeposit

func (d *Database) GetDeposit(id uint64) (*types.Deposit, error)

GetDeposit implementation

func (*Database) GetEnqueuedDeposits

func (d *Database) GetEnqueuedDeposits(max uint16) ([]*types.Deposit, error)

GetEnqueuedDeposits implementation

func (*Database) GetSetting

func (d *Database) GetSetting(k, def string) (string, error)

GetSetting implementation

func (*Database) GetWallet

func (d *Database) GetWallet(user mint.PublicKey) (*types.Wallet, error)

GetWallet implementation

func (*Database) MaxPacketError

func (d *Database) MaxPacketError(err error) bool

MaxPacketError impl.

func (*Database) PutDeposit

func (d *Database) PutDeposit(v *types.Deposit) (dup bool, err error)

PutDeposit implementation

func (*Database) PutSetting

func (d *Database) PutSetting(k, v string) error

PutSetting implementation

func (*Database) PutWallet

func (d *Database) PutWallet(v *types.Wallet) (dup bool, err error)

PutWallet implementation

func (*Database) UpdateDeposit

func (d *Database) UpdateDeposit(v *types.Deposit) error

UpdateDeposit implementation

func (*Database) UpdateWallet

func (d *Database) UpdateWallet(v *types.Wallet) error

UpdateWallet implementation