queue

package
v1.16.6 Latest Latest
Warning

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

 Go to latest Published: Jan 4, 2026 License: MIT Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config added in v1.15.12 

type Config struct {
	mock.Mock
}

Config is an autogenerated mock type for the Config type

func NewConfig added in v1.15.12 

func NewConfig(t interface {
	mock.TestingT
	Cleanup(func())
}) *Config

NewConfig creates a new instance of Config. 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 (*Config) Add added in v1.15.12 

func (_m *Config) Add(name string, configuration interface{})

Add provides a mock function with given fields: name, configuration

func (*Config) Debug added in v1.15.12 

func (_m *Config) Debug() bool

Debug provides a mock function with no fields

func (*Config) DefaultConcurrent added in v1.15.12 

func (_m *Config) DefaultConcurrent() int

DefaultConcurrent provides a mock function with no fields

func (*Config) DefaultConnection added in v1.15.12 

func (_m *Config) DefaultConnection() string

DefaultConnection provides a mock function with no fields

func (*Config) DefaultQueue added in v1.15.12 

func (_m *Config) DefaultQueue() string

DefaultQueue provides a mock function with no fields

func (*Config) Driver added in v1.15.12 

func (_m *Config) Driver(connection string) string

Driver provides a mock function with given fields: connection

func (*Config) EXPECT added in v1.15.12 

func (_m *Config) EXPECT() *Config_Expecter

func (*Config) Env added in v1.15.12 

func (_m *Config) Env(envName string, defaultValue ...interface{}) interface{}

Env provides a mock function with given fields: envName, defaultValue

func (*Config) FailedDatabase added in v1.15.12 

func (_m *Config) FailedDatabase() string

FailedDatabase provides a mock function with no fields

func (*Config) FailedTable added in v1.15.12 

func (_m *Config) FailedTable() string

FailedTable provides a mock function with no fields

func (*Config) Get added in v1.15.12 

func (_m *Config) Get(path string, defaultValue ...interface{}) interface{}

Get provides a mock function with given fields: path, defaultValue

func (*Config) GetBool added in v1.15.12 

func (_m *Config) GetBool(path string, defaultValue ...bool) bool

GetBool provides a mock function with given fields: path, defaultValue

func (*Config) GetDuration added in v1.15.12 

func (_m *Config) GetDuration(path string, defaultValue ...time.Duration) time.Duration

GetDuration provides a mock function with given fields: path, defaultValue

func (*Config) GetInt added in v1.15.12 

func (_m *Config) GetInt(path string, defaultValue ...int) int

GetInt provides a mock function with given fields: path, defaultValue

func (*Config) GetString added in v1.15.12 

func (_m *Config) GetString(path string, defaultValue ...string) string

GetString provides a mock function with given fields: path, defaultValue

func (*Config) Via added in v1.15.12 

func (_m *Config) Via(connection string) interface{}

Via provides a mock function with given fields: connection

type Config_Add_Call added in v1.15.12 

type Config_Add_Call struct {
	*mock.Call
}

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

func (*Config_Add_Call) Return added in v1.15.12 

func (_c *Config_Add_Call) Return() *Config_Add_Call

func (*Config_Add_Call) Run added in v1.15.12 

func (_c *Config_Add_Call) Run(run func(name string, configuration interface{})) *Config_Add_Call

func (*Config_Add_Call) RunAndReturn added in v1.15.12 

func (_c *Config_Add_Call) RunAndReturn(run func(string, interface{})) *Config_Add_Call

type Config_Debug_Call added in v1.15.12 

type Config_Debug_Call struct {
	*mock.Call
}

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

func (*Config_Debug_Call) Return added in v1.15.12 

func (_c *Config_Debug_Call) Return(_a0 bool) *Config_Debug_Call

func (*Config_Debug_Call) Run added in v1.15.12 

func (_c *Config_Debug_Call) Run(run func()) *Config_Debug_Call

func (*Config_Debug_Call) RunAndReturn added in v1.15.12 

func (_c *Config_Debug_Call) RunAndReturn(run func() bool) *Config_Debug_Call

type Config_DefaultConcurrent_Call added in v1.15.12 

type Config_DefaultConcurrent_Call struct {
	*mock.Call
}

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

func (*Config_DefaultConcurrent_Call) Return added in v1.15.12 

func (_c *Config_DefaultConcurrent_Call) Return(_a0 int) *Config_DefaultConcurrent_Call

func (*Config_DefaultConcurrent_Call) Run added in v1.15.12 

func (_c *Config_DefaultConcurrent_Call) Run(run func()) *Config_DefaultConcurrent_Call

func (*Config_DefaultConcurrent_Call) RunAndReturn added in v1.15.12 

func (_c *Config_DefaultConcurrent_Call) RunAndReturn(run func() int) *Config_DefaultConcurrent_Call

type Config_DefaultConnection_Call added in v1.15.12 

type Config_DefaultConnection_Call struct {
	*mock.Call
}

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

func (*Config_DefaultConnection_Call) Return added in v1.15.12 

func (_c *Config_DefaultConnection_Call) Return(_a0 string) *Config_DefaultConnection_Call

func (*Config_DefaultConnection_Call) Run added in v1.15.12 

func (_c *Config_DefaultConnection_Call) Run(run func()) *Config_DefaultConnection_Call

func (*Config_DefaultConnection_Call) RunAndReturn added in v1.15.12 

func (_c *Config_DefaultConnection_Call) RunAndReturn(run func() string) *Config_DefaultConnection_Call

type Config_DefaultQueue_Call added in v1.15.12 

type Config_DefaultQueue_Call struct {
	*mock.Call
}

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

func (*Config_DefaultQueue_Call) Return added in v1.15.12 

func (_c *Config_DefaultQueue_Call) Return(_a0 string) *Config_DefaultQueue_Call

func (*Config_DefaultQueue_Call) Run added in v1.15.12 

func (_c *Config_DefaultQueue_Call) Run(run func()) *Config_DefaultQueue_Call

func (*Config_DefaultQueue_Call) RunAndReturn added in v1.15.12 

func (_c *Config_DefaultQueue_Call) RunAndReturn(run func() string) *Config_DefaultQueue_Call

type Config_Driver_Call added in v1.15.12 

type Config_Driver_Call struct {
	*mock.Call
}

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

func (*Config_Driver_Call) Return added in v1.15.12 

func (_c *Config_Driver_Call) Return(_a0 string) *Config_Driver_Call

func (*Config_Driver_Call) Run added in v1.15.12 

func (_c *Config_Driver_Call) Run(run func(connection string)) *Config_Driver_Call

func (*Config_Driver_Call) RunAndReturn added in v1.15.12 

func (_c *Config_Driver_Call) RunAndReturn(run func(string) string) *Config_Driver_Call

type Config_Env_Call added in v1.15.12 

type Config_Env_Call struct {
	*mock.Call
}

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

func (*Config_Env_Call) Return added in v1.15.12 

func (_c *Config_Env_Call) Return(_a0 interface{}) *Config_Env_Call

func (*Config_Env_Call) Run added in v1.15.12 

func (_c *Config_Env_Call) Run(run func(envName string, defaultValue ...interface{})) *Config_Env_Call

func (*Config_Env_Call) RunAndReturn added in v1.15.12 

func (_c *Config_Env_Call) RunAndReturn(run func(string, ...interface{}) interface{}) *Config_Env_Call

type Config_Expecter added in v1.15.12 

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

func (*Config_Expecter) Add added in v1.15.12 

func (_e *Config_Expecter) Add(name interface{}, configuration interface{}) *Config_Add_Call

Add is a helper method to define mock.On call

  • name string
  • configuration interface{}

func (*Config_Expecter) Debug added in v1.15.12 

func (_e *Config_Expecter) Debug() *Config_Debug_Call

Debug is a helper method to define mock.On call

