collector

Documentation

Overview

Package collector contains the mempool collector service

Index

• Constants
• Variables
• func Start(opts *CollectorOpts)
• type BlxNodeConnection
  • func NewBlxNodeConnection(opts BlxNodeOpts) *BlxNodeConnection
  • func (nc *BlxNodeConnection) Start()
• type BlxNodeConnectionGRPC
  • func NewBlxNodeConnectionGRPC(opts BlxNodeOpts) *BlxNodeConnectionGRPC
  • func (nc *BlxNodeConnectionGRPC) Start()
• type BlxNodeOpts
• type ChainboundNodeConnection
  • func NewChainboundNodeConnection(opts ChainboundNodeOpts) *ChainboundNodeConnection
  • func (cbc *ChainboundNodeConnection) Start()
• type ChainboundNodeOpts
• type CollectorOpts
• type EdenNodeConnection
  • func NewEdenNodeConnection(opts EdenNodeOpts) *EdenNodeConnection
  • func (nc *EdenNodeConnection) Start()
• type EdenNodeConnectionGRPC
  • func NewEdenNodeConnectionGRPC(opts EdenNodeOpts) *EdenNodeConnectionGRPC
  • func (nc *EdenNodeConnectionGRPC) Start()
• type EdenNodeOpts
• type HTTPReceiver
  • func NewHTTPReceiver(url string) *HTTPReceiver
  • func (r *HTTPReceiver) SendTx(ctx context.Context, tx *common.TxIn) error
• type NodeConnection
  • func NewNodeConnection(log *zap.SugaredLogger, nodeURI string, txC chan common.TxIn) *NodeConnection
  • func (nc *NodeConnection) StartInBackground()
• type OutFiles
• type SourceMetrics
  • 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 TxDetail
• type TxProcessor
  • func NewTxProcessor(opts TxProcessorOpts) *TxProcessor
  • func (p *TxProcessor) Start()
• type TxProcessorOpts
• type TxReceiver

Constants

const (
	KeyStatsAll       = "all"
	KeyStatsFirst     = "first"
	KeyStatsUnique    = "unique"
	KeyStatsTxOnChain = "tx-onchain"
	KeyStatsTxTrash   = "tx-trash"
)

Variables

var ErrBlobMissingSidecar = errors.New("missing blob sidecar")

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) *BlxNodeConnection

func (*BlxNodeConnection) Start

func (nc *BlxNodeConnection) Start()

type BlxNodeConnectionGRPC

type BlxNodeConnectionGRPC struct {
	// contains filtered or unexported fields
}

func NewBlxNodeConnectionGRPC

func NewBlxNodeConnectionGRPC(opts BlxNodeOpts) *BlxNodeConnectionGRPC

func (*BlxNodeConnectionGRPC) Start

func (nc *BlxNodeConnectionGRPC) Start()

type BlxNodeOpts

type BlxNodeOpts struct {
	TxC        chan common.TxIn
	Log        *zap.SugaredLogger
	AuthHeader string
	URL        string // optional override, default: blxDefaultURL
	SourceTag  string // optional override, default: "blx" (common.BloxrouteTag)
}

type ChainboundNodeConnection

type ChainboundNodeConnection struct {
	// contains filtered or unexported fields
}

func NewChainboundNodeConnection

func NewChainboundNodeConnection(opts ChainboundNodeOpts) *ChainboundNodeConnection

func (*ChainboundNodeConnection) Start

func (cbc *ChainboundNodeConnection) Start()

type ChainboundNodeOpts

type ChainboundNodeOpts struct {
	TxC       chan common.TxIn
	Log       *zap.SugaredLogger
	APIKey    string
	URL       string // optional override, default: ChainboundDefaultURL
	SourceTag string // optional override, default: "Chainbound"
}

type CollectorOpts

type CollectorOpts struct {
	Log          *zap.SugaredLogger
	UID          string
	Nodes        []string
	OutDir       string
	CheckNodeURI string

	BloxrouteAuth  []string
	EdenAuth       []string
	ChainboundAuth []string

	Receivers               []string
	ReceiversAllowedSources []string

	APIListenAddr string
}

type EdenNodeConnection

type EdenNodeConnection struct {
	// contains filtered or unexported fields
}

func NewEdenNodeConnection

func NewEdenNodeConnection(opts EdenNodeOpts) *EdenNodeConnection

func (*EdenNodeConnection) Start

func (nc *EdenNodeConnection) Start()

type EdenNodeConnectionGRPC

type EdenNodeConnectionGRPC struct {
	// contains filtered or unexported fields
}

func NewEdenNodeConnectionGRPC

func NewEdenNodeConnectionGRPC(opts EdenNodeOpts) *EdenNodeConnectionGRPC

func (*EdenNodeConnectionGRPC) Start

func (nc *EdenNodeConnectionGRPC) Start()

type EdenNodeOpts

type EdenNodeOpts struct {
	TxC        chan common.TxIn
	Log        *zap.SugaredLogger
	AuthHeader string
	URL        string // optional override, default: edenDefaultURL
	SourceTag  string // optional override, default: "eden" (common.SourceTagEden)
}

type HTTPReceiver

type HTTPReceiver struct {
	// contains filtered or unexported fields
}

func NewHTTPReceiver

func NewHTTPReceiver(url string) *HTTPReceiver

func (*HTTPReceiver) SendTx

func (r *HTTPReceiver) SendTx(ctx context.Context, tx *common.TxIn) error

type NodeConnection

type NodeConnection struct {
	// contains filtered or unexported fields
}

func NewNodeConnection

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

func (*NodeConnection) StartInBackground

func (nc *NodeConnection) StartInBackground()

type OutFiles

type OutFiles struct {
	FTxs       *os.File
	FSourcelog *os.File
	FTrash     *os.File
}

type SourceMetrics

type SourceMetrics struct {
	// contains filtered or unexported fields
}

func NewMetricsCounter

func NewMetricsCounter() SourceMetrics

func (*SourceMetrics) Get

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

func (*SourceMetrics) Inc

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

func (*SourceMetrics) IncKey

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

func (*SourceMetrics) Logger

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

func (*SourceMetrics) Reset

func (sc *SourceMetrics) Reset()

type TxDetail

type TxDetail struct {
	Timestamp int64  `json:"timestamp"`
	Hash      string `json:"hash"`
	RawTx     string `json:"rawTx"`
}

type TxProcessor

type TxProcessor struct {
	// contains filtered or unexported fields
}

func NewTxProcessor

func NewTxProcessor(opts TxProcessorOpts) *TxProcessor

func (*TxProcessor) Start

func (p *TxProcessor) Start()

type TxProcessorOpts

type TxProcessorOpts struct {
	Log                     *zap.SugaredLogger
	OutDir                  string
	UID                     string
	CheckNodeURI            string
	HTTPReceivers           []string
	ReceiversAllowedSources []string
}

type TxReceiver

type TxReceiver interface {
	SendTx(ctx context.Context, tx *common.TxIn) error
}