blackhole

Documentation

Index

• type DDLSink
  • func NewDDLSink() *DDLSink
  • func (d *DDLSink) Close()
  • func (d *DDLSink) WriteCheckpointTs(ctx context.Context, ts uint64, tables []*model.TableInfo) error
  • func (d *DDLSink) WriteDDLEvent(ctx context.Context, ddl *model.DDLEvent) error

Types

type DDLSink

type DDLSink struct{}

DDLSink is a black hole DDL sink.

func NewDDLSink

func NewDDLSink() *DDLSink

NewDDLSink create a black hole DDL sink.

func (*DDLSink) Close

func (d *DDLSink) Close()

Close do nothing.

func (*DDLSink) WriteCheckpointTs

func (d *DDLSink) WriteCheckpointTs(ctx context.Context,
	ts uint64, tables []*model.TableInfo,
) error

WriteCheckpointTs do nothing.

func (*DDLSink) WriteDDLEvent

func (d *DDLSink) WriteDDLEvent(ctx context.Context,
	ddl *model.DDLEvent,
) error

WriteDDLEvent do nothing.