db

Documentation

Index

• type DB
  • func New(localDBDir string, prover common.Address) (*DB, error)
  • func (p *DB) CreateTask(projectID uint64, taskID common.Hash, prover common.Address) error
  • func (p *DB) DeleteTask(projectID uint64, taskID common.Hash) error
  • func (p *DB) ProcessTask(projectID uint64, taskID common.Hash) error
  • func (p *DB) Project(projectID uint64) (string, common.Hash, error)
  • func (p *DB) ProjectFile(projectID uint64) ([]byte, common.Hash, error)
  • func (p *DB) ScannedBlockNumber() (uint64, error)
  • func (p *DB) UnprocessedTask() (uint64, common.Hash, error)
  • func (p *DB) UpsertProject(projectID uint64, uri string, hash common.Hash) error
  • func (p *DB) UpsertProjectFile(projectID uint64, file []byte, hash common.Hash) 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, prover common.Address) (*DB, error)

func (*DB) CreateTask

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

func (*DB) DeleteTask

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

func (*DB) ProcessTask

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

func (*DB) Project

func (p *DB) Project(projectID uint64) (string, common.Hash, error)

func (*DB) ProjectFile

func (p *DB) ProjectFile(projectID uint64) ([]byte, common.Hash, error)

func (*DB) ScannedBlockNumber

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

func (*DB) UnprocessedTask

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

func (*DB) UpsertProject

func (p *DB) UpsertProject(projectID uint64, uri string, hash common.Hash) error

func (*DB) UpsertProjectFile

func (p *DB) UpsertProjectFile(projectID uint64, file []byte, hash common.Hash) error

func (*DB) UpsertScannedBlockNumber

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