workqueue

Dec 11, 2024

Changes in this version

+ type Mock struct

+ func (m *Mock[T]) Add(item T)

+ func (m *Mock[T]) AddAfter(item T, duration time.Duration)

+ func (m *Mock[T]) AddRateLimited(item T)

+ func (m *Mock[T]) Done(item T)

+ func (m *Mock[T]) Forget(item T)

+ func (m *Mock[T]) Get() (item T, shutdown bool)

+ func (m *Mock[T]) Len() int

+ func (m *Mock[T]) NumRequeues(item T) int

+ func (m *Mock[T]) ShutDown()

+ func (m *Mock[T]) ShutDownWithDrain()

+ func (m *Mock[T]) ShuttingDown() bool

+ func (m *Mock[T]) State() MockState[T]

+ func (m *Mock[T]) SyncOne(item T, sync func(workqueue.TypedRateLimitingInterface[T]))

+ type MockDelayedItem struct

+ Duration time.Duration

+ Item T

+ type MockState struct

+ Failures map[T]int

+ InFlight []T

+ Later []MockDelayedItem[T]

+ MismatchedDone []T

+ Ready []T

+ ShutDownCalled int

+ ShutDownWithDrainCalled int

+ func (m MockState[T]) DeepCopy() *MockState[T]