forward

Documentation

Index

• type ArweaveFetcher
  • 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
  • func NewController(config *config.Config) (self *Controller, err error)
• type InteractionStreamer
  • func NewInteractionStreamer(config *config.Config) (self *InteractionStreamer)
  • func (self *InteractionStreamer) WithMonitor(monitor monitoring.Monitor) *InteractionStreamer
• type Notification
• type Payload
  • func (self *Payload) IsFirst() bool
  • func (self *Payload) IsLast() bool
• type Sequencer
  • func NewSequencer(config *config.Config) (self *Sequencer)
  • func (self *Sequencer) WithDB(db *gorm.DB) *Sequencer
  • func (self *Sequencer) WithMonitor(monitor monitoring.Monitor) *Sequencer

Types

type ArweaveFetcher

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

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

func (*ArweaveFetcher) WithDB

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

func (*ArweaveFetcher) WithInputChannel

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

func (*ArweaveFetcher) WithMonitor

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

type Controller

type Controller struct {
	*task.Task
}

func NewController

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

type InteractionStreamer

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

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

func (*InteractionStreamer) WithMonitor

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

type Notification

type Notification struct {
	Interaction pgtype.JSONB `json:"interaction"`
	ContractId  string       `json:"contractId"`
	SrcTxId     string       `json:"srcTxId"`
}

type Payload

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

func (*Payload) IsFirst

func (self *Payload) IsFirst() bool

func (*Payload) IsLast

func (self *Payload) IsLast() bool

type Sequencer

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

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

func (*Sequencer) WithDB

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

func (*Sequencer) WithMonitor

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