Versions in this module Expand all Collapse all v1 v1.0.0 Jul 30, 2026 Changes in this version + type PostgresPubSub struct + func NewPostgresPubSub(connStr string) *PostgresPubSub + func (p *PostgresPubSub) CreateWorker() hydro.ISubWorker + func (p *PostgresPubSub) Publish(ctx context.Context, db *gorm.DB, channel string, message string) error + type PostgresWorker struct + func (w *PostgresWorker) Close() + func (w *PostgresWorker) OnError(fn func(channel string, err error)) + func (w *PostgresWorker) OnMessage(fn func(channel string, message string)) + func (w *PostgresWorker) Subscribe(ctx context.Context, channels ...string) error + func (w *PostgresWorker) Unsubscribe(ctx context.Context, channels ...string) error
Go to main page