postgres

Documentation

Index

• type Postgres
  • func New(pgEndpoint string) (*Postgres, error)
  • func (p *Postgres) BlockNumber() (uint64, error)
  • func (p *Postgres) Create(tl *task.StateLog, t *task.Task) error
  • func (p *Postgres) Difficulty() ([4]byte, error)
  • func (p *Postgres) Fetch(taskID, projectID uint64) ([]*task.StateLog, error)
  • func (p *Postgres) PrevHash() (common.Hash, error)
  • func (p *Postgres) ProcessedTaskID(projectID uint64) (uint64, error)
  • func (p *Postgres) UpsertBlockNumber(number uint64) error
  • func (p *Postgres) UpsertDifficulty(difficulty [4]byte) error
  • func (p *Postgres) UpsertPrevHash(hash common.Hash) error
  • func (p *Postgres) UpsertProcessedTask(projectID, taskID uint64) error

Types

type Postgres

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

func New

func New(pgEndpoint string) (*Postgres, error)

func (*Postgres) BlockNumber

func (p *Postgres) BlockNumber() (uint64, error)

func (*Postgres) Create

func (p *Postgres) Create(tl *task.StateLog, t *task.Task) error

func (*Postgres) Difficulty

func (p *Postgres) Difficulty() ([4]byte, error)

func (*Postgres) Fetch

func (p *Postgres) Fetch(taskID, projectID uint64) ([]*task.StateLog, error)

func (*Postgres) PrevHash

func (p *Postgres) PrevHash() (common.Hash, error)

func (*Postgres) ProcessedTaskID

func (p *Postgres) ProcessedTaskID(projectID uint64) (uint64, error)

func (*Postgres) UpsertBlockNumber

func (p *Postgres) UpsertBlockNumber(number uint64) error

func (*Postgres) UpsertDifficulty

func (p *Postgres) UpsertDifficulty(difficulty [4]byte) error

func (*Postgres) UpsertPrevHash

func (p *Postgres) UpsertPrevHash(hash common.Hash) error

func (*Postgres) UpsertProcessedTask

func (p *Postgres) UpsertProcessedTask(projectID, taskID uint64) error