everpay_sync

Documentation

Index

• Variables
• type EverPaySync
  • func New(dsn string, seedUrl string) *EverPaySync
  • func (e *EverPaySync) FetchArIds()
  • func (e *EverPaySync) PostToArseeding()
  • func (e *EverPaySync) Run()
• type RollupArId
• type Wdb
  • func NewWdb(dsn string) *Wdb
  • func (w *Wdb) GetArIds(fromId int) ([]RollupArId, error)
  • func (w *Wdb) GetLastPostTx() (RollupArId, error)
  • func (w *Wdb) GetNeedPostTxs() ([]RollupArId, error)
  • func (w *Wdb) Insert(arIds []*RollupArId) error
  • func (w *Wdb) UpdatePosted(arId string) error

Variables

var (
	ErrNotNeedSync = errors.New("not need sync")
)

Types

type EverPaySync

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

function: sync everpay rollup txs to arseeding

func New

func New(dsn string, seedUrl string) *EverPaySync

func (*EverPaySync) FetchArIds

func (e *EverPaySync) FetchArIds()

func (*EverPaySync) PostToArseeding

func (e *EverPaySync) PostToArseeding()

func (*EverPaySync) Run

func (e *EverPaySync) Run()

type RollupArId

type RollupArId struct {
	gorm.Model
	ArId string `gorm:"index:idx01"`
	Post bool
}

type Wdb

type Wdb struct {
	Db *gorm.DB
}

func NewWdb

func NewWdb(dsn string) *Wdb

func (*Wdb) GetArIds

func (w *Wdb) GetArIds(fromId int) ([]RollupArId, error)

func (*Wdb) GetLastPostTx

func (w *Wdb) GetLastPostTx() (RollupArId, error)

func (*Wdb) GetNeedPostTxs

func (w *Wdb) GetNeedPostTxs() ([]RollupArId, error)

func (*Wdb) Insert

func (w *Wdb) Insert(arIds []*RollupArId) error

func (*Wdb) UpdatePosted

func (w *Wdb) UpdatePosted(arId string) error