Versions in this module Expand all Collapse all v12 v12.0.0 Aug 20, 2026 Changes in this version + const DefaultMaxReconnectBackoff + const DefaultMinReconnectBackoff + const MaxChannelLength + var ErrChannelTooLong = platformerrors.New("postgres notification channel name is too long") + var ErrNilConfig = platformerrors.Wrap(platformerrors.ErrNilInputParameter, "nil postgres listener config") + type Config struct + Channel string + ConnectionString string + MaxReconnectBackoff time.Duration + MinReconnectBackoff time.Duration + func (cfg *Config) EnsureDefaults() + func (cfg *Config) ValidateWithContext(ctx context.Context) error + type Listener struct + func NewListener(ctx context.Context, cfg *Config, opts ...Option) (*Listener, error) + func (l *Listener) Close(ctx context.Context) error + func (l *Listener) Run() + func (l *Listener) Signal() <-chan struct{} + type Option func(*options) + func WithLogger(logger logging.Logger) Option + func WithMetricsProvider(metricsProvider metrics.Provider) Option + func WithRand(fn retry.Rand) Option + func WithTracerProvider(tracerProvider tracing.Provider) Option Other modules containing this package github.com/primandproper/platform-go/v10 github.com/primandproper/platform-go/v11
Go to main page