postgres

Documentation

Index

• type Checkpointer
  • func New(syncer lsnSyncer) *Checkpointer
  • func (c *Checkpointer) Close() error
  • func (c *Checkpointer) SyncLSN(ctx context.Context, positions []wal.CommitPosition) error
• type Config

Types

type Checkpointer

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

Checkpointer is a postgres implementation of a wal checkpointer. It syncs the LSN to postgres.

func New

func New(syncer lsnSyncer) *Checkpointer

New returns a postgres checkpointer that syncs the LSN to postgres on demand.

func (*Checkpointer) Close

func (c *Checkpointer) Close() error

func (*Checkpointer) SyncLSN

func (c *Checkpointer) SyncLSN(ctx context.Context, positions []wal.CommitPosition) error

type Config

type Config struct {
	Replication pgreplication.Config
}