testutil

type CounterCache interface {
	Put(string, Counters)
	Get(string) Counters
	Reset(string)
}

type Counters interface {
	Reset()
	Inc()
	Count() int
}

type GroupConstructor func(context.Context, time.Duration) (amboy.QueueGroup, TestCloser, error)

type GroupConstructorCase struct {
	Name             string
	Valid            bool
	LocalConstructor func(context.Context) (amboy.Queue, error)
	TTL              time.Duration
	SkipRemote       bool
}

type GroupIntegrationCase struct {
	Name             string
	Constructor      GroupConstructor
	LocalConstructor QueueConstructor
}

type ManagerSuite struct {
	Queue   amboy.Queue
	Manager management.Manager
	Factory func() management.Manager
	Setup   func()
	Cleanup func() error

	suite.Suite
	// contains filtered or unexported fields
}

type PoolTestCase struct {
	Name         string
	SetPool      func(amboy.Queue, int) error
	SkipRemote   bool
	SkipMulti    bool
	RateLimiting bool
	MinSize      int
	MaxSize      int
}

type QueueConstructor func(context.Context) (amboy.Queue, error)

type QueueTestCase struct {
	Name                    string
	Constructor             func(context.Context, string, int) (amboy.Queue, TestCloser, error)
	MinSize                 int
	MaxSize                 int
	DisableParallelTests    bool
	SingleWorker            bool
	SkipRateLimitedWorker   bool
	MultiSupported          bool
	OrderedSupported        bool
	OrderedStartsBefore     bool
	WaitUntilSupported      bool
	DispatchBeforeSupported bool
	SkipUnordered           bool
	IsRemote                bool
	Skip                    bool
}

type SizeTestCase struct {
	Name string
	Size int
}

type TestCloser func(context.Context) error