db

Documentation

Index

• type DB
  • func New(localDBDir string, prover common.Address) (*DB, error)
  • func (p *DB) CreateTask(taskID common.Hash, prover common.Address, projectID string) error
  • func (p *DB) DeleteTask(taskID, tx common.Hash) error
  • func (p *DB) ProcessTasks(taskIDs []common.Hash, err error) error
  • func (p *DB) ProcessedTask(taskID common.Hash) (bool, string, time.Time, error)
  • func (p *DB) Project(projectID string) (string, common.Hash, error)
  • func (p *DB) ProjectFile(projectID string) ([]byte, common.Hash, error)
  • func (p *DB) ScannedBlockNumber() (uint64, error)
  • func (p *DB) UnprocessedProjects() (map[string]uint64, error)
  • func (p *DB) UnprocessedTasks(projectID string) ([]common.Hash, error)
  • func (p *DB) UpsertProject(projectID string, uri string, hash common.Hash) error
  • func (p *DB) UpsertProjectFile(projectID string, 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(taskID common.Hash, prover common.Address, projectID string) error

func (*DB) DeleteTask

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

func (*DB) ProcessTasks

func (p *DB) ProcessTasks(taskIDs []common.Hash, err error) error

func (*DB) ProcessedTask

func (p *DB) ProcessedTask(taskID common.Hash) (bool, string, time.Time, error)

func (*DB) Project

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

func (*DB) ProjectFile

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

func (*DB) ScannedBlockNumber

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

func (*DB) UnprocessedProjects

func (p *DB) UnprocessedProjects() (map[string]uint64, error)

func (*DB) UnprocessedTasks

func (p *DB) UnprocessedTasks(projectID string) ([]common.Hash, error)

func (*DB) UpsertProject

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

func (*DB) UpsertProjectFile

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

func (*DB) UpsertScannedBlockNumber

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