redisutil

Jun 10, 2025

Changes in this version

+ const CmdPTTL

+ const LogPrefixValuePool

+ const LogPrefixValueRoleChecker

+ const ParamEX

type DefaultPool

+ func NewPoolFromEnvironment(ctx context.Context, baseLogger *slog.Logger, mtrc PoolMetrics) (p *DefaultPool, err error)

+ type Environment struct

+ DBIndex uint8

+ Host string

+ IdleTimeout timeutil.Duration

+ MaxActive int

+ MaxConnLifetime timeutil.Duration

+ MaxIdle int

+ Network string

+ Port uint16

+ Wait bool

Apr 14, 2025

Changes in this version

+ const CmdDEL

+ const CmdFCALL

+ const CmdFLUSHDB

+ const CmdFUNCTION

+ const CmdGET

+ const CmdROLE

+ const CmdSET

+ const DefaultPort

+ const ErrStrFunctionNotFound

+ const MinTTL

+ const ParamASYNC

+ const ParamLOAD

+ const ParamNX

+ const ParamPX

+ const ParamREPLACE

+ const ParamSYNC

+ const RespOK

+ const RoleMaster

+ const RoleSentinel

+ const RoleSlave

+ const RoleStringMaster

+ const RoleStringSentinel

+ const RoleStringSlave

+ type ConnectionTester interface

+ TestConnection func(ctx context.Context, c redis.Conn, lastUsed time.Time) (err error)

+ type DefaultDialer struct

+ func NewDefaultDialer(c *DefaultDialerConfig) (d *DefaultDialer, err error)

+ func (d *DefaultDialer) DialContext(ctx context.Context) (conn redis.Conn, err error)

+ type DefaultDialerConfig struct

+ Addr *netutil.HostPort

+ DBIndex uint8

+ Network string

+ Resolver *net.Resolver

+ type DefaultPool struct

+ func NewDefaultPool(c *DefaultPoolConfig) (p *DefaultPool, err error)

+ func (p *DefaultPool) Close() (err error)

+ func (p *DefaultPool) Get(ctx context.Context) (c redis.Conn, err error)

+ type DefaultPoolConfig struct

+ ConnectionTester ConnectionTester

+ Dialer Dialer

+ IdleTimeout time.Duration

+ Logger *slog.Logger

+ MaxActive int

+ MaxConnLifetime time.Duration

+ MaxIdle int

+ Metrics PoolMetrics

+ Wait bool

+ type Dialer interface

+ DialContext func(ctx context.Context) (c redis.Conn, err error)

+ type EmptyPoolMetrics struct

+ func (EmptyPoolMetrics) Update(_ context.Context, _ redis.PoolStats, _ error)

+ type Pool interface

+ Close func() (err error)

+ Get func(ctx context.Context) (c redis.Conn, err error)

+ type PoolMetrics interface

+ Update func(ctx context.Context, s redis.PoolStats, err error)

+ type Role string

+ func NewRole(s string) (r Role, err error)

+ func (r Role) Validate() (err error)

+ type RoleChecker struct

+ func NewRoleChecker(c *RoleCheckerConfig) (rc *RoleChecker, err error)

+ func (c *RoleChecker) TestConnection(ctx context.Context, conn redis.Conn, lastUsed time.Time) (err error)

+ type RoleCheckerConfig struct

+ Logger *slog.Logger

+ Role Role