eventemitting

Documentation

Index

• type EventEmitter
  • func NewEventEmitter(replicationContext replicationcontext.ReplicationContext, ...) (*EventEmitter, error)
  • func NewEventEmitterFromConfig(c *config.Config, replicationContext replicationcontext.ReplicationContext, ...) (*EventEmitter, error)
  • func (ee *EventEmitter) NewEventHandler() eventhandlers.BaseReplicationEventHandler
  • func (ee *EventEmitter) PostConstruct() error
  • func (ee *EventEmitter) Start() error
  • func (ee *EventEmitter) Stop() error
  • func (ee *EventEmitter) Stop1() error

Types

type EventEmitter

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

func NewEventEmitter

func NewEventEmitter(
	replicationContext replicationcontext.ReplicationContext, streamManager stream.Manager,
	typeManager pgtypes.TypeManager, taskManager task.TaskManager, statsService *stats.Service,
	filter eventfiltering.EventFilter,
) (*EventEmitter, error)

func NewEventEmitterFromConfig

func NewEventEmitterFromConfig(
	c *config.Config, replicationContext replicationcontext.ReplicationContext,
	streamManager stream.Manager, typeManager pgtypes.TypeManager,
	taskManager task.TaskManager, statsService *stats.Service,
) (*EventEmitter, error)

func (*EventEmitter) NewEventHandler

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

func (*EventEmitter) PostConstruct

func (ee *EventEmitter) PostConstruct() error

func (*EventEmitter) Start

func (ee *EventEmitter) Start() error

func (*EventEmitter) Stop

func (ee *EventEmitter) Stop() error

func (*EventEmitter) Stop1

func (ee *EventEmitter) Stop1() error