redis

Documentation

Index

• type RedisPool
  • func NewRedisPool(ctx context.Context, o RedisPoolOpts) (*RedisPool, error)
  • func (r *RedisPool) MakeRedisClient() interface{}
• type RedisPoolOpts

Types

type RedisPool

type RedisPool struct {
	Client *redis.Client
}

func NewRedisPool

func NewRedisPool(ctx context.Context, o RedisPoolOpts) (*RedisPool, error)

NewRedisPool creates a reusable connection across the cic-custodial componenent. Note: Each db namespace requires its own connection pool.

func (*RedisPool) MakeRedisClient

func (r *RedisPool) MakeRedisClient() interface{}

Interface adapter for asynq to resuse the same Redis connection pool.

type RedisPoolOpts

type RedisPoolOpts struct {
	DSN          string
	MinIdleConns int
}