check

Documentation

Index

• type Checker
  • func NewChecker(config *config.Config) (self *Checker)
  • func (self *Checker) WithInputChannel(input chan *Payload) *Checker
  • func (self *Checker) WithIrysClient(client *bundlr.Client) *Checker
  • func (self *Checker) WithMonitor(monitor monitoring.Monitor) *Checker
  • func (self *Checker) WithTurboClient(client *turbo.Client) *Checker
• type Controller
  • func NewController(config *config.Config) (self *Controller, err error)
• type Payload
• type Poller
  • func NewPoller(config *config.Config) (self *Poller)
  • func (self *Poller) WithDB(db *gorm.DB) *Poller
  • func (self *Poller) WithMonitor(monitor monitoring.Monitor) *Poller
  • func (self *Poller) WithNetworkMonitor(v *listener.NetworkMonitor) *Poller
• type Store
  • func NewStore(config *config.Config) (self *Store)
  • func (self *Store) WithDB(db *gorm.DB) *Store
  • func (self *Store) WithInputChannel(input chan *Payload) *Store
  • func (self *Store) WithMonitor(monitor monitoring.Monitor) *Store

Types

type Checker

type Checker struct {
	*task.Task

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

Periodically gets the current network height from warp's GW and confirms bundle is FINALIZED

func NewChecker

func NewChecker(config *config.Config) (self *Checker)

Receives bundles that can be checked in bundlr

func (*Checker) WithInputChannel

func (self *Checker) WithInputChannel(input chan *Payload) *Checker

func (*Checker) WithIrysClient

func (self *Checker) WithIrysClient(client *bundlr.Client) *Checker

func (*Checker) WithMonitor

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

func (*Checker) WithTurboClient

func (self *Checker) WithTurboClient(client *turbo.Client) *Checker

type Controller

type Controller struct {
	*task.Task
}

func NewController

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

Main class that orchestrates everything

type Payload

type Payload struct {
	InteractionId int
	BundlerTxId   string
	Service       model.BundlingService
	Table         string
}

type Poller

type Poller struct {
	*task.Task

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

Periodically gets the current network height from warp's GW and confirms bundle is FINALIZED

func NewPoller

func NewPoller(config *config.Config) (self *Poller)

For every network height, fetches unfinished bundles

func (*Poller) WithDB

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

func (*Poller) WithMonitor

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

func (*Poller) WithNetworkMonitor

func (self *Poller) WithNetworkMonitor(v *listener.NetworkMonitor) *Poller

type Store

type Store struct {
	*task.Hole[*Payload]
	// contains filtered or unexported fields
}

Periodically saves the states SinkTask handles caching data and periodically calling flush function

func NewStore

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

func (*Store) WithDB

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

func (*Store) WithInputChannel

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

func (*Store) WithMonitor

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