translator

Documentation

Index

• type Config
• type Option
  • func WithIDFinder(idFinder columnFinder) Option
  • func WithInstrumentation(i *otel.Instrumentation) Option
  • func WithLogger(l loglib.Logger) Option
  • func WithSkipDataEvent(skip dataEventFilter) Option
  • func WithSkipSchemaEvent(skip schemaEventFilter) Option
  • func WithVersionFinder(versionFinder columnFinder) Option
• type Translator
  • func New(cfg *Config, p processor.Processor, opts ...Option) (*Translator, error)
  • func (t *Translator) Close() error
  • func (t *Translator) Name() string
  • func (t *Translator) ProcessWALEvent(ctx context.Context, event *wal.Event) error

Types

type Config

type Config struct {
	Store schemalogpg.Config
}

type Option

type Option func(t *Translator)

func WithIDFinder

func WithIDFinder(idFinder columnFinder) Option

func WithInstrumentation

func WithInstrumentation(i *otel.Instrumentation) Option

func WithLogger

func WithLogger(l loglib.Logger) Option

func WithSkipDataEvent

func WithSkipDataEvent(skip dataEventFilter) Option

func WithSkipSchemaEvent

func WithSkipSchemaEvent(skip schemaEventFilter) Option

func WithVersionFinder

func WithVersionFinder(versionFinder columnFinder) Option

type Translator

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

Translator is a decorator around a wal processor that populates the wal metadata with the schemalog entry for the relevant schema. This allows following processors to have more information for processing the event effectively.

func New

func New(cfg *Config, p processor.Processor, opts ...Option) (*Translator, error)

New will return a translator processor wrapper that will inject pgstream metadata into the wal data events before passing them over to the processor on input. By default, all schemas are processed and the pgstream identity will be the primary key/not null unique column if present.

func (*Translator) Close

func (t *Translator) Close() error

func (*Translator) Name

func (t *Translator) Name() string

func (*Translator) ProcessWALEvent

func (t *Translator) ProcessWALEvent(ctx context.Context, event *wal.Event) error

ProcessWALEvent populates the metadata of the wal event on input, before passing it over to the configured wal processor.