mocks

package
v0.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 28, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockClient 

type MockClient struct {
	mock.Mock
}

MockClient is an autogenerated mock type for the Client type

func NewMockClient 

func NewMockClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockClient

NewMockClient creates a new instance of MockClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockClient) Close 

func (_m *MockClient) Close() error

Close provides a mock function with no fields

func (*MockClient) EXPECT 

func (_m *MockClient) EXPECT() *MockClient_Expecter

func (*MockClient) Enqueue 

func (_m *MockClient) Enqueue(taskName string, payload interface{}, opts ...queue.Option) (*queue.TaskInfo, error)

Enqueue provides a mock function with given fields: taskName, payload, opts

func (*MockClient) EnqueueAt 

func (_m *MockClient) EnqueueAt(taskName string, processAt time.Time, payload interface{}, opts ...queue.Option) (*queue.TaskInfo, error)

EnqueueAt provides a mock function with given fields: taskName, processAt, payload, opts

func (*MockClient) EnqueueContext 

func (_m *MockClient) EnqueueContext(ctx context.Context, taskName string, payload interface{}, opts ...queue.Option) (*queue.TaskInfo, error)

EnqueueContext provides a mock function with given fields: ctx, taskName, payload, opts

func (*MockClient) EnqueueIn 

func (_m *MockClient) EnqueueIn(taskName string, delay time.Duration, payload interface{}, opts ...queue.Option) (*queue.TaskInfo, error)

EnqueueIn provides a mock function with given fields: taskName, delay, payload, opts

type MockClient_Close_Call 

type MockClient_Close_Call struct {
	*mock.Call
}

MockClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*MockClient_Close_Call) Return 

func (_c *MockClient_Close_Call) Return(_a0 error) *MockClient_Close_Call

func (*MockClient_Close_Call) Run 

func (_c *MockClient_Close_Call) Run(run func()) *MockClient_Close_Call

func (*MockClient_Close_Call) RunAndReturn 

func (_c *MockClient_Close_Call) RunAndReturn(run func() error) *MockClient_Close_Call

type MockClient_EnqueueAt_Call 

type MockClient_EnqueueAt_Call struct {
	*mock.Call
}

MockClient_EnqueueAt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnqueueAt'

func (*MockClient_EnqueueAt_Call) Return 

func (_c *MockClient_EnqueueAt_Call) Return(_a0 *queue.TaskInfo, _a1 error) *MockClient_EnqueueAt_Call

func (*MockClient_EnqueueAt_Call) Run 

func (_c *MockClient_EnqueueAt_Call) Run(run func(taskName string, processAt time.Time, payload interface{}, opts ...queue.Option)) *MockClient_EnqueueAt_Call

func (*MockClient_EnqueueAt_Call) RunAndReturn 

func (_c *MockClient_EnqueueAt_Call) RunAndReturn(run func(string, time.Time, interface{}, ...queue.Option) (*queue.TaskInfo, error)) *MockClient_EnqueueAt_Call

type MockClient_EnqueueContext_Call 

type MockClient_EnqueueContext_Call struct {
	*mock.Call
}

MockClient_EnqueueContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnqueueContext'

func (*MockClient_EnqueueContext_Call) Return 

func (_c *MockClient_EnqueueContext_Call) Return(_a0 *queue.TaskInfo, _a1 error) *MockClient_EnqueueContext_Call

func (*MockClient_EnqueueContext_Call) Run 

func (_c *MockClient_EnqueueContext_Call) Run(run func(ctx context.Context, taskName string, payload interface{}, opts ...queue.Option)) *MockClient_EnqueueContext_Call

func (*MockClient_EnqueueContext_Call) RunAndReturn 

func (_c *MockClient_EnqueueContext_Call) RunAndReturn(run func(context.Context, string, interface{}, ...queue.Option) (*queue.TaskInfo, error)) *MockClient_EnqueueContext_Call

type MockClient_EnqueueIn_Call 

