profiles

type AdHocPerson struct {
	Name     int64
	UID      bson.ObjectId `bson:"_id,omitempty"`
	Group    int
	Payload  [40]int
	Payload1 [120]byte
	Payload2 [120]byte
	Payload3 [120]byte
	Payload4 [120]byte
	Payload5 [120]byte
	Payload6 [120]byte
}

type AggSmallDoc struct {
	Name          int64
	UID           bson.ObjectId `bson:"_id,omitempty"`
	RandUnindexed int
	Rem100        int
	RandIndexed   int
	Array         [10]int
}

type Event struct {
	ID        bson.ObjectId `bson:"_id,omitempty"`
	Tags      []string      // between 1 and 20 <tagValues> per document
	Stream    string
	Position  int
	Payload   string // 0 - 16kb, peak 500 bytes
	Timestamp time.Time
}

type Person struct {
	Name    int64
	UID     bson.ObjectId `bson:"_id,omitempty"`
	Group   int
	Payload string
}

type Profile interface {
	// Next()                      // return next call information  ??Need this??
	SendNext(c *mgo.Session, worker_id int) error // prepare and send the next call
	SetupTest(s *mgo.Session, _initdb bool) error
	CsvString(total_time float64) string
	CsvHeader() string
}

type ProfileFinalFunc interface {
	Final(c *mgo.Session) // will be run before program exit, used for correctness check
}

type ProfilePointer *Profile

type ProfileStats struct {
	// contains filtered or unexported fields
}

type QA408Config struct {
	Profile struct {
		Staging          int // number of record to be insert at the beginning of the run
		QueryLimit       int
		FindByStreamName float64
		FindByTag        float64
		FindByDateRange  float64
		UpdateTag        float64
		UpdatePayload    float64
		AddDoc           float64
		FindByPayload    float64
		BatchSize        int
	}
}

type QA408Distribution struct {
	// contains filtered or unexported fields
}

type QA492Config struct {
	Profile struct {
		Staging          int // number of record to be insert at the beginning of the run
		QueryLimit       int
		BatchSize        int
		UIDRange         int
		DateRange        int
		FindByStreamName float64
		FindByTag        float64
		FindByDateRange  float64
		UpdateTag        float64
		UpdatePayload    float64
		AddDoc           float64
		FindByPayload    float64

		// qa492 new
		FindByStreamAndUser    float64
		FindByTagAndUser       float64
		FindByDateEangeAndUser float64

		FindByStreamAndUserHint    bool
		FindByTagAndUserHint       bool
		FindByDateEangeAndUserHint bool

		NumOfStreams int64
		NumOfTags    int64

		Distribution      string
		NormalStdDevRatio float64
	}
}

type QA492Distribution struct {
	// contains filtered or unexported fields
}

type QA492_Event struct {
	ID        bson.ObjectId `bson:"_id,omitempty"`
	User      int64         `bson:"user"` // user name, could be duplicate
	Tags      []string      `bson:"tags"` // between 1 and 20 <tagValues> per document
	Stream    string        `bson:"stream"`
	Position  int           `bson:"position"`
	Payload   string        `bson:"payload"` // 0 - 16kb, peak 500 bytes
	Timestamp time.Time     `bson:"timestamp"`
}

type RandomDataMaker struct {
	// contains filtered or unexported fields
}

type SmallDoc struct {
	Name    int64
	UID     bson.ObjectId `bson:"_id,omitempty"`
	Group   int
	Payload [25]int
}