common

Jul 2, 2025

Changes in this version

type TxSummaryEntry

+ func ParseTxRLP(timestampMs int64, rawTxHex string) (TxSummaryEntry, *types.Transaction, error)

+ func (t *TxSummaryEntry) RawTxBytes() ([]byte, error)

Jun 6, 2025

Changes in this version

+ var Version = "dev"

May 30, 2025

Changes in this version

+ var ErrChainIDNotSet = errors.New("ChainID not set")

type Analyzer2

+ Sourcelog map[string]map[string]int64

Jun 24, 2024

Changes in this version

+ type TxIn struct

+ Source string

+ T time.Time

+ Tx *types.Transaction

type TxSummaryEntry

+ TxType int64

Oct 16, 2023

Changes in this version

+ const TrashTxSignatureError

Oct 3, 2023

Changes in this version

+ const TxAlreadyIncludedThreshold

+ var Caser = cases.Title(language.English)

+ var DefaultSourceComparisons = []SourceComp

+ var Title = Caser.String

+ func FmtDateDay(t time.Time) string

+ func FmtDateDayTime(t time.Time) string

+ func FmtDuration(d time.Duration) string

+ func GetAuthTokenAndURL(auth string) (string, string)

+ func GetEnvInt(key string, defaultValue int) int

+ func GetMemUsageHuman() string

+ func Int64DiffPercentFmtC(a, b int64, decimals uint, fmtSuffix string) string

+ func IntDiffPercentFmtC(a, b int, decimals uint, fmtSuffix string) string

+ func MustBeCSVFile(log *zap.SugaredLogger, fn string)

+ func MustBeParquetFile(log *zap.SugaredLogger, fn string)

+ func PrettyInt(i int) string

+ func PrettyInt64(i int64) string

+ func SetupMarkdownTableWriter(table *tablewriter.Table)

+ func TitleStrings(s []string) []string

+ type Analyzer2 struct

+ SourceComps []SourceComp

+ Sourelog map[string]map[string]int64

+ Transactions map[string]*TxSummaryEntry

+ func NewAnalyzer2(opts Analyzer2Opts) *Analyzer2

+ func (a *Analyzer2) Print()

+ func (a *Analyzer2) Sprint() string

+ func (a *Analyzer2) WriteToFile(filename string) error

+ type Analyzer2Opts struct

+ SourceComps []SourceComp

+ Sourelog map[string]map[string]int64

+ Transactions map[string]*TxSummaryEntry

type TxSummaryEntry

+ IncludedAtBlockHeight int64

+ IncludedBlockTimestamp int64

+ InclusionDelayMs int64

+ func (t *TxSummaryEntry) HasSource(src string) bool

+ func (t *TxSummaryEntry) UpdateInclusionStatus(ethClient *ethclient.Client) (*types.Header, error)

+ func (t *TxSummaryEntry) WasIncludedBeforeReceived() bool

+ type TxSummaryEntryNoRaw struct

+ ChainID string

+ Data4Bytes string

+ DataSize int64

+ From string

+ Gas string

+ GasFeeCap string

+ GasPrice string

+ GasTipCap string

+ Hash string

+ IncludedAtBlockHeight int64

+ IncludedBlockTimestamp int64

+ InclusionDelayMs int64

+ Nonce string

+ Sources []string

+ Timestamp int64

+ To string

+ Value string

Sep 18, 2023

Changes in this version

+ const GRPCWindowSize

+ const SourceTagAlchemy

+ const SourceTagBloxroute

+ const SourceTagChainbound

+ const SourceTagEden

+ const SourceTagInfura

+ const SourceTagLocal

+ const TrashTxAlreadyOnChain

+ func GetCSVFromFiles(filenames []string) (rows [][]string, err error)

+ func IsWebsocketProtocol(url string) bool

+ func LoadSourcelogFiles(log *zap.SugaredLogger, files []string) (txs map[string]map[string]int64, cntProcessedRecords int64)

+ func LoadTrashFiles(log *zap.SugaredLogger, files []string) (txs map[string]map[string]*TrashEntry, err error)

+ type TrashEntry struct

+ Hash string

+ Notes string

+ Reason string

+ Source string

+ Timestamp int64

+ func NewTrashEntryFromCSVRow(row []string) *TrashEntry

+ func (entry *TrashEntry) TrashEntryToCSVRow() string

type TxSummaryEntry

+ Sources []string

Sep 11, 2023

Changes in this version

+ const BloxrouteTag

+ const ChainboundTag

+ const LocalTag

+ var ErrUnsupportedFileFormat = errors.New("unsupported file format")

+ var Printer = message.NewPrinter(language.English)

+ var TxSummaryEntryCSVHeader = []string

+ func GetCSV(filename string) (rows [][]string, err error)

+ func GetEnv(key, defaultValue string) string

+ func GetLogger(debug, prod bool) *zap.SugaredLogger

+ func GetMemUsageMb() uint64

+ func HumanBytes(n uint64) string

+ func Int64DiffPercentFmt(a, b int64) string

+ func IntDiffPercentFmt(a, b int) string

+ func LoadSourceLogFiles(log *zap.SugaredLogger, files []string) (txs map[string]map[string]int64, cntProcessedRecords int64)

+ func LoadTransactionCSVFiles(log *zap.SugaredLogger, files, knownTxsFiles []string) (txs map[string]*TxSummaryEntry, err error)

+ func LoadTxHashesFromMetadataCSVFiles(log *zap.SugaredLogger, files []string) (txs map[string]bool, err error)

+ func MustBeFile(log *zap.SugaredLogger, fn string)

+ func MustNotExist(log *zap.SugaredLogger, fn string)

+ func PrintMemUsage()

+ func RLPDecode(rlpBytes []byte) (*types.Transaction, error)

+ func RLPStringToTx(rlpHex string) (*types.Transaction, error)

+ func SourceAliasesFromEnv() map[string]string

+ func TxSourcName(uri string) string

+ func TxToRLPString(tx *types.Transaction) (string, error)

+ type BlxRawTxMsg struct

+ Params struct{ ... }

+ type EdenRawTxMsg struct

+ Params struct{ ... }

+ type SourceComp struct

+ Reference string

+ Source string

+ func NewSourceComps(args []string) (srcComp []SourceComp)

+ type TxSummaryEntry struct

+ ChainID string

+ Data4Bytes string

+ DataSize int64

+ From string

+ Gas string

+ GasFeeCap string

+ GasPrice string

+ GasTipCap string

+ Hash string

+ Nonce string

+ RawTx string

+ Timestamp int64

+ To string

+ Value string

+ func ParseTx(timestampMs int64, rawTxHex string) (TxSummaryEntry, *types.Transaction, error)

+ func (t TxSummaryEntry) RawTxHex() string

+ func (t TxSummaryEntry) ToCSVRow() []string