db

Documentation

Index

• type DB
  • func New(localDBDir string) (*DB, error)
  • func (p *DB) AssignTasks(ids []common.Hash) error
  • func (p *DB) CreateTask(taskID common.Hash) error
  • func (p *DB) DeleteTask(taskID, tx common.Hash) error
  • func (p *DB) Provers() ([]common.Address, error)
  • func (p *DB) ScannedBlockNumber() (uint64, error)
  • func (p *DB) UnassignedTasks(limit int) ([]common.Hash, error)
  • func (p *DB) UpsertProver(addr common.Address) error
  • func (p *DB) UpsertScannedBlockNumber(number uint64) error

Types

type DB

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

func New

func New(localDBDir string) (*DB, error)

func (*DB) AssignTasks

func (p *DB) AssignTasks(ids []common.Hash) error

func (*DB) CreateTask

func (p *DB) CreateTask(taskID common.Hash) error

func (*DB) DeleteTask

func (p *DB) DeleteTask(taskID, tx common.Hash) error

func (*DB) Provers

func (p *DB) Provers() ([]common.Address, error)

func (*DB) ScannedBlockNumber

func (p *DB) ScannedBlockNumber() (uint64, error)

func (*DB) UnassignedTasks

func (p *DB) UnassignedTasks(limit int) ([]common.Hash, error)

func (*DB) UpsertProver

func (p *DB) UpsertProver(addr common.Address) error

func (*DB) UpsertScannedBlockNumber

func (p *DB) UpsertScannedBlockNumber(number uint64) error