Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CallEveryInterval ¶
CallEveryInterval 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( name string, logger log.StructuredLogger, 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.
type Counter ¶ added in v0.17.0
type Counter struct {
// contains filtered or unexported fields
}
func NewCounter ¶ added in v0.17.0
func (*Counter) SetProgress ¶ added in v0.17.0
SetProgress names the work unit and declares how much of it there is, which turns on the percentage and total-runtime fields. Call it before the first Log; allUnits of zero leaves the extra fields off.
Source Files