common

Documentation

Index

• func ConfigurePGXLogger(connConfig *pgx.ConnConfig)
• func ConvertToWriteConstraintError(livingTupleConstraint string, err error) error
• func NewPGXExecutor(txSource TxFactory) common.ExecuteQueryFunc
• func NewPgxpoolStatsCollector(dbpool *pgxpool.Pool, dbName string) prometheus.Collector
• type TxFactory

Functions

func ConfigurePGXLogger

func ConfigurePGXLogger(connConfig *pgx.ConnConfig)

ConfigurePGXLogger sets zerolog global logger into the connection pool configuration, and maps info level events to debug, as they are rather verbose for SpiceDB's info level

func ConvertToWriteConstraintError

func ConvertToWriteConstraintError(livingTupleConstraint string, err error) error

ConvertToWriteConstraintError converts the given Postgres error into a CreateRelationshipExistsError if applicable. If not applicable, returns nils.

func NewPGXExecutor

func NewPGXExecutor(txSource TxFactory) common.ExecuteQueryFunc

NewPGXExecutor creates an executor that uses the pgx library to make the specified queries.

func NewPgxpoolStatsCollector

func NewPgxpoolStatsCollector(dbpool *pgxpool.Pool, dbName string) prometheus.Collector

NewPgxpoolStatsCollector returns a collector that exports stats available in a pgxpool.

For more info see: https://pkg.go.dev/github.com/jackc/pgx/v4/pgxpool#Stat

Types

type TxFactory

type TxFactory func(context.Context) (pgx.Tx, common.TxCleanupFunc, error)

TxFactory returns a transaction, cleanup function, and any errors that may have occurred when building the transaction.