mocks

Jan 31, 2026

Changes in this version

type IndexedWorkQueue

+ func NewIndexedWorkQueue(t interface{ ... }) *IndexedWorkQueue

+ func (_m *IndexedWorkQueue) EXPECT() *IndexedWorkQueue_Expecter

+ type IndexedWorkQueue_Expecter struct

+ func (_e *IndexedWorkQueue_Expecter) Get(id interface{}) *IndexedWorkQueue_Get_Call

+ func (_e *IndexedWorkQueue_Expecter) Queue(ctx interface{}, id interface{}, once interface{}) *IndexedWorkQueue_Queue_Call

+ func (_e *IndexedWorkQueue_Expecter) Start(ctx interface{}) *IndexedWorkQueue_Start_Call

+ type IndexedWorkQueue_Get_Call struct

+ func (_c *IndexedWorkQueue_Get_Call) Return(info workqueue.WorkItemInfo, found bool, err error) *IndexedWorkQueue_Get_Call

+ func (_c *IndexedWorkQueue_Get_Call) Run(run func(id workqueue.WorkItemID)) *IndexedWorkQueue_Get_Call

+ func (_c *IndexedWorkQueue_Get_Call) RunAndReturn(run func(workqueue.WorkItemID) (workqueue.WorkItemInfo, bool, error)) *IndexedWorkQueue_Get_Call

+ type IndexedWorkQueue_Queue_Call struct

+ func (_c *IndexedWorkQueue_Queue_Call) Return(_a0 error) *IndexedWorkQueue_Queue_Call

+ func (_c *IndexedWorkQueue_Queue_Call) Run(...) *IndexedWorkQueue_Queue_Call

+ func (_c *IndexedWorkQueue_Queue_Call) RunAndReturn(run func(context.Context, workqueue.WorkItemID, workqueue.WorkItem) error) *IndexedWorkQueue_Queue_Call

+ type IndexedWorkQueue_Start_Call struct

+ func (_c *IndexedWorkQueue_Start_Call) Return(_a0 error) *IndexedWorkQueue_Start_Call

+ func (_c *IndexedWorkQueue_Start_Call) Run(run func(ctx context.Context)) *IndexedWorkQueue_Start_Call

+ func (_c *IndexedWorkQueue_Start_Call) RunAndReturn(run func(context.Context) error) *IndexedWorkQueue_Start_Call

type Processor

+ func NewProcessor(t interface{ ... }) *Processor

+ func (_m *Processor) EXPECT() *Processor_Expecter

+ type Processor_Expecter struct

+ func (_e *Processor_Expecter) Process(ctx interface{}, workItem interface{}) *Processor_Process_Call

+ type Processor_Process_Call struct

+ func (_c *Processor_Process_Call) Return(_a0 workqueue.WorkStatus, _a1 error) *Processor_Process_Call

+ func (_c *Processor_Process_Call) Run(run func(ctx context.Context, workItem workqueue.WorkItem)) *Processor_Process_Call

+ func (_c *Processor_Process_Call) RunAndReturn(run func(context.Context, workqueue.WorkItem) (workqueue.WorkStatus, error)) *Processor_Process_Call

type WorkItem

+ func NewWorkItem(t interface{ ... }) *WorkItem

+ func (_m *WorkItem) EXPECT() *WorkItem_Expecter

type WorkItemInfo

+ func NewWorkItemInfo(t interface{ ... }) *WorkItemInfo

+ func (_m *WorkItemInfo) EXPECT() *WorkItemInfo_Expecter

+ type WorkItemInfo_Error_Call struct

+ func (_c *WorkItemInfo_Error_Call) Return(_a0 error) *WorkItemInfo_Error_Call

+ func (_c *WorkItemInfo_Error_Call) Run(run func()) *WorkItemInfo_Error_Call

+ func (_c *WorkItemInfo_Error_Call) RunAndReturn(run func() error) *WorkItemInfo_Error_Call

+ type WorkItemInfo_Expecter struct

+ func (_e *WorkItemInfo_Expecter) Error() *WorkItemInfo_Error_Call

+ func (_e *WorkItemInfo_Expecter) ID() *WorkItemInfo_ID_Call

+ func (_e *WorkItemInfo_Expecter) Item() *WorkItemInfo_Item_Call

+ func (_e *WorkItemInfo_Expecter) Status() *WorkItemInfo_Status_Call

+ type WorkItemInfo_ID_Call struct

+ func (_c *WorkItemInfo_ID_Call) Return(_a0 workqueue.WorkItemID) *WorkItemInfo_ID_Call

+ func (_c *WorkItemInfo_ID_Call) Run(run func()) *WorkItemInfo_ID_Call

+ func (_c *WorkItemInfo_ID_Call) RunAndReturn(run func() workqueue.WorkItemID) *WorkItemInfo_ID_Call

+ type WorkItemInfo_Item_Call struct

