collector

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

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

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 struct {
	// contains filtered or unexported fields
}

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 Clickhouse struct {
	// contains filtered or unexported fields
}

type ClickhouseOpts struct {
	Log *zap.SugaredLogger
	DSN string
}

type CollectorOpts struct {
	Log      *zap.SugaredLogger
	UID      string
	Location string // location of the collector, will be stored in sourcelogs
	Nodes    []string
	OutDir   string

	CheckNodeURI  string
	ClickhouseDSN string

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

	Receivers               []string
	ReceiversAllowedSources []string

	APIListenAddr     string
	MetricsListenAddr string
	EnablePprof       bool // if true, enables pprof on the metrics server
}

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

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

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 struct {
	// contains filtered or unexported fields
}

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

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

type SourceLogEntry struct {
	ReceivedAt time.Time
	Hash       string
	Source     string
	Location   string
}

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

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

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

type TxProcessorOpts struct {
	Log                     *zap.SugaredLogger
	OutDir                  string // if empty no files will be written
	UID                     string
	Location                string // location of the collector, will be stored in sourcelogs
	CheckNodeURI            string
	ClickhouseDSN           string
	HTTPReceivers           []string
	ReceiversAllowedSources []string
}

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