Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

redis_v2

package

Go to main page

Versions in this module

v1

v1.0.14

Sep 27, 2023

v1.0.13

Feb 24, 2023

v1.0.12

Feb 23, 2023

Changes in this version

+ const BatchSize

+ const DeadLetterPrefix

+ const MaxRedisConnections

+ const MetaPrefix

+ const Namespace

+ const PoolPrefix

+ const QueuePrefix

+ const Subsystem

+ const VersionV2

+ func NewEngine(redisName string, cfg *config.RedisConf, conn *go_redis.Client) (engine.Engine, error)

+ func PoolJobKey(j engine.Job) string

+ func PoolJobKey2(namespace, queue, jobID string) string

+ func PoolJobKeyPrefix(namespace, queue string) string

+ func PreloadDeadLetterLuaScript(redis *RedisInstance) error

+ func PreloadQueueLuaScript(redis *RedisInstance) error

+ func RedisInstanceMonitor(redis *RedisInstance)

+ func SetLogger(l *logrus.Logger)

+ func Setup(conf *config.Config) error

+ type DeadLetter struct

+ func NewDeadLetter(namespace, queue string, redis *RedisInstance) (*DeadLetter, error)

+ func (dl *DeadLetter) Add(jobID string) error

+ func (dl *DeadLetter) Delete(limit int64) (count int64, err error)

+ func (dl *DeadLetter) Name() string

+ func (dl *DeadLetter) Peek() (size int64, jobID string, err error)

+ func (dl *DeadLetter) Respawn(limit, ttlSecond int64) (count int64, err error)

+ func (dl *DeadLetter) Size() (size int64, err error)

+ type Engine struct

+ func (e *Engine) BatchConsume(namespace string, queues []string, count, ttrSecond, timeoutSecond uint32) (jobs []engine.Job, err error)

+ func (e *Engine) Consume(namespace string, queues []string, ttrSecond, timeoutSecond uint32) (job engine.Job, err error)

+ func (e *Engine) Delete(namespace, queue, jobID string) error

+ func (e *Engine) DeleteDeadLetter(namespace, queue string, limit int64) (count int64, err error)

+ func (e *Engine) Destroy(namespace, queue string) (count int64, err error)

+ func (e *Engine) DumpInfo(out io.Writer) error

+ func (e *Engine) Peek(namespace, queue, optionalJobID string) (job engine.Job, err error)

+ func (e *Engine) PeekDeadLetter(namespace, queue string) (size int64, jobID string, err error)

+ func (e *Engine) Publish(job engine.Job) (jobID string, err error)

+ func (e *Engine) RespawnDeadLetter(namespace, queue string, limit, ttlSecond int64) (count int64, err error)

+ func (e *Engine) Shutdown()

+ func (e *Engine) Size(namespace, queue string) (size int64, err error)

+ func (e *Engine) SizeOfDeadLetter(namespace, queue string) (size int64, err error)

+ type MetaManager struct

+ func NewMetaManager(redis *RedisInstance) *MetaManager

+ func (m *MetaManager) Dump() (map[string][]string, error)

+ func (m *MetaManager) ListNamespaces() (namespaces []string, err error)

+ func (m *MetaManager) ListQueues(namespace string) (queues []string, err error)

+ func (m *MetaManager) RecordIfNotExist(namespace, queue string)

+ func (m *MetaManager) Remove(namespace, queue string)

+ type Metrics struct

+ type Pool struct

+ func NewPool(redis *RedisInstance) *Pool

+ func (p *Pool) Add(j engine.Job) error

+ func (p *Pool) Delete(namespace, queue, jobID string) error

+ func (p *Pool) Get(namespace, queue, jobID string) (body []byte, ttlSecond uint32, err error)

+ type Queue struct

+ func NewQueue(namespace, queue string, redis *RedisInstance, timer *Timer) *Queue

+ func (q *Queue) Destroy() (count int64, err error)

+ func (q *Queue) Name() string

+ func (q *Queue) Peek() (jobID string, tries uint16, err error)

+ func (q *Queue) Poll(timeoutSecond, ttrSecond uint32) (jobID string, tries uint16, err error)

+ func (q *Queue) Push(j engine.Job) error

+ func (q *Queue) Size() (size int64, err error)

+ type QueueName struct

+ Namespace string

+ Queue string

+ func PollQueues(redis *RedisInstance, timer *Timer, queueNames []QueueName, ...) (queueName *QueueName, jobID string, retries uint16, err error)

+ func (k *QueueName) Decode(str string) error

+ func (k *QueueName) String() string

+ type RedisInfo struct

+ MemMax int64

+ MemUsed int64

+ NBlocking int64

+ NClients int64

+ NExpires int64

+ NKeys int64

+ func GetRedisInfo(redis *RedisInstance) *RedisInfo

+ type RedisInstance struct

+ Conn *go_redis.Client

+ Name string

+ type SizeMonitor struct

+ func NewSizeMonitor(redis *RedisInstance, timer *Timer, preloadData map[string][]string) *SizeMonitor

+ func (m *SizeMonitor) Loop()

+ func (m *SizeMonitor) MonitorIfNotExist(namespace, queue string)

+ func (m *SizeMonitor) Remove(namespace, queue string)

+ type SizeProvider interface

+ Size func() (size int64, err error)

+ type Timer struct

+ func NewTimer(name string, redis *RedisInstance, interval, checkBackupInterval time.Duration) (*Timer, error)

+ func (t *Timer) Add(namespace, queue, jobID string, delaySecond uint32, tries uint16) error

+ func (t *Timer) BackupName() string

+ func (t *Timer) Name() string

+ func (t *Timer) Shutdown()

+ func (t *Timer) Size() (size int64, err error)