type MockClient_EnqueueIn_Call struct {
	*mock.Call
}

MockClient_EnqueueIn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnqueueIn'

func (*MockClient_EnqueueIn_Call) Return 

func (_c *MockClient_EnqueueIn_Call) Return(_a0 *queue.TaskInfo, _a1 error) *MockClient_EnqueueIn_Call

func (*MockClient_EnqueueIn_Call) Run 

func (_c *MockClient_EnqueueIn_Call) Run(run func(taskName string, delay time.Duration, payload interface{}, opts ...queue.Option)) *MockClient_EnqueueIn_Call

func (*MockClient_EnqueueIn_Call) RunAndReturn 

func (_c *MockClient_EnqueueIn_Call) RunAndReturn(run func(string, time.Duration, interface{}, ...queue.Option) (*queue.TaskInfo, error)) *MockClient_EnqueueIn_Call

type MockClient_Enqueue_Call 

type MockClient_Enqueue_Call struct {
	*mock.Call
}

MockClient_Enqueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Enqueue'

func (*MockClient_Enqueue_Call) Return 

func (_c *MockClient_Enqueue_Call) Return(_a0 *queue.TaskInfo, _a1 error) *MockClient_Enqueue_Call

func (*MockClient_Enqueue_Call) Run 

func (_c *MockClient_Enqueue_Call) Run(run func(taskName string, payload interface{}, opts ...queue.Option)) *MockClient_Enqueue_Call

func (*MockClient_Enqueue_Call) RunAndReturn 

func (_c *MockClient_Enqueue_Call) RunAndReturn(run func(string, interface{}, ...queue.Option) (*queue.TaskInfo, error)) *MockClient_Enqueue_Call

type MockClient_Expecter 

type MockClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockClient_Expecter) Close 

func (_e *MockClient_Expecter) Close() *MockClient_Close_Call

Close is a helper method to define mock.On call

func (*MockClient_Expecter) Enqueue 

func (_e *MockClient_Expecter) Enqueue(taskName interface{}, payload interface{}, opts ...interface{}) *MockClient_Enqueue_Call

Enqueue is a helper method to define mock.On call

  • taskName string
  • payload interface{}
  • opts ...queue.Option

func (*MockClient_Expecter) EnqueueAt 

func (_e *MockClient_Expecter) EnqueueAt(taskName interface{}, processAt interface{}, payload interface{}, opts ...interface{}) *MockClient_EnqueueAt_Call

EnqueueAt is a helper method to define mock.On call

  • taskName string
  • processAt time.Time
  • payload interface{}
  • opts ...queue.Option

func (*MockClient_Expecter) EnqueueContext 

func (_e *MockClient_Expecter) EnqueueContext(ctx interface{}, taskName interface{}, payload interface{}, opts ...interface{}) *MockClient_EnqueueContext_Call

EnqueueContext is a helper method to define mock.On call

  • ctx context.Context
  • taskName string
  • payload interface{}
  • opts ...queue.Option

func (*MockClient_Expecter) EnqueueIn 

func (_e *MockClient_Expecter) EnqueueIn(taskName interface{}, delay interface{}, payload interface{}, opts ...interface{}) *MockClient_EnqueueIn_Call

EnqueueIn is a helper method to define mock.On call

  • taskName string
  • delay time.Duration
  • payload interface{}
  • opts ...queue.Option

type MockManager 

type MockManager struct {
	mock.Mock
}

MockManager is an autogenerated mock type for the Manager type

func NewMockManager 

func NewMockManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockManager

NewMockManager creates a new instance of MockManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockManager) Adapter 

func (_m *MockManager) Adapter(name string) adapter.QueueAdapter

Adapter provides a mock function with given fields: name

func (*MockManager) Client 

func (_m *MockManager) Client() queue.Client

Client provides a mock function with no fields

func (*MockManager) EXPECT 

func (_m *MockManager) EXPECT() *MockManager_Expecter

func (*MockManager) MemoryAdapter 