+ func (_c *WorkItemInfo_Item_Call) Return(_a0 workqueue.WorkItem) *WorkItemInfo_Item_Call

+ func (_c *WorkItemInfo_Item_Call) Run(run func()) *WorkItemInfo_Item_Call

+ func (_c *WorkItemInfo_Item_Call) RunAndReturn(run func() workqueue.WorkItem) *WorkItemInfo_Item_Call

+ type WorkItemInfo_Status_Call struct

+ func (_c *WorkItemInfo_Status_Call) Return(_a0 workqueue.WorkStatus) *WorkItemInfo_Status_Call

+ func (_c *WorkItemInfo_Status_Call) Run(run func()) *WorkItemInfo_Status_Call

+ func (_c *WorkItemInfo_Status_Call) RunAndReturn(run func() workqueue.WorkStatus) *WorkItemInfo_Status_Call

+ type WorkItem_Expecter struct

Dec 22, 2025

Changes in this version

+ type IndexedWorkQueue struct

+ func (_m *IndexedWorkQueue) Get(id string) (workqueue.WorkItemInfo, bool, error)

+ func (_m *IndexedWorkQueue) OnGet(id string) *IndexedWorkQueue_Get

+ func (_m *IndexedWorkQueue) OnGetMatch(matchers ...interface{}) *IndexedWorkQueue_Get

+ func (_m *IndexedWorkQueue) OnQueue(ctx context.Context, id string, once workqueue.WorkItem) *IndexedWorkQueue_Queue

+ func (_m *IndexedWorkQueue) OnQueueMatch(matchers ...interface{}) *IndexedWorkQueue_Queue

+ func (_m *IndexedWorkQueue) OnStart(ctx context.Context) *IndexedWorkQueue_Start

+ func (_m *IndexedWorkQueue) OnStartMatch(matchers ...interface{}) *IndexedWorkQueue_Start

+ func (_m *IndexedWorkQueue) Queue(ctx context.Context, id string, once workqueue.WorkItem) error

+ func (_m *IndexedWorkQueue) Start(ctx context.Context) error

+ type IndexedWorkQueue_Get struct

+ func (_m IndexedWorkQueue_Get) Return(info workqueue.WorkItemInfo, found bool, err error) *IndexedWorkQueue_Get

+ type IndexedWorkQueue_Queue struct

+ func (_m IndexedWorkQueue_Queue) Return(_a0 error) *IndexedWorkQueue_Queue

+ type IndexedWorkQueue_Start struct

+ func (_m IndexedWorkQueue_Start) Return(_a0 error) *IndexedWorkQueue_Start

+ type Processor struct

+ func (_m *Processor) OnProcess(ctx context.Context, workItem workqueue.WorkItem) *Processor_Process

+ func (_m *Processor) OnProcessMatch(matchers ...interface{}) *Processor_Process

+ func (_m *Processor) Process(ctx context.Context, workItem workqueue.WorkItem) (workqueue.WorkStatus, error)

+ type Processor_Process struct

+ func (_m Processor_Process) Return(_a0 workqueue.WorkStatus, _a1 error) *Processor_Process

+ type WorkItem struct

+ type WorkItemInfo struct

+ func (_m *WorkItemInfo) Error() error

+ func (_m *WorkItemInfo) ID() string

+ func (_m *WorkItemInfo) Item() workqueue.WorkItem

+ func (_m *WorkItemInfo) OnError() *WorkItemInfo_Error

+ func (_m *WorkItemInfo) OnErrorMatch(matchers ...interface{}) *WorkItemInfo_Error

+ func (_m *WorkItemInfo) OnID() *WorkItemInfo_ID

+ func (_m *WorkItemInfo) OnIDMatch(matchers ...interface{}) *WorkItemInfo_ID

+ func (_m *WorkItemInfo) OnItem() *WorkItemInfo_Item

+ func (_m *WorkItemInfo) OnItemMatch(matchers ...interface{}) *WorkItemInfo_Item

+ func (_m *WorkItemInfo) OnStatus() *WorkItemInfo_Status

+ func (_m *WorkItemInfo) OnStatusMatch(matchers ...interface{}) *WorkItemInfo_Status

+ func (_m *WorkItemInfo) Status() workqueue.WorkStatus

+ type WorkItemInfo_Error struct

+ func (_m WorkItemInfo_Error) Return(_a0 error) *WorkItemInfo_Error

+ type WorkItemInfo_ID struct

+ func (_m WorkItemInfo_ID) Return(_a0 string) *WorkItemInfo_ID

+ type WorkItemInfo_Item struct

+ func (_m WorkItemInfo_Item) Return(_a0 workqueue.WorkItem) *WorkItemInfo_Item

+ type WorkItemInfo_Status struct

+ func (_m WorkItemInfo_Status) Return(_a0 workqueue.WorkStatus) *WorkItemInfo_Status