blackhole

Documentation

Index

• type DMLSink
  • func NewDMLSink() *DMLSink
  • func (s *DMLSink) Close()
  • func (s *DMLSink) Dead() <-chan struct{}
  • func (s *DMLSink) SchemeOption() (string, bool)
  • func (s *DMLSink) WriteEvents(rows ...*dmlsink.CallbackableEvent[*model.RowChangedEvent]) (err error)

Types

type DMLSink

type DMLSink struct{}

DMLSink is a black hole sink.

func NewDMLSink

func NewDMLSink() *DMLSink

NewDMLSink create a black hole DML sink.

func (*DMLSink) Close

func (s *DMLSink) Close()

Close do nothing.

func (*DMLSink) Dead

func (s *DMLSink) Dead() <-chan struct{}

Dead returns a checker.

func (*DMLSink) SchemeOption

func (s *DMLSink) SchemeOption() (string, bool)

SchemeOption returns the scheme and the option.

func (*DMLSink) WriteEvents

func (s *DMLSink) WriteEvents(rows ...*dmlsink.CallbackableEvent[*model.RowChangedEvent]) (err error)

WriteEvents log the events.