func (o StoreMock) LoadByTimestamp(ctx context.Context, timestamp int64, opts ...QueryOption) (record []Record, err error) {
	args := o.Called(ctx, timestamp, opts)
	return args.Get(0).([]Record), args.Error(1)
}
LoadByTimestamp is a mock
package eventsource
import (
	"context"
	"github.com/stretchr/testify/mock"
)
type SerializerMock struct {
	*mock.Mock
}
func CreateSerializerMock() *SerializerMock {
	return &SerializerMock{
		Mock: &mock.Mock{},
	}
}
type StoreMock struct {
	*mock.Mock
}
func CreateStoreMock() *StoreMock {
	return &StoreMock{
		Mock: &mock.Mock{},
	}
}
type AggregatorMock struct {
	Mock *mock.Mock
}
func CreateAggregatorMock() *AggregatorMock {
	return &AggregatorMock{
		Mock: &mock.Mock{},
	}
}
func (o SerializerMock) Unmarshal(data []byte, eventType string) (event Event, err error) {
	args := o.Called(data, eventType)
	return args.Get(0).(Event), args.Error(1)
}
func (o SerializerMock) Marshal(event Event) (data []byte, err error) {
	args := o.Called(event)
	return args.Get(0).([]byte), args.Error(1)
}
type StoreTransactionMock struct {
	*mock.Mock
}
func CreateStoreTransactionMock() *StoreTransactionMock {
	return &StoreTransactionMock{
		Mock: &mock.Mock{},
	}
}
func (o StoreTransactionMock) Commit() error {
	args := o.Called()
	return args.Error(0)
}
func (o StoreTransactionMock) Rollback() error {
	args := o.Called()
	return args.Error(0)
}
func (o StoreTransactionMock) GetRecords() []Record {
	args := o.Called()
	return args.Get(0).([]Record)
}
func (o StoreMock) NewTransaction(ctx context.Context, records ...Record) (StoreTransaction, error) {
	args := o.Called(ctx, records)
	return args.Get(0).(StoreTransaction), args.Error(1)
}
func (o StoreMock) LoadByAggregate(ctx context.Context, aggregateID string, opts ...QueryOption) (record []Record, err error) {
	args := o.Called(ctx, aggregateID, opts)
	return args.Get(0).([]Record), args.Error(1)
}
func (o StoreMock) Load(ctx context.Context, opts ...QueryOption) (record []Record, err error) {
	args := o.Called(ctx, opts)
	return args.Get(0).([]Record), args.Error(1)
}
func (o StoreMock) LoadBySequenceID(ctx context.Context, sequenceID string, opts ...QueryOption) (record []Record, err error) {
	args := o.Called(ctx, sequenceID, opts)
	return args.Get(0).([]Record), args.Error(1)
}
func (o StoreMock) LoadBySequenceIDAndType(ctx context.Context, sequenceID string, eventType string, opts ...QueryOption) (record []Record, err error) {
	args := o.Called(ctx, sequenceID, eventType, opts)
	return args.Get(0).([]Record), args.Error(1)
}