Versions in this module Expand all Collapse all v0 v0.24.2 Sep 6, 2023 Changes in this version + var IgnoreIDOpt = cmpopts.IgnoreFields(base.TaskMessage{}, "ID") + var SortMsgOpt = cmp.Transformer("SortTaskMessages", func(in []*base.TaskMessage) []*base.TaskMessage { ... }) + var SortRedisZSetEntryOpt = cmp.Transformer("SortZSetEntries", func(in []redis.Z) []redis.Z { ... }) + var SortSchedulerEnqueueEventOpt = cmp.Transformer("SortSchedulerEnqueueEvent", ...) + var SortSchedulerEntryOpt = cmp.Transformer("SortSchedulerEntry", ...) + var SortServerInfoOpt = cmp.Transformer("SortServerInfo", func(in []*base.ServerInfo) []*base.ServerInfo { ... }) + var SortStringSliceOpt = cmp.Transformer("SortStringSlice", func(in []string) []string { ... }) + var SortWorkerInfoOpt = cmp.Transformer("SortWorkerInfo", func(in []*base.WorkerInfo) []*base.WorkerInfo { ... }) + var SortZSetEntryOpt = cmp.Transformer("SortZSetEntries", func(in []base.Z) []base.Z { ... }) + func AssertRedisLists(t *testing.T, r redis.UniversalClient, wantLists map[string][]string) + func AssertRedisSets(t *testing.T, r redis.UniversalClient, wantSets map[string][]string) + func AssertRedisZSets(t *testing.T, r redis.UniversalClient, wantZSets map[string][]redis.Z) + func EquateInt64Approx(margin int64) cmp.Option + func FlushDB(tb testing.TB, r redis.UniversalClient) + func GetActiveMessages(tb testing.TB, r redis.UniversalClient, qname string) []*base.TaskMessage + func GetArchivedEntries(tb testing.TB, r redis.UniversalClient, qname string) []base.Z + func GetArchivedMessages(tb testing.TB, r redis.UniversalClient, qname string) []*base.TaskMessage + func GetCompletedEntries(tb testing.TB, r redis.UniversalClient, qname string) []base.Z + func GetCompletedMessages(tb testing.TB, r redis.UniversalClient, qname string) []*base.TaskMessage + func GetGroupEntries(tb testing.TB, r redis.UniversalClient, qname, groupKey string) []base.Z + func GetLeaseEntries(tb testing.TB, r redis.UniversalClient, qname string) []base.Z + func GetPendingMessages(tb testing.TB, r redis.UniversalClient, qname string) []*base.TaskMessage + func GetRetryEntries(tb testing.TB, r redis.UniversalClient, qname string) []base.Z + func GetRetryMessages(tb testing.TB, r redis.UniversalClient, qname string) []*base.TaskMessage + func GetScheduledEntries(tb testing.TB, r redis.UniversalClient, qname string) []base.Z + func GetScheduledMessages(tb testing.TB, r redis.UniversalClient, qname string) []*base.TaskMessage + func JSON(kv map[string]interface{}) []byte + func MustMarshal(tb testing.TB, msg *base.TaskMessage) string + func MustUnmarshal(tb testing.TB, data string) *base.TaskMessage + func NewLeaseWithClock(expirationTime time.Time, clock timeutil.Clock) *base.Lease + func NewTaskMessage(taskType string, payload []byte) *base.TaskMessage + func NewTaskMessageWithQueue(taskType string, payload []byte, qname string) *base.TaskMessage + func SeedActiveQueue(tb testing.TB, r redis.UniversalClient, msgs []*base.TaskMessage, qname string) + func SeedAggregationSet(tb testing.TB, r redis.UniversalClient, entries []base.Z, ...) + func SeedAllActiveQueues(tb testing.TB, r redis.UniversalClient, active map[string][]*base.TaskMessage) + func SeedAllArchivedQueues(tb testing.TB, r redis.UniversalClient, archived map[string][]base.Z) + func SeedAllCompletedQueues(tb testing.TB, r redis.UniversalClient, completed map[string][]base.Z) + func SeedAllGroups(tb testing.TB, r redis.UniversalClient, groups map[string]map[string][]base.Z) + func SeedAllLease(tb testing.TB, r redis.UniversalClient, lease map[string][]base.Z) + func SeedAllPendingQueues(tb testing.TB, r redis.UniversalClient, pending map[string][]*base.TaskMessage) + func SeedAllRetryQueues(tb testing.TB, r redis.UniversalClient, retry map[string][]base.Z) + func SeedAllScheduledQueues(tb testing.TB, r redis.UniversalClient, scheduled map[string][]base.Z) + func SeedArchivedQueue(tb testing.TB, r redis.UniversalClient, entries []base.Z, qname string) + func SeedCompletedQueue(tb testing.TB, r redis.UniversalClient, entries []base.Z, qname string) + func SeedGroup(tb testing.TB, r redis.UniversalClient, entries []base.Z, qname, gname string) + func SeedLease(tb testing.TB, r redis.UniversalClient, entries []base.Z, qname string) + func SeedPendingQueue(tb testing.TB, r redis.UniversalClient, msgs []*base.TaskMessage, qname string) + func SeedRedisLists(tb testing.TB, r redis.UniversalClient, lists map[string][]string) + func SeedRedisSet(tb testing.TB, r redis.UniversalClient, key string, members []string) + func SeedRedisSets(tb testing.TB, r redis.UniversalClient, sets map[string][]string) + func SeedRedisZSets(tb testing.TB, r redis.UniversalClient, zsets map[string][]redis.Z) + func SeedRetryQueue(tb testing.TB, r redis.UniversalClient, entries []base.Z, qname string) + func SeedScheduledQueue(tb testing.TB, r redis.UniversalClient, entries []base.Z, qname string) + func SeedTasks(tb testing.TB, r redis.UniversalClient, taskData []*TaskSeedData) + func TaskMessageAfterRetry(t base.TaskMessage, errMsg string, failedAt time.Time) *base.TaskMessage + func TaskMessageWithCompletedAt(t base.TaskMessage, completedAt time.Time) *base.TaskMessage + func TaskMessageWithError(t base.TaskMessage, errMsg string, failedAt time.Time) *base.TaskMessage + type TaskMessageBuilder struct + func NewTaskMessageBuilder() *TaskMessageBuilder + func (b *TaskMessageBuilder) Build() *base.TaskMessage + func (b *TaskMessageBuilder) SetDeadline(deadline time.Time) *TaskMessageBuilder + func (b *TaskMessageBuilder) SetGroup(gname string) *TaskMessageBuilder + func (b *TaskMessageBuilder) SetPayload(payload []byte) *TaskMessageBuilder + func (b *TaskMessageBuilder) SetQueue(qname string) *TaskMessageBuilder + func (b *TaskMessageBuilder) SetRetry(n int) *TaskMessageBuilder + func (b *TaskMessageBuilder) SetTimeout(timeout time.Duration) *TaskMessageBuilder + func (b *TaskMessageBuilder) SetType(typename string) *TaskMessageBuilder + type TaskSeedData struct + Msg *base.TaskMessage + PendingSince time.Time + State base.TaskState