gloomberg

Documentation

Index

• Variables
• func GasTicker(gasTicker *time.Ticker, providerPool *provider.Pool, queueOutput chan string)
• type Gloomberg
  • func New() *Gloomberg
  • func (m Gloomberg) CreatePeriodicTask(name string, runEvery time.Duration, run func(*Gloomberg))
  • func (m Gloomberg) CreateScheduledTask(name string, runAt time.Time, run func(*Gloomberg))
  • func (gb *Gloomberg) Pr(message string)
  • func (gb *Gloomberg) PrDMod(mod string, message string)
  • func (gb *Gloomberg) PrDModf(mod string, format string, a ...any)
  • func (gb *Gloomberg) PrMod(mod string, message string)
  • func (gb *Gloomberg) PrModf(mod string, format string, a ...any)
  • func (gb *Gloomberg) PrVMod(mod string, message string)
  • func (gb *Gloomberg) PrVModf(mod string, format string, a ...any)
  • func (gb *Gloomberg) PrWarn(message string)
  • func (gb *Gloomberg) PrWithKeywordAndIcon(icon string, keyword string, message string)
  • func (gb *Gloomberg) Prf(format string, a ...any)
  • func (gb *Gloomberg) SendSlugsToServer()
  • func (eh Gloomberg) SubscribNewBlocks() chan uint64
  • func (eh Gloomberg) SubscribeCollectionOffer() chan *models.CollectionOffer
  • func (eh Gloomberg) SubscribeItemListed() chan *models.ItemListed
  • func (eh Gloomberg) SubscribeItemReceivedBid() chan *models.ItemReceivedBid
  • func (eh Gloomberg) SubscribePrintToTerminal() chan string
  • func (eh Gloomberg) SubscribeSeawatcherMgmt() chan *models.MgmtEvent
  • func (eh Gloomberg) SubscribeTokenTransactions() chan *totra.TokenTransaction
  • func (eh Gloomberg) SubscribeTxWithLogs() chan *chawagoModels.TxWithLogs
• type Stats
  • func NewStats(gb *Gloomberg, gasTicker *time.Ticker, wallets *wallet.Wallets, ...) *Stats
  • func (s *Stats) AddEvent(eventType degendb.EventType, amountTokens int64, value *big.Int)
  • func (s *Stats) Print(queueOutput chan string)
  • func (s *Stats) StartTicker(intervalPrintStats time.Duration, queueOutput chan string)
  • func (s *Stats) UpdateBalances() (*wallet.Wallets, error)

Variables

var ErrWalletBalance = fmt.Errorf("error fetching wallet balance")

ErrWalletBalance given for issues while fetching wallet balances.

Functions

func GasTicker

func GasTicker(gasTicker *time.Ticker, providerPool *provider.Pool, queueOutput chan string)

Types

type Gloomberg

type Gloomberg struct {
	// Nodes        *nodes.Nodes
	ProviderPool *provider.Pool
	Watcher      *watch.Watcher

	CollectionDB *collections.CollectionDB
	OwnWallets   *wallet.Wallets
	Stats        *Stats

	Ranks map[common.Address]map[int64]degendb.TokenRank

	Rdb    rueidis.Client
	Rueidi *rueidica.Rueidica

	QueueSlugs chan common.Address
	// contains filtered or unexported fields
}

func New

func New() *Gloomberg

func (Gloomberg) CreatePeriodicTask

func (m Gloomberg) CreatePeriodicTask(name string, runEvery time.Duration, run func(*Gloomberg))

func (Gloomberg) CreateScheduledTask

func (m Gloomberg) CreateScheduledTask(name string, runAt time.Time, run func(*Gloomberg))

func (*Gloomberg) Pr

func (gb *Gloomberg) Pr(message string)

Pr prints messages from gloomberg to the terminal.

func (*Gloomberg) PrDMod

func (gb *Gloomberg) PrDMod(mod string, message string)

PrDMod prints messages from gloomberg to the terminal if debug mode is enabled.

func (*Gloomberg) PrDModf

func (gb *Gloomberg) PrDModf(mod string, format string, a ...any)

PrDModf formats and prints messages from gloomberg to the terminal if debug mode is enabled.

func (*Gloomberg) PrMod

func (gb *Gloomberg) PrMod(mod string, message string)

func (*Gloomberg) PrModf

func (gb *Gloomberg) PrModf(mod string, format string, a ...any)

PrModf formats and prints messages from gloomberg to the terminal.

func (*Gloomberg) PrVMod

func (gb *Gloomberg) PrVMod(mod string, message string)

PrVMod prints messages from gloomberg to the terminal if verbose mode is enabled.

func (*Gloomberg) PrVModf

func (gb *Gloomberg) PrVModf(mod string, format string, a ...any)

PrVModf formats and prints messages from gloomberg to the terminal if verbose mode is enabled.

func (*Gloomberg) PrWarn

func (gb *Gloomberg) PrWarn(message string)

func (*Gloomberg) PrWithKeywordAndIcon

func (gb *Gloomberg) PrWithKeywordAndIcon(icon string, keyword string, message string)

func (*Gloomberg) Prf

func (gb *Gloomberg) Prf(format string, a ...any)

Prf formats and prints messages from gloomberg to the terminal.

func (*Gloomberg) SendSlugsToServer

func (gb *Gloomberg) SendSlugsToServer()

func (Gloomberg) SubscribNewBlocks

func (eh Gloomberg) SubscribNewBlocks() chan uint64

func (Gloomberg) SubscribeCollectionOffer

func (eh Gloomberg) SubscribeCollectionOffer() chan *models.CollectionOffer

func (Gloomberg) SubscribeItemListed

func (eh Gloomberg) SubscribeItemListed() chan *models.ItemListed

func (Gloomberg) SubscribeItemReceivedBid

func (eh Gloomberg) SubscribeItemReceivedBid() chan *models.ItemReceivedBid

func (Gloomberg) SubscribePrintToTerminal

func (eh Gloomberg) SubscribePrintToTerminal() chan string

func (Gloomberg) SubscribeSeawatcherMgmt

func (eh Gloomberg) SubscribeSeawatcherMgmt() chan *models.MgmtEvent

func (Gloomberg) SubscribeTokenTransactions

func (eh Gloomberg) SubscribeTokenTransactions() chan *totra.TokenTransaction

func (Gloomberg) SubscribeTxWithLogs

func (eh Gloomberg) SubscribeTxWithLogs() chan *chawagoModels.TxWithLogs

type Stats

type Stats struct {
	RecentEvents mapset.Set[*degendb.RecentEvent]

	OwnEventsHistory []string
	EventHistory     []*totra.HistoryTokenTransaction

	NewLogs        uint64
	NewListings    uint64
	EventsToFormat uint64
	OutputLines    uint64
	// contains filtered or unexported fields
}

func NewStats

func NewStats(gb *Gloomberg, gasTicker *time.Ticker, wallets *wallet.Wallets, providerPool *provider.Pool, rdb rueidis.Client) *Stats

func (*Stats) AddEvent

func (s *Stats) AddEvent(eventType degendb.EventType, amountTokens int64, value *big.Int)

func (*Stats) Print

func (s *Stats) Print(queueOutput chan string)

func (*Stats) StartTicker

func (s *Stats) StartTicker(intervalPrintStats time.Duration, queueOutput chan string)

func (*Stats) UpdateBalances

func (s *Stats) UpdateBalances() (*wallet.Wallets, error)