Versions in this module Expand all Collapse all v1 v1.0.1 Aug 28, 2026 v1.0.0 Aug 26, 2026 Changes in this version + type MockQueuedMessage struct + func NewMockQueuedMessage(ctrl *gomock.Controller) *MockQueuedMessage + func (m *MockQueuedMessage) Bytes() []byte + func (m *MockQueuedMessage) EXPECT() *MockQueuedMessageMockRecorder + type MockQueuedMessageMockRecorder struct + func (mr *MockQueuedMessageMockRecorder) Bytes() *gomock.Call + type MockTaskMessage struct + func NewMockTaskMessage(ctrl *gomock.Controller) *MockTaskMessage + func (m *MockTaskMessage) Bytes() []byte + func (m *MockTaskMessage) EXPECT() *MockTaskMessageMockRecorder + func (m *MockTaskMessage) Payload() []byte + type MockTaskMessageMockRecorder struct + func (mr *MockTaskMessageMockRecorder) Bytes() *gomock.Call + func (mr *MockTaskMessageMockRecorder) Payload() *gomock.Call + type MockWorker struct + func NewMockWorker(ctrl *gomock.Controller) *MockWorker + func (m *MockWorker) EXPECT() *MockWorkerMockRecorder + func (m *MockWorker) Queue(arg0 core.TaskMessage) error + func (m *MockWorker) Request() (core.TaskMessage, error) + func (m *MockWorker) Run(arg0 context.Context, arg1 core.TaskMessage) error + func (m *MockWorker) Shutdown() error + type MockWorkerMockRecorder struct + func (mr *MockWorkerMockRecorder) Queue(arg0 any) *gomock.Call + func (mr *MockWorkerMockRecorder) Request() *gomock.Call + func (mr *MockWorkerMockRecorder) Run(arg0, arg1 any) *gomock.Call + func (mr *MockWorkerMockRecorder) Shutdown() *gomock.Call
Go to main page