func (m *MockOffsetStore) persist(mqs []*primitive.MessageQueue) {
	m.ctrl.Call(m, "persist", mqs)
}
persist mocks base method
package consumer
import (
	reflect "reflect"
	primitive "github.com/apache/rocketmq-client-go/v2/primitive"
	gomock "github.com/golang/mock/gomock"
)
type MockOffsetStore struct {
	ctrl     *gomock.Controller
	recorder *MockOffsetStoreMockRecorder
}
type MockOffsetStoreMockRecorder struct {
	mock *MockOffsetStore
}
func NewMockOffsetStore(ctrl *gomock.Controller) *MockOffsetStore {
	mock := &MockOffsetStore{ctrl: ctrl}
	mock.recorder = &MockOffsetStoreMockRecorder{mock}
	return mock
}
func (m *MockOffsetStore) EXPECT() *MockOffsetStoreMockRecorder {
	return m.recorder
}