forward

package

v0.2.11 Latest Latest Go to latest Published: Aug 9, 2023 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ArweaveFetcher struct {
	*task.Task

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

Gets L1 (Arweave) interactions from the DB in batches Fills in last_sort_key for each interaction before emiting to the output channel

func NewArweaveFetcher(config *config.Config) (self *ArweaveFetcher)

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

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

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

type Controller struct {
	*task.Task
}

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

type InteractionStreamer struct {
	*task.Task

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

Produces current syncer's height

func NewInteractionStreamer(config *config.Config) (self *InteractionStreamer)

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

type Payload struct {
	First       bool
	Last        bool
	Interaction *model.Interaction
}

func (self *Payload) IsFirst() bool

func (self *Payload) IsLast() bool

type Sequencer struct {
	*task.Task

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

Produces current syncer's height

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

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

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