task

Documentation

Index

• type Notificator
• type Task
• type TaskManager

Types

type Notificator

type Notificator interface {
	NotifyBaseReplicationEventHandler(
		fn func(handler eventhandlers.BaseReplicationEventHandler) error,
	)
	NotifySystemCatalogReplicationEventHandler(
		fn func(handler eventhandlers.SystemCatalogReplicationEventHandler) error,
	)
	NotifyCompressionReplicationEventHandler(
		fn func(handler eventhandlers.CompressionReplicationEventHandler) error,
	)
	NotifyRecordReplicationEventHandler(
		fn func(handler eventhandlers.RecordReplicationEventHandler) error,
	)
	NotifyLogicalReplicationEventHandler(
		fn func(handler eventhandlers.LogicalReplicationEventHandler) error,
	)
	NotifySnapshottingEventHandler(
		fn func(handler eventhandlers.SnapshottingEventHandler) error,
	)
}

type Task

type Task = func(notificator Notificator)

type TaskManager

type TaskManager interface {
	StartDispatcher()
	StopDispatcher() error
	RegisterReplicationEventHandler(
		handler eventhandlers.BaseReplicationEventHandler,
	)
	EnqueueTask(
		task Task,
	) error
	RunTask(
		task Task,
	) error
	EnqueueTaskAndWait(
		task Task,
	) error
}