func (m *MockStoreHost) PurgeMessages(ctx thrift.Context, purgeMessagesRequest *store.PurgeMessagesRequest) (*store.PurgeMessagesResult_, error) {
	args := m.Called(ctx, purgeMessagesRequest)
	return args.Get(0).(*store.PurgeMessagesResult_), args.Error(1)
}
PurgeMessages is a mock of the corresponding storehost routine
package storehost
import (
	serverStream "github.com/uber/cherami-server/stream"
	"github.com/uber/cherami-thrift/.generated/go/store"
	"github.com/stretchr/testify/mock"
	"github.com/uber/tchannel-go/thrift"
)
type MockStoreHost struct {
	mock.Mock
}
func (m *MockStoreHost) OpenAppendStream(ctx thrift.Context) (serverStream.BStoreOpenAppendStreamOutCall, error) {
	args := m.Called(ctx)
	return args.Get(0).(serverStream.BStoreOpenAppendStreamOutCall), args.Error(1)
}
func (m *MockStoreHost) GetAddressFromTimestamp(ctx thrift.Context, getAddressRequest *store.GetAddressFromTimestampRequest) (*store.GetAddressFromTimestampResult_, error) {
	args := m.Called(ctx, getAddressRequest)
	return args.Get(0).(*store.GetAddressFromTimestampResult_), args.Error(1)
}
func (m *MockStoreHost) GetExtentInfo(ctx thrift.Context, extentInfoRequest *store.GetExtentInfoRequest) (*store.ExtentInfo, error) {
	args := m.Called(ctx, extentInfoRequest)
	return args.Get(0).(*store.ExtentInfo), args.Error(1)
}
func (m *MockStoreHost) SealExtent(ctx thrift.Context, sealRequest *store.SealExtentRequest) error {
	args := m.Called(ctx, sealRequest)
	return args.Error(0)
}
func (m *MockStoreHost) OpenReadStream(ctx thrift.Context) (serverStream.BStoreOpenReadStreamOutCall, error) {
	args := m.Called(ctx)
	return args.Get(0).(serverStream.BStoreOpenReadStreamOutCall), args.Error(1)
}