structlog

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