func (mr *MockOffsetStoreMockRecorder) read(mq, t interface{}) *gomock.Call {
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "read", reflect.TypeOf((*MockOffsetStore)(nil).read), mq, t)
}
read indicates an expected call of read
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
}
func (m *MockOffsetStore) persist(mqs []*primitive.MessageQueue) {
	m.ctrl.Call(m, "persist", mqs)
}
func (mr *MockOffsetStoreMockRecorder) persist(mqs interface{}) *gomock.Call {
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "persist", reflect.TypeOf((*MockOffsetStore)(nil).persist), mqs)
}
func (m *MockOffsetStore) remove(mq *primitive.MessageQueue) {
	m.ctrl.Call(m, "remove", mq)
}
func (mr *MockOffsetStoreMockRecorder) remove(mq interface{}) *gomock.Call {
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "remove", reflect.TypeOf((*MockOffsetStore)(nil).remove), mq)
}
func (m *MockOffsetStore) read(mq *primitive.MessageQueue, t readType) int64 {
	ret := m.ctrl.Call(m, "read", mq, t)
	ret0, _ := ret[0].(int64)
	return ret0
}