sanitizer

type Option ¶

type Option func(*Sanitizer)

func WithLogger(l loglib.Logger) Option

type Sanitizer ¶

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

Sanitizer is a decorator around a wal processor that sanitizes wal event column values before passing them to the inner processor. It strips null bytes (0x00) from string values, which PostgreSQL does not allow in text/varchar columns. Source databases may contain them due to historical bugs in older PostgreSQL versions where the binary receive function did not validate for null bytes.

func New(inner processor.Processor, opts ...Option) *Sanitizer

func (s *Sanitizer) Close() error

func (s *Sanitizer) Name() string

func (s *Sanitizer) ProcessWALEvent(ctx context.Context, event *wal.Event) error