postgres

Documentation

Index

• type Postgres
  • func New(pgEndpoint string) (*Postgres, error)
  • func (p *Postgres) BlockNumber() (uint64, error)
  • func (p *Postgres) ChainHead() (uint64, common.Hash, error)
  • func (p *Postgres) Create(tl *task.StateLog, t *task.Task) error
  • func (p *Postgres) Fetch(taskID, projectID uint64) ([]*task.StateLog, error)
  • func (p *Postgres) NBits() (uint32, error)
  • func (p *Postgres) ProcessedTaskID(projectID uint64) (uint64, error)
  • func (p *Postgres) UpsertBlockNumber(number uint64) error
  • func (p *Postgres) UpsertNBits(nbits uint32) error
  • func (p *Postgres) UpsertPrevHash(number uint64, 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) ChainHead

func (p *Postgres) ChainHead() (uint64, common.Hash, error)

func (*Postgres) Create

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

func (*Postgres) Fetch

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

func (*Postgres) NBits

func (p *Postgres) NBits() (uint32, error)

func (*Postgres) ProcessedTaskID

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

func (*Postgres) UpsertBlockNumber

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

func (*Postgres) UpsertNBits

func (p *Postgres) UpsertNBits(nbits uint32) error

func (*Postgres) UpsertPrevHash

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

func (*Postgres) UpsertProcessedTask

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