sync

type Controller ¶

type Controller struct {
	*task.Task
}

func NewController(config *config.Config, startBlockHeight, stopBlockHeight uint64, replaceExisting bool) (self *Controller, err error)

type Parser ¶

type Parser struct {
	*task.Task

	Output chan *Payload
	// contains filtered or unexported fields
}

Gets contract's source and init state

func NewParser(config *config.Config) (self *Parser)

func (self *Parser) WithInputChannel(v chan *listener.Payload) *Parser

func (self *Parser) WithMonitor(monitor monitoring.Monitor) *Parser

type Payload ¶

type Payload struct {
	BlockHeight    uint64
	BlockHash      arweave.Base64String
	BlockTimestamp uint64
	Interactions   []*model.Interaction
}

type Store ¶

type Store struct {
	*task.Processor[*Payload, *model.Interaction]

	DB *gorm.DB
	// contains filtered or unexported fields
}

Store handles saving data to the database in na robust way. - groups incoming Interactions into batches, - ensures data isn't stuck even if a batch isn't big enough

func NewStore(config *config.Config) (self *Store)

func (self *Store) WithDB(v *gorm.DB) *Store

func (self *Store) WithInputChannel(v chan *Payload) *Store

func (self *Store) WithMonitor(v monitoring.Monitor) *Store

func (self *Store) WithReplaceExistingData(replace bool) *Store