attest

Documentation

Index

• Constants
• type AttestMonitor
  • func NewAttestMonitor(executor *executor.Executor, dataProvider DataProvider, ...) *AttestMonitor
  • func (a *AttestMonitor) UpdateAttestedChallengeIdLoop()
• type DataHandler
  • func NewDataHandler(daoManager *dao.DaoManager) *DataHandler
  • func (h *DataHandler) GetEventByChallengeId(challengeId uint64) (*model.Event, error)
  • func (h *DataHandler) UpdateEventStatus(challengeId uint64, status model.EventStatus) error
• type DataProvider

Constants

const (
	QueryAttestedChallengeInterval = 10 * time.Second // query last attested challenge id
	MaxQueryCount                  = 3000
)

Types

type AttestMonitor

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

func NewAttestMonitor

func NewAttestMonitor(executor *executor.Executor, dataProvider DataProvider, metricService *metrics.MetricService) *AttestMonitor

func (*AttestMonitor) UpdateAttestedChallengeIdLoop

func (a *AttestMonitor) UpdateAttestedChallengeIdLoop()

UpdateAttestedChallengeIdLoop polls the blockchain for latest attested challengeIds and updates their status

type DataHandler

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

func NewDataHandler

func NewDataHandler(daoManager *dao.DaoManager) *DataHandler

func (*DataHandler) GetEventByChallengeId

func (h *DataHandler) GetEventByChallengeId(challengeId uint64) (*model.Event, error)

func (*DataHandler) UpdateEventStatus

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

type DataProvider

type DataProvider interface {
	GetEventByChallengeId(challengeId uint64) (*model.Event, error)
	UpdateEventStatus(challengeId uint64, status model.EventStatus) error
}