interact

Documentation

Index

• type Checker
  • func NewChecker(config *config.Config) (self *Checker)
  • func (self *Checker) WithDb(db *gorm.DB) *Checker
  • func (self *Checker) WithInputChannel(input <-chan *Payload) *Checker
  • func (self *Checker) WithMonitor(monitor monitoring.Monitor) *Checker
• type Controller
  • func NewController(config *config.Config) (self *Controller, err error)
• type Generator
  • func NewGenerator(config *config.Config) (self *Generator)
  • func (self *Generator) WithClient(v *sequencer.Client) *Generator
  • func (self *Generator) WithMonitor(monitor monitoring.Monitor) *Generator
• type Input
• type Payload
• type Sender
  • func NewSender(config *config.Config) (self *Sender)
  • func (self *Sender) WithClient(client *sequencer.Client) *Sender
  • func (self *Sender) WithInputChannel(input <-chan *Payload) *Sender
  • func (self *Sender) WithMonitor(monitor monitoring.Monitor) *Sender

Types

type Checker

type Checker struct {
	*task.Task
	// 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) WithDb

func (self *Checker) WithDb(db *gorm.DB) *Checker

func (*Checker) WithInputChannel

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

func (*Checker) WithMonitor

func (self *Checker) WithMonitor(monitor monitoring.Monitor) *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 Generator

type Generator 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 NewGenerator

func NewGenerator(config *config.Config) (self *Generator)

For every network height, fetches unfinished bundles

func (*Generator) WithClient

func (self *Generator) WithClient(v *sequencer.Client) *Generator

func (*Generator) WithMonitor

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

type Input

type Input struct {
	Timestamp time.Time `json:"t"`
}

type Payload

type Payload struct {
	DataItem  *bundlr.BundleItem
	Timestamp time.Time
}

type Sender

type Sender struct {
	*task.Task

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

Sends data item to sequencer

func NewSender

func NewSender(config *config.Config) (self *Sender)

Receives bundles that can be checked in bundlr

func (*Sender) WithClient

func (self *Sender) WithClient(client *sequencer.Client) *Sender

func (*Sender) WithInputChannel

func (self *Sender) WithInputChannel(input <-chan *Payload) *Sender

func (*Sender) WithMonitor

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