structlog

Feb 26, 2026

Changes in this version

+ func ClassifyColdAccess(structlogs []execution.StructLog, gasSelf []uint64, memExpGas []uint64) []uint64

+ func ComputeMemoryWords(structlogs []execution.StructLog) (wordsBefore, wordsAfter []uint32)

+ func IsPrecompile(addr string) bool

+ func MemoryExpansionGas(wordsBefore, wordsAfter uint32) uint64

Feb 4, 2026

Changes in this version

+ const DefaultBufferFlushInterval

+ const DefaultBufferMaxRows

+ const OpcodeCALL

+ const OpcodeCALLCODE

+ const OpcodeCREATE

+ const OpcodeCREATE2

+ const OpcodeDELEGATECALL

+ const OpcodeSTATICCALL

+ var ErrTaskIDConflict = asynq.ErrTaskIDConflict

+ func ComputeCreateAddresses(structlogs []execution.StructLog) map[int]*string

+ func ComputeGasSelf(structlogs []execution.StructLog, gasUsed []uint64) []uint64

+ func GenerateTaskID(network string, blockNumber uint64, txHash string) string

+ type CallFrame struct

+ Depth uint64

+ ID uint32

+ type CallTracker struct

+ func NewCallTracker() *CallTracker

+ func (ct *CallTracker) CurrentFrameID() uint32

+ func (ct *CallTracker) CurrentPath() []uint32

+ func (ct *CallTracker) IssueFrameID() (frameID uint32, framePath []uint32)

+ func (ct *CallTracker) ProcessDepthChange(newDepth uint64) (frameID uint32, framePath []uint32)

type ClickHouseTime

+ func (t ClickHouseTime) Time() time.Time

+ type Columns struct

+ BlockNumber proto.ColUInt64

+ CallFrameID proto.ColUInt32

+ CallFramePath *proto.ColArr[uint32]

+ CallToAddress *proto.ColNullable[string]

+ Depth proto.ColUInt64

+ Error *proto.ColNullable[string]

+ Gas proto.ColUInt64

+ GasCost proto.ColUInt64

+ GasSelf proto.ColUInt64

+ GasUsed proto.ColUInt64

+ Index proto.ColUInt32

+ MetaNetworkName proto.ColStr

+ Operation proto.ColStr

+ Refund *proto.ColNullable[uint64]

+ ReturnData *proto.ColNullable[string]

+ TransactionFailed proto.ColBool

+ TransactionGas proto.ColUInt64

+ TransactionHash proto.ColStr

+ TransactionIndex proto.ColUInt32

+ TransactionReturnValue *proto.ColNullable[string]

+ UpdatedDateTime proto.ColDateTime

+ func NewColumns() *Columns

+ func (c *Columns) Append(updatedDateTime time.Time, blockNumber uint64, txHash string, txIndex uint32, ...)

+ func (c *Columns) Input() proto.Input

+ func (c *Columns) Reset()

+ func (c *Columns) Rows() int

type Config

+ BufferFlushInterval time.Duration

+ BufferMaxRows int

+ MaxPendingBlockRange int

type Dependencies

+ AsynqInspector *asynq.Inspector

+ RedisClient *redis.Client

type Processor

+ func (p *Processor) GetCompletionTracker() *tracker.BlockCompletionTracker

+ func (p *Processor) ProcessBlock(ctx context.Context, block execution.Block) error

+ func (p *Processor) ReprocessBlock(ctx context.Context, blockNum uint64) error

type Structlog

+ CallFrameID uint32

+ CallFramePath []uint32

+ GasSelf uint64

Dec 19, 2025

Changes in this version

+ func ComputeGasUsed(structlogs []execution.StructLog) []uint64

type Structlog

+ GasUsed uint64

Dec 2, 2025

Changes in this version

+ type BatchItem struct

+ type BatchManager struct

+ func NewBatchManager(processor *Processor, config *Config) *BatchManager

+ func (bm *BatchManager) Add(structlogs []Structlog, task *asynq.Task, payload *ProcessPayload) error

+ func (bm *BatchManager) Flush()

+ func (bm *BatchManager) FlushIfNeeded()

+ func (bm *BatchManager) Start() error

+ func (bm *BatchManager) Stop()

+ type BigTransactionManager struct

+ func NewBigTransactionManager(threshold int, log logrus.FieldLogger) *BigTransactionManager

+ func (btm *BigTransactionManager) GetThreshold() int

+ func (btm *BigTransactionManager) RegisterBigTransaction(txHash string, processor *Processor)

+ func (btm *BigTransactionManager) ShouldPauseNewWork() bool

+ func (btm *BigTransactionManager) UnregisterBigTransaction(txHash string)

+ type ClickHouseTime struct

+ func NewClickHouseTime(t time.Time) ClickHouseTime

+ func (t *ClickHouseTime) UnmarshalJSON(data []byte) error

+ func (t ClickHouseTime) MarshalJSON() ([]byte, error)

type Config

+ BatchFlushInterval time.Duration

+ BatchInsertThreshold int64

+ BatchMaxSize int64

+ BigTransactionThreshold int

+ ChannelBufferSize int

+ ChunkSize int

+ ProgressLogThreshold int

type Processor

+ func (p *Processor) ProcessTransaction(ctx context.Context, block *types.Block, index int, tx *types.Transaction) (int, error)

+ func (p *Processor) ShouldBatch(structlogCount int64) bool

Jul 2, 2025

Changes in this version

type Config

+ LargeTransactionConfig *LargeTransactionConfig

+ type LargeTransactionConfig struct

+ EnableSequentialMode bool

+ Enabled bool

