Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

testutil

package

Go to main page

Versions in this module

v0

v0.29.1

Jul 12, 2025

v0.29.0

Jul 12, 2025

v0.28.1

Jul 11, 2025

v0.28.0

Jul 11, 2025

v0.27.1

Jul 10, 2025

v0.27.0

Jul 10, 2025

v0.26.1

Jul 10, 2025

v0.26.0

Jul 10, 2025

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