gloomberg

Documentation

Index

• type Gloomberg
  • func New() *Gloomberg
  • func (gb *Gloomberg) SendSlugsToServer()
  • func (eh Gloomberg) SubscribeItemEvents() chan *osmodels.ItemEvent
  • func (eh Gloomberg) SubscribeItemListed() chan *osmodels.ItemListedEvent
  • func (eh Gloomberg) SubscribePrintToTerminal() chan string
  • 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

	Rdb    rueidis.Client
	Rueidi *rueidica.Rueidica

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

func New

func New() *Gloomberg

func (*Gloomberg) SendSlugsToServer

func (gb *Gloomberg) SendSlugsToServer()

func (Gloomberg) SubscribeItemEvents

func (eh Gloomberg) SubscribeItemEvents() chan *osmodels.ItemEvent

func (Gloomberg) SubscribeItemListed

func (eh Gloomberg) SubscribeItemListed() chan *osmodels.ItemListedEvent

func (Gloomberg) SubscribePrintToTerminal

func (eh Gloomberg) SubscribePrintToTerminal() chan string

func (Gloomberg) SubscribeTxWithLogs

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