stdout

package

v1.1.0 Latest Latest Go to latest Published: Jun 12, 2026 License: Apache-2.0 Imports: 9 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

Documentation ¶

Index ¶

type Option
type Writer
- func NewWriter(opts ...Option) *Writer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Option ¶

type Option func(*Writer)

func WithCheckpoint ¶

func WithCheckpoint(c checkpointer.Checkpoint) Option

func WithLogger ¶

func WithLogger(l loglib.Logger) Option

func WithWriter ¶

func WithWriter(out io.Writer) Option

WithWriter overrides the destination io.Writer. Primarily intended for tests.

type Writer ¶

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

Writer is a processor that serialises WAL events as NDJSON to an io.Writer (defaulting to os.Stdout). It is intended for debugging and quick validation of a pgstream pipeline without needing a real target.

func NewWriter ¶

func NewWriter(opts ...Option) *Writer

func (*Writer) Close ¶

func (w *Writer) Close() error

func (*Writer) Name ¶

func (w *Writer) Name() string

func (*Writer) ProcessWALEvent ¶

func (w *Writer) ProcessWALEvent(ctx context.Context, walEvent *wal.Event) (retErr error)

Source Files ¶

View all Source files

wal_stdout_writer.go

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