statement

type ExecStatement struct {
	StatementID string
	Script      string
	// contains filtered or unexported fields
}

type Function struct {
	Type     string
	Fn       string
	Argument int
	Count    int
}

type GoStatement struct {
	Statement

	StatementID string
}

type InfluxqlStatement struct {
	StatementID string
	Query       string
	Tracer      *stressClient.Tracer
}

type InsertStatement struct {
	TestID      string
	StatementID string

	// Statement Name
	Name string

	// Template string for points. Filled by the output of stringers
	TemplateString string

	// TagCount is used to find the number of series in the dataset
	TagCount int

	// The Tracer prevents InsertStatement.Run() from returning early
	Tracer *stressClient.Tracer

	// Timestamp is #points to write and percision
	Timestamp *Timestamp

	// Templates turn into stringers
	Templates Templates

	// Concurrency utiliities
	sync.WaitGroup
	sync.Mutex
	// contains filtered or unexported fields
}

type QueryStatement struct {
	StatementID string
	Name        string

	// TemplateString is a query template that can be filled in by Args
	TemplateString string
	Args           []string

	// Number of queries to run
	Count int

	// Tracer for tracking returns
	Tracer *stressClient.Tracer
	// contains filtered or unexported fields
}

type ResponseTime struct {
	Value int
	Time  time.Time
}

type ResponseTimes []ResponseTime

type SetStatement struct {
	Var   string
	Value string

	StatementID string

	Tracer *stressClient.Tracer
}

type Statement interface {
	Run(s *stressClient.StressTest)
	Report(s *stressClient.StressTest) string
	SetID(s string)
}

type Stringer func() string

type Stringers []Stringer

type Template struct {
	Tags     []string
	Function *Function
}

type Templates []*Template

type Timestamp struct {
	Count    int
	Duration time.Duration
	Jitter   bool
}

type WaitStatement struct {
	StatementID string
	// contains filtered or unexported fields
}