func (*Config_Expecter) DefaultConcurrent added in v1.15.12 

func (_e *Config_Expecter) DefaultConcurrent() *Config_DefaultConcurrent_Call

DefaultConcurrent is a helper method to define mock.On call

func (*Config_Expecter) DefaultConnection added in v1.15.12 

func (_e *Config_Expecter) DefaultConnection() *Config_DefaultConnection_Call

DefaultConnection is a helper method to define mock.On call

func (*Config_Expecter) DefaultQueue added in v1.15.12 

func (_e *Config_Expecter) DefaultQueue() *Config_DefaultQueue_Call

DefaultQueue is a helper method to define mock.On call

func (*Config_Expecter) Driver added in v1.15.12 

func (_e *Config_Expecter) Driver(connection interface{}) *Config_Driver_Call

Driver is a helper method to define mock.On call

  • connection string

func (*Config_Expecter) Env added in v1.15.12 

func (_e *Config_Expecter) Env(envName interface{}, defaultValue ...interface{}) *Config_Env_Call

Env is a helper method to define mock.On call

  • envName string
  • defaultValue ...interface{}

func (*Config_Expecter) FailedDatabase added in v1.15.12 

func (_e *Config_Expecter) FailedDatabase() *Config_FailedDatabase_Call

FailedDatabase is a helper method to define mock.On call

func (*Config_Expecter) FailedTable added in v1.15.12 

func (_e *Config_Expecter) FailedTable() *Config_FailedTable_Call

FailedTable is a helper method to define mock.On call

func (*Config_Expecter) Get added in v1.15.12 

func (_e *Config_Expecter) Get(path interface{}, defaultValue ...interface{}) *Config_Get_Call

Get is a helper method to define mock.On call

  • path string
  • defaultValue ...interface{}

func (*Config_Expecter) GetBool added in v1.15.12 

func (_e *Config_Expecter) GetBool(path interface{}, defaultValue ...interface{}) *Config_GetBool_Call

GetBool is a helper method to define mock.On call

  • path string
  • defaultValue ...bool

func (*Config_Expecter) GetDuration added in v1.15.12 

func (_e *Config_Expecter) GetDuration(path interface{}, defaultValue ...interface{}) *Config_GetDuration_Call

GetDuration is a helper method to define mock.On call

  • path string
  • defaultValue ...time.Duration

func (*Config_Expecter) GetInt added in v1.15.12 

func (_e *Config_Expecter) GetInt(path interface{}, defaultValue ...interface{}) *Config_GetInt_Call

GetInt is a helper method to define mock.On call

  • path string
  • defaultValue ...int

func (*Config_Expecter) GetString added in v1.15.12 

func (_e *Config_Expecter) GetString(path interface{}, defaultValue ...interface{}) *Config_GetString_Call

GetString is a helper method to define mock.On call

  • path string
  • defaultValue ...string

func (*Config_Expecter) Via added in v1.15.12 

func (_e *Config_Expecter) Via(connection interface{}) *Config_Via_Call

Via is a helper method to define mock.On call

  • connection string

type Config_FailedDatabase_Call added in v1.15.12 

type Config_FailedDatabase_Call struct {
	*mock.Call
}

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

func (*Config_FailedDatabase_Call) Return added in v1.15.12 

func (_c *Config_FailedDatabase_Call) Return(_a0 string) *Config_FailedDatabase_Call

func (*Config_FailedDatabase_Call) Run added in v1.15.12 

func (_c *Config_FailedDatabase_Call) Run(run func()) *Config_FailedDatabase_Call

func (*Config_FailedDatabase_Call) RunAndReturn added in v1.15.12 

func (_c *Config_FailedDatabase_Call) RunAndReturn(run func() string) *Config_FailedDatabase_Call

type Config_FailedTable_Call added in v1.15.12 

type Config_FailedTable_Call struct {
	*mock.Call
}

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

func (*Config_FailedTable_Call) Return added in v1.15.12 

func (_c *Config_FailedTable_Call) Return(_a0 string) *Config_FailedTable_Call

func (*Config_FailedTable_Call) Run added in v1.15.12 

func (_c *Config_FailedTable_Call) Run(run func()) *Config_FailedTable_Call

func (*Config_FailedTable_Call) RunAndReturn added in v1.15.12 

func (_c *Config_FailedTable_Call) RunAndReturn(run func() string) *Config_FailedTable_Call

type Config_GetBool_Call added in v1.15.12 

type Config_GetBool_Call struct {
	*mock.Call
}

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

func (*Config_GetBool_Call) Return added in v1.15.12 

func (_c *Config_GetBool_Call) Return(_a0 bool) *Config_GetBool_Call

func (*Config_GetBool_Call) Run added in v1.15.12 

func (_c *Config_GetBool_Call) Run(run func(path string, defaultValue ...bool)) *Config_GetBool_Call

func (*Config_GetBool_Call) RunAndReturn added in v1.15.12 

func (_c *Config_GetBool_Call) RunAndReturn(run func(string, ...bool) bool) *Config_GetBool_Call

type Config_GetDuration_Call added in v1.15.12 

type Config_GetDuration_Call struct {
	*mock.Call
}

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

func (*Config_GetDuration_Call) Return added in v1.15.12 

func (_c *Config_GetDuration_Call) Return(_a0 time.Duration) *Config_GetDuration_Call

func (*Config_GetDuration_Call) Run added in v1.15.12 

func (_c *Config_GetDuration_Call) Run(run func(path string, defaultValue ...time.Duration)) *Config_GetDuration_Call

func (*Config_GetDuration_Call) RunAndReturn added in v1.15.12 

func (_c *Config_GetDuration_Call) RunAndReturn(run func(string, ...time.Duration) time.Duration) *Config_GetDuration_Call

type Config_GetInt_Call added in v1.15.12 

type Config_GetInt_Call struct {
	*mock.Call
}

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

func (*Config_GetInt_Call) Return added in v1.15.12 

func (_c *Config_GetInt_Call) Return(_a0 int) *Config_GetInt_Call

func (*Config_GetInt_Call) Run added in v1.15.12 

func (_c *Config_GetInt_Call) Run(run func(path string, defaultValue ...int)) *Config_GetInt_Call

func (*Config_GetInt_Call) RunAndReturn added in v1.15.12 

func (_c *Config_GetInt_Call) RunAndReturn(run func(string, ...int) int) *Config_GetInt_Call

type Config_GetString_Call added in v1.15.12 

type Config_GetString_Call struct {
	*mock.Call
}

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

func (*Config_GetString_Call) Return added in v1.15.12 

func (_c *Config_GetString_Call) Return(_a0 string) *Config_GetString_Call

func (*Config_GetString_Call) Run added in v1.15.12 

func (_c *Config_GetString_Call) Run(run func(path string, defaultValue ...string)) *Config_GetString_Call

func (*Config_GetString_Call) RunAndReturn added in v1.15.12 

func (_c *Config_GetString_Call) RunAndReturn(run func(string, ...string) string) *Config_GetString_Call

type Config_Get_Call added in v1.15.12 

type Config_Get_Call struct {
	*mock.Call
}

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

func (*Config_Get_Call) Return added in v1.15.12 

func (_c *Config_Get_Call) Return(_a0 interface{}) *Config_Get_Call

func (*Config_Get_Call) Run added in v1.15.12 

func (_c *Config_Get_Call) Run(run func(path string, defaultValue ...interface{})) *Config_Get_Call

func (*Config_Get_Call) RunAndReturn added in v1.15.12 

func (_c *Config_Get_Call) RunAndReturn(run func(string, ...interface{}) interface{}) *Config_Get_Call

type Config_Via_Call added in v1.15.12 

type Config_Via_Call struct {
	*mock.Call
}

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

func (*Config_Via_Call) Return added in v1.15.12 

func (_c *Config_Via_Call) Return(_a0 interface{}) *Config_Via_Call

