sink

type InitFunc func(context.Context, model.ChangeFeedID, *url.URL, *config.ReplicaConfig, map[string]string, chan error) (Sink, error)

type Manager struct {
	// contains filtered or unexported fields
}

type Sink interface {
	// EmitChangedEvents sends Changed Event to Sink
	// EmitChangedEvents may write rows to downstream directly;
	//
	// EmitChangedEvents is thread-safe.
	// FIXME: some sink implementation, they should be.
	EmitChangedEvents(ctx context.Context, rawKVEntries ...*model.RawKVEntry) error

	// FlushChangedEvents flushes each row which of commitTs less than or
	// equal to `resolvedTs` into downstream.
	// TiKV-CDC guarantees that all the Events whose commitTs is less than or
	// equal to `resolvedTs` are sent to Sink through `EmitRowChangedEvents`
	//
	// FlushChangedEvents is thread-safe.
	// FIXME: some sink implementation, they should be.
	FlushChangedEvents(ctx context.Context, keyspanID model.KeySpanID, resolvedTs uint64) (uint64, error)

	// EmitCheckpointTs sends CheckpointTs to Sink.
	// TiCDC guarantees that all Events **in the cluster** which of commitTs
	// less than or equal `checkpointTs` are sent to downstream successfully.
	//
	// EmitCheckpointTs is thread-safe.
	// FIXME: some sink implementation, they should be.
	EmitCheckpointTs(ctx context.Context, ts uint64) error

	// Close closes the Sink.
	//
	// Close is thread-safe and idempotent.
	Close(ctx context.Context) error

	// Barrier is a synchronous function to wait all events to be flushed
	// in underlying sink.
	// Note once Barrier is called, the resolved ts won't be pushed until
	// the Barrier call returns.
	//
	// Barrier is thread-safe.
	Barrier(ctx context.Context, keyspanID model.KeySpanID) error
}

type Statistics struct {
	// contains filtered or unexported fields
}

type TikvBatcher struct {
	Batches []innerBatch
	// contains filtered or unexported fields
}