syncpointstore

Documentation

Index

• type SyncPointStore
  • func NewSyncPointStore(ctx context.Context, changefeedID model.ChangeFeedID, sinkURIStr string, ...) (SyncPointStore, error)

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,
	replicaConfig *config.ReplicaConfig,
) (SyncPointStore, error)

NewSyncPointStore creates a new SyncPoint sink with the sink-uri