func (_m *MockManager) MemoryAdapter() adapter.QueueAdapter

MemoryAdapter provides a mock function with no fields

func (*MockManager) RedisAdapter 

func (_m *MockManager) RedisAdapter() adapter.QueueAdapter

RedisAdapter provides a mock function with no fields

func (*MockManager) RedisClient 

func (_m *MockManager) RedisClient() redis.UniversalClient

RedisClient provides a mock function with no fields

func (*MockManager) Scheduler 

func (_m *MockManager) Scheduler() scheduler.Manager

Scheduler provides a mock function with no fields

func (*MockManager) Server 

func (_m *MockManager) Server() queue.Server

Server provides a mock function with no fields

func (*MockManager) SetScheduler 

func (_m *MockManager) SetScheduler(_a0 scheduler.Manager)

SetScheduler provides a mock function with given fields: _a0

type MockManager_Adapter_Call 

type MockManager_Adapter_Call struct {
	*mock.Call
}

MockManager_Adapter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Adapter'

func (*MockManager_Adapter_Call) Return 

func (_c *MockManager_Adapter_Call) Return(_a0 adapter.QueueAdapter) *MockManager_Adapter_Call

func (*MockManager_Adapter_Call) Run 

func (_c *MockManager_Adapter_Call) Run(run func(name string)) *MockManager_Adapter_Call

func (*MockManager_Adapter_Call) RunAndReturn 

func (_c *MockManager_Adapter_Call) RunAndReturn(run func(string) adapter.QueueAdapter) *MockManager_Adapter_Call

type MockManager_Client_Call 

type MockManager_Client_Call struct {
	*mock.Call
}

MockManager_Client_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Client'

func (*MockManager_Client_Call) Return 

func (_c *MockManager_Client_Call) Return(_a0 queue.Client) *MockManager_Client_Call

func (*MockManager_Client_Call) Run 

func (_c *MockManager_Client_Call) Run(run func()) *MockManager_Client_Call

func (*MockManager_Client_Call) RunAndReturn 

func (_c *MockManager_Client_Call) RunAndReturn(run func() queue.Client) *MockManager_Client_Call

type MockManager_Expecter 

type MockManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockManager_Expecter) Adapter 

func (_e *MockManager_Expecter) Adapter(name interface{}) *MockManager_Adapter_Call

Adapter is a helper method to define mock.On call

  • name string

func (*MockManager_Expecter) Client 

func (_e *MockManager_Expecter) Client() *MockManager_Client_Call

Client is a helper method to define mock.On call

func (*MockManager_Expecter) MemoryAdapter 

func (_e *MockManager_Expecter) MemoryAdapter() *MockManager_MemoryAdapter_Call

MemoryAdapter is a helper method to define mock.On call

func (*MockManager_Expecter) RedisAdapter 

func (_e *MockManager_Expecter) RedisAdapter() *MockManager_RedisAdapter_Call

RedisAdapter is a helper method to define mock.On call

func (*MockManager_Expecter) RedisClient 

func (_e *MockManager_Expecter) RedisClient() *MockManager_RedisClient_Call

RedisClient is a helper method to define mock.On call

func (*MockManager_Expecter) Scheduler 

func (_e *MockManager_Expecter) Scheduler() *MockManager_Scheduler_Call

Scheduler is a helper method to define mock.On call

func (*MockManager_Expecter) Server 

func (_e *MockManager_Expecter) Server() *MockManager_Server_Call

Server is a helper method to define mock.On call

func (*MockManager_Expecter) SetScheduler 

func (_e *MockManager_Expecter) SetScheduler(_a0 interface{}) *MockManager_SetScheduler_Call

SetScheduler is a helper method to define mock.On call

  • _a0 scheduler.Manager

type MockManager_MemoryAdapter_Call 

type MockManager_MemoryAdapter_Call struct {
	*mock.Call
}

MockManager_MemoryAdapter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MemoryAdapter'

func (*MockManager_MemoryAdapter_Call) Return 

