Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SyncPointStore ¶
type SyncPointStore interface {
// CreateSyncTable create a table to record the syncpoints
CreateSyncTable(ctx context.Context) error
// SinkSyncPoint record the syncpoint(a map with ts) in downstream db
SinkSyncPoint(ctx context.Context, id model.ChangeFeedID, checkpointTs uint64) error
// Close closes the SyncPointSink
Close() error
}
SyncPointStore is an abstraction for anything that a changefeed may emit into.
func NewSyncPointStore ¶
func NewSyncPointStore( ctx context.Context, changefeedID model.ChangeFeedID, sinkURIStr string, syncPointRetention time.Duration, ) (SyncPointStore, error)
NewSyncPointStore creates a new SyncPoint sink with the sink-uri
Source Files
Click to show internal directories.
Click to hide internal directories.