mocks

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2025 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IRepository 

type IRepository struct {
	mock.Mock
}

IRepository is an autogenerated mock type for the IRepository type

func NewIRepository 

func NewIRepository(t interface {
	mock.TestingT
	Cleanup(func())
}) *IRepository

NewIRepository creates a new instance of IRepository. 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 (*IRepository) CleanTasks 

func (_mock *IRepository) CleanTasks(ctx context.Context, minimumAge time.Duration) (int64, error)

CleanTasks provides a mock function for the type IRepository

func (*IRepository) CountTasks added in v1.1.0 

func (_mock *IRepository) CountTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string) (int64, error)

CountTasks provides a mock function for the type IRepository

func (*IRepository) DeleteTask 

func (_mock *IRepository) DeleteTask(ctx context.Context, task *tasq.Task, safeDelete bool) error

DeleteTask provides a mock function for the type IRepository

func (*IRepository) EXPECT added in v1.1.3 

func (_m *IRepository) EXPECT() *IRepository_Expecter

func (*IRepository) Migrate 

func (_mock *IRepository) Migrate(ctx context.Context) error

Migrate provides a mock function for the type IRepository

func (*IRepository) PingTasks 

func (_mock *IRepository) PingTasks(ctx context.Context, taskIDs []uuid.UUID, visibilityTimeout time.Duration) ([]*tasq.Task, error)

PingTasks provides a mock function for the type IRepository

func (*IRepository) PollTasks 

func (_mock *IRepository) PollTasks(ctx context.Context, types []string, queues []string, visibilityTimeout time.Duration, ordering tasq.Ordering, limit int) ([]*tasq.Task, error)

PollTasks provides a mock function for the type IRepository

func (*IRepository) PurgeTasks added in v1.1.0 

func (_mock *IRepository) PurgeTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string, safeDelete bool) (int64, error)

PurgeTasks provides a mock function for the type IRepository

func (*IRepository) RegisterError 

func (_mock *IRepository) RegisterError(ctx context.Context, task *tasq.Task, errTask error) (*tasq.Task, error)

RegisterError provides a mock function for the type IRepository

func (*IRepository) RegisterFinish 

func (_mock *IRepository) RegisterFinish(ctx context.Context, task *tasq.Task, finishStatus tasq.TaskStatus) (*tasq.Task, error)

RegisterFinish provides a mock function for the type IRepository

func (*IRepository) RegisterStart 

func (_mock *IRepository) RegisterStart(ctx context.Context, task *tasq.Task) (*tasq.Task, error)

RegisterStart provides a mock function for the type IRepository

func (*IRepository) RequeueTask 

func (_mock *IRepository) RequeueTask(ctx context.Context, task *tasq.Task) (*tasq.Task, error)

RequeueTask provides a mock function for the type IRepository

func (*IRepository) ScanTasks added in v1.1.0 

func (_mock *IRepository) ScanTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string, ordering tasq.Ordering, limit int) ([]*tasq.Task, error)

ScanTasks provides a mock function for the type IRepository

func (*IRepository) SubmitTask 

func (_mock *IRepository) SubmitTask(ctx context.Context, task *tasq.Task) (*tasq.Task, error)

SubmitTask provides a mock function for the type IRepository

type IRepository_CleanTasks_Call added in v1.1.3 

type IRepository_CleanTasks_Call struct {
	*mock.Call
}

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

func (*IRepository_CleanTasks_Call) Return added in v1.1.3 

func (_c *IRepository_CleanTasks_Call) Return(n int64, err error) *IRepository_CleanTasks_Call

func (*IRepository_CleanTasks_Call) Run added in v1.1.3 

func (_c *IRepository_CleanTasks_Call) Run(run func(ctx context.Context, minimumAge time.Duration)) *IRepository_CleanTasks_Call

func (*IRepository_CleanTasks_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_CleanTasks_Call) RunAndReturn(run func(ctx context.Context, minimumAge time.Duration) (int64, error)) *IRepository_CleanTasks_Call

type IRepository_CountTasks_Call added in v1.1.3 

type IRepository_CountTasks_Call struct {
	*mock.Call
}

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

func (*IRepository_CountTasks_Call) Return added in v1.1.3 

func (_c *IRepository_CountTasks_Call) Return(n int64, err error) *IRepository_CountTasks_Call

func (*IRepository_CountTasks_Call) Run added in v1.1.3 

func (_c *IRepository_CountTasks_Call) Run(run func(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string)) *IRepository_CountTasks_Call

func (*IRepository_CountTasks_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_CountTasks_Call) RunAndReturn(run func(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string) (int64, error)) *IRepository_CountTasks_Call

