common

Documentation

Index

• func ConfigurePGXLogger(connConfig *pgx.ConnConfig)
• func ConvertToWriteConstraintError(livingTupleConstraint string, err error) error
• func NewPGXExecutor(txSource TxFactory) common.ExecuteQueryFunc
• type PoolOptions
  • func (opts PoolOptions) ConfigurePgx(pgxConfig *pgxpool.Config)
• 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.

Types

type PoolOptions

type PoolOptions struct {
	ConnMaxIdleTime         *time.Duration
	ConnMaxLifetime         *time.Duration
	ConnHealthCheckInterval *time.Duration
	MinOpenConns            *int
	MaxOpenConns            *int
}

PoolOptions is the set of configuration used for a pgx connection pool.

func (PoolOptions) ConfigurePgx

func (opts PoolOptions) ConfigurePgx(pgxConfig *pgxpool.Config)

ConfigurePgx applies PoolOptions to a pgx connection pool confiugration.

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.