Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockQueuedMessage ¶
type MockQueuedMessage struct {
// contains filtered or unexported fields
}
MockQueuedMessage is a mock of QueuedMessage interface.
func NewMockQueuedMessage ¶
func NewMockQueuedMessage(ctrl *gomock.Controller) *MockQueuedMessage
NewMockQueuedMessage creates a new mock instance.
func (*MockQueuedMessage) Bytes ¶
func (m *MockQueuedMessage) Bytes() []byte
Bytes mocks base method.
func (*MockQueuedMessage) EXPECT ¶
func (m *MockQueuedMessage) EXPECT() *MockQueuedMessageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockQueuedMessageMockRecorder ¶
type MockQueuedMessageMockRecorder struct {
// contains filtered or unexported fields
}
MockQueuedMessageMockRecorder is the mock recorder for MockQueuedMessage.
func (*MockQueuedMessageMockRecorder) Bytes ¶
func (mr *MockQueuedMessageMockRecorder) Bytes() *gomock.Call
Bytes indicates an expected call of Bytes.
type MockTaskMessage ¶ added in v0.3.0
type MockTaskMessage struct {
// contains filtered or unexported fields
}
MockTaskMessage is a mock of TaskMessage interface.
func NewMockTaskMessage ¶ added in v0.3.0
func NewMockTaskMessage(ctrl *gomock.Controller) *MockTaskMessage
NewMockTaskMessage creates a new mock instance.
func (*MockTaskMessage) Bytes ¶ added in v0.3.0
func (m *MockTaskMessage) Bytes() []byte
Bytes mocks base method.
func (*MockTaskMessage) EXPECT ¶ added in v0.3.0
func (m *MockTaskMessage) EXPECT() *MockTaskMessageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTaskMessage) Payload ¶ added in v0.3.0
func (m *MockTaskMessage) Payload() []byte
Payload mocks base method.
type MockTaskMessageMockRecorder ¶ added in v0.3.0
type MockTaskMessageMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskMessageMockRecorder is the mock recorder for MockTaskMessage.
func (*MockTaskMessageMockRecorder) Bytes ¶ added in v0.3.0
func (mr *MockTaskMessageMockRecorder) Bytes() *gomock.Call
Bytes indicates an expected call of Bytes.
func (*MockTaskMessageMockRecorder) Payload ¶ added in v0.3.0
func (mr *MockTaskMessageMockRecorder) Payload() *gomock.Call
Payload indicates an expected call of Payload.
type MockWorker ¶
type MockWorker struct {
// contains filtered or unexported fields
}
MockWorker is a mock of Worker interface.
func NewMockWorker ¶
func NewMockWorker(ctrl *gomock.Controller) *MockWorker
NewMockWorker creates a new mock instance.
func (*MockWorker) EXPECT ¶
func (m *MockWorker) EXPECT() *MockWorkerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockWorker) Queue ¶
func (m *MockWorker) Queue(arg0 core.TaskMessage) error
Queue mocks base method.
func (*MockWorker) Request ¶
func (m *MockWorker) Request() (core.TaskMessage, error)
Request mocks base method.
func (*MockWorker) Run ¶
func (m *MockWorker) Run(arg0 context.Context, arg1 core.TaskMessage) error
Run mocks base method.
type MockWorkerMockRecorder ¶
type MockWorkerMockRecorder struct {
// contains filtered or unexported fields
}
MockWorkerMockRecorder is the mock recorder for MockWorker.
func (*MockWorkerMockRecorder) Queue ¶
func (mr *MockWorkerMockRecorder) Queue(arg0 any) *gomock.Call
Queue indicates an expected call of Queue.
func (*MockWorkerMockRecorder) Request ¶
func (mr *MockWorkerMockRecorder) Request() *gomock.Call
Request indicates an expected call of Request.
func (*MockWorkerMockRecorder) Run ¶
func (mr *MockWorkerMockRecorder) Run(arg0, arg1 any) *gomock.Call
Run indicates an expected call of Run.
func (*MockWorkerMockRecorder) Shutdown ¶
func (mr *MockWorkerMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
Source Files