func (*Config_Via_Call) Run added in v1.15.12 

func (_c *Config_Via_Call) Run(run func(connection string)) *Config_Via_Call

func (*Config_Via_Call) RunAndReturn added in v1.15.12 

func (_c *Config_Via_Call) RunAndReturn(run func(string) interface{}) *Config_Via_Call

type Driver added in v1.15.12 

type Driver struct {
	mock.Mock
}

Driver is an autogenerated mock type for the Driver type

func NewDriver added in v1.15.12 

func NewDriver(t interface {
	mock.TestingT
	Cleanup(func())
}) *Driver

NewDriver creates a new instance of Driver. 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 (*Driver) Driver added in v1.15.12 

func (_m *Driver) Driver() string

Driver provides a mock function with no fields

func (*Driver) EXPECT added in v1.15.12 

func (_m *Driver) EXPECT() *Driver_Expecter

func (*Driver) Pop added in v1.15.12 

func (_m *Driver) Pop(_a0 string) (queue.ReservedJob, error)

Pop provides a mock function with given fields: _a0

func (*Driver) Push added in v1.15.12 

func (_m *Driver) Push(task queue.Task, _a1 string) error

Push provides a mock function with given fields: task, _a1

type DriverCreator added in v1.15.12 

type DriverCreator struct {
	mock.Mock
}

DriverCreator is an autogenerated mock type for the DriverCreator type

func NewDriverCreator added in v1.15.12 

func NewDriverCreator(t interface {
	mock.TestingT
	Cleanup(func())
}) *DriverCreator

NewDriverCreator creates a new instance of DriverCreator. 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 (*DriverCreator) Create added in v1.15.12 

func (_m *DriverCreator) Create(connection string) (queue.Driver, error)

Create provides a mock function with given fields: connection

func (*DriverCreator) EXPECT added in v1.15.12 

func (_m *DriverCreator) EXPECT() *DriverCreator_Expecter

type DriverCreator_Create_Call added in v1.15.12 

type DriverCreator_Create_Call struct {
	*mock.Call
}

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

func (*DriverCreator_Create_Call) Return added in v1.15.12 

func (_c *DriverCreator_Create_Call) Return(_a0 queue.Driver, _a1 error) *DriverCreator_Create_Call

func (*DriverCreator_Create_Call) Run added in v1.15.12 

func (_c *DriverCreator_Create_Call) Run(run func(connection string)) *DriverCreator_Create_Call

func (*DriverCreator_Create_Call) RunAndReturn added in v1.15.12 

func (_c *DriverCreator_Create_Call) RunAndReturn(run func(string) (queue.Driver, error)) *DriverCreator_Create_Call

type DriverCreator_Expecter added in v1.15.12 

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

func (*DriverCreator_Expecter) Create added in v1.15.12 

func (_e *DriverCreator_Expecter) Create(connection interface{}) *DriverCreator_Create_Call

Create is a helper method to define mock.On call

  • connection string

type Driver_Driver_Call added in v1.15.12 

type Driver_Driver_Call struct {
	*mock.Call
}

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

func (*Driver_Driver_Call) Return added in v1.15.12 

func (_c *Driver_Driver_Call) Return(_a0 string) *Driver_Driver_Call

func (*Driver_Driver_Call) Run added in v1.15.12 

func (_c *Driver_Driver_Call) Run(run func()) *Driver_Driver_Call

func (*Driver_Driver_Call) RunAndReturn added in v1.15.12 

func (_c *Driver_Driver_Call) RunAndReturn(run func() string) *Driver_Driver_Call

type Driver_Expecter added in v1.15.12 

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

func (*Driver_Expecter) Driver added in v1.15.12 

func (_e *Driver_Expecter) Driver() *Driver_Driver_Call

Driver is a helper method to define mock.On call

func (*Driver_Expecter) Pop added in v1.15.12 

func (_e *Driver_Expecter) Pop(_a0 interface{}) *Driver_Pop_Call

Pop is a helper method to define mock.On call

  • _a0 string

func (*Driver_Expecter) Push added in v1.15.12 

func (_e *Driver_Expecter) Push(task interface{}, _a1 interface{}) *Driver_Push_Call

Push is a helper method to define mock.On call

  • task queue.Task
  • _a1 string

type Driver_Pop_Call added in v1.15.12 

type Driver_Pop_Call struct {
	*mock.Call
}

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

func (*Driver_Pop_Call) Return added in v1.15.12 

func (_c *Driver_Pop_Call) Return(_a0 queue.ReservedJob, _a1 error) *Driver_Pop_Call

func (*Driver_Pop_Call) Run added in v1.15.12 

func (_c *Driver_Pop_Call) Run(run func(_a0 string)) *Driver_Pop_Call

func (*Driver_Pop_Call) RunAndReturn added in v1.15.12 

func (_c *Driver_Pop_Call) RunAndReturn(run func(string) (queue.ReservedJob, error)) *Driver_Pop_Call

type Driver_Push_Call added in v1.15.12 

type Driver_Push_Call struct {
	*mock.Call
}

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

func (*Driver_Push_Call) Return added in v1.15.12 

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

func (*Driver_Push_Call) Run added in v1.15.12 

func (_c *Driver_Push_Call) Run(run func(task queue.Task, _a1 string)) *Driver_Push_Call

func (*Driver_Push_Call) RunAndReturn added in v1.15.12 

func (_c *Driver_Push_Call) RunAndReturn(run func(queue.Task, string) error) *Driver_Push_Call

type FailedJob added in v1.15.12 

type FailedJob struct {
	mock.Mock
}

FailedJob is an autogenerated mock type for the FailedJob type

func NewFailedJob added in v1.15.12 

func NewFailedJob(t interface {
	mock.TestingT
	Cleanup(func())
}) *FailedJob

NewFailedJob creates a new instance of FailedJob. 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 (*FailedJob) Connection added in v1.15.12 

func (_m *FailedJob) Connection() string

Connection provides a mock function with no fields

func (*FailedJob) EXPECT added in v1.15.12 

func (_m *FailedJob) EXPECT() *FailedJob_Expecter

func (*FailedJob) FailedAt added in v1.15.12 

func (_m *FailedJob) FailedAt() *carbon.LayoutType[supportcarbon.DateTimeType]

FailedAt provides a mock function with no fields

func (*FailedJob) Queue added in v1.15.12 

func (_m *FailedJob) Queue() string

Queue provides a mock function with no fields

func (*FailedJob) Retry added in v1.15.12 

func (_m *FailedJob) Retry() error

Retry provides a mock function with no fields

func (*FailedJob) Signature added in v1.15.12 

func (_m *FailedJob) Signature() string

Signature provides a mock function with no fields

func (*FailedJob) UUID added in v1.15.12 

func (_m *FailedJob) UUID() string

UUID provides a mock function with no fields

type FailedJob_Connection_Call added in v1.15.12 

type FailedJob_Connection_Call struct {
	*mock.Call
}

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

func (*FailedJob_Connection_Call) Return added in v1.15.12 

func (_c *FailedJob_Connection_Call) Return(_a0 string) *FailedJob_Connection_Call

func (*FailedJob_Connection_Call) Run added in v1.15.12 

func (_c *FailedJob_Connection_Call) Run(run func()) *FailedJob_Connection_Call

func (*FailedJob_Connection_Call) RunAndReturn added in v1.15.12 

func (_c *FailedJob_Connection_Call) RunAndReturn(run func() string) *FailedJob_Connection_Call

type FailedJob_Expecter added in v1.15.12 

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

func (*FailedJob_Expecter) Connection added in v1.15.12 

func (_e *FailedJob_Expecter) Connection() *FailedJob_Connection_Call

Connection is a helper method to define mock.On call

func (*FailedJob_Expecter) FailedAt added in v1.15.12 

func (_e *FailedJob_Expecter) FailedAt() *FailedJob_FailedAt_Call

