gloomberg

Documentation

Index

• 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

Types

type Gloomberg

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

	CollectionDB *collections.CollectionDB
	OwnWallets   *wallet.Wallets
	Stats        *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