type IRepository_DeleteTask_Call added in v1.1.3 

type IRepository_DeleteTask_Call struct {
	*mock.Call
}

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

func (*IRepository_DeleteTask_Call) Return added in v1.1.3 

func (_c *IRepository_DeleteTask_Call) Return(err error) *IRepository_DeleteTask_Call

func (*IRepository_DeleteTask_Call) Run added in v1.1.3 

func (_c *IRepository_DeleteTask_Call) Run(run func(ctx context.Context, task *tasq.Task, safeDelete bool)) *IRepository_DeleteTask_Call

func (*IRepository_DeleteTask_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_DeleteTask_Call) RunAndReturn(run func(ctx context.Context, task *tasq.Task, safeDelete bool) error) *IRepository_DeleteTask_Call

type IRepository_Expecter added in v1.1.3 

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

func (*IRepository_Expecter) CleanTasks added in v1.1.3 

func (_e *IRepository_Expecter) CleanTasks(ctx interface{}, minimumAge interface{}) *IRepository_CleanTasks_Call

CleanTasks is a helper method to define mock.On call

  • ctx context.Context
  • minimumAge time.Duration

func (*IRepository_Expecter) CountTasks added in v1.1.3 

func (_e *IRepository_Expecter) CountTasks(ctx interface{}, taskStatuses interface{}, taskTypes interface{}, queues interface{}) *IRepository_CountTasks_Call

CountTasks is a helper method to define mock.On call

  • ctx context.Context
  • taskStatuses []tasq.TaskStatus
  • taskTypes []string
  • queues []string

func (*IRepository_Expecter) DeleteTask added in v1.1.3 

func (_e *IRepository_Expecter) DeleteTask(ctx interface{}, task interface{}, safeDelete interface{}) *IRepository_DeleteTask_Call

DeleteTask is a helper method to define mock.On call

  • ctx context.Context
  • task *tasq.Task
  • safeDelete bool

func (*IRepository_Expecter) Migrate added in v1.1.3 

func (_e *IRepository_Expecter) Migrate(ctx interface{}) *IRepository_Migrate_Call

Migrate is a helper method to define mock.On call

  • ctx context.Context

func (*IRepository_Expecter) PingTasks added in v1.1.3 

func (_e *IRepository_Expecter) PingTasks(ctx interface{}, taskIDs interface{}, visibilityTimeout interface{}) *IRepository_PingTasks_Call

PingTasks is a helper method to define mock.On call

  • ctx context.Context
  • taskIDs []uuid.UUID
  • visibilityTimeout time.Duration

func (*IRepository_Expecter) PollTasks added in v1.1.3 

func (_e *IRepository_Expecter) PollTasks(ctx interface{}, types interface{}, queues interface{}, visibilityTimeout interface{}, ordering interface{}, limit interface{}) *IRepository_PollTasks_Call

PollTasks is a helper method to define mock.On call

  • ctx context.Context
  • types []string
  • queues []string
  • visibilityTimeout time.Duration
  • ordering tasq.Ordering
  • limit int

func (*IRepository_Expecter) PurgeTasks added in v1.1.3 

func (_e *IRepository_Expecter) PurgeTasks(ctx interface{}, taskStatuses interface{}, taskTypes interface{}, queues interface{}, safeDelete interface{}) *IRepository_PurgeTasks_Call

PurgeTasks is a helper method to define mock.On call

  • ctx context.Context
  • taskStatuses []tasq.TaskStatus
  • taskTypes []string
  • queues []string
  • safeDelete bool

func (*IRepository_Expecter) RegisterError added in v1.1.3 

func (_e *IRepository_Expecter) RegisterError(ctx interface{}, task interface{}, errTask interface{}) *IRepository_RegisterError_Call

RegisterError is a helper method to define mock.On call

  • ctx context.Context
  • task *tasq.Task
  • errTask error

func (*IRepository_Expecter) RegisterFinish added in v1.1.3 

func (_e *IRepository_Expecter) RegisterFinish(ctx interface{}, task interface{}, finishStatus interface{}) *IRepository_RegisterFinish_Call

RegisterFinish is a helper method to define mock.On call

  • ctx context.Context
  • task *tasq.Task
  • finishStatus tasq.TaskStatus

func (*IRepository_Expecter) RegisterStart added in v1.1.3 

func (_e *IRepository_Expecter) RegisterStart(ctx interface{}, task interface{}) *IRepository_RegisterStart_Call

RegisterStart is a helper method to define mock.On call

  • ctx context.Context
  • task *tasq.Task

