Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion source/capability.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,8 @@ type Seekable interface {
// SeekToTime repositions delivery to the first message at or after t.
SeekToTime(ctx context.Context, t time.Time) error
// SeekToCursor repositions delivery to resume from a previously observed
// [Cursor] (re-delivering from just after it, per the backend's convention).
// [Cursor], re-delivering from the cursor's position per the backend's
// convention (Kafka re-delivers the record at the cursor).
SeekToCursor(ctx context.Context, c Cursor) error
// SeekToStart repositions delivery to the earliest retained message.
SeekToStart(ctx context.Context) error
Expand Down