func (_c *MockManager_MemoryAdapter_Call) Return(_a0 adapter.QueueAdapter) *MockManager_MemoryAdapter_Call

func (*MockManager_MemoryAdapter_Call) Run 

func (_c *MockManager_MemoryAdapter_Call) Run(run func()) *MockManager_MemoryAdapter_Call

func (*MockManager_MemoryAdapter_Call) RunAndReturn 

func (_c *MockManager_MemoryAdapter_Call) RunAndReturn(run func() adapter.QueueAdapter) *MockManager_MemoryAdapter_Call

type MockManager_RedisAdapter_Call 

type MockManager_RedisAdapter_Call struct {
	*mock.Call
}

MockManager_RedisAdapter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RedisAdapter'

func (*MockManager_RedisAdapter_Call) Return 

func (_c *MockManager_RedisAdapter_Call) Return(_a0 adapter.QueueAdapter) *MockManager_RedisAdapter_Call

func (*MockManager_RedisAdapter_Call) Run 

func (_c *MockManager_RedisAdapter_Call) Run(run func()) *MockManager_RedisAdapter_Call

func (*MockManager_RedisAdapter_Call) RunAndReturn 

func (_c *MockManager_RedisAdapter_Call) RunAndReturn(run func() adapter.QueueAdapter) *MockManager_RedisAdapter_Call

type MockManager_RedisClient_Call 

type MockManager_RedisClient_Call struct {
	*mock.Call
}

MockManager_RedisClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RedisClient'

func (*MockManager_RedisClient_Call) Return 

func (_c *MockManager_RedisClient_Call) Return(_a0 redis.UniversalClient) *MockManager_RedisClient_Call

func (*MockManager_RedisClient_Call) Run 

func (_c *MockManager_RedisClient_Call) Run(run func()) *MockManager_RedisClient_Call

func (*MockManager_RedisClient_Call) RunAndReturn 

func (_c *MockManager_RedisClient_Call) RunAndReturn(run func() redis.UniversalClient) *MockManager_RedisClient_Call

type MockManager_Scheduler_Call 

type MockManager_Scheduler_Call struct {
	*mock.Call
}

MockManager_Scheduler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Scheduler'

func (*MockManager_Scheduler_Call) Return 

func (_c *MockManager_Scheduler_Call) Return(_a0 scheduler.Manager) *MockManager_Scheduler_Call

func (*MockManager_Scheduler_Call) Run 

func (_c *MockManager_Scheduler_Call) Run(run func()) *MockManager_Scheduler_Call

func (*MockManager_Scheduler_Call) RunAndReturn 

func (_c *MockManager_Scheduler_Call) RunAndReturn(run func() scheduler.Manager) *MockManager_Scheduler_Call

type MockManager_Server_Call 

type MockManager_Server_Call struct {
	*mock.Call
}

MockManager_Server_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Server'

func (*MockManager_Server_Call) Return 

func (_c *MockManager_Server_Call) Return(_a0 queue.Server) *MockManager_Server_Call

func (*MockManager_Server_Call) Run 

func (_c *MockManager_Server_Call) Run(run func()) *MockManager_Server_Call

func (*MockManager_Server_Call) RunAndReturn 

func (_c *MockManager_Server_Call) RunAndReturn(run func() queue.Server) *MockManager_Server_Call

type MockManager_SetScheduler_Call 

type MockManager_SetScheduler_Call struct {
	*mock.Call
}

MockManager_SetScheduler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetScheduler'

func (*MockManager_SetScheduler_Call) Return 

func (_c *MockManager_SetScheduler_Call) Return() *MockManager_SetScheduler_Call

func (*MockManager_SetScheduler_Call) Run 

func (_c *MockManager_SetScheduler_Call) Run(run func(_a0 scheduler.Manager)) *MockManager_SetScheduler_Call

func (*MockManager_SetScheduler_Call) RunAndReturn 