func (*IRepository_Expecter) RequeueTask added in v1.1.3 

func (_e *IRepository_Expecter) RequeueTask(ctx interface{}, task interface{}) *IRepository_RequeueTask_Call

RequeueTask is a helper method to define mock.On call

  • ctx context.Context
  • task *tasq.Task

func (*IRepository_Expecter) ScanTasks added in v1.1.3 

func (_e *IRepository_Expecter) ScanTasks(ctx interface{}, taskStatuses interface{}, taskTypes interface{}, queues interface{}, ordering interface{}, limit interface{}) *IRepository_ScanTasks_Call

ScanTasks is a helper method to define mock.On call

  • ctx context.Context
  • taskStatuses []tasq.TaskStatus
  • taskTypes []string
  • queues []string
  • ordering tasq.Ordering
  • limit int

func (*IRepository_Expecter) SubmitTask added in v1.1.3 

func (_e *IRepository_Expecter) SubmitTask(ctx interface{}, task interface{}) *IRepository_SubmitTask_Call

SubmitTask is a helper method to define mock.On call

  • ctx context.Context
  • task *tasq.Task

type IRepository_Migrate_Call added in v1.1.3 

type IRepository_Migrate_Call struct {
	*mock.Call
}

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

func (*IRepository_Migrate_Call) Return added in v1.1.3 

func (_c *IRepository_Migrate_Call) Return(err error) *IRepository_Migrate_Call

func (*IRepository_Migrate_Call) Run added in v1.1.3 

func (_c *IRepository_Migrate_Call) Run(run func(ctx context.Context)) *IRepository_Migrate_Call

func (*IRepository_Migrate_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_Migrate_Call) RunAndReturn(run func(ctx context.Context) error) *IRepository_Migrate_Call

type IRepository_PingTasks_Call added in v1.1.3 

type IRepository_PingTasks_Call struct {
	*mock.Call
}

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

func (*IRepository_PingTasks_Call) Return added in v1.1.3 

func (_c *IRepository_PingTasks_Call) Return(tasks []*tasq.Task, err error) *IRepository_PingTasks_Call

func (*IRepository_PingTasks_Call) Run added in v1.1.3 

func (_c *IRepository_PingTasks_Call) Run(run func(ctx context.Context, taskIDs []uuid.UUID, visibilityTimeout time.Duration)) *IRepository_PingTasks_Call

func (*IRepository_PingTasks_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_PingTasks_Call) RunAndReturn(run func(ctx context.Context, taskIDs []uuid.UUID, visibilityTimeout time.Duration) ([]*tasq.Task, error)) *IRepository_PingTasks_Call

type IRepository_PollTasks_Call added in v1.1.3 

type IRepository_PollTasks_Call struct {
	*mock.Call
}

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

func (*IRepository_PollTasks_Call) Return added in v1.1.3 

func (_c *IRepository_PollTasks_Call) Return(tasks []*tasq.Task, err error) *IRepository_PollTasks_Call

func (*IRepository_PollTasks_Call) Run added in v1.1.3 

func (_c *IRepository_PollTasks_Call) Run(run func(ctx context.Context, types []string, queues []string, visibilityTimeout time.Duration, ordering tasq.Ordering, limit int)) *IRepository_PollTasks_Call

func (*IRepository_PollTasks_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_PollTasks_Call) RunAndReturn(run func(ctx context.Context, types []string, queues []string, visibilityTimeout time.Duration, ordering tasq.Ordering, limit int) ([]*tasq.Task, error)) *IRepository_PollTasks_Call

type IRepository_PurgeTasks_Call added in v1.1.3 

type IRepository_PurgeTasks_Call struct {
	*mock.Call
}

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

func (*IRepository_PurgeTasks_Call) Return added in v1.1.3 

func (_c *IRepository_PurgeTasks_Call) Return(n int64, err error) *IRepository_PurgeTasks_Call

func (*IRepository_PurgeTasks_Call) Run added in v1.1.3 

func (_c *IRepository_PurgeTasks_Call) Run(run func(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string, safeDelete bool)) *IRepository_PurgeTasks_Call

func (*IRepository_PurgeTasks_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_PurgeTasks_Call) RunAndReturn(run func(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string, safeDelete bool) (int64, error)) *IRepository_PurgeTasks_Call

type IRepository_RegisterError_Call added in v1.1.3 

type IRepository_RegisterError_Call struct {
	*mock.Call
}

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

func (*IRepository_RegisterError_Call) Return added in v1.1.3 

func (_c *IRepository_RegisterError_Call) Return(task1 *tasq.Task, err error) *IRepository_RegisterError_Call

