verifier

Documentation

Index

• Variables
• type DataHandler
  • func NewDataHandler(daoManager *dao.DaoManager) *DataHandler
  • func (h *DataHandler) FetchEventsForVerification(currentHeight uint64) ([]*model.Event, error)
  • func (h *DataHandler) FetchVotesForAggregation(eventHash string) ([]*model.Vote, error)
  • func (h *DataHandler) IsEventExistsBetween(objectId string, spOperatorAddr string, fromChallengeId uint64, ...) (bool, error)
  • func (h *DataHandler) UpdateEventStatus(challengeId uint64, status model.EventStatus) error
  • func (h *DataHandler) UpdateEventStatusVerifyResult(challengeId uint64, status model.EventStatus, verifyResult model.VerifyResult) error
• type DataProvider
• type Verifier
  • func NewHashVerifier(cfg *config.Config, executor *executor.Executor, dataProvider DataProvider, ...) *Verifier
  • func (v *Verifier) VerifyHashLoop()

Variables

var UpdateDeduplicationInterval = 24 * time.Hour

var VerifyHashLoopInterval = 2 * time.Second

Types

type DataHandler

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

func NewDataHandler

func NewDataHandler(daoManager *dao.DaoManager) *DataHandler

func (*DataHandler) FetchEventsForVerification

func (h *DataHandler) FetchEventsForVerification(currentHeight uint64) ([]*model.Event, error)

func (*DataHandler) FetchVotesForAggregation

func (h *DataHandler) FetchVotesForAggregation(eventHash string) ([]*model.Vote, error)

func (*DataHandler) IsEventExistsBetween

func (h *DataHandler) IsEventExistsBetween(objectId string, spOperatorAddr string, fromChallengeId uint64, toChallengeId uint64) (bool, error)

func (*DataHandler) UpdateEventStatus

func (h *DataHandler) UpdateEventStatus(challengeId uint64, status model.EventStatus) error

func (*DataHandler) UpdateEventStatusVerifyResult

func (h *DataHandler) UpdateEventStatusVerifyResult(challengeId uint64, status model.EventStatus, verifyResult model.VerifyResult) error

type DataProvider

type DataProvider interface {
	FetchEventsForVerification(currentHeight uint64) ([]*model.Event, error)
	UpdateEventStatusVerifyResult(challengeId uint64, status model.EventStatus, verifyResult model.VerifyResult) error
	UpdateEventStatus(challengeId uint64, status model.EventStatus) error
	IsEventExistsBetween(objectId string, spOperatorAddr string, fromChallengeId uint64, toChallengeId uint64) (bool, error)
}

type Verifier

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

func NewHashVerifier

func NewHashVerifier(cfg *config.Config, executor *executor.Executor, dataProvider DataProvider, metricService *metrics.MetricService,
) *Verifier

func (*Verifier) VerifyHashLoop

func (v *Verifier) VerifyHashLoop()