FailedAt is a helper method to define mock.On call

func (*FailedJob_Expecter) Queue added in v1.15.12 

func (_e *FailedJob_Expecter) Queue() *FailedJob_Queue_Call

Queue is a helper method to define mock.On call

func (*FailedJob_Expecter) Retry added in v1.15.12 

func (_e *FailedJob_Expecter) Retry() *FailedJob_Retry_Call

Retry is a helper method to define mock.On call

func (*FailedJob_Expecter) Signature added in v1.15.12 

func (_e *FailedJob_Expecter) Signature() *FailedJob_Signature_Call

Signature is a helper method to define mock.On call

func (*FailedJob_Expecter) UUID added in v1.15.12 

func (_e *FailedJob_Expecter) UUID() *FailedJob_UUID_Call

UUID is a helper method to define mock.On call

type FailedJob_FailedAt_Call added in v1.15.12 

type FailedJob_FailedAt_Call struct {
	*mock.Call
}

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

func (*FailedJob_FailedAt_Call) Return added in v1.15.12 

func (_c *FailedJob_FailedAt_Call) Return(_a0 *carbon.LayoutType[supportcarbon.DateTimeType]) *FailedJob_FailedAt_Call

func (*FailedJob_FailedAt_Call) Run added in v1.15.12 

func (_c *FailedJob_FailedAt_Call) Run(run func()) *FailedJob_FailedAt_Call

func (*FailedJob_FailedAt_Call) RunAndReturn added in v1.15.12 

func (_c *FailedJob_FailedAt_Call) RunAndReturn(run func() *carbon.LayoutType[supportcarbon.DateTimeType]) *FailedJob_FailedAt_Call

type FailedJob_Queue_Call added in v1.15.12 

type FailedJob_Queue_Call struct {
	*mock.Call
}

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

func (*FailedJob_Queue_Call) Return added in v1.15.12 

func (_c *FailedJob_Queue_Call) Return(_a0 string) *FailedJob_Queue_Call

func (*FailedJob_Queue_Call) Run added in v1.15.12 

func (_c *FailedJob_Queue_Call) Run(run func()) *FailedJob_Queue_Call

func (*FailedJob_Queue_Call) RunAndReturn added in v1.15.12 

func (_c *FailedJob_Queue_Call) RunAndReturn(run func() string) *FailedJob_Queue_Call

type FailedJob_Retry_Call added in v1.15.12 

type FailedJob_Retry_Call struct {
	*mock.Call
}

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

func (*FailedJob_Retry_Call) Return added in v1.15.12 

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

func (*FailedJob_Retry_Call) Run added in v1.15.12 

func (_c *FailedJob_Retry_Call) Run(run func()) *FailedJob_Retry_Call

func (*FailedJob_Retry_Call) RunAndReturn added in v1.15.12 

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

type FailedJob_Signature_Call added in v1.15.12 

type FailedJob_Signature_Call struct {
	*mock.Call
}

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

func (*FailedJob_Signature_Call) Return added in v1.15.12 

func (_c *FailedJob_Signature_Call) Return(_a0 string) *FailedJob_Signature_Call

func (*FailedJob_Signature_Call) Run added in v1.15.12 

func (_c *FailedJob_Signature_Call) Run(run func()) *FailedJob_Signature_Call

func (*FailedJob_Signature_Call) RunAndReturn added in v1.15.12 

func (_c *FailedJob_Signature_Call) RunAndReturn(run func() string) *FailedJob_Signature_Call

type FailedJob_UUID_Call added in v1.15.12 

type FailedJob_UUID_Call struct {
	*mock.Call
}

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

func (*FailedJob_UUID_Call) Return added in v1.15.12 

func (_c *FailedJob_UUID_Call) Return(_a0 string) *FailedJob_UUID_Call

func (*FailedJob_UUID_Call) Run added in v1.15.12 

func (_c *FailedJob_UUID_Call) Run(run func()) *FailedJob_UUID_Call

func (*FailedJob_UUID_Call) RunAndReturn added in v1.15.12 

func (_c *FailedJob_UUID_Call) RunAndReturn(run func() string) *FailedJob_UUID_Call

type Failer added in v1.15.12 

type Failer struct {
	mock.Mock
}

Failer is an autogenerated mock type for the Failer type

func NewFailer added in v1.15.12 

func NewFailer(t interface {
	mock.TestingT
	Cleanup(func())
}) *Failer

NewFailer creates a new instance of Failer. 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 (*Failer) All added in v1.15.12 

func (_m *Failer) All() ([]queue.FailedJob, error)

All provides a mock function with no fields

func (*Failer) EXPECT added in v1.15.12 

func (_m *Failer) EXPECT() *Failer_Expecter

func (*Failer) Get added in v1.15.12 

func (_m *Failer) Get(connection string, _a1 string, uuids []string) ([]queue.FailedJob, error)

Get provides a mock function with given fields: connection, _a1, uuids

type Failer_All_Call added in v1.15.12 

type Failer_All_Call struct {
	*mock.Call
}

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

func (*Failer_All_Call) Return added in v1.15.12 

func (_c *Failer_All_Call) Return(_a0 []queue.FailedJob, _a1 error) *Failer_All_Call

func (*Failer_All_Call) Run added in v1.15.12 

func (_c *Failer_All_Call) Run(run func()) *Failer_All_Call

func (*Failer_All_Call) RunAndReturn added in v1.15.12 

func (_c *Failer_All_Call) RunAndReturn(run func() ([]queue.FailedJob, error)) *Failer_All_Call

type Failer_Expecter added in v1.15.12 

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

func (*Failer_Expecter) All added in v1.15.12 

func (_e *Failer_Expecter) All() *Failer_All_Call

All is a helper method to define mock.On call

func (*Failer_Expecter) Get added in v1.15.12 

func (_e *Failer_Expecter) Get(connection interface{}, _a1 interface{}, uuids interface{}) *Failer_Get_Call

Get is a helper method to define mock.On call

  • connection string
  • _a1 string
  • uuids []string

type Failer_Get_Call added in v1.15.12 

type Failer_Get_Call struct {
	*mock.Call
}

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

func (*Failer_Get_Call) Return added in v1.15.12 

func (_c *Failer_Get_Call) Return(_a0 []queue.FailedJob, _a1 error) *Failer_Get_Call

func (*Failer_Get_Call) Run added in v1.15.12 

func (_c *Failer_Get_Call) Run(run func(connection string, _a1 string, uuids []string)) *Failer_Get_Call

func (*Failer_Get_Call) RunAndReturn added in v1.15.12 

func (_c *Failer_Get_Call) RunAndReturn(run func(string, string, []string) ([]queue.FailedJob, error)) *Failer_Get_Call

type Job 

type Job struct {
	mock.Mock
}

Job is an autogenerated mock type for the Job type

func NewJob 

func NewJob(t interface {
	mock.TestingT
	Cleanup(func())
}) *Job

NewJob creates a new instance of Job. 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 (*Job) EXPECT 

func (_m *Job) EXPECT() *Job_Expecter

func (*Job) Handle 

func (_m *Job) Handle(args ...interface{}) error

Handle provides a mock function with given fields: args

func (*Job) Signature 

func (_m *Job) Signature() string

Signature provides a mock function with no fields

type JobStorer added in v1.15.12 

type JobStorer struct {
	mock.Mock
}

JobStorer is an autogenerated mock type for the JobStorer type

func NewJobStorer added in v1.15.12 

func NewJobStorer(t interface {
	mock.TestingT
	Cleanup(func())
}) *JobStorer

NewJobStorer creates a new instance of JobStorer. 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 (*JobStorer) All added in v1.15.12 

func (_m *JobStorer) All() []queue.Job

All provides a mock function with no fields

func (*JobStorer) Call added in v1.15.12 

func (_m *JobStorer) Call(signature string, args []interface{}) error

