Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
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 (*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 (*Store) WithInputChannel ¶
func (self *Store) WithInputChannel(input chan *model.ContractSource) *Store
func (*Store) WithMonitor ¶
func (self *Store) WithMonitor(monitor monitoring.Monitor) *Store
Source Files
Click to show internal directories.
Click to hide internal directories.