Versions in this module Expand all Collapse all v0 v0.0.0 Feb 8, 2018 Changes in this version + type Crow interface + AddToQueue func(string, interface{}, bool) + ClearQueue func(string, string) error + CreateLockKey func(string, string, int) bool + ExtendLockKey func(string, int) + FindQueueByKey func(string) (string, bool) + GetQueueContents func(string) []string + GetReadyQueues func(string) []string + IsLocked func(string) bool + MoveToReady func(string, string) + QueueSize func(string) int + QueueTimeSinceCreation func(string) int + RemoveLockKey func(string) + type Murder struct + func NewMurder(bulkSize, TTL int, crow Crow, groupID string) *Murder + func NewMurderWithAge(bulkSize, TTL int, crow Crow, groupID string, queueAge int) *Murder + func (m *Murder) Ack(lockKey string) + func (m *Murder) Add(obj interface{}) + func (m *Murder) AgeConfigured() bool + func (m *Murder) Get(lockKey string) []string + func (m *Murder) Lock() (string, bool) + func (m *Murder) Mark(lockKey string) + func (m *Murder) Unlock(lockKey string) + type RedisCrow struct + Redis *redis.Client + func (c *RedisCrow) AddToQueue(groupName string, obj interface{}, ageConfigured bool) + func (c *RedisCrow) ClearQueue(queueName string, groupID string) error + func (c *RedisCrow) CreateLockKey(queueName string, lockKey string, TTL int) bool + func (c *RedisCrow) CurrentQueue(groupName string) string + func (c *RedisCrow) ExtendLockKey(lockKey string, TTL int) + func (c *RedisCrow) FindQueueByKey(lockKey string) (string, bool) + func (c *RedisCrow) GetQueueContents(queueName string) []string + func (c *RedisCrow) GetReadyQueues(groupID string) []string + func (c *RedisCrow) IsLocked(queueName string) bool + func (c *RedisCrow) MoveToReady(groupName, newName string) + func (c *RedisCrow) QueueSize(groupName string) int + func (c *RedisCrow) QueueTimeSinceCreation(groupName string) int + func (c *RedisCrow) RemoveLockKey(lockKey string)