eventemitting

Documentation

Index

• type EventEmitter
  • func NewEventEmitter(replicationContext *context.ReplicationContext, sink sink.Sink, ...) (*EventEmitter, error)
  • func (ee *EventEmitter) NewEventHandler() eventhandlers.BaseReplicationEventHandler
  • func (ee *EventEmitter) Start() error
  • func (ee *EventEmitter) Stop() error

Types

type EventEmitter

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

func NewEventEmitter

func NewEventEmitter(
	replicationContext *context.ReplicationContext, sink sink.Sink, filter eventfiltering.EventFilter) (*EventEmitter, error)

func (*EventEmitter) NewEventHandler

func (ee *EventEmitter) NewEventHandler() eventhandlers.BaseReplicationEventHandler

func (*EventEmitter) Start

func (ee *EventEmitter) Start() error

func (*EventEmitter) Stop

func (ee *EventEmitter) Stop() error