// Code generated by MockGen. DO NOT EDIT. // Source: github.com/zitadel/zitadel/internal/notification/handlers (interfaces: Queue) // // Generated by this command: // // mockgen -package mock -destination ./mock/queue.mock.go github.com/zitadel/zitadel/internal/notification/handlers Queue // // Package mock is a generated GoMock package. package mock import ( context "context" reflect "reflect" river "github.com/riverqueue/river" queue "github.com/zitadel/zitadel/internal/queue" gomock "go.uber.org/mock/gomock" ) // MockQueue is a mock of Queue interface. type MockQueue struct { ctrl *gomock.Controller recorder *MockQueueMockRecorder isgomock struct{} } // MockQueueMockRecorder is the mock recorder for MockQueue. type MockQueueMockRecorder struct { mock *MockQueue } // NewMockQueue creates a new mock instance. func NewMockQueue(ctrl *gomock.Controller) *MockQueue { mock := &MockQueue{ctrl: ctrl} mock.recorder = &MockQueueMockRecorder{mock} return mock } // EXPECT returns an object that allows the caller to indicate expected use. func (m *MockQueue) EXPECT() *MockQueueMockRecorder { return m.recorder } // Insert mocks base method. func (m *MockQueue) Insert(ctx context.Context, args river.JobArgs, opts ...queue.InsertOpt) error { m.ctrl.T.Helper() varargs := []any{ctx, args} for _, a := range opts { varargs = append(varargs, a) } ret := m.ctrl.Call(m, "Insert", varargs...) ret0, _ := ret[0].(error) return ret0 } // Insert indicates an expected call of Insert. func (mr *MockQueueMockRecorder) Insert(ctx, args any, opts ...any) *gomock.Call { mr.mock.ctrl.T.Helper() varargs := append([]any{ctx, args}, opts...) return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Insert", reflect.TypeOf((*MockQueue)(nil).Insert), varargs...) }