Documentation
¶
Index ¶
Constants ¶
View Source
const EnvPrefix = "RQ_POD"
EnvPrefix for env
View Source
const RedisConfigKey = "rq:pod:conf"
RedisConfigKey TODO
View Source
const RedisPausedQueuesKey = "rq:pod:paused"
RedisPausedQueuesKey TODO
View Source
const RedisQueueKeyPrefix = "rq:q:"
RedisQueueKeyPrefix TODO
View Source
const RedisRequestConfigKey = "rq:pod:conf:request"
RedisRequestConfigKey TODO
Variables ¶
View Source
var DefaultConfig = map[string]interface{}{ "debug": false, "log.level": "info", "http.addr": ":6789", "http.log.enable": true, "http.api.path": "", "redis.addr": "localhost:6379", "redis.password": "", "redis.db": 0, "limit.http.size": 1 << 20, "limit.redis.memory": int64(1 << 30), "limit.request.num": 10000000, "limit.queue.num": 1000, "limit.queue.length": 10000, }
DefaultConfig TODO
Functions ¶
This section is empty.
Types ¶
type ExceedLimitError ¶
type ExceedLimitError string
ExceedLimitError TODO
func (ExceedLimitError) Error ¶
func (e ExceedLimitError) Error() string
type ExistError ¶
type ExistError string
ExistError TODO
func (ExistError) Error ¶
func (e ExistError) Error() string
type NotExistError ¶
type NotExistError string
NotExistError TODO
func (NotExistError) Error ¶
func (e NotExistError) Error() string
type UnavailableError ¶
type UnavailableError string
UnavailableError TODO
func (UnavailableError) Error ¶
func (e UnavailableError) Error() string
Click to show internal directories.
Click to hide internal directories.