databases

package

v0.19.4 Latest Latest Go to latest Published: Aug 10, 2026 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var (
	RedisClient *redis.Client
	RedisOnce   sync.Once
)

func CloseRedisClient() error

CloseRedisClient gracefully closes the Redis connection

func GetPoolStats() *redis.PoolStats

GetPoolStats returns current pool statistics

func GetRedisClient() *redis.Client

func WithTransaction(fn func(tx orm.Query) error) error

WithTransaction begins a database transaction, executes fn within it, and commits on success or rolls back on failure or panic.

func WithTransactionQuery(q orm.Query, fn func(tx orm.Query) error) error

WithTransactionQuery is the testable core — accepts an orm.Query directly.

type TransactionFunc func(fn func(tx orm.Query) error) error

TransactionFunc is the type for a function that wraps logic inside a DB transaction.