func (_c *MockManager_SetScheduler_Call) RunAndReturn(run func(scheduler.Manager)) *MockManager_SetScheduler_Call

type MockQueueAdapter 

type MockQueueAdapter struct {
	mock.Mock
}

MockQueueAdapter is an autogenerated mock type for the QueueAdapter type

func NewMockQueueAdapter 

func NewMockQueueAdapter(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockQueueAdapter

NewMockQueueAdapter creates a new instance of MockQueueAdapter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockQueueAdapter) Clear 

func (_m *MockQueueAdapter) Clear(ctx context.Context, queueName string) error

Clear provides a mock function with given fields: ctx, queueName

func (*MockQueueAdapter) Dequeue 

func (_m *MockQueueAdapter) Dequeue(ctx context.Context, queueName string, dest interface{}) error

Dequeue provides a mock function with given fields: ctx, queueName, dest

func (*MockQueueAdapter) EXPECT 

func (_m *MockQueueAdapter) EXPECT() *MockQueueAdapter_Expecter

func (*MockQueueAdapter) Enqueue 

func (_m *MockQueueAdapter) Enqueue(ctx context.Context, queueName string, item interface{}) error

Enqueue provides a mock function with given fields: ctx, queueName, item

func (*MockQueueAdapter) EnqueueBatch 

func (_m *MockQueueAdapter) EnqueueBatch(ctx context.Context, queueName string, items []interface{}) error

EnqueueBatch provides a mock function with given fields: ctx, queueName, items

func (*MockQueueAdapter) IsEmpty 

func (_m *MockQueueAdapter) IsEmpty(ctx context.Context, queueName string) (bool, error)

IsEmpty provides a mock function with given fields: ctx, queueName

func (*MockQueueAdapter) Size 

func (_m *MockQueueAdapter) Size(ctx context.Context, queueName string) (int64, error)

Size provides a mock function with given fields: ctx, queueName

type MockQueueAdapter_Clear_Call 

type MockQueueAdapter_Clear_Call struct {
	*mock.Call
}

MockQueueAdapter_Clear_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Clear'

func (*MockQueueAdapter_Clear_Call) Return 

func (_c *MockQueueAdapter_Clear_Call) Return(_a0 error) *MockQueueAdapter_Clear_Call

func (*MockQueueAdapter_Clear_Call) Run 

func (_c *MockQueueAdapter_Clear_Call) Run(run func(ctx context.Context, queueName string)) *MockQueueAdapter_Clear_Call

func (*MockQueueAdapter_Clear_Call) RunAndReturn 

func (_c *MockQueueAdapter_Clear_Call) RunAndReturn(run func(context.Context, string) error) *MockQueueAdapter_Clear_Call

type MockQueueAdapter_Dequeue_Call 

type MockQueueAdapter_Dequeue_Call struct {
	*mock.Call
}

MockQueueAdapter_Dequeue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Dequeue'

func (*MockQueueAdapter_Dequeue_Call) Return 

func (_c *MockQueueAdapter_Dequeue_Call) Return(_a0 error) *MockQueueAdapter_Dequeue_Call

func (*MockQueueAdapter_Dequeue_Call) Run 

func (_c *MockQueueAdapter_Dequeue_Call) Run(run func(ctx context.Context, queueName string, dest interface{})) *MockQueueAdapter_Dequeue_Call

func (*MockQueueAdapter_Dequeue_Call) RunAndReturn 

func (_c *MockQueueAdapter_Dequeue_Call) RunAndReturn(run func(context.Context, string, interface{}) error) *MockQueueAdapter_Dequeue_Call

type MockQueueAdapter_EnqueueBatch_Call 

type MockQueueAdapter_EnqueueBatch_Call struct {
	*mock.Call
}

MockQueueAdapter_EnqueueBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnqueueBatch'

func (*MockQueueAdapter_EnqueueBatch_Call) Return 

func (_c *MockQueueAdapter_EnqueueBatch_Call) Return(_a0 error) *MockQueueAdapter_EnqueueBatch_Call

