load

Documentation

Index

• type BlockDownloader
  • func NewBlockDownloader(config *config.Config) (self *BlockDownloader)
  • func (self *BlockDownloader) GetNewestBlock() *arweave.Block
  • func (self *BlockDownloader) WithClient(client *arweave.Client) *BlockDownloader
  • func (self *BlockDownloader) WithInputChannel(v chan *arweave.NetworkInfo) *BlockDownloader
• type Controller
  • func NewController(config *config.Config) (self *Controller, err error)
• type Generator
  • func NewGenerator(config *config.Config) (self *Generator)
• type Parser
  • func NewParser(config *config.Config) (self *Parser)
  • func (self *Parser) WithBlockDownloader(v *BlockDownloader) *Parser
  • func (self *Parser) WithInputChannel(v chan *arweave.Transaction) *Parser
• type Payload
• 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

Types

type BlockDownloader

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

Gets the latest block

func NewBlockDownloader

func NewBlockDownloader(config *config.Config) (self *BlockDownloader)

func (*BlockDownloader) GetNewestBlock

func (self *BlockDownloader) GetNewestBlock() *arweave.Block

func (*BlockDownloader) WithClient

func (self *BlockDownloader) WithClient(client *arweave.Client) *BlockDownloader

func (*BlockDownloader) WithInputChannel

func (self *BlockDownloader) WithInputChannel(v chan *arweave.NetworkInfo) *BlockDownloader

type Controller

type Controller struct {
	*task.Task
}

func NewController

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

Main class that orchestrates functionalities

type Generator

type Generator struct {
	*task.Task

	Output chan *arweave.Transaction
	// contains filtered or unexported fields
}

Generates fake transactions

func NewGenerator

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

type Parser

type Parser struct {
	*task.Task

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

Generates fake transactions

func NewParser

func NewParser(config *config.Config) (self *Parser)

func (*Parser) WithBlockDownloader

func (self *Parser) WithBlockDownloader(v *BlockDownloader) *Parser

func (*Parser) WithInputChannel

func (self *Parser) WithInputChannel(v chan *arweave.Transaction) *Parser

type Payload

type Payload struct {
	Interaction *model.Interaction
	BundleItem  *model.BundleItem
}

type Store

type Store struct {
	*task.SinkTask[*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