PQ

In order to work with the Postgres aggregate and stream projector a postgres Listener is provided for the pq postgres driver.

import "github.com/hellofresh/goengine/v2/extension/pq"

listener, err := pq.NewListener(
    s.PostgresDSN,
    string(projection.FromStream()),
    time.Millisecond,
    time.Second,
    s.GetLogger(),
)