monitor

Documentation

Index

• func Run(h *Handler, addr *ContractAddr, beginningBlockNumber uint64, ...) error
• type AssignTask
• type ContractAddr
• type Handler
• type ScannedBlockNumber
• type SettleTask
• type UpsertProject
• type UpsertProjectDevice
• type UpsertProver
• type UpsertScannedBlockNumber

Functions

func Run

func Run(h *Handler, addr *ContractAddr, beginningBlockNumber uint64, chainEndpoint string) error

Types

type AssignTask

type AssignTask func(taskID common.Hash, prover common.Address, projectID string) error

type ContractAddr

type ContractAddr struct {
	Prover      common.Address
	Project     common.Address
	Minter      common.Address
	TaskManager common.Address
	IoID        common.Address
}

type Handler

type Handler struct {
	ScannedBlockNumber
	UpsertScannedBlockNumber
	AssignTask
	SettleTask
	UpsertProject
	UpsertProver
	UpsertProjectDevice
}

type ScannedBlockNumber

type ScannedBlockNumber func() (uint64, error)

type SettleTask

type SettleTask func(taskID, tx common.Hash) error

type UpsertProject

type UpsertProject func(projectID string, uri string, hash common.Hash) error

type UpsertProjectDevice

type UpsertProjectDevice func(projectID string, address common.Address) error

type UpsertProver

type UpsertProver func(addr common.Address) error

type UpsertScannedBlockNumber

type UpsertScannedBlockNumber func(number uint64) error