Skip to content

Commit

Permalink
Merge #59728
Browse files Browse the repository at this point in the history
59728: kvserver: add a comment r=andreimatei a=andreimatei

Hint at the reason why a rangefeed checkpoint with an empty resolved
timestamp is published.

This revives an old comment delete in #33557.

Release note: None

Co-authored-by: Andrei Matei <[email protected]>
  • Loading branch information
craig[bot] and andreimatei committed Jan 22, 2022
2 parents 41afb44 + b50b3af commit e1068d7
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions pkg/kv/kvserver/rangefeed/processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -265,9 +265,11 @@ func (p *Processor) run(
// Publish an updated filter that includes the new registration.
p.filterResC <- p.reg.NewFilter()

// Immediately publish a checkpoint event to the registry. This will be
// the first event published to this registration after its initial
// catch-up scan completes.
// Immediately publish a checkpoint event to the registry. This will be the first event
// published to this registration after its initial catch-up scan completes. The resolved
// timestamp might be empty but the checkpoint event is still useful to indicate that the
// catch-up scan has completed. This allows clients to rely on stronger ordering semantics
// once they observe the first checkpoint event.
r.publish(p.newCheckpointEvent())

// Run an output loop for the registry.
Expand Down

0 comments on commit e1068d7

Please sign in to comment.