+ MaxProcessingTime time.Duration

+ StructlogThreshold int

+ WorkerWaitTimeout time.Duration

+ type LargeTxLockManager struct

+ func NewLargeTxLockManager(log logrus.FieldLogger, config *LargeTransactionConfig) *LargeTxLockManager

+ func (m *LargeTxLockManager) AcquireLock(ctx context.Context, txHash string, size int, operation string) error

+ func (m *LargeTxLockManager) GetStatus() map[string]interface{}

+ func (m *LargeTxLockManager) IsLargeTransaction(structlogCount int) bool

+ func (m *LargeTxLockManager) ReleaseLock(txHash string)

+ func (m *LargeTxLockManager) WaitForLargeTransaction(ctx context.Context, workerTask string) error

type Processor

+ func (p *Processor) GetLargeTxStatus() map[string]interface{}

type Structlog

+ CallToAddress *string

Jun 20, 2025

Changes in this version

type Processor

+ func (p *Processor) EnqueueTransactionTasks(ctx context.Context, block *types.Block) (int, error)

Jun 20, 2025

Changes in this version

type BatchConfig

+ FlushTimeout time.Duration

Jun 4, 2025

Changes in this version

+ var ErrChannelFull = fmt.Errorf("batch collector channel is full")

+ type BatchCollector struct

+ func NewBatchCollector(processor *Processor, config BatchConfig) *BatchCollector

+ func (bc *BatchCollector) Start(ctx context.Context) error

+ func (bc *BatchCollector) Stop(ctx context.Context) error

+ func (bc *BatchCollector) SubmitBatch(taskBatch TaskBatch) error

+ type BatchConfig struct

+ ChannelBufferSize int

+ ChunkSize int

+ Enabled bool

+ FlushInterval time.Duration

+ MaxRows int

type Config

+ BatchConfig BatchConfig

type Processor

+ func (p *Processor) ExtractStructlogs(ctx context.Context, block *types.Block, index int, tx *types.Transaction) ([]Structlog, error)

+ type TaskBatch struct

+ ResponseChan chan error

+ Rows []Structlog

+ TaskID string

Jun 4, 2025

Changes in this version

+ type CountMismatchError struct

+ Actual int

+ Expected int

+ Message string

+ func (e *CountMismatchError) Error() string

type Dependencies

+ RedisPrefix string

Jun 1, 2025

Changes in this version

+ const ProcessBackwardsTaskType

+ const ProcessForwardsTaskType

+ const ProcessorName

+ const VerifyBackwardsTaskType

+ const VerifyForwardsTaskType

+ func NewProcessBackwardsTask(payload *ProcessPayload) (*asynq.Task, error)

+ func NewProcessForwardsTask(payload *ProcessPayload) (*asynq.Task, error)

+ func NewVerifyBackwardsTask(payload *VerifyPayload) (*asynq.Task, error)

+ func NewVerifyForwardsTask(payload *VerifyPayload) (*asynq.Task, error)

+ type Config struct

+ BatchSize int

+ Enabled bool

+ Table string

+ func (c *Config) Validate() error

+ type Dependencies struct

+ AsynqClient *asynq.Client

+ Log logrus.FieldLogger

+ Network *ethereum.Network

+ Pool *ethereum.Pool

+ State *state.Manager

+ type ProcessPayload struct

+ BlockNumber big.Int

+ Network string

+ NetworkID int32

+ NetworkName string

+ ProcessingMode string

+ TransactionHash string

+ TransactionIndex uint32

+ func (p *ProcessPayload) MarshalBinary() ([]byte, error)

+ func (p *ProcessPayload) UnmarshalBinary(data []byte) error

+ type Processor struct

+ func New(ctx context.Context, deps *Dependencies, config *Config) (*Processor, error)

+ func (p *Processor) BatchInsertStructlogs(ctx context.Context, blockNumber uint64, transactionHash string, ...) error

+ func (p *Processor) EnqueueTask(ctx context.Context, task *asynq.Task, opts ...asynq.Option) error

+ func (p *Processor) GetHandlers() map[string]asynq.HandlerFunc

+ func (p *Processor) GetQueues() []c.QueueInfo

+ func (p *Processor) Name() string

+ func (p *Processor) ProcessNextBlock(ctx context.Context) error

+ func (p *Processor) ProcessSingleTransaction(ctx context.Context, block *types.Block, index int, tx *types.Transaction) (int, error)

+ func (p *Processor) SetProcessingMode(mode string)

+ func (p *Processor) Start(ctx context.Context) error

+ func (p *Processor) Stop(ctx context.Context) error

+ func (p *Processor) VerifyTransaction(ctx context.Context, blockNumber *big.Int, transactionHash string, ...) error

+ type Structlog struct

+ BlockNumber uint64

+ Depth uint64

+ Error *string

+ Gas uint64

+ GasCost uint64

+ Index uint32

+ MetaNetworkID int32

+ MetaNetworkName string

+ Operation string

+ ProgramCounter uint32

+ Refund *uint64

+ ReturnData *string

+ TransactionFailed bool

+ TransactionGas uint64

+ TransactionHash string

+ TransactionIndex uint32

+ TransactionReturnValue *string

+ UpdatedDateTime time.Time

+ type VerifyPayload struct

+ BlockNumber big.Int

+ InsertedCount int

+ Network string

+ NetworkID int32

+ NetworkName string

+ ProcessingMode string

+ TransactionHash string

+ TransactionIndex uint32

+ func (v *VerifyPayload) MarshalBinary() ([]byte, error)

+ func (v *VerifyPayload) UnmarshalBinary(data []byte) error