postgres

Documentation

Index

• type Config
• type Listener
  • func New(handler replicationHandler, processEvent listenerProcessWalEvent, ...) *Listener
  • func (l *Listener) Close() error
  • func (l *Listener) Listen(ctx context.Context) error
• type Option
  • func WithLogger(logger loglib.Logger) Option

Types

type Config

type Config struct {
	Replication pgreplication.Config
}

type Listener

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

Listener contains the environment for subscribing and listening to postgres logical replication events.

func New

func New(handler replicationHandler, processEvent listenerProcessWalEvent, opts ...Option) *Listener

func (*Listener) Close

func (l *Listener) Close() error

Close closes the listener internal resources

func (*Listener) Listen

func (l *Listener) Listen(ctx context.Context) error

Listen starts the subscription process to listen for updates from PG.

type Option

type Option func(l *Listener)

func WithLogger

func WithLogger(logger loglib.Logger) Option