handler

Documentation

Index

• type Handler
  • func NewHandler(sub *conf.Subscribe, callback PosCallback) (Handler, error)
• type PosCallback

Types

type Handler

type Handler interface {
	// Handle row data
	Handle(wal ...*model.WalData) error
	Stop()
}

Handler handle dump data

func NewHandler

func NewHandler(sub *conf.Subscribe, callback PosCallback) (Handler, error)

NewHandler create wal handler with subscribe config

type PosCallback

type PosCallback func(uint64)

PosCallback for handler