Method Start

internal/webhookpub/worker.go:97–100

Start blocks on ctx — call in its own goroutine. Spawns the LISTEN reader in a sibling goroutine and runs the tick loop on the calling goroutine. Both stop when ctx is cancelled.

(ctx context.Context)

// reader in a sibling goroutine and runs the tick loop on the calling
// goroutine. Both stop when ctx is cancelled.
func (w *OutboxWorker) Start(ctx context.Context) {
	go w.listenLoop(ctx)
	w.tickLoop(ctx)
}

// listenLoop owns a dedicated, non-pool connection and re-issues
// LISTEN webhook_events_new on each reconnect. pgx's pool connections