mocks

Documentation

Index

• type IRepository
  • func NewIRepository(t mockConstructorTestingTNewIRepository) *IRepository
  • func (_m *IRepository) CleanTasks(ctx context.Context, minimumAge time.Duration) (int64, error)
  • func (_m *IRepository) CountTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, ...) (int64, error)
  • func (_m *IRepository) DeleteTask(ctx context.Context, task *tasq.Task, safeDelete bool) error
  • func (_m *IRepository) Migrate(ctx context.Context) error
  • func (_m *IRepository) PingTasks(ctx context.Context, taskIDs []uuid.UUID, visibilityTimeout time.Duration) ([]*tasq.Task, error)
  • func (_m *IRepository) PollTasks(ctx context.Context, types []string, queues []string, ...) ([]*tasq.Task, error)
  • func (_m *IRepository) PurgeTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, ...) (int64, error)
  • func (_m *IRepository) RegisterError(ctx context.Context, task *tasq.Task, errTask error) (*tasq.Task, error)
  • func (_m *IRepository) RegisterFinish(ctx context.Context, task *tasq.Task, finishStatus tasq.TaskStatus) (*tasq.Task, error)
  • func (_m *IRepository) RegisterStart(ctx context.Context, task *tasq.Task) (*tasq.Task, error)
  • func (_m *IRepository) RequeueTask(ctx context.Context, task *tasq.Task) (*tasq.Task, error)
  • func (_m *IRepository) ScanTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes []string, ...) ([]*tasq.Task, error)
  • func (_m *IRepository) SubmitTask(ctx context.Context, task *tasq.Task) (*tasq.Task, error)

Types

type IRepository

type IRepository struct {
	mock.Mock
}

IRepository is an autogenerated mock type for the IRepository type

func NewIRepository

func NewIRepository(t mockConstructorTestingTNewIRepository) *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.

func (*IRepository) CleanTasks

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

CleanTasks provides a mock function with given fields: ctx, minimumAge

func (*IRepository) CountTasks

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

CountTasks provides a mock function with given fields: ctx, taskStatuses, taskTypes, queues

func (*IRepository) DeleteTask

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

DeleteTask provides a mock function with given fields: ctx, task, safeDelete

func (*IRepository) Migrate

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

Migrate provides a mock function with given fields: ctx

func (*IRepository) PingTasks

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

PingTasks provides a mock function with given fields: ctx, taskIDs, visibilityTimeout

func (*IRepository) PollTasks

func (_m *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 with given fields: ctx, types, queues, visibilityTimeout, ordering, limit

func (*IRepository) PurgeTasks

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

PurgeTasks provides a mock function with given fields: ctx, taskStatuses, taskTypes, queues, safeDelete

func (*IRepository) RegisterError

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

RegisterError provides a mock function with given fields: ctx, task, errTask

func (*IRepository) RegisterFinish

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

RegisterFinish provides a mock function with given fields: ctx, task, finishStatus

func (*IRepository) RegisterStart

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

RegisterStart provides a mock function with given fields: ctx, task

func (*IRepository) RequeueTask

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

RequeueTask provides a mock function with given fields: ctx, task

func (*IRepository) ScanTasks

func (_m *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 with given fields: ctx, taskStatuses, taskTypes, queues, ordering, limit

func (*IRepository) SubmitTask

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

SubmitTask provides a mock function with given fields: ctx, task