redisext

type Client struct {
	Configs
	DB      *redis.Client
	Queue   rmq.Connection
	Lock    *redsync.Redsync
	Limiter *redis_rate.Limiter
	// contains filtered or unexported fields
}

type Configs struct {
	RedisAddress       string        `env:"REDIS_ADDRESS,required"`
	RedisPassword      string        `env:"REDIS_PASSWORD"`
	RedisDatabase      int           `env:"REDIS_DATABASE"`
	RedisQueueCleaning time.Duration `env:"REDIS_QUEUE_CLEANING" envDefault:"1m"`
	RedisQueuePool     int64         `env:"REDIS_QUEUE_POOL" envDefault:"10"`
	RedisQueueApp      string        `env:"REDIS_QUEUE_APP" envDefault:"app"`
}

type Consumer interface {
	Tag() string
	Consume(delivery *Delivery) error
}

type Delivery struct {
	// contains filtered or unexported fields
}

type Queue struct {
	// contains filtered or unexported fields
}