Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Checkpoint ¶
type Checkpoint func(ctx context.Context, positions []wal.CommitPosition) error
Checkpoint defines the way to confirm the positions that have been read. The actual implementation depends on the source of events (postgres, kafka,...)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.