evolve

Documentation

Index

• type Controller
  • func NewController(config *config.Config) (self *Controller, err error)
• type Downloader
  • func NewDownloader(config *config.Config) (self *Downloader)
  • func (self *Downloader) WithClient(client *arweave.Client) *Downloader
  • func (self *Downloader) WithInputChannel(v chan string) *Downloader
  • func (self *Downloader) WithMonitor(monitor monitoring.Monitor) *Downloader
• 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
• type Store
  • func NewStore(config *config.Config) (self *Store)
  • func (self *Store) WithDB(db *gorm.DB) *Store
  • func (self *Store) WithInputChannel(input chan *model.ContractSource) *Store
  • func (self *Store) WithMonitor(monitor monitoring.Monitor) *Store

Types

type Controller

type Controller struct {
	*task.Task
}

func NewController

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

type Downloader

type Downloader struct {
	*task.Task

	Output chan *model.ContractSource
	// contains filtered or unexported fields
}

func NewDownloader

func NewDownloader(config *config.Config) (self *Downloader)

func (*Downloader) WithClient

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

func (*Downloader) WithInputChannel

func (self *Downloader) WithInputChannel(v chan string) *Downloader

func (*Downloader) WithMonitor

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

type Poller

type Poller struct {
	*task.Task

	// Evolve to be sent out
	Output chan string
	// contains filtered or unexported fields
}

Periodically gets new evolved contract sources which are not yet in the db

func NewPoller

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

func (*Poller) WithDB

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

func (*Poller) WithMonitor

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

type Store

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

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 *model.ContractSource) *Store

func (*Store) WithMonitor

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