Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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(ctx context.Context, 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.
type Option ¶
type Option func(t *Injector)
func WithInstrumentation ¶
func WithInstrumentation(instr *otel.Instrumentation) Option
func WithLogger ¶
Source Files
Click to show internal directories.
Click to hide internal directories.