Call provides a mock function with given fields: signature, args

func (*JobStorer) EXPECT added in v1.15.12 

func (_m *JobStorer) EXPECT() *JobStorer_Expecter

func (*JobStorer) Get added in v1.15.12 

func (_m *JobStorer) Get(signature string) (queue.Job, error)

Get provides a mock function with given fields: signature

func (*JobStorer) Register added in v1.15.12 

func (_m *JobStorer) Register(jobs []queue.Job)

Register provides a mock function with given fields: jobs

type JobStorer_All_Call added in v1.15.12 

type JobStorer_All_Call struct {
	*mock.Call
}

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

func (*JobStorer_All_Call) Return added in v1.15.12 

func (_c *JobStorer_All_Call) Return(_a0 []queue.Job) *JobStorer_All_Call

func (*JobStorer_All_Call) Run added in v1.15.12 

func (_c *JobStorer_All_Call) Run(run func()) *JobStorer_All_Call

func (*JobStorer_All_Call) RunAndReturn added in v1.15.12 

func (_c *JobStorer_All_Call) RunAndReturn(run func() []queue.Job) *JobStorer_All_Call

type JobStorer_Call_Call added in v1.15.12 

type JobStorer_Call_Call struct {
	*mock.Call
}

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

func (*JobStorer_Call_Call) Return added in v1.15.12 

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

func (*JobStorer_Call_Call) Run added in v1.15.12 

func (_c *JobStorer_Call_Call) Run(run func(signature string, args []interface{})) *JobStorer_Call_Call

func (*JobStorer_Call_Call) RunAndReturn added in v1.15.12 

func (_c *JobStorer_Call_Call) RunAndReturn(run func(string, []interface{}) error) *JobStorer_Call_Call

type JobStorer_Expecter added in v1.15.12 

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

func (*JobStorer_Expecter) All added in v1.15.12 

func (_e *JobStorer_Expecter) All() *JobStorer_All_Call

All is a helper method to define mock.On call

func (*JobStorer_Expecter) Call added in v1.15.12 

func (_e *JobStorer_Expecter) Call(signature interface{}, args interface{}) *JobStorer_Call_Call

Call is a helper method to define mock.On call

  • signature string
  • args []interface{}

func (*JobStorer_Expecter) Get added in v1.15.12 

func (_e *JobStorer_Expecter) Get(signature interface{}) *JobStorer_Get_Call

Get is a helper method to define mock.On call

  • signature string

func (*JobStorer_Expecter) Register added in v1.15.12 

func (_e *JobStorer_Expecter) Register(jobs interface{}) *JobStorer_Register_Call

Register is a helper method to define mock.On call

  • jobs []queue.Job

type JobStorer_Get_Call added in v1.15.12 

type JobStorer_Get_Call struct {
	*mock.Call
}

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

func (*JobStorer_Get_Call) Return added in v1.15.12 

func (_c *JobStorer_Get_Call) Return(_a0 queue.Job, _a1 error) *JobStorer_Get_Call

func (*JobStorer_Get_Call) Run added in v1.15.12 

func (_c *JobStorer_Get_Call) Run(run func(signature string)) *JobStorer_Get_Call

func (*JobStorer_Get_Call) RunAndReturn added in v1.15.12 

func (_c *JobStorer_Get_Call) RunAndReturn(run func(string) (queue.Job, error)) *JobStorer_Get_Call

type JobStorer_Register_Call added in v1.15.12 

type JobStorer_Register_Call struct {
	*mock.Call
}

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

func (*JobStorer_Register_Call) Return added in v1.15.12 

func (_c *JobStorer_Register_Call) Return() *JobStorer_Register_Call

func (*JobStorer_Register_Call) Run added in v1.15.12 

func (_c *JobStorer_Register_Call) Run(run func(jobs []queue.Job)) *JobStorer_Register_Call

func (*JobStorer_Register_Call) RunAndReturn added in v1.15.12 

func (_c *JobStorer_Register_Call) RunAndReturn(run func([]queue.Job)) *JobStorer_Register_Call

type JobWithShouldRetry added in v1.15.12 

type JobWithShouldRetry struct {
	mock.Mock
}

JobWithShouldRetry is an autogenerated mock type for the JobWithShouldRetry type

func NewJobWithShouldRetry added in v1.15.12 

func NewJobWithShouldRetry(t interface {
	mock.TestingT
	Cleanup(func())
}) *JobWithShouldRetry

NewJobWithShouldRetry creates a new instance of JobWithShouldRetry. 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 (*JobWithShouldRetry) EXPECT added in v1.15.12 

func (_m *JobWithShouldRetry) EXPECT() *JobWithShouldRetry_Expecter

func (*JobWithShouldRetry) ShouldRetry added in v1.15.12 

func (_m *JobWithShouldRetry) ShouldRetry(err error, attempt int) (bool, time.Duration)

ShouldRetry provides a mock function with given fields: err, attempt

type JobWithShouldRetry_Expecter added in v1.15.12 

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

func (*JobWithShouldRetry_Expecter) ShouldRetry added in v1.15.12 

func (_e *JobWithShouldRetry_Expecter) ShouldRetry(err interface{}, attempt interface{}) *JobWithShouldRetry_ShouldRetry_Call

ShouldRetry is a helper method to define mock.On call

  • err error
  • attempt int

type JobWithShouldRetry_ShouldRetry_Call added in v1.15.12 

type JobWithShouldRetry_ShouldRetry_Call struct {
	*mock.Call
}

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

func (*JobWithShouldRetry_ShouldRetry_Call) Return added in v1.15.12 

func (_c *JobWithShouldRetry_ShouldRetry_Call) Return(retryable bool, delay time.Duration) *JobWithShouldRetry_ShouldRetry_Call

func (*JobWithShouldRetry_ShouldRetry_Call) Run added in v1.15.12 

func (_c *JobWithShouldRetry_ShouldRetry_Call) Run(run func(err error, attempt int)) *JobWithShouldRetry_ShouldRetry_Call

func (*JobWithShouldRetry_ShouldRetry_Call) RunAndReturn added in v1.15.12 

func (_c *JobWithShouldRetry_ShouldRetry_Call) RunAndReturn(run func(error, int) (bool, time.Duration)) *JobWithShouldRetry_ShouldRetry_Call

type Job_Expecter 

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

func (*Job_Expecter) Handle 

func (_e *Job_Expecter) Handle(args ...interface{}) *Job_Handle_Call

Handle is a helper method to define mock.On call

  • args ...interface{}

func (*Job_Expecter) Signature 

func (_e *Job_Expecter) Signature() *Job_Signature_Call

Signature is a helper method to define mock.On call

type Job_Handle_Call 

type Job_Handle_Call struct {
	*mock.Call
}

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

func (*Job_Handle_Call) Return 

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

func (*Job_Handle_Call) Run 

func (_c *Job_Handle_Call) Run(run func(args ...interface{})) *Job_Handle_Call

func (*Job_Handle_Call) RunAndReturn 

func (_c *Job_Handle_Call) RunAndReturn(run func(...interface{}) error) *Job_Handle_Call

type Job_Signature_Call 

type Job_Signature_Call struct {
	*mock.Call
}

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

func (*Job_Signature_Call) Return 

func (_c *Job_Signature_Call) Return(_a0 string) *Job_Signature_Call

func (*Job_Signature_Call) Run 

func (_c *Job_Signature_Call) Run(run func()) *Job_Signature_Call

func (*Job_Signature_Call) RunAndReturn 

func (_c *Job_Signature_Call) RunAndReturn(run func() string) *Job_Signature_Call

type PendingJob added in v1.15.12 

type PendingJob struct {
	mock.Mock
}

PendingJob is an autogenerated mock type for the PendingJob type

func NewPendingJob added in v1.15.12 

