Versions in this module Expand all Collapse all v0 v0.1.0 Sep 11, 2026 Changes in this version + const DefaultErrorRetryInterval + const DefaultFeedbackInterval + var DefaultPlugins = map[string][]string + var ErrConfirmedFlushLSN = errors.New("ConfirmedFlushLSN is in the future") + var ErrNoLogger = errors.New("Logger not set") + var ErrPlugin = errors.New("Wrong decoding plugin") + var ErrReceiverLocked = errors.New("Receiver is locked by another thread") + var ErrReceiverStopped = errors.New("Receiver was stopped before") + type Logger interface + Debg2 func(string) + Debg2f func(string, ...interface{}) + Debg3 func(string) + Debg3f func(string, ...interface{}) + Debg4 func(string) + Debg4f func(string, ...interface{}) + Debg5 func(string) + Debg5f func(string, ...interface{}) + Debug func(string) + Debugf func(string, ...interface{}) + Error func(string) + Errorf func(string, ...interface{}) + Info func(string) + Infof func(string, ...interface{}) + Warn func(string) + Warnf func(string, ...interface{}) + type MsgItem interface + type Next int8 + const Break + const Connect + const Recv + const Stop + func (nxt Next) String() string + type Opt func(*rOpts) + func WithAcceptedPlugins(x map[string][]string) Opt + func WithParams(x *Param) Opt + func WithStartLSN(x pglogrepl.LSN) Opt + type Param struct + CloseOnActivation chan<- struct{} + ConnInfo string + ErrorRetryInterval time.Duration + FeedbackInterval time.Duration + Logger Logger + SlotName string + type Receiver struct + func NewReceiver(p ...Opt) *Receiver + func (r *Receiver) AckLSN(write pglogrepl.LSN, other ...pglogrepl.LSN) + func (r *Receiver) Close() error + func (r *Receiver) Err() error + func (r *Receiver) Params() Param + func (r *Receiver) Plugin() string + func (r *Receiver) Produce(ctx context.Context) (iter.Seq[MsgItem], error) + func (r *Receiver) RequestReload(p Param) + func (r *Receiver) Shutdown(err error) + func (r *Receiver) State() Next
Go to main page