fixsortkey

Documentation

Index

• type Controller
  • func NewController(config *config.Config, startBlockHeight, stopBlockHeight uint64) (self *Controller, err error)
• type Processor
  • func NewProcessor(config *config.Config) (self *Processor)
  • func (self *Processor) WithDB(db *gorm.DB) *Processor
  • func (self *Processor) WithInputChannel(input chan uint64) *Processor
• type Sequencer
  • func NewSequencer(config *config.Config) (self *Sequencer)
  • func (self *Sequencer) WithDB(db *gorm.DB) *Sequencer
  • func (self *Sequencer) WithStart(height uint64) *Sequencer
  • func (self *Sequencer) WithStop(height uint64) *Sequencer

Types

type Controller

type Controller struct {
	*task.Task
}

func NewController

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

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

type Processor

type Processor struct {
	*task.Task
	// contains filtered or unexported fields
}

Gets all interactions per block from the database Updates sort key for each interaction Updates last sort key for each interaction that was pointing to the old sort key

func NewProcessor

func NewProcessor(config *config.Config) (self *Processor)

func (*Processor) WithDB

func (self *Processor) WithDB(db *gorm.DB) *Processor

func (*Processor) WithInputChannel

func (self *Processor) WithInputChannel(input chan uint64) *Processor

type Sequencer

type Sequencer struct {
	*task.Task

	// Current Syncer's block height
	Output chan uint64
	// contains filtered or unexported fields
}

Produces network info in a sequential order, but only from the specified range

func NewSequencer

func NewSequencer(config *config.Config) (self *Sequencer)

func (*Sequencer) WithDB

func (self *Sequencer) WithDB(db *gorm.DB) *Sequencer

func (*Sequencer) WithStart

func (self *Sequencer) WithStart(height uint64) *Sequencer

func (*Sequencer) WithStop

func (self *Sequencer) WithStop(height uint64) *Sequencer