func NewPendingJob(t interface {
	mock.TestingT
	Cleanup(func())
}) *PendingJob

NewPendingJob creates a new instance of PendingJob. 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 (*PendingJob) Delay added in v1.15.12 

func (_m *PendingJob) Delay(_a0 time.Time) queue.PendingJob

Delay provides a mock function with given fields: _a0

func (*PendingJob) Dispatch added in v1.15.12 

func (_m *PendingJob) Dispatch() error

Dispatch provides a mock function with no fields

func (*PendingJob) DispatchSync added in v1.15.12 

func (_m *PendingJob) DispatchSync() error

DispatchSync provides a mock function with no fields

func (*PendingJob) EXPECT added in v1.15.12 

func (_m *PendingJob) EXPECT() *PendingJob_Expecter

func (*PendingJob) OnConnection added in v1.15.12 

func (_m *PendingJob) OnConnection(connection string) queue.PendingJob

OnConnection provides a mock function with given fields: connection

func (*PendingJob) OnQueue added in v1.15.12 

func (_m *PendingJob) OnQueue(_a0 string) queue.PendingJob

OnQueue provides a mock function with given fields: _a0

type PendingJob_Delay_Call added in v1.15.12 

type PendingJob_Delay_Call struct {
	*mock.Call
}

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

func (*PendingJob_Delay_Call) Return added in v1.15.12 

func (_c *PendingJob_Delay_Call) Return(_a0 queue.PendingJob) *PendingJob_Delay_Call

func (*PendingJob_Delay_Call) Run added in v1.15.12 

func (_c *PendingJob_Delay_Call) Run(run func(_a0 time.Time)) *PendingJob_Delay_Call

func (*PendingJob_Delay_Call) RunAndReturn added in v1.15.12 

func (_c *PendingJob_Delay_Call) RunAndReturn(run func(time.Time) queue.PendingJob) *PendingJob_Delay_Call

type PendingJob_DispatchSync_Call added in v1.15.12 

type PendingJob_DispatchSync_Call struct {
	*mock.Call
}

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

func (*PendingJob_DispatchSync_Call) Return added in v1.15.12 

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

func (*PendingJob_DispatchSync_Call) Run added in v1.15.12 

func (_c *PendingJob_DispatchSync_Call) Run(run func()) *PendingJob_DispatchSync_Call

func (*PendingJob_DispatchSync_Call) RunAndReturn added in v1.15.12 

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

type PendingJob_Dispatch_Call added in v1.15.12 

type PendingJob_Dispatch_Call struct {
	*mock.Call
}

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

func (*PendingJob_Dispatch_Call) Return added in v1.15.12 

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

func (*PendingJob_Dispatch_Call) Run added in v1.15.12 

func (_c *PendingJob_Dispatch_Call) Run(run func()) *PendingJob_Dispatch_Call

func (*PendingJob_Dispatch_Call) RunAndReturn added in v1.15.12 

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

type PendingJob_Expecter added in v1.15.12 

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

func (*PendingJob_Expecter) Delay added in v1.15.12 

func (_e *PendingJob_Expecter) Delay(_a0 interface{}) *PendingJob_Delay_Call

Delay is a helper method to define mock.On call

  • _a0 time.Time

func (*PendingJob_Expecter) Dispatch added in v1.15.12 

func (_e *PendingJob_Expecter) Dispatch() *PendingJob_Dispatch_Call

Dispatch is a helper method to define mock.On call

func (*PendingJob_Expecter) DispatchSync added in v1.15.12 

func (_e *PendingJob_Expecter) DispatchSync() *PendingJob_DispatchSync_Call

DispatchSync is a helper method to define mock.On call

func (*PendingJob_Expecter) OnConnection added in v1.15.12 

func (_e *PendingJob_Expecter) OnConnection(connection interface{}) *PendingJob_OnConnection_Call

OnConnection is a helper method to define mock.On call

  • connection string

func (*PendingJob_Expecter) OnQueue added in v1.15.12 

func (_e *PendingJob_Expecter) OnQueue(_a0 interface{}) *PendingJob_OnQueue_Call

OnQueue is a helper method to define mock.On call

  • _a0 string

type PendingJob_OnConnection_Call added in v1.15.12 

type PendingJob_OnConnection_Call struct {
	*mock.Call
}

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

func (*PendingJob_OnConnection_Call) Return added in v1.15.12 

func (_c *PendingJob_OnConnection_Call) Return(_a0 queue.PendingJob) *PendingJob_OnConnection_Call

func (*PendingJob_OnConnection_Call) Run added in v1.15.12 

func (_c *PendingJob_OnConnection_Call) Run(run func(connection string)) *PendingJob_OnConnection_Call

func (*PendingJob_OnConnection_Call) RunAndReturn added in v1.15.12 

func (_c *PendingJob_OnConnection_Call) RunAndReturn(run func(string) queue.PendingJob) *PendingJob_OnConnection_Call

type PendingJob_OnQueue_Call added in v1.15.12 

type PendingJob_OnQueue_Call struct {
	*mock.Call
}

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

func (*PendingJob_OnQueue_Call) Return added in v1.15.12 

func (_c *PendingJob_OnQueue_Call) Return(_a0 queue.PendingJob) *PendingJob_OnQueue_Call

func (*PendingJob_OnQueue_Call) Run added in v1.15.12 

func (_c *PendingJob_OnQueue_Call) Run(run func(_a0 string)) *PendingJob_OnQueue_Call

func (*PendingJob_OnQueue_Call) RunAndReturn added in v1.15.12 

func (_c *PendingJob_OnQueue_Call) RunAndReturn(run func(string) queue.PendingJob) *PendingJob_OnQueue_Call

type Queue 

type Queue struct {
	mock.Mock
}

Queue is an autogenerated mock type for the Queue type

func NewQueue 

func NewQueue(t interface {
	mock.TestingT
	Cleanup(func())
}) *Queue

NewQueue creates a new instance of Queue. 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 (*Queue) Chain 

func (_m *Queue) Chain(jobs []queue.ChainJob) queue.PendingJob

Chain provides a mock function with given fields: jobs

func (*Queue) Connection added in v1.15.12 

func (_m *Queue) Connection(name string) (queue.Driver, error)

Connection provides a mock function with given fields: name

func (*Queue) EXPECT 

func (_m *Queue) EXPECT() *Queue_Expecter

func (*Queue) Failer added in v1.15.12 

func (_m *Queue) Failer() queue.Failer

Failer provides a mock function with no fields

func (*Queue) GetJob added in v1.15.12 

func (_m *Queue) GetJob(signature string) (queue.Job, error)

GetJob provides a mock function with given fields: signature

func (*Queue) GetJobs 

func (_m *Queue) GetJobs() []queue.Job

GetJobs provides a mock function with no fields

func (*Queue) Job 

func (_m *Queue) Job(job queue.Job, args ...[]queue.Arg) queue.PendingJob

Job provides a mock function with given fields: job, args

func (*Queue) JobStorer added in v1.15.12 

func (_m *Queue) JobStorer() queue.JobStorer

JobStorer provides a mock function with no fields

func (*Queue) Register 

func (_m *Queue) Register(jobs []queue.Job)

Register provides a mock function with given fields: jobs

func (*Queue) Worker 

func (_m *Queue) Worker(payloads ...queue.Args) queue.Worker

Worker provides a mock function with given fields: payloads

type Queue_Chain_Call 

type Queue_Chain_Call struct {
	*mock.Call
}

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

func (*Queue_Chain_Call) Return 

func (_c *Queue_Chain_Call) Return(_a0 queue.PendingJob) *Queue_Chain_Call

func (*Queue_Chain_Call) Run 

func (_c *Queue_Chain_Call) Run(run func(jobs []queue.ChainJob)) *Queue_Chain_Call

func (*Queue_Chain_Call) RunAndReturn 

