ddlsink

Documentation

Index

• type Sink

Types

type Sink

type Sink interface {
	// WriteDDLEvent writes a DDL event to the sink.
	// Note: This is a synchronous and thread-safe method.
	WriteDDLEvent(ctx context.Context, ddl *model.DDLEvent) error
	// WriteCheckpointTs writes a checkpoint timestamp to the sink.
	// Note: This is a synchronous and thread-safe method.
	// This only for MQSink for now.
	WriteCheckpointTs(ctx context.Context, ts uint64, tables []*model.TableInfo) error
	// Close closes the sink.
	Close()
}

Sink is the interface for sink of DDL events.