func (*MockQueueAdapter_EnqueueBatch_Call) Run 

func (_c *MockQueueAdapter_EnqueueBatch_Call) Run(run func(ctx context.Context, queueName string, items []interface{})) *MockQueueAdapter_EnqueueBatch_Call

func (*MockQueueAdapter_EnqueueBatch_Call) RunAndReturn 

func (_c *MockQueueAdapter_EnqueueBatch_Call) RunAndReturn(run func(context.Context, string, []interface{}) error) *MockQueueAdapter_EnqueueBatch_Call

type MockQueueAdapter_Enqueue_Call 

type MockQueueAdapter_Enqueue_Call struct {
	*mock.Call
}

MockQueueAdapter_Enqueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Enqueue'

func (*MockQueueAdapter_Enqueue_Call) Return 

func (_c *MockQueueAdapter_Enqueue_Call) Return(_a0 error) *MockQueueAdapter_Enqueue_Call

func (*MockQueueAdapter_Enqueue_Call) Run 

func (_c *MockQueueAdapter_Enqueue_Call) Run(run func(ctx context.Context, queueName string, item interface{})) *MockQueueAdapter_Enqueue_Call

func (*MockQueueAdapter_Enqueue_Call) RunAndReturn 

func (_c *MockQueueAdapter_Enqueue_Call) RunAndReturn(run func(context.Context, string, interface{}) error) *MockQueueAdapter_Enqueue_Call

type MockQueueAdapter_Expecter 

type MockQueueAdapter_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockQueueAdapter_Expecter) Clear 

func (_e *MockQueueAdapter_Expecter) Clear(ctx interface{}, queueName interface{}) *MockQueueAdapter_Clear_Call

Clear is a helper method to define mock.On call

  • ctx context.Context
  • queueName string

func (*MockQueueAdapter_Expecter) Dequeue 

func (_e *MockQueueAdapter_Expecter) Dequeue(ctx interface{}, queueName interface{}, dest interface{}) *MockQueueAdapter_Dequeue_Call

Dequeue is a helper method to define mock.On call

  • ctx context.Context
  • queueName string
  • dest interface{}

func (*MockQueueAdapter_Expecter) Enqueue 

func (_e *MockQueueAdapter_Expecter) Enqueue(ctx interface{}, queueName interface{}, item interface{}) *MockQueueAdapter_Enqueue_Call

Enqueue is a helper method to define mock.On call

  • ctx context.Context
  • queueName string
  • item interface{}

func (*MockQueueAdapter_Expecter) EnqueueBatch 

func (_e *MockQueueAdapter_Expecter) EnqueueBatch(ctx interface{}, queueName interface{}, items interface{}) *MockQueueAdapter_EnqueueBatch_Call

EnqueueBatch is a helper method to define mock.On call

  • ctx context.Context
  • queueName string
  • items []interface{}

func (*MockQueueAdapter_Expecter) IsEmpty 

func (_e *MockQueueAdapter_Expecter) IsEmpty(ctx interface{}, queueName interface{}) *MockQueueAdapter_IsEmpty_Call

IsEmpty is a helper method to define mock.On call

  • ctx context.Context
  • queueName string

func (*MockQueueAdapter_Expecter) Size 

func (_e *MockQueueAdapter_Expecter) Size(ctx interface{}, queueName interface{}) *MockQueueAdapter_Size_Call

Size is a helper method to define mock.On call

  • ctx context.Context
  • queueName string

type MockQueueAdapter_IsEmpty_Call 

type MockQueueAdapter_IsEmpty_Call struct {
	*mock.Call
}

MockQueueAdapter_IsEmpty_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsEmpty'

func (*MockQueueAdapter_IsEmpty_Call) Return 

func (_c *MockQueueAdapter_IsEmpty_Call) Return(_a0 bool, _a1 error) *MockQueueAdapter_IsEmpty_Call

func (*MockQueueAdapter_IsEmpty_Call) Run 

