Skip to content

Commit

Permalink
Merge branch 'wm-rfr' of github.com:numaproj/numaflow into wm-rfr
Browse files Browse the repository at this point in the history
  • Loading branch information
yhl25 committed Aug 31, 2023
2 parents 68b9e56 + 4c8032b commit d85c981
Showing 1 changed file with 0 additions and 6 deletions.
6 changes: 0 additions & 6 deletions pkg/watermark/store/interface.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,9 +28,3 @@ type WatermarkStore interface {
HeartbeatStore() kvs.KVStorer
OffsetTimelineStore() kvs.KVStorer
}

// WatermarkStoreWatcher defines a pair of heartbeat KV watcher and offset timeline KV watcher
type WatermarkStoreWatcher interface {
HeartbeatWatcher() kvs.KVWatcher
OffsetTimelineWatcher() kvs.KVWatcher
}

0 comments on commit d85c981

Please sign in to comment.