Documentation
¶
Index ¶
- type MockClient
- func (_mock *MockClient) Close() error
- func (_m *MockClient) EXPECT() *MockClient_Expecter
- func (_mock *MockClient) Submit(ctx context.Context, pattern worker.TaskPattern, payload []byte) error
- func (_mock *MockClient) SubmitToBatch(ctx context.Context, pattern worker.TaskPattern, payload []byte) error
- type MockClient_Close_Call
- type MockClient_Expecter
- type MockClient_SubmitToBatch_Call
- func (_c *MockClient_SubmitToBatch_Call) Return(err error) *MockClient_SubmitToBatch_Call
- func (_c *MockClient_SubmitToBatch_Call) Run(run func(ctx context.Context, pattern worker.TaskPattern, payload []byte)) *MockClient_SubmitToBatch_Call
- func (_c *MockClient_SubmitToBatch_Call) RunAndReturn(...) *MockClient_SubmitToBatch_Call
- type MockClient_Submit_Call
- type MockServer
- func (_m *MockServer) EXPECT() *MockServer_Expecter
- func (_mock *MockServer) HandleCron(spec worker.CronSpec, cronFunc worker.CronHandler, ...)
- func (_mock *MockServer) HandleTask(pattern worker.TaskPattern, cb worker.TaskHandler, opts ...worker.TaskOption)
- func (_mock *MockServer) Shutdown()
- func (_mock *MockServer) Start() error
- type MockServer_Expecter
- func (_e *MockServer_Expecter) HandleCron(spec any, cronFunc any, opts ...any) *MockServer_HandleCron_Call
- func (_e *MockServer_Expecter) HandleTask(pattern any, cb any, opts ...any) *MockServer_HandleTask_Call
- func (_e *MockServer_Expecter) Shutdown() *MockServer_Shutdown_Call
- func (_e *MockServer_Expecter) Start() *MockServer_Start_Call
- type MockServer_HandleCron_Call
- func (_c *MockServer_HandleCron_Call) Return() *MockServer_HandleCron_Call
- func (_c *MockServer_HandleCron_Call) Run(run func(spec worker.CronSpec, cronFunc worker.CronHandler, ...)) *MockServer_HandleCron_Call
- func (_c *MockServer_HandleCron_Call) RunAndReturn(run func(spec worker.CronSpec, cronFunc worker.CronHandler, ...)) *MockServer_HandleCron_Call
- type MockServer_HandleTask_Call
- type MockServer_Shutdown_Call
- type MockServer_Start_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClient ¶ added in v0.26.0
MockClient is an autogenerated mock type for the Client type
func NewMockClient ¶ added in v0.26.0
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 ¶ added in v0.26.0
func (_mock *MockClient) Close() error
Close provides a mock function for the type MockClient
func (*MockClient) EXPECT ¶ added in v0.26.0
func (_m *MockClient) EXPECT() *MockClient_Expecter
func (*MockClient) Submit ¶ added in v0.26.0
func (_mock *MockClient) Submit(ctx context.Context, pattern worker.TaskPattern, payload []byte) error
Submit provides a mock function for the type MockClient
func (*MockClient) SubmitToBatch ¶ added in v0.26.0
func (_mock *MockClient) SubmitToBatch(ctx context.Context, pattern worker.TaskPattern, payload []byte) error
SubmitToBatch provides a mock function for the type MockClient
type MockClient_Close_Call ¶ added in v0.26.0
MockClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockClient_Close_Call) Return ¶ added in v0.26.0
func (_c *MockClient_Close_Call) Return(err error) *MockClient_Close_Call
func (*MockClient_Close_Call) Run ¶ added in v0.26.0
func (_c *MockClient_Close_Call) Run(run func()) *MockClient_Close_Call
func (*MockClient_Close_Call) RunAndReturn ¶ added in v0.26.0
func (_c *MockClient_Close_Call) RunAndReturn(run func() error) *MockClient_Close_Call
type MockClient_Expecter ¶ added in v0.26.0
type MockClient_Expecter struct {
// contains filtered or unexported fields
}
func (*MockClient_Expecter) Close ¶ added in v0.26.0
func (_e *MockClient_Expecter) Close() *MockClient_Close_Call
Close is a helper method to define mock.On call
func (*MockClient_Expecter) Submit ¶ added in v0.26.0
func (_e *MockClient_Expecter) Submit(ctx any, pattern any, payload any) *MockClient_Submit_Call
Submit is a helper method to define mock.On call
- ctx context.Context
- pattern worker.TaskPattern
- payload []byte
func (*MockClient_Expecter) SubmitToBatch ¶ added in v0.26.0
func (_e *MockClient_Expecter) SubmitToBatch(ctx any, pattern any, payload any) *MockClient_SubmitToBatch_Call
SubmitToBatch is a helper method to define mock.On call
- ctx context.Context
- pattern worker.TaskPattern
- payload []byte
type MockClient_SubmitToBatch_Call ¶ added in v0.26.0
MockClient_SubmitToBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubmitToBatch'
func (*MockClient_SubmitToBatch_Call) Return ¶ added in v0.26.0
func (_c *MockClient_SubmitToBatch_Call) Return(err error) *MockClient_SubmitToBatch_Call
func (*MockClient_SubmitToBatch_Call) Run ¶ added in v0.26.0
func (_c *MockClient_SubmitToBatch_Call) Run(run func(ctx context.Context, pattern worker.TaskPattern, payload []byte)) *MockClient_SubmitToBatch_Call
func (*MockClient_SubmitToBatch_Call) RunAndReturn ¶ added in v0.26.0
func (_c *MockClient_SubmitToBatch_Call) RunAndReturn(run func(ctx context.Context, pattern worker.TaskPattern, payload []byte) error) *MockClient_SubmitToBatch_Call
type MockClient_Submit_Call ¶ added in v0.26.0
MockClient_Submit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Submit'
func (*MockClient_Submit_Call) Return ¶ added in v0.26.0
func (_c *MockClient_Submit_Call) Return(err error) *MockClient_Submit_Call
func (*MockClient_Submit_Call) Run ¶ added in v0.26.0
func (_c *MockClient_Submit_Call) Run(run func(ctx context.Context, pattern worker.TaskPattern, payload []byte)) *MockClient_Submit_Call
func (*MockClient_Submit_Call) RunAndReturn ¶ added in v0.26.0
func (_c *MockClient_Submit_Call) RunAndReturn(run func(ctx context.Context, pattern worker.TaskPattern, payload []byte) error) *MockClient_Submit_Call
type MockServer ¶ added in v0.26.0
MockServer is an autogenerated mock type for the Server type
func NewMockServer ¶ added in v0.26.0
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 ¶ added in v0.26.0
func (_m *MockServer) EXPECT() *MockServer_Expecter
func (*MockServer) HandleCron ¶ added in v0.26.0
func (_mock *MockServer) HandleCron(spec worker.CronSpec, cronFunc worker.CronHandler, opts ...worker.CronjobOption)
HandleCron provides a mock function for the type MockServer
func (*MockServer) HandleTask ¶ added in v0.26.0
func (_mock *MockServer) HandleTask(pattern worker.TaskPattern, cb worker.TaskHandler, opts ...worker.TaskOption)
HandleTask provides a mock function for the type MockServer
func (*MockServer) Shutdown ¶ added in v0.26.0
func (_mock *MockServer) Shutdown()
Shutdown provides a mock function for the type MockServer
func (*MockServer) Start ¶ added in v0.26.0
func (_mock *MockServer) Start() error
Start provides a mock function for the type MockServer
type MockServer_Expecter ¶ added in v0.26.0
type MockServer_Expecter struct {
// contains filtered or unexported fields
}
func (*MockServer_Expecter) HandleCron ¶ added in v0.26.0
func (_e *MockServer_Expecter) HandleCron(spec any, cronFunc any, opts ...any) *MockServer_HandleCron_Call
HandleCron is a helper method to define mock.On call
- spec worker.CronSpec
- cronFunc worker.CronHandler
- opts ...worker.CronjobOption
func (*MockServer_Expecter) HandleTask ¶ added in v0.26.0
func (_e *MockServer_Expecter) HandleTask(pattern any, cb any, opts ...any) *MockServer_HandleTask_Call
HandleTask is a helper method to define mock.On call
- pattern worker.TaskPattern
- cb worker.TaskHandler
- opts ...worker.TaskOption
func (*MockServer_Expecter) Shutdown ¶ added in v0.26.0
func (_e *MockServer_Expecter) Shutdown() *MockServer_Shutdown_Call
Shutdown is a helper method to define mock.On call
func (*MockServer_Expecter) Start ¶ added in v0.26.0
func (_e *MockServer_Expecter) Start() *MockServer_Start_Call
Start is a helper method to define mock.On call
type MockServer_HandleCron_Call ¶ added in v0.26.0
MockServer_HandleCron_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleCron'
func (*MockServer_HandleCron_Call) Return ¶ added in v0.26.0
func (_c *MockServer_HandleCron_Call) Return() *MockServer_HandleCron_Call
func (*MockServer_HandleCron_Call) Run ¶ added in v0.26.0
func (_c *MockServer_HandleCron_Call) Run(run func(spec worker.CronSpec, cronFunc worker.CronHandler, opts ...worker.CronjobOption)) *MockServer_HandleCron_Call
func (*MockServer_HandleCron_Call) RunAndReturn ¶ added in v0.26.0
func (_c *MockServer_HandleCron_Call) RunAndReturn(run func(spec worker.CronSpec, cronFunc worker.CronHandler, opts ...worker.CronjobOption)) *MockServer_HandleCron_Call
type MockServer_HandleTask_Call ¶ added in v0.26.0
MockServer_HandleTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleTask'
func (*MockServer_HandleTask_Call) Return ¶ added in v0.26.0
func (_c *MockServer_HandleTask_Call) Return() *MockServer_HandleTask_Call
func (*MockServer_HandleTask_Call) Run ¶ added in v0.26.0
func (_c *MockServer_HandleTask_Call) Run(run func(pattern worker.TaskPattern, cb worker.TaskHandler, opts ...worker.TaskOption)) *MockServer_HandleTask_Call
func (*MockServer_HandleTask_Call) RunAndReturn ¶ added in v0.26.0
func (_c *MockServer_HandleTask_Call) RunAndReturn(run func(pattern worker.TaskPattern, cb worker.TaskHandler, opts ...worker.TaskOption)) *MockServer_HandleTask_Call
type MockServer_Shutdown_Call ¶ added in v0.26.0
MockServer_Shutdown_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Shutdown'
func (*MockServer_Shutdown_Call) Return ¶ added in v0.26.0
func (_c *MockServer_Shutdown_Call) Return() *MockServer_Shutdown_Call
func (*MockServer_Shutdown_Call) Run ¶ added in v0.26.0
func (_c *MockServer_Shutdown_Call) Run(run func()) *MockServer_Shutdown_Call
func (*MockServer_Shutdown_Call) RunAndReturn ¶ added in v0.26.0
func (_c *MockServer_Shutdown_Call) RunAndReturn(run func()) *MockServer_Shutdown_Call
type MockServer_Start_Call ¶ added in v0.26.0
MockServer_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*MockServer_Start_Call) Return ¶ added in v0.26.0
func (_c *MockServer_Start_Call) Return(err error) *MockServer_Start_Call
func (*MockServer_Start_Call) Run ¶ added in v0.26.0
func (_c *MockServer_Start_Call) Run(run func()) *MockServer_Start_Call
func (*MockServer_Start_Call) RunAndReturn ¶ added in v0.26.0
func (_c *MockServer_Start_Call) RunAndReturn(run func() error) *MockServer_Start_Call