db

Documentation

Index

• type DB
  • func New(localDBDir string) (*DB, error)
  • func (p *DB) AssignTask(projectID uint64, taskID common.Hash, prover common.Address) error
  • func (p *DB) CreateTask(projectID uint64, taskID common.Hash) error
  • func (p *DB) DeleteTask(projectID uint64, taskID, tx common.Hash) error
  • func (p *DB) Provers() ([]common.Address, error)
  • func (p *DB) ScannedBlockNumber() (uint64, error)
  • func (p *DB) UnassignedTask() (uint64, 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) AssignTask

func (p *DB) AssignTask(projectID uint64, taskID common.Hash, prover common.Address) error

func (*DB) CreateTask

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

func (*DB) DeleteTask

func (p *DB) DeleteTask(projectID uint64, 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) UnassignedTask

func (p *DB) UnassignedTask() (uint64, common.Hash, error)

func (*DB) UpsertProver

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

func (*DB) UpsertScannedBlockNumber

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