progresslogger

Documentation

Index

• func CallEveryInterval(ctx context.Context, interval time.Duration, fn func()) context.CancelFunc
• type BlockProgressTracker
  • func NewBlockProgressTracker(logger utils.SimpleLogger, totalBlocks uint64, initialCompletedBlocks uint64) *BlockProgressTracker
  • func (t *BlockProgressTracker) Elapsed() time.Duration
  • func (t *BlockProgressTracker) IncrementCompletedBlocks(amount uint64)
  • func (t *BlockProgressTracker) LogProgress()

Functions

func CallEveryInterval

func CallEveryInterval(ctx context.Context, interval time.Duration, fn func()) context.CancelFunc

StartIntervalLogger starts a goroutine that calls the provided function at regular intervals

Types

type BlockProgressTracker

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

BlockProgressTracker tracks the progress of a migration by block number.

func NewBlockProgressTracker

func NewBlockProgressTracker(
	logger utils.SimpleLogger,
	totalBlocks uint64,
	initialCompletedBlocks uint64,
) *BlockProgressTracker

NewBlockProgressTracker creates a new progress tracker for block-based migrations. initialCompletedBlocks allows resuming from a previous migration state.

func (*BlockProgressTracker) Elapsed

func (t *BlockProgressTracker) Elapsed() time.Duration

func (*BlockProgressTracker) IncrementCompletedBlocks

func (t *BlockProgressTracker) IncrementCompletedBlocks(amount uint64)

IncrementCompletedBlocks increments the completed blocks counter by the specified amount. Safe to call from multiple goroutines concurrently.

func (*BlockProgressTracker) LogProgress

func (t *BlockProgressTracker) LogProgress()

LogProgress logs the progress of the migration.