Versions in this module Expand all Collapse all v0 v0.3.8 Jul 6, 2026 v0.3.2 May 13, 2026 Changes in this version + func GenFilter(filter, placeholder string) (sql string, args []any) + func GenFilterValidated(filter, placeholder string) (sql string, args []any, err error) + func NewRuntime() providers.RuntimeBroker + type Connection struct + func OpenConnection(ctx context.Context, dsn string, maxConns int32) (*Connection, error) + func (c *Connection) Close() error + func (c *Connection) DSN() string + func (c *Connection) PollInterval() time.Duration + func (c *Connection) Pool() *pgxpool.Pool + func (c *Connection) Provider() string + func (c *Connection) SetPollInterval(d time.Duration) + type EventRow struct + CorrelationID string + Headers json.RawMessage + ID int64 + Payload []byte + StreamName string + Subject string + Ts time.Time
Go to main page