injector

package

v0.4.0 Latest Latest Go to latest Published: Mar 14, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xataio/pgstream

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Config
type Injector
- func New(cfg *Config, p processor.Processor, opts ...Option) (*Injector, error)
type Option

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrUseLSN = errors.New("use LSN as event version")

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Store schemalogpg.Config
}

type Injector ¶

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

Injector is a decorator around a wal processor that injects 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) (*Injector, error)

New will return an injector 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 (*Injector) Close ¶

func (in *Injector) Close() error

func (*Injector) Name ¶

func (in *Injector) Name() string

func (*Injector) ProcessWALEvent ¶

func (in *Injector) 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.

type Option ¶

type Option func(t *Injector)

func WithIDFinder ¶

func WithIDFinder(idFinder columnFinder) Option

func WithInstrumentation ¶

func WithInstrumentation(instr *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 columnFinderWithErr) Option

Source Files ¶

View all Source files

wal_injector.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL