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

testutil

package

Go to main page

Versions in this module

v0

v0.25.2

Apr 12, 2023

v0.25.1

Apr 5, 2023

v0.25.0

Apr 3, 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 NewTaskMessageWithMetadata(taskType string, md map[string]string) *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