EquateInt64Approx returns a Comparer option that treats int64 values to be equal if they are within the given margin.

FlushDB deletes all the keys of the currently selected DB.

GetActiveMessages returns all active messages in the given queue.

GetArchivedEntries returns all archived messages and its score in the given queue.

GetArchivedMessages returns all archived messages in the given queue.

GetCompletedEntries returns all completed messages and its score in the given queue.

GetCompletedMessages returns all completed task messages in the given queue.

GetGroupEntries returns all scheduled messages and its score in the given queue.

GetLeaseEntries returns all task IDs and its score in the lease set for the given queue.

GetPendingMessages returns all pending messages in the given queue.

GetRetryEntries returns all retry messages and its score in the given queue.

GetRetryMessages returns all retry messages in the given queue.

GetScheduledEntries returns all scheduled messages and its score in the given queue.

GetScheduledMessages returns all scheduled task messages in the given queue.

JSON serializes the given key-value pairs into stream of bytes in JSON.

MustMarshal marshals given task message and returns a json string.

MustUnmarshal unmarshals given string into task message struct.

NewLeaseWithClock returns a new lease with the given expiration time and clock.

NewTaskMessage returns a new instance of TaskMessage given a task type and payload.

NewTaskMessageWithQueue returns a new instance of TaskMessage given a task type, payload and queue name.

SeedActiveQueue initializes the active queue with the given messages.

SeedAllActiveQueues initializes all of the specified active queues with the given messages.

SeedAllArchivedQueues initializes all of the specified archived queues with the given entries.

SeedAllCompletedQueues initializes all of the completed queues with the given entries.

SeedAllGroups initializes all groups in all queues.

SeedAllLease initializes all of the lease sets with the given entries.

SeedAllPendingQueues initializes all of the specified queues with the given messages.

SeedAllRetryQueues initializes all of the specified retry queues with the given entries.

SeedAllScheduledQueues initializes all of the specified scheduled queues with the given entries.

SeedArchivedQueue initializes the archived queue with the given messages.

SeedCompletedQueue initializes the completed set with the given entries.

SeedGroup initializes the group with the given entries.

SeedLease initializes the lease set with the given entries.

SeedPendingQueue initializes the specified queue with the given messages.

SeedRetryQueue initializes the retry queue with the given messages.

SeedScheduledQueue initializes the scheduled queue with the given messages.

TaskMessageAfterRetry returns an updated copy of t after retry.

TaskMessageWithCompletedAt returns an updated copy of t after completion.

TaskMessageWithError returns an updated copy of t with the given error message.

IgnoreIDOpt is an cmp.Option to ignore ID field in task messages when comparing.

SortMsgOpt is a cmp.Option to sort base.TaskMessage for comparing slice of task messages.

SortSchedulerEnqueueEventOpt is a cmp.Option to sort base.SchedulerEnqueueEvent for comparing slice of events.

SortSchedulerEntryOpt is a cmp.Option to sort base.SchedulerEntry for comparing slice of entries.

SortServerInfoOpt is a cmp.Option to sort base.ServerInfo for comparing slice of process info.

SortStringSliceOpt is a cmp.Option to sort string slice.

SortWorkerInfoOpt is a cmp.Option to sort base.WorkerInfo for comparing slice of worker info.

SortZSetEntryOpt is an cmp.Option to sort ZSetEntry for comparing slice of zset entries.

TaskSeedData holds the data required to seed tasks under the task key in test.