gloomberg

package
v0.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 7, 2023 License: MIT Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

ErrWalletBalance given for issues while fetching wallet balances.

View Source 
var (
	TerminalPrinterQueue = make(chan string, viper.GetInt("gloomberg.eventhub.inQueuesSize"))
)

Functions

func CheckEIP6551TokenAccount added in v0.11.0 

func CheckEIP6551TokenAccount(gb *Gloomberg, tokenContract *common.Address, tokenID *big.Int) (bool, *common.Address, error)

func GasTicker added in v0.9.1 

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

func GetFirstTxsForContract added in v0.11.0 

func GetFirstTxsForContract(collectionName string, contractAddress common.Address)

GetFirstTxsForContract fetches the first 1337 txs for a contract from etherscan and saves them to a json file.

func GetServerTLSConfig added in v0.11.0 

func GetServerTLSConfig() (*tls.Config, error)

func GetTLSClientCredentials added in v0.11.0 

func GetTLSClientCredentials() credentials.TransportCredentials

func GetTLSCredentialsWithoutClientAuth added in v0.11.0 

func GetTLSCredentialsWithoutClientAuth() (credentials.TransportCredentials, error)

func JobCheckEIP6551TokenAccount added in v0.11.0 

func JobCheckEIP6551TokenAccount(params ...any)

func JobFirstTxsForContract added in v0.11.0 

func JobFirstTxsForContract(params ...any)

func Pr added in v0.11.1 

func Pr(message string)

Pr prints messages from gloomberg to the terminal. func (gb *Gloomberg) Pr(message string) {.

func PrDMod added in v0.11.1 

func PrDMod(mod string, message string)

PrDMod prints messages from gloomberg to the terminal if debug mode is enabled. func (gb *Gloomberg) PrDMod(mod string, message string) {.

func PrDModf added in v0.11.1 

func PrDModf(mod string, format string, a ...any)

PrDModf formats and prints messages from gloomberg to the terminal if debug mode is enabled. func (gb *Gloomberg) PrDModf(mod string, format string, a ...any) {.

func PrMod added in v0.11.1 

func PrMod(mod string, message string)

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

func PrModf added in v0.11.1 

func PrModf(mod string, format string, a ...any)

PrModf formats and prints messages from gloomberg to the terminal. func (gb *Gloomberg) PrModf(mod string, format string, a ...any) {.

func PrVMod added in v0.11.1 

func PrVMod(mod string, message string)

PrVMod prints messages from gloomberg to the terminal if verbose mode is enabled. func (gb *Gloomberg) PrVMod(mod string, message string) {.

func PrVModf added in v0.11.1 

func PrVModf(mod string, format string, a ...any)

PrVModf formats and prints messages from gloomberg to the terminal if verbose mode is enabled. func (gb *Gloomberg) PrVModf(mod string, format string, a ...any) {.

func PrWarn added in v0.11.1 

func PrWarn(message string)

func (gb *Gloomberg) PrWarn(message string) {.

func PrWithKeywordAndIcon added in v0.11.1 

func PrWithKeywordAndIcon(icon string, keyword string, message string)

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

func Prf added in v0.11.1 

func Prf(format string, a ...any)

Prf formats and prints messages from gloomberg to the terminal. func (gb *Gloomberg) Prf(format string, a ...any) {.

Types

type FirstTxsTask added in v0.11.0 

type FirstTxsTask struct {
	CollectionName  string
	ContractAddress common.Address
}

type Gloomberg 

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

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

	RecentOwnEvents mapset.Set[*degendb.PreformattedEvent]

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

	Rdb    rueidis.Client
	Rueidi *rueidica.Rueidica

	QueueSlugs chan common.Address

	CurrentGasPriceGwei   uint64
	CurrentOnlineWebUsers uint64

	// GloomHub *gloomhub
	Jobs *jobs.Runner
	*degendb.DegenDB

	// misc / maybe find better solutions...
	PrintConfigurations map[string]*printConfig
	// contains filtered or unexported fields
}
var GB *Gloomberg

func New added in v0.7.1 

func New() *Gloomberg

func (*Gloomberg) PublishCollectionsSlugs added in v0.12.0 

func (gb *Gloomberg) PublishCollectionsSlugs(slugs []string)

func (*Gloomberg) PublishOwnCollectionsSlugs added in v0.12.0 

func (gb *Gloomberg) PublishOwnCollectionsSlugs()

func (*Gloomberg) String added in v0.11.0 

func (gb *Gloomberg) String()

func (Gloomberg) SubscribNewBlocks added in v0.7.3 

func (eh Gloomberg) SubscribNewBlocks() chan uint64

func (Gloomberg) SubscribeCollectionOffer added in v0.7.3 

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

func (Gloomberg) SubscribeItemListed added in v0.7.1 

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

func (Gloomberg) SubscribeItemMetadataUpdated added in v0.11.0 

func (eh Gloomberg) SubscribeItemMetadataUpdated() chan *models.ItemMetadataUpdated

func (Gloomberg) SubscribeItemReceivedBid added in v0.7.3 

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

func (Gloomberg) SubscribeParsedEvents added in v0.10.0 

func (eh Gloomberg) SubscribeParsedEvents() chan *degendb.PreformattedEvent

func (Gloomberg) SubscribeRecentOwnEvents added in v0.11.0 

func (eh Gloomberg) SubscribeRecentOwnEvents() chan []*degendb.PreformattedEvent

func (Gloomberg) SubscribeSeawatcherMgmt added in v0.8.0 

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

func (Gloomberg) SubscribeTokenTransactions added in v0.7.3 

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

func (Gloomberg) SubscribeTxWithLogs added in v0.7.1 

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

func (Gloomberg) UnsubscribeCollectionOffer added in v0.11.1 

func (eh Gloomberg) UnsubscribeCollectionOffer(collectionOfferChan chan *models.CollectionOffer)

func (Gloomberg) UnsubscribeItemListed added in v0.11.1 

func (eh Gloomberg) UnsubscribeItemListed(itemListedChan chan *models.ItemListed)

func (Gloomberg) UnsubscribeItemMetadataUpdated added in v0.11.1 

func (eh Gloomberg) UnsubscribeItemMetadataUpdated(itemMetadataUpdatedChan chan *models.ItemMetadataUpdated)

func (Gloomberg) UnsubscribeItemReceivedBid added in v0.11.1 

func (eh Gloomberg) UnsubscribeItemReceivedBid(itemReceivedBidChan chan *models.ItemReceivedBid)

type Stats added in v0.9.1 

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

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

func NewStats added in v0.9.1 

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

func (*Stats) AddEvent added in v0.9.1 

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

func (*Stats) Print added in v0.9.1 

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

func (*Stats) StartTicker added in v0.9.1 

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

func (*Stats) UpdateBalances added in v0.9.1 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.