func (*IRepository_RegisterError_Call) Run added in v1.1.3 

func (_c *IRepository_RegisterError_Call) Run(run func(ctx context.Context, task *tasq.Task, errTask error)) *IRepository_RegisterError_Call

func (*IRepository_RegisterError_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_RegisterError_Call) RunAndReturn(run func(ctx context.Context, task *tasq.Task, errTask error) (*tasq.Task, error)) *IRepository_RegisterError_Call

type IRepository_RegisterFinish_Call added in v1.1.3 

type IRepository_RegisterFinish_Call struct {
	*mock.Call
}

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

func (*IRepository_RegisterFinish_Call) Return added in v1.1.3 

func (_c *IRepository_RegisterFinish_Call) Return(task1 *tasq.Task, err error) *IRepository_RegisterFinish_Call

func (*IRepository_RegisterFinish_Call) Run added in v1.1.3 

func (_c *IRepository_RegisterFinish_Call) Run(run func(ctx context.Context, task *tasq.Task, finishStatus tasq.TaskStatus)) *IRepository_RegisterFinish_Call

func (*IRepository_RegisterFinish_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_RegisterFinish_Call) RunAndReturn(run func(ctx context.Context, task *tasq.Task, finishStatus tasq.TaskStatus) (*tasq.Task, error)) *IRepository_RegisterFinish_Call

type IRepository_RegisterStart_Call added in v1.1.3 

type IRepository_RegisterStart_Call struct {
	*mock.Call
}

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

func (*IRepository_RegisterStart_Call) Return added in v1.1.3 

func (_c *IRepository_RegisterStart_Call) Return(task1 *tasq.Task, err error) *IRepository_RegisterStart_Call

func (*IRepository_RegisterStart_Call) Run added in v1.1.3 

func (_c *IRepository_RegisterStart_Call) Run(run func(ctx context.Context, task *tasq.Task)) *IRepository_RegisterStart_Call

func (*IRepository_RegisterStart_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_RegisterStart_Call) RunAndReturn(run func(ctx context.Context, task *tasq.Task) (*tasq.Task, error)) *IRepository_RegisterStart_Call

type IRepository_RequeueTask_Call added in v1.1.3 

type IRepository_RequeueTask_Call struct {
	*mock.Call
}

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

func (*IRepository_RequeueTask_Call) Return added in v1.1.3 

func (_c *IRepository_RequeueTask_Call) Return(task1 *tasq.Task, err error) *IRepository_RequeueTask_Call

func (*IRepository_RequeueTask_Call) Run added in v1.1.3 

func (_c *IRepository_RequeueTask_Call) Run(run func(ctx context.Context, task *tasq.Task)) *IRepository_RequeueTask_Call

func (*IRepository_RequeueTask_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_RequeueTask_Call) RunAndReturn(run func(ctx context.Context, task *tasq.Task) (*tasq.Task, error)) *IRepository_RequeueTask_Call

type IRepository_ScanTasks_Call added in v1.1.3 

type IRepository_ScanTasks_Call struct {
	*mock.Call
}

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

func (*IRepository_ScanTasks_Call) Return added in v1.1.3 

func (_c *IRepository_ScanTasks_Call) Return(tasks []*tasq.Task, err error) *IRepository_ScanTasks_Call

func (*IRepository_ScanTasks_Call) Run added in v1.1.3 

func (_c *IRepository_ScanTasks_Call) Run(run func(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string, ordering tasq.Ordering, limit int)) *IRepository_ScanTasks_Call

func (*IRepository_ScanTasks_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_ScanTasks_Call) RunAndReturn(run func(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, queues []string, ordering tasq.Ordering, limit int) ([]*tasq.Task, error)) *IRepository_ScanTasks_Call

type IRepository_SubmitTask_Call added in v1.1.3 

type IRepository_SubmitTask_Call struct {
	*mock.Call
}

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

func (*IRepository_SubmitTask_Call) Return added in v1.1.3 

func (_c *IRepository_SubmitTask_Call) Return(task1 *tasq.Task, err error) *IRepository_SubmitTask_Call

func (*IRepository_SubmitTask_Call) Run added in v1.1.3 

func (_c *IRepository_SubmitTask_Call) Run(run func(ctx context.Context, task *tasq.Task)) *IRepository_SubmitTask_Call

func (*IRepository_SubmitTask_Call) RunAndReturn added in v1.1.3 

func (_c *IRepository_SubmitTask_Call) RunAndReturn(run func(ctx context.Context, task *tasq.Task) (*tasq.Task, error)) *IRepository_SubmitTask_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.