func (_c *Queue_Chain_Call) RunAndReturn(run func([]queue.ChainJob) queue.PendingJob) *Queue_Chain_Call

type Queue_Connection_Call added in v1.15.12 

type Queue_Connection_Call struct {
	*mock.Call
}

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

func (*Queue_Connection_Call) Return added in v1.15.12 

func (_c *Queue_Connection_Call) Return(_a0 queue.Driver, _a1 error) *Queue_Connection_Call

func (*Queue_Connection_Call) Run added in v1.15.12 

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

func (*Queue_Connection_Call) RunAndReturn added in v1.15.12 

func (_c *Queue_Connection_Call) RunAndReturn(run func(string) (queue.Driver, error)) *Queue_Connection_Call

type Queue_Expecter 

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

func (*Queue_Expecter) Chain 

func (_e *Queue_Expecter) Chain(jobs interface{}) *Queue_Chain_Call

Chain is a helper method to define mock.On call

  • jobs []queue.ChainJob

func (*Queue_Expecter) Connection added in v1.15.12 

func (_e *Queue_Expecter) Connection(name interface{}) *Queue_Connection_Call

Connection is a helper method to define mock.On call

  • name string

func (*Queue_Expecter) Failer added in v1.15.12 

func (_e *Queue_Expecter) Failer() *Queue_Failer_Call

Failer is a helper method to define mock.On call

func (*Queue_Expecter) GetJob added in v1.15.12 

func (_e *Queue_Expecter) GetJob(signature interface{}) *Queue_GetJob_Call

GetJob is a helper method to define mock.On call

  • signature string

func (*Queue_Expecter) GetJobs 

func (_e *Queue_Expecter) GetJobs() *Queue_GetJobs_Call

GetJobs is a helper method to define mock.On call

func (*Queue_Expecter) Job 

func (_e *Queue_Expecter) Job(job interface{}, args ...interface{}) *Queue_Job_Call

Job is a helper method to define mock.On call

  • job queue.Job
  • args ...[]queue.Arg

func (*Queue_Expecter) JobStorer added in v1.15.12 

func (_e *Queue_Expecter) JobStorer() *Queue_JobStorer_Call

JobStorer is a helper method to define mock.On call

func (*Queue_Expecter) Register 

func (_e *Queue_Expecter) Register(jobs interface{}) *Queue_Register_Call

Register is a helper method to define mock.On call

  • jobs []queue.Job

func (*Queue_Expecter) Worker 

func (_e *Queue_Expecter) Worker(payloads ...interface{}) *Queue_Worker_Call

Worker is a helper method to define mock.On call

  • payloads ...queue.Args

type Queue_Failer_Call added in v1.15.12 

type Queue_Failer_Call struct {
	*mock.Call
}

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

func (*Queue_Failer_Call) Return added in v1.15.12 

func (_c *Queue_Failer_Call) Return(_a0 queue.Failer) *Queue_Failer_Call

func (*Queue_Failer_Call) Run added in v1.15.12 

func (_c *Queue_Failer_Call) Run(run func()) *Queue_Failer_Call

func (*Queue_Failer_Call) RunAndReturn added in v1.15.12 

func (_c *Queue_Failer_Call) RunAndReturn(run func() queue.Failer) *Queue_Failer_Call

type Queue_GetJob_Call added in v1.15.12 

type Queue_GetJob_Call struct {
	*mock.Call
}

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

func (*Queue_GetJob_Call) Return added in v1.15.12 

func (_c *Queue_GetJob_Call) Return(_a0 queue.Job, _a1 error) *Queue_GetJob_Call

func (*Queue_GetJob_Call) Run added in v1.15.12 

func (_c *Queue_GetJob_Call) Run(run func(signature string)) *Queue_GetJob_Call

func (*Queue_GetJob_Call) RunAndReturn added in v1.15.12 

func (_c *Queue_GetJob_Call) RunAndReturn(run func(string) (queue.Job, error)) *Queue_GetJob_Call

type Queue_GetJobs_Call 

type Queue_GetJobs_Call struct {
	*mock.Call
}

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

func (*Queue_GetJobs_Call) Return 

func (_c *Queue_GetJobs_Call) Return(_a0 []queue.Job) *Queue_GetJobs_Call

func (*Queue_GetJobs_Call) Run 

func (_c *Queue_GetJobs_Call) Run(run func()) *Queue_GetJobs_Call

func (*Queue_GetJobs_Call) RunAndReturn 

func (_c *Queue_GetJobs_Call) RunAndReturn(run func() []queue.Job) *Queue_GetJobs_Call

type Queue_JobStorer_Call added in v1.15.12 

type Queue_JobStorer_Call struct {
	*mock.Call
}

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

func (*Queue_JobStorer_Call) Return added in v1.15.12 

func (_c *Queue_JobStorer_Call) Return(_a0 queue.JobStorer) *Queue_JobStorer_Call

func (*Queue_JobStorer_Call) Run added in v1.15.12 

func (_c *Queue_JobStorer_Call) Run(run func()) *Queue_JobStorer_Call

func (*Queue_JobStorer_Call) RunAndReturn added in v1.15.12 

func (_c *Queue_JobStorer_Call) RunAndReturn(run func() queue.JobStorer) *Queue_JobStorer_Call

type Queue_Job_Call 

type Queue_Job_Call struct {
	*mock.Call
}

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

func (*Queue_Job_Call) Return 

func (_c *Queue_Job_Call) Return(_a0 queue.PendingJob) *Queue_Job_Call

func (*Queue_Job_Call) Run 

func (_c *Queue_Job_Call) Run(run func(job queue.Job, args ...[]queue.Arg)) *Queue_Job_Call

func (*Queue_Job_Call) RunAndReturn 

func (_c *Queue_Job_Call) RunAndReturn(run func(queue.Job, ...[]queue.Arg) queue.PendingJob) *Queue_Job_Call

type Queue_Register_Call 

type Queue_Register_Call struct {
	*mock.Call
}

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

func (*Queue_Register_Call) Return 

func (_c *Queue_Register_Call) Return() *Queue_Register_Call

func (*Queue_Register_Call) Run 

func (_c *Queue_Register_Call) Run(run func(jobs []queue.Job)) *Queue_Register_Call

func (*Queue_Register_Call) RunAndReturn 

func (_c *Queue_Register_Call) RunAndReturn(run func([]queue.Job)) *Queue_Register_Call

type Queue_Worker_Call 

type Queue_Worker_Call struct {
	*mock.Call
}

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

func (*Queue_Worker_Call) Return 

func (_c *Queue_Worker_Call) Return(_a0 queue.Worker) *Queue_Worker_Call

func (*Queue_Worker_Call) Run 

func (_c *Queue_Worker_Call) Run(run func(payloads ...queue.Args)) *Queue_Worker_Call

func (*Queue_Worker_Call) RunAndReturn 

func (_c *Queue_Worker_Call) RunAndReturn(run func(...queue.Args) queue.Worker) *Queue_Worker_Call

type ReservedJob added in v1.15.12 

type ReservedJob struct {
	mock.Mock
}

ReservedJob is an autogenerated mock type for the ReservedJob type

func NewReservedJob added in v1.15.12 

func NewReservedJob(t interface {
	mock.TestingT
	Cleanup(func())
}) *ReservedJob

NewReservedJob creates a new instance of ReservedJob. 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 (*ReservedJob) Delete added in v1.15.12 

func (_m *ReservedJob) Delete() error

Delete provides a mock function with no fields

func (*ReservedJob) EXPECT added in v1.15.12 

func (_m *ReservedJob) EXPECT() *ReservedJob_Expecter

func (*ReservedJob) Task added in v1.15.12 

func (_m *ReservedJob) Task() queue.Task

Task provides a mock function with no fields

type ReservedJob_Delete_Call added in v1.15.12 

type ReservedJob_Delete_Call struct {
	*mock.Call
}

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

