Versions in this module Expand all Collapse all v0 v0.1.0 Mar 19, 2022 Changes in this version + const DefaultDQBindAddress + const DefaultDQBucketMaxFetchNum + const DefaultDQBucketName + const DefaultDQBucketSize + const DefaultDQQueueName + const DefaultFetchJobBlockTime + const DefaultRedisAddress + const DefaultRedisDialTimeout + const DefaultRedisNetwork + const DefaultRedisReadTimeout + const DefaultRedisWriteTimeout + const DefaultTimerFetchInterval + type Conf struct + DelayQueue DelayQueue + Redis Redis + func New() *Conf + func (c *Conf) Load(file string, fileType FileType) error + func (c *Conf) String() string + type DelayQueue struct + BindAddress string + BucketMaxFetchNum uint64 + BucketName string + BucketSize uint64 + QueueName string + TimerFetchDelay int + TimerFetchInterval int + type FileType string + const FileTypeJSON + const FileTypeYAML + type Redis struct + Address string + DB int + DialTimeout int + MinIdleConns int + Mode RedisMode + Network string + Password string + PoolSize int + ReadTimeout int + Username string + WriteTimeout int + type RedisMode string + const RedisModeCluster + const RedisModeNormal + func (r RedisMode) IsCluster() bool v0.1.0-beta Jul 14, 2021