mongodb

package
v0.0.0-...-407d02d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 28, 2019 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var MongoQueryPool sync.Pool = sync.Pool{
	New: func() interface{} {
		return &MongoQuery{
			HumanLabel:       []byte{},
			HumanDescription: []byte{},
			DatabaseName:     []byte{},
			CollectionName:   []byte{},
			BsonDoc:          []M{},

			MeasurementName: []byte{},
			FieldName:       []byte{},
			AggregationType: []byte{},
			TagSets:         [][]string{},
		}
	},
}

Functions

func NewMongoDevops 

func NewMongoDevops(interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

NewMongoDevops makes an MongoDevops object ready to generate Queries.

func NewMongoDevops8Hosts1Hr 

func NewMongoDevops8Hosts1Hr(_ bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewMongoDevopsSingleHost 

func NewMongoDevopsSingleHost(_ bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewMongoDevopsSingleHost12hr 

func NewMongoDevopsSingleHost12hr(_ bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

func NewMongoIot 

func NewMongoIot(interval bulkQuerygen.TimeInterval, duration time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

NewMongoIot makes an MongoIot object ready to generate Queries.

func NewMongoIotSingleHost 

func NewMongoIotSingleHost(_ bulkQuerygen.DatabaseConfig, queriesFullRange bulkQuerygen.TimeInterval, queryInterval time.Duration, scaleVar int) bulkQuerygen.QueryGenerator

Types

type M 

type M map[string]interface{}

type MongoDevops 

type MongoDevops struct {
	bulkQuerygen.CommonParams
}

MongoDevops produces Mongo-specific queries for the devops use case.

func (*MongoDevops) Dispatch 

func (d *MongoDevops) Dispatch(i int) bulkQuerygen.Query

Dispatch fulfills the QueryGenerator interface.

func (*MongoDevops) MaxCPUUsage12HoursByMinuteOneHost 

func (d *MongoDevops) MaxCPUUsage12HoursByMinuteOneHost(q bulkQuerygen.Query)

func (*MongoDevops) MaxCPUUsageHourByMinuteEightHosts 

func (d *MongoDevops) MaxCPUUsageHourByMinuteEightHosts(q bulkQuerygen.Query)

MaxCPUUsageHourByMinuteEightHosts populates a Query for getting the maximum CPU usage for four hosts over the course of an hour.

func (*MongoDevops) MaxCPUUsageHourByMinuteFourHosts 

func (d *MongoDevops) MaxCPUUsageHourByMinuteFourHosts(q bulkQuerygen.Query)

MaxCPUUsageHourByMinuteFourHosts populates a Query for getting the maximum CPU usage for four hosts over the course of an hour.

func (*MongoDevops) MaxCPUUsageHourByMinuteOneHost 

func (d *MongoDevops) MaxCPUUsageHourByMinuteOneHost(q bulkQuerygen.Query)

MaxCPUUsageHourByMinuteOneHost populates a Query for getting the maximum CPU usage for one host over the course of an hour.

func (*MongoDevops) MaxCPUUsageHourByMinuteSixteenHosts 

func (d *MongoDevops) MaxCPUUsageHourByMinuteSixteenHosts(q bulkQuerygen.Query)

MaxCPUUsageHourByMinuteSixteenHosts populates a Query for getting the maximum CPU usage for four hosts over the course of an hour.

func (*MongoDevops) MaxCPUUsageHourByMinuteThirtyTwoHosts 

func (d *MongoDevops) MaxCPUUsageHourByMinuteThirtyTwoHosts(q bulkQuerygen.Query)

func (*MongoDevops) MaxCPUUsageHourByMinuteTwoHosts 

func (d *MongoDevops) MaxCPUUsageHourByMinuteTwoHosts(q bulkQuerygen.Query)

MaxCPUUsageHourByMinuteTwoHosts populates a Query for getting the maximum CPU usage for two hosts over the course of an hour.

func (*MongoDevops) MeanCPUUsageDayByHourAllHostsGroupbyHost 

func (d *MongoDevops) MeanCPUUsageDayByHourAllHostsGroupbyHost(qi bulkQuerygen.Query)

type MongoDevops8Hosts1Hr 

type MongoDevops8Hosts1Hr struct {
	MongoDevops
}

MongoDevopsSingleHost produces Mongo-specific queries for the devops single-host case.

func (*MongoDevops8Hosts1Hr) Dispatch 

func (d *MongoDevops8Hosts1Hr) Dispatch(i int) bulkQuerygen.Query

type MongoDevopsSingleHost 

type MongoDevopsSingleHost struct {
	MongoDevops
}

MongoDevopsSingleHost produces Mongo-specific queries for the devops single-host case.

func (*MongoDevopsSingleHost) Dispatch 

func (d *MongoDevopsSingleHost) Dispatch(i int) bulkQuerygen.Query

type MongoDevopsSingleHost12hr 

type MongoDevopsSingleHost12hr struct {
	MongoDevops
}

MongoDevopsSingleHost produces Mongo-specific queries for the devops single-host case.

func (*MongoDevopsSingleHost12hr) Dispatch 

func (d *MongoDevopsSingleHost12hr) Dispatch(i int) bulkQuerygen.Query

type MongoIot 

type MongoIot struct {
	bulkQuerygen.CommonParams
}

MongoIot produces Mongo-specific queries for the devops use case.

func (*MongoIot) AverageTemperatureDayByHourOneHome 

func (d *MongoIot) AverageTemperatureDayByHourOneHome(q bulkQuerygen.Query)

AverageTemperatureDayByHourOneHome populates a Query for getting the average temperature for one home over the course of a half a day.

func (*MongoIot) Dispatch 

func (d *MongoIot) Dispatch(i int) bulkQuerygen.Query

Dispatch fulfills the QueryGenerator interface.

type MongoIotSingleHost 

type MongoIotSingleHost struct {
	MongoIot
}

MongoIotSingleHost produces Mongo-specific queries for the devops single-host case.

func (*MongoIotSingleHost) Dispatch 

func (d *MongoIotSingleHost) Dispatch(i int) bulkQuerygen.Query

type MongoQuery 

type MongoQuery struct {
	HumanLabel       []byte
	HumanDescription []byte
	DatabaseName     []byte
	CollectionName   []byte
	BsonDoc          []M

	// these are only for debugging. the data is encoded in BsonDoc.
	MeasurementName []byte // e.g. "cpu"
	FieldName       []byte // e.g. "usage_user"
	AggregationType []byte // e.g. "avg" or "sum"
	TimeStart       time.Time
	TimeEnd         time.Time
	GroupByDuration time.Duration
	TagSets         [][]string // semantically, each subgroup is OR'ed and they are all AND'ed together
}

MongoQuery encodes a Mongo request. This will be serialized for use by the query_benchmarker program.

func NewMongoQuery 

func NewMongoQuery() *MongoQuery

func (*MongoQuery) HumanDescriptionName 

func (q *MongoQuery) HumanDescriptionName() []byte

func (*MongoQuery) HumanLabelName 

func (q *MongoQuery) HumanLabelName() []byte

func (*MongoQuery) Release 

func (q *MongoQuery) Release()

func (*MongoQuery) String 

func (q *MongoQuery) String() string

String produces a debug-ready description of a Query.

type S 

type S []interface{}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.