Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

collector

package

Go to main page

Versions in this module

v0

v0.7.0

Oct 16, 2023

Changes in this version

+ const KeyStatsTxTrash

v0.6.0

Oct 3, 2023

Changes in this version

type BlxNodeOpts

+ TxC chan TxIn

type ChainboundNodeOpts

+ TxC chan TxIn

type CollectorOpts

+ BloxrouteAuth []string

+ ChainboundAuth []string

+ EdenAuth []string

+ type EdenNodeConnection struct

+ func NewEdenNodeConnection(opts EdenNodeOpts) *EdenNodeConnection

+ func (nc *EdenNodeConnection) Start()

+ type EdenNodeConnectionGRPC struct

+ func NewEdenNodeConnectionGRPC(opts EdenNodeOpts) *EdenNodeConnectionGRPC

+ func (nc *EdenNodeConnectionGRPC) Start()

+ type EdenNodeOpts struct

+ AuthHeader string

+ Log *zap.SugaredLogger

+ SourceTag string

+ TxC chan TxIn

+ URL string

v0.5.2

Sep 18, 2023

Changes in this version

+ const KeyStatsAll

+ const KeyStatsFirst

+ const KeyStatsTxOnChain

+ const KeyStatsUnique

+ type BlxNodeConnectionGRPC struct

+ func NewBlxNodeConnectionGRPC(opts BlxNodeOpts, txC chan TxIn) *BlxNodeConnectionGRPC

+ func (nc *BlxNodeConnectionGRPC) Start()

type CollectorOpts

+ CheckNodeURI string

+ EdenAuthToken string

type NodeConnection

+ func (nc *NodeConnection) StartInBackground()

+ type OutFiles struct

+ FSourcelog *os.File

+ FTrash *os.File

+ FTxs *os.File

+ type SourceMetrics struct

+ func NewMetricsCounter() SourceMetrics

+ func (sc *SourceMetrics) Get(cntType string) map[string]map[string]uint64

+ func (sc *SourceMetrics) Inc(cntType, source string)

+ func (sc *SourceMetrics) IncKey(cntType, source, key string)

+ func (sc *SourceMetrics) Logger(log *zap.SugaredLogger, cntType string, useLen bool) *zap.SugaredLogger

+ func (sc *SourceMetrics) Reset()

+ type TxProcessorOpts struct

+ CheckNodeURI string

+ Log *zap.SugaredLogger

+ OutDir string

+ UID string

v0.4.0

Sep 11, 2023

Changes in this version

+ func Start(opts *CollectorOpts)

+ type BlxNodeConnection struct

+ func NewBlxNodeConnection(opts BlxNodeOpts, txC chan TxIn) *BlxNodeConnection

+ func (nc *BlxNodeConnection) Start()

+ type BlxNodeOpts struct

+ AuthHeader string

+ IsEden bool

+ Log *zap.SugaredLogger

+ SourceTag string

+ URL string

+ type ChainboundNodeConnection struct

+ func NewChainboundNodeConnection(opts ChainboundNodeOpts, txC chan TxIn) *ChainboundNodeConnection

+ func (cbc *ChainboundNodeConnection) Start()

+ type ChainboundNodeOpts struct

+ APIKey string

+ Log *zap.SugaredLogger

+ SourceTag string

+ URL string

+ type CollectorOpts struct

+ BloxrouteAuthToken string

+ ChainboundAPIKey string

+ Log *zap.SugaredLogger

+ Nodes []string

+ OutDir string

+ UID string

+ WriteSourcelog bool

+ type NodeConnection struct

+ func NewNodeConnection(log *zap.SugaredLogger, nodeURI string, txC chan TxIn) *NodeConnection

+ func (nc *NodeConnection) Start()

+ type TxDetail struct

+ Hash string

+ RawTx string

+ Timestamp int64

+ type TxIn struct

+ Source string

+ T time.Time

+ Tx *types.Transaction

+ type TxProcessor struct

+ func NewTxProcessor(log *zap.SugaredLogger, outDir, uid string, writeSourcelog bool) *TxProcessor

+ func (p *TxProcessor) Start()