func (*ReservedJob_Delete_Call) Return added in v1.15.12 

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

func (*ReservedJob_Delete_Call) Run added in v1.15.12 

func (_c *ReservedJob_Delete_Call) Run(run func()) *ReservedJob_Delete_Call

func (*ReservedJob_Delete_Call) RunAndReturn added in v1.15.12 

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

type ReservedJob_Expecter added in v1.15.12 

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

func (*ReservedJob_Expecter) Delete added in v1.15.12 

func (_e *ReservedJob_Expecter) Delete() *ReservedJob_Delete_Call

Delete is a helper method to define mock.On call

func (*ReservedJob_Expecter) Task added in v1.15.12 

func (_e *ReservedJob_Expecter) Task() *ReservedJob_Task_Call

Task is a helper method to define mock.On call

type ReservedJob_Task_Call added in v1.15.12 

type ReservedJob_Task_Call struct {
	*mock.Call
}

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

func (*ReservedJob_Task_Call) Return added in v1.15.12 

func (_c *ReservedJob_Task_Call) Return(_a0 queue.Task) *ReservedJob_Task_Call

func (*ReservedJob_Task_Call) Run added in v1.15.12 

func (_c *ReservedJob_Task_Call) Run(run func()) *ReservedJob_Task_Call

func (*ReservedJob_Task_Call) RunAndReturn added in v1.15.12 

func (_c *ReservedJob_Task_Call) RunAndReturn(run func() queue.Task) *ReservedJob_Task_Call

type Task 

type Task struct {
	mock.Mock
}

Task is an autogenerated mock type for the Task type

func NewTask 

func NewTask(t interface {
	mock.TestingT
	Cleanup(func())
}) *Task

NewTask creates a new instance of Task. 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 (*Task) Delay 

func (_m *Task) Delay(_a0 time.Time) queue.PendingJob

Delay provides a mock function with given fields: _a0

func (*Task) Dispatch 

func (_m *Task) Dispatch() error

Dispatch provides a mock function with no fields

func (*Task) DispatchSync 

func (_m *Task) DispatchSync() error

DispatchSync provides a mock function with no fields

func (*Task) EXPECT 

func (_m *Task) EXPECT() *Task_Expecter

func (*Task) OnConnection 

func (_m *Task) OnConnection(connection string) queue.PendingJob

OnConnection provides a mock function with given fields: connection

func (*Task) OnQueue 

func (_m *Task) OnQueue(_a0 string) queue.PendingJob

OnQueue provides a mock function with given fields: _a0

type Task_Delay_Call 

type Task_Delay_Call struct {
	*mock.Call
}

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

func (*Task_Delay_Call) Return 

func (_c *Task_Delay_Call) Return(_a0 queue.PendingJob) *Task_Delay_Call

func (*Task_Delay_Call) Run 

func (_c *Task_Delay_Call) Run(run func(_a0 time.Time)) *Task_Delay_Call

func (*Task_Delay_Call) RunAndReturn 

func (_c *Task_Delay_Call) RunAndReturn(run func(time.Time) queue.PendingJob) *Task_Delay_Call

type Task_DispatchSync_Call 

type Task_DispatchSync_Call struct {
	*mock.Call
}

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

func (*Task_DispatchSync_Call) Return 

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

func (*Task_DispatchSync_Call) Run 

func (_c *Task_DispatchSync_Call) Run(run func()) *Task_DispatchSync_Call

func (*Task_DispatchSync_Call) RunAndReturn 

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

type Task_Dispatch_Call 

type Task_Dispatch_Call struct {
	*mock.Call
}

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

func (*Task_Dispatch_Call) Return 

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

func (*Task_Dispatch_Call) Run 

func (_c *Task_Dispatch_Call) Run(run func()) *Task_Dispatch_Call

func (*Task_Dispatch_Call) RunAndReturn 

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

type Task_Expecter 

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

func (*Task_Expecter) Delay 

func (_e *Task_Expecter) Delay(_a0 interface{}) *Task_Delay_Call

Delay is a helper method to define mock.On call

  • _a0 time.Time

func (*Task_Expecter) Dispatch 

func (_e *Task_Expecter) Dispatch() *Task_Dispatch_Call

Dispatch is a helper method to define mock.On call

func (*Task_Expecter) DispatchSync 

func (_e *Task_Expecter) DispatchSync() *Task_DispatchSync_Call

DispatchSync is a helper method to define mock.On call

func (*Task_Expecter) OnConnection 

func (_e *Task_Expecter) OnConnection(connection interface{}) *Task_OnConnection_Call

OnConnection is a helper method to define mock.On call

  • connection string

func (*Task_Expecter) OnQueue 

func (_e *Task_Expecter) OnQueue(_a0 interface{}) *Task_OnQueue_Call

OnQueue is a helper method to define mock.On call

  • _a0 string

type Task_OnConnection_Call 

type Task_OnConnection_Call struct {
	*mock.Call
}

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

func (*Task_OnConnection_Call) Return 

func (_c *Task_OnConnection_Call) Return(_a0 queue.PendingJob) *Task_OnConnection_Call

func (*Task_OnConnection_Call) Run 

func (_c *Task_OnConnection_Call) Run(run func(connection string)) *Task_OnConnection_Call

func (*Task_OnConnection_Call) RunAndReturn 

func (_c *Task_OnConnection_Call) RunAndReturn(run func(string) queue.PendingJob) *Task_OnConnection_Call

type Task_OnQueue_Call 

type Task_OnQueue_Call struct {
	*mock.Call
}

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

func (*Task_OnQueue_Call) Return 

func (_c *Task_OnQueue_Call) Return(_a0 queue.PendingJob) *Task_OnQueue_Call

func (*Task_OnQueue_Call) Run 

func (_c *Task_OnQueue_Call) Run(run func(_a0 string)) *Task_OnQueue_Call

func (*Task_OnQueue_Call) RunAndReturn 

func (_c *Task_OnQueue_Call) RunAndReturn(run func(string) queue.PendingJob) *Task_OnQueue_Call

type Worker 

type Worker struct {
	mock.Mock
}

Worker is an autogenerated mock type for the Worker type

func NewWorker 

func NewWorker(t interface {
	mock.TestingT
	Cleanup(func())
}) *Worker

NewWorker creates a new instance of Worker. 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 (*Worker) EXPECT 

func (_m *Worker) EXPECT() *Worker_Expecter

func (*Worker) Run 

func (_m *Worker) Run() error

Run provides a mock function with no fields

func (*Worker) Shutdown added in v1.15.12 

func (_m *Worker) Shutdown() error

Shutdown provides a mock function with no fields

type Worker_Expecter 

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

func (*Worker_Expecter) Run 

func (_e *Worker_Expecter) Run() *Worker_Run_Call

Run is a helper method to define mock.On call

func (*Worker_Expecter) Shutdown added in v1.15.12 

func (_e *Worker_Expecter) Shutdown() *Worker_Shutdown_Call

Shutdown is a helper method to define mock.On call

type Worker_Run_Call 

type Worker_Run_Call struct {
	*mock.Call
}

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

func (*Worker_Run_Call) Return 

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

func (*Worker_Run_Call) Run 

func (_c *Worker_Run_Call) Run(run func()) *Worker_Run_Call

func (*Worker_Run_Call) RunAndReturn 

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

type Worker_Shutdown_Call added in v1.15.12 

type Worker_Shutdown_Call struct {
	*mock.Call
}

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

func (*Worker_Shutdown_Call) Return added in v1.15.12 

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

func (*Worker_Shutdown_Call) Run added in v1.15.12 

func (_c *Worker_Shutdown_Call) Run(run func()) *Worker_Shutdown_Call

func (*Worker_Shutdown_Call) RunAndReturn added in v1.15.12 

func (_c *Worker_Shutdown_Call) RunAndReturn(run func() error) *Worker_Shutdown_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.