sync

Documentation

Index

• type Controller
  • func NewController(config *config.Config, startBlockHeight, stopBlockHeight uint64, ...) (self *Controller, err error)
• type Parser
  • 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 Store
  • 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

Types

type Controller

type Controller struct {
	*task.Task
}

func NewController

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

Main class that orchestrates main syncer functionalities Setups listening and storing interactions

type Parser

type Parser struct {
	*task.Task

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

Gets contract's source and init state

func NewParser

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

Converts Arweave transactions into Warp's contracts

func (*Parser) WithInputChannel

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

func (*Parser) WithMonitor

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

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

func (*Store) WithDB

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

func (*Store) WithInputChannel

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

func (*Store) WithMonitor

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

func (*Store) WithReplaceExistingData

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