Skip to content

Commit

Permalink
Add docstring to lp.Replay()
Browse files Browse the repository at this point in the history
  • Loading branch information
reductionista committed Feb 14, 2025
1 parent 70aec51 commit 25c06be
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions pkg/solana/logpoller/log_poller.go
Original file line number Diff line number Diff line change
Expand Up @@ -213,6 +213,12 @@ func (lp *Service) UnregisterFilter(ctx context.Context, name string) error {
return lp.filters.UnregisterFilter(ctx, name)
}

// Replay submits a new replay request. If there was already a new replay request
// submitted since the last replay completed, it will be updated to the earlier of the
// two requested fromBlock's. The expectation is that, on the next timer tick of the
// LogPoller run loop it will backfill all filters starting from fromBlock. If there
// are new filters in the backfill queue, with an earlier StartingBlock, then they
// will get backfilled from there instead.
func (lp *Service) Replay(ctx context.Context, fromBlock int64) error {
ctx, cancel := lp.eng.Ctx(ctx)
defer cancel()
Expand Down

0 comments on commit 25c06be

Please sign in to comment.