submitter

Documentation

Index

• Constants
• type DataHandler
  • func NewDataHandler(daoManager *dao.DaoManager, executor *executor.Executor) *DataHandler
  • func (h *DataHandler) FetchEventsForSubmit(currentHeight uint64) ([]*model.Event, error)
  • func (h *DataHandler) FetchVotesForAggregation(eventHash string) ([]*model.Vote, error)
  • func (h *DataHandler) UpdateEventStatus(challengeId uint64, status model.EventStatus) error
• type DataProvider
• type TxSubmitter
  • func NewTxSubmitter(cfg *config.Config, executor *executor.Executor, ...) *TxSubmitter
  • func (s *TxSubmitter) SubmitTransactionLoop()

Constants

const (
	CacheSize            = 300
	TimeFormat           = "15:04:05.00"
	TxSubmitLoopInterval = 5 * time.Second        // query last attested challenge id
	TxSubmitInterval     = 100 * time.Millisecond // query last attested challenge id
)

Types

type DataHandler

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

func NewDataHandler

func NewDataHandler(daoManager *dao.DaoManager, executor *executor.Executor) *DataHandler

func (*DataHandler) FetchEventsForSubmit

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

func (*DataHandler) FetchVotesForAggregation

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

func (*DataHandler) UpdateEventStatus

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

type DataProvider

type DataProvider interface {
	FetchEventsForSubmit(currentHeight uint64) ([]*model.Event, error)
	FetchVotesForAggregation(eventHash string) ([]*model.Vote, error)
	UpdateEventStatus(challengeId uint64, status model.EventStatus) error
}

type TxSubmitter

type TxSubmitter struct {
	DataProvider
	// contains filtered or unexported fields
}

func NewTxSubmitter

func NewTxSubmitter(cfg *config.Config, executor *executor.Executor, submitterDataProvider DataProvider) *TxSubmitter

func (*TxSubmitter) SubmitTransactionLoop

func (s *TxSubmitter) SubmitTransactionLoop()

SubmitTransactionLoop polls for submitter inturn and fetches events for submit.