Documentation
¶
Overview ¶
Package collector contains the mempool collector service
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Start ¶
func Start(opts *CollectorOpts)
Start kicks off all the service components in the background
Types ¶
type BlxNodeConnection ¶
type BlxNodeConnection struct {
// contains filtered or unexported fields
}
func NewBlxNodeConnection ¶
func NewBlxNodeConnection(opts BlxNodeOpts, txC chan TxIn) *BlxNodeConnection
func (*BlxNodeConnection) Start ¶
func (nc *BlxNodeConnection) Start()
type BlxNodeOpts ¶
type ChainboundNodeConnection ¶
type ChainboundNodeConnection struct {
// contains filtered or unexported fields
}
func NewChainboundNodeConnection ¶
func NewChainboundNodeConnection(opts ChainboundNodeOpts, txC chan TxIn) *ChainboundNodeConnection
func (*ChainboundNodeConnection) Start ¶
func (cbc *ChainboundNodeConnection) Start()
type ChainboundNodeOpts ¶
type ChainboundNodeOpts struct {
Log *zap.SugaredLogger
APIKey string
URL string // optional override, default: ChainboundDefaultURL
SourceTag string // optional override, default: "Chainbound"
}
type CollectorOpts ¶
type NodeConnection ¶
type NodeConnection struct {
// contains filtered or unexported fields
}
func NewNodeConnection ¶
func NewNodeConnection(log *zap.SugaredLogger, nodeURI string, txC chan TxIn) *NodeConnection
func (*NodeConnection) Start ¶
func (nc *NodeConnection) Start()
type TxProcessor ¶
type TxProcessor struct {
// contains filtered or unexported fields
}
func NewTxProcessor ¶
func NewTxProcessor(log *zap.SugaredLogger, outDir, uid string, writeSourcelog bool) *TxProcessor
func (*TxProcessor) Start ¶
func (p *TxProcessor) Start()
Click to show internal directories.
Click to hide internal directories.