Skip to content

Commit

Permalink
fix lint error
Browse files Browse the repository at this point in the history
  • Loading branch information
CharlesCheung96 committed May 18, 2022
1 parent 4e0a441 commit 63f12d4
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
9 changes: 5 additions & 4 deletions cdc/model/mounter.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,14 +94,15 @@ func ComparePolymorphicEvents(i, j *PolymorphicEvent) bool {
return i.CRTs < j.CRTs
}

// ResolvedMode describes the batch type of a resolved event.
type ResolvedMode int

const (
// With `ResolvedTs.Mode == NormalResolvedMode`, TiCDC guarantees that all events whose commitTs
// is less than or equal to `resolved.Ts` are sent to Sink.
// NormalResolvedMode means that all events whose commitTs is less than or equal to
// `resolved.Ts` are sent to Sink.
NormalResolvedMode ResolvedMode = iota
// With `ResolvedTs.Mode == BatchResolvedMode`, TiCDC guarantees that all events whose commitTs
// is less than 'resolved.Ts' are sent to Sink.
// BatchResolvedMode means that all events whose commitTs is less than
// 'resolved.Ts' are sent to Sink.
BatchResolvedMode
)

Expand Down
4 changes: 2 additions & 2 deletions cdc/sink/sink.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,9 +54,9 @@ type Sink interface {

// FlushRowChangedEvents flushes each row which of commitTs less than or
// equal to `resolved.Ts` into downstream.
// 1. With `resolved.Mode == NormalResolvedMode`, TiCDC guarantees that all events whose commitTs
// With `resolved.Mode == NormalResolvedMode`, TiCDC guarantees that all events whose commitTs
// is less than or equal to `resolved.Ts` are sent to Sink.
// 2. With `resolved.Mode == BatchResolvedMode`, TiCDC guarantees that all events whose commitTs
// With `resolved.Mode == BatchResolvedMode`, TiCDC guarantees that all events whose commitTs
// is less than 'resolved.Ts' are sent to Sink.
//
// FlushRowChangedEvents is thread-safe.
Expand Down

0 comments on commit 63f12d4

Please sign in to comment.