redis

package

v0.0.0-...-5bcfc9d Latest Latest Go to latest Published: Mar 1, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation ¶

This section is empty.

View Source

var (
	Ctx     = context.Background()
	KeyName = "EmailQueue"
)

func ConnectToRedis(logger *utility.Logger, configDatabases config.Redis) *redis.Client

type Redis struct {
	Red *redis.Client
}

func NewRedisConnection(rdb *redis.Client) *Redis

func (rdb *Redis) PopFromQueue() (interface{}, error)

func (rdb *Redis) PushToQueue(value interface{}) error

func (rdb *Redis) RedisDb() *redis.Client

func (rdb *Redis) RedisDelete(key string) (int64, error)

func (rdb *Redis) RedisGet(key string) ([]byte, error)

func (rdb *Redis) RedisSet(key string, value interface{}) error