Versions in this module Expand all Collapse all v0 v0.1.0 Apr 2, 2026 Changes in this version + type RedisClusterDataConn struct + func (dc *RedisClusterDataConn) AddForceBack(fn func(*redis.ClusterClient) errs.Err) + func (dc *RedisClusterDataConn) AddPostCommit(fn func(*redis.ClusterClient) errs.Err) + func (dc *RedisClusterDataConn) AddPreCommit(fn func(*redis.ClusterClient) errs.Err) + func (dc *RedisClusterDataConn) Close() + func (dc *RedisClusterDataConn) Commit(ag *sabi.AsyncGroup) errs.Err + func (dc *RedisClusterDataConn) ForceBack(ag *sabi.AsyncGroup) + func (dc *RedisClusterDataConn) GetConnection() *redis.ClusterClient + func (dc *RedisClusterDataConn) PostCommit(ag *sabi.AsyncGroup) + func (dc *RedisClusterDataConn) PreCommit(ag *sabi.AsyncGroup) errs.Err + func (dc *RedisClusterDataConn) Rollback(ag *sabi.AsyncGroup) + func (dc *RedisClusterDataConn) ShouldForceBack() bool + type RedisClusterDataSrc struct + func NewRedisClusterDataSrc(opt *redis.ClusterOptions) *RedisClusterDataSrc + func (ds *RedisClusterDataSrc) Close() + func (ds *RedisClusterDataSrc) CreateDataConn() (sabi.DataConn, errs.Err) + func (ds *RedisClusterDataSrc) Setup(ag *sabi.AsyncGroup) errs.Err + type RedisClusterDataSrcAlreadySetup struct + type RedisClusterDataSrcFailToPing struct + Options *redis.ClusterOptions + type RedisClusterDataSrcNotSetupYet struct + type RedisDataConn struct + func (dc *RedisDataConn) AddForceBack(fn func(*redis.Conn) errs.Err) + func (dc *RedisDataConn) AddPostCommit(fn func(*redis.Conn) errs.Err) + func (dc *RedisDataConn) AddPreCommit(fn func(*redis.Conn) errs.Err) + func (dc *RedisDataConn) Close() + func (dc *RedisDataConn) Commit(ag *sabi.AsyncGroup) errs.Err + func (dc *RedisDataConn) ForceBack(ag *sabi.AsyncGroup) + func (dc *RedisDataConn) GetConnection() *redis.Conn + func (dc *RedisDataConn) PostCommit(ag *sabi.AsyncGroup) + func (dc *RedisDataConn) PreCommit(ag *sabi.AsyncGroup) errs.Err + func (dc *RedisDataConn) Rollback(ag *sabi.AsyncGroup) + func (dc *RedisDataConn) ShouldForceBack() bool + type RedisDataSrc struct + func NewRedisDataSrc(opt *redis.Options) *RedisDataSrc + func (ds *RedisDataSrc) Close() + func (ds *RedisDataSrc) CreateDataConn() (sabi.DataConn, errs.Err) + func (ds *RedisDataSrc) Setup(ag *sabi.AsyncGroup) errs.Err + type RedisDataSrcAlreadySetup struct + type RedisDataSrcFailToPing struct + Options *redis.Options + type RedisDataSrcNotSetupYet struct + type RedisSentinelDataConn struct + func (dc *RedisSentinelDataConn) AddForceBack(fn func(*redis.Conn) errs.Err) + func (dc *RedisSentinelDataConn) AddPostCommit(fn func(*redis.Conn) errs.Err) + func (dc *RedisSentinelDataConn) AddPreCommit(fn func(*redis.Conn) errs.Err) + func (dc *RedisSentinelDataConn) Close() + func (dc *RedisSentinelDataConn) Commit(ag *sabi.AsyncGroup) errs.Err + func (dc *RedisSentinelDataConn) ForceBack(ag *sabi.AsyncGroup) + func (dc *RedisSentinelDataConn) GetConnection() *redis.Conn + func (dc *RedisSentinelDataConn) PostCommit(ag *sabi.AsyncGroup) + func (dc *RedisSentinelDataConn) PreCommit(ag *sabi.AsyncGroup) errs.Err + func (dc *RedisSentinelDataConn) Rollback(ag *sabi.AsyncGroup) + func (dc *RedisSentinelDataConn) ShouldForceBack() bool + type RedisSentinelDataSrc struct + func NewRedisSentinelDataSrc(opt *redis.FailoverOptions) *RedisSentinelDataSrc + func (ds *RedisSentinelDataSrc) Close() + func (ds *RedisSentinelDataSrc) CreateDataConn() (sabi.DataConn, errs.Err) + func (ds *RedisSentinelDataSrc) Setup(ag *sabi.AsyncGroup) errs.Err + type RedisSentinelDataSrcAlreadySetup struct + type RedisSentinelDataSrcFailToPing struct + Options *redis.Options + type RedisSentinelDataSrcNotSetupYet struct