func (_c *MockQueueAdapter_IsEmpty_Call) Run(run func(ctx context.Context, queueName string)) *MockQueueAdapter_IsEmpty_Call

func (*MockQueueAdapter_IsEmpty_Call) RunAndReturn 

func (_c *MockQueueAdapter_IsEmpty_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *MockQueueAdapter_IsEmpty_Call

type MockQueueAdapter_Size_Call 

type MockQueueAdapter_Size_Call struct {
	*mock.Call
}

MockQueueAdapter_Size_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Size'

func (*MockQueueAdapter_Size_Call) Return 

func (_c *MockQueueAdapter_Size_Call) Return(_a0 int64, _a1 error) *MockQueueAdapter_Size_Call

func (*MockQueueAdapter_Size_Call) Run 

func (_c *MockQueueAdapter_Size_Call) Run(run func(ctx context.Context, queueName string)) *MockQueueAdapter_Size_Call

func (*MockQueueAdapter_Size_Call) RunAndReturn 

func (_c *MockQueueAdapter_Size_Call) RunAndReturn(run func(context.Context, string) (int64, error)) *MockQueueAdapter_Size_Call

type MockServer 

type MockServer struct {
	mock.Mock
}

MockServer is an autogenerated mock type for the Server type

func NewMockServer 

func NewMockServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockServer

NewMockServer creates a new instance of MockServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockServer) EXPECT 

func (_m *MockServer) EXPECT() *MockServer_Expecter

func (*MockServer) GetScheduler 

func (_m *MockServer) GetScheduler() scheduler.Manager

GetScheduler provides a mock function with no fields

func (*MockServer) RegisterHandler 

func (_m *MockServer) RegisterHandler(taskName string, handler queue.HandlerFunc)

RegisterHandler provides a mock function with given fields: taskName, handler

func (*MockServer) RegisterHandlers 

func (_m *MockServer) RegisterHandlers(handlers map[string]queue.HandlerFunc)

RegisterHandlers provides a mock function with given fields: handlers

func (*MockServer) SetScheduler 

func (_m *MockServer) SetScheduler(_a0 scheduler.Manager)

SetScheduler provides a mock function with given fields: _a0

func (*MockServer) Start 

func (_m *MockServer) Start() error

Start provides a mock function with no fields

func (*MockServer) Stop 

func (_m *MockServer) Stop() error

Stop provides a mock function with no fields

type MockServer_Expecter 

type MockServer_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockServer_Expecter) GetScheduler 

func (_e *MockServer_Expecter) GetScheduler() *MockServer_GetScheduler_Call

GetScheduler is a helper method to define mock.On call

func (*MockServer_Expecter) RegisterHandler 

func (_e *MockServer_Expecter) RegisterHandler(taskName interface{}, handler interface{}) *MockServer_RegisterHandler_Call

RegisterHandler is a helper method to define mock.On call

  • taskName string
  • handler queue.HandlerFunc

func (*MockServer_Expecter) RegisterHandlers 

func (_e *MockServer_Expecter) RegisterHandlers(handlers interface{}) *MockServer_RegisterHandlers_Call

RegisterHandlers is a helper method to define mock.On call

  • handlers map[string]queue.HandlerFunc

func (*MockServer_Expecter) SetScheduler 

func (_e *MockServer_Expecter) SetScheduler(_a0 interface{}) *MockServer_SetScheduler_Call

SetScheduler is a helper method to define mock.On call

  • _a0 scheduler.Manager

func (*MockServer_Expecter) Start 

func (_e *MockServer_Expecter) Start() *MockServer_Start_Call

Start is a helper method to define mock.On call

func (*MockServer_Expecter) Stop 

func (_e *MockServer_Expecter) Stop() *MockServer_Stop_Call

Stop is a helper method to define mock.On call

type MockServer_GetScheduler_Call 

type MockServer_GetScheduler_Call struct {
	*mock.Call
}

MockServer_GetScheduler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScheduler'

func (*MockServer_GetScheduler_Call) Return 

func (_c *MockServer_GetScheduler_Call) Return(_a0 scheduler.Manager) *MockServer_GetScheduler_Call

func (*MockServer_GetScheduler_Call) Run 

func (_c *MockServer_GetScheduler_Call) Run(run func()) *MockServer_GetScheduler_Call

func (*MockServer_GetScheduler_Call) RunAndReturn 

func (_c *MockServer_GetScheduler_Call) RunAndReturn(run func() scheduler.Manager) *MockServer_GetScheduler_Call

type MockServer_RegisterHandler_Call 

type MockServer_RegisterHandler_Call struct {
	*mock.Call
}

MockServer_RegisterHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterHandler'

func (*MockServer_RegisterHandler_Call) Return 

func (_c *MockServer_RegisterHandler_Call) Return() *MockServer_RegisterHandler_Call

func (*MockServer_RegisterHandler_Call) Run 

func (_c *MockServer_RegisterHandler_Call) Run(run func(taskName string, handler queue.HandlerFunc)) *MockServer_RegisterHandler_Call

func (*MockServer_RegisterHandler_Call) RunAndReturn 

func (_c *MockServer_RegisterHandler_Call) RunAndReturn(run func(string, queue.HandlerFunc)) *MockServer_RegisterHandler_Call

type MockServer_RegisterHandlers_Call 

type MockServer_RegisterHandlers_Call struct {
	*mock.Call
}

MockServer_RegisterHandlers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterHandlers'

func (*MockServer_RegisterHandlers_Call) Return 

func (_c *MockServer_RegisterHandlers_Call) Return() *MockServer_RegisterHandlers_Call

func (*MockServer_RegisterHandlers_Call) Run 

func (_c *MockServer_RegisterHandlers_Call) Run(run func(handlers map[string]queue.HandlerFunc)) *MockServer_RegisterHandlers_Call

func (*MockServer_RegisterHandlers_Call) RunAndReturn 

func (_c *MockServer_RegisterHandlers_Call) RunAndReturn(run func(map[string]queue.HandlerFunc)) *MockServer_RegisterHandlers_Call

type MockServer_SetScheduler_Call 

type MockServer_SetScheduler_Call struct {
	*mock.Call
}

MockServer_SetScheduler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetScheduler'

func (*MockServer_SetScheduler_Call) Return 

func (_c *MockServer_SetScheduler_Call) Return() *MockServer_SetScheduler_Call

func (*MockServer_SetScheduler_Call) Run 

func (_c *MockServer_SetScheduler_Call) Run(run func(_a0 scheduler.Manager)) *MockServer_SetScheduler_Call

func (*MockServer_SetScheduler_Call) RunAndReturn 

func (_c *MockServer_SetScheduler_Call) RunAndReturn(run func(scheduler.Manager)) *MockServer_SetScheduler_Call

type MockServer_Start_Call 

type MockServer_Start_Call struct {
	*mock.Call
}

MockServer_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*MockServer_Start_Call) Return 

func (_c *MockServer_Start_Call) Return(_a0 error) *MockServer_Start_Call

func (*MockServer_Start_Call) Run 

func (_c *MockServer_Start_Call) Run(run func()) *MockServer_Start_Call

func (*MockServer_Start_Call) RunAndReturn 

func (_c *MockServer_Start_Call) RunAndReturn(run func() error) *MockServer_Start_Call

type MockServer_Stop_Call 

type MockServer_Stop_Call struct {
	*mock.Call
}

MockServer_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*MockServer_Stop_Call) Return 

func (_c *MockServer_Stop_Call) Return(_a0 error) *MockServer_Stop_Call

func (*MockServer_Stop_Call) Run 

func (_c *MockServer_Stop_Call) Run(run func()) *MockServer_Stop_Call

func (*MockServer_Stop_Call) RunAndReturn 

func (_c *MockServer_Stop_Call) RunAndReturn(run func() error) *MockServer_Stop_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.