Versions in this module Expand all Collapse all v1 v1.0.0 Aug 2, 2020 Changes in this version + const DatasetSizeMarker + const DefaultDateTimeEnd + const DefaultDateTimeStart + const UseCaseDashboard + const UseCaseDevOps + const UseCaseIot + var DatasetSizeMarkerRE = regexp.MustCompile(DatasetSizeMarker + `(\d+),(\d+)`) + var DefaultValueGenerator = map[string]interface + var UseCaseChoices = []string + func CheckTotalValues(line string) (totalPoints, totalValues int64, err error) + func LoadURL(url string) (tree *toml.Tree, err error) + func NewSerializerInflux() *serializerInflux + func RandChoice(choices [][]byte) []byte + func Seed(seed int64) + type ClampedRandomWalkDistribution struct + Max float64 + Min float64 + State float64 + Step Distribution + func CWD(step Distribution, min, max, state float64) *ClampedRandomWalkDistribution + func (d *ClampedRandomWalkDistribution) Advance() + func (d *ClampedRandomWalkDistribution) Get() float64 + type ConstantDistribution struct + State float64 + func (d *ConstantDistribution) Advance() + func (d *ConstantDistribution) Get() float64 + type Distribution interface + Advance func() + Get func() float64 + type ExternalConfig struct + var Config *ExternalConfig + func NewConfig(path string) (*ExternalConfig, error) + func (c *ExternalConfig) GetFieldBytesValue(measurementName, tagKey []byte, failIfNotFound bool, defaultValue interface{}) interface{} + func (c *ExternalConfig) GetFieldValue(measurementName, fieldKey string, failIfNotFound bool, ...) interface{} + func (c *ExternalConfig) GetTagBytesValue(measurementName, tagKey []byte, failIfNotFound bool, defaultValue []byte) []byte + func (c *ExternalConfig) GetTagValue(measurementName, tagKey string, failIfNotFound bool, defaultValue string) string + func (c *ExternalConfig) String() string + type Field struct + Count int + Name string + Source Source + type Measurement struct + Fields []Field + Name string + Sample float32 + Tags []Tag + type MonotonicRandomWalkDistribution struct + State float64 + Step Distribution + func MWD(step Distribution, state float64) *MonotonicRandomWalkDistribution + func (d *MonotonicRandomWalkDistribution) Advance() + func (d *MonotonicRandomWalkDistribution) Get() float64 + type MonotonicUpDownRandomWalkDistribution struct + Max float64 + Min float64 + State float64 + Step Distribution + func MUDWD(step Distribution, min float64, max float64, state float64) *MonotonicUpDownRandomWalkDistribution + func (d *MonotonicUpDownRandomWalkDistribution) Advance() + func (d *MonotonicUpDownRandomWalkDistribution) Get() float64 + type NormalDistribution struct + Mean float64 + StdDev float64 + func ND(mean, stddev float64) *NormalDistribution + func (d *NormalDistribution) Advance() + func (d *NormalDistribution) Get() float64 + type Point struct + FieldKeys [][]byte + FieldValues []interface{} + MeasurementName []byte + TagKeys [][]byte + TagValues [][]byte + Timestamp *time.Time + func MakeUsablePoint() *Point + func (p *Point) AppendField(key []byte, value interface{}) + func (p *Point) AppendTag(key, value []byte) + func (p *Point) Reset() + func (p *Point) SetMeasurementName(s []byte) + func (p *Point) SetTimestamp(t *time.Time) + type RandomWalkDistribution struct + State float64 + Step Distribution + func WD(step Distribution, state float64) *RandomWalkDistribution + func (d *RandomWalkDistribution) Advance() + func (d *RandomWalkDistribution) Get() float64 + type Serializer interface + SerializePoint func(w io.Writer, p *Point) error + SerializeSize func(w io.Writer, points int64, values int64) error + type SerializerCassandra struct + func NewSerializerCassandra() *SerializerCassandra + func (m *SerializerCassandra) SerializePoint(w io.Writer, p *Point) (err error) + func (s *SerializerCassandra) SerializeSize(w io.Writer, points int64, values int64) error + type SerializerElastic struct + func NewSerializerElastic(version string) *SerializerElastic + func (s *SerializerElastic) SerializePoint(w io.Writer, p *Point) error + func (s *SerializerElastic) SerializeSize(w io.Writer, points int64, values int64) error + type SerializerGraphiteLine struct + func NewSerializerGraphiteLine() *SerializerGraphiteLine + func (s *SerializerGraphiteLine) SerializePoint(w io.Writer, p *Point) (err error) + func (s *SerializerGraphiteLine) SerializeSize(w io.Writer, points int64, values int64) error + type SerializerMongo struct + func NewSerializerMongo() *SerializerMongo + func (s *SerializerMongo) SerializePoint(w io.Writer, p *Point) (err error) + func (s *SerializerMongo) SerializeSize(w io.Writer, points int64, values int64) error + type SerializerOpenTSDB struct + func NewSerializerOpenTSDB() *SerializerOpenTSDB + func (m *SerializerOpenTSDB) SerializePoint(w io.Writer, p *Point) (err error) + func (s *SerializerOpenTSDB) SerializeSize(w io.Writer, points int64, values int64) error + type SerializerSplunkJson struct + func NewSerializerSplunkJson() *SerializerSplunkJson + func (s *SerializerSplunkJson) SerializePoint(w io.Writer, p *Point) (err error) + func (s *SerializerSplunkJson) SerializeSize(w io.Writer, points int64, values int64) error + type SerializerTimescaleBin struct + func NewSerializerTimescaleBin() *SerializerTimescaleBin + func (s *SerializerTimescaleBin) SerializeSize(w io.Writer, points int64, values int64) error + func (t *SerializerTimescaleBin) SerializePoint(w io.Writer, p *Point) (err error) + type SerializerTimescaleSql struct + func NewSerializerTimescaleSql() *SerializerTimescaleSql + func (s *SerializerTimescaleSql) SerializePoint(w io.Writer, p *Point) (err error) + func (s *SerializerTimescaleSql) SerializeSize(w io.Writer, points int64, values int64) error + type SimulatedMeasurement interface + Tick func(time.Duration) + ToPoint func(*Point) bool + type Simulator interface + Finished func() bool + Next func(*Point) + SeenPoints func() int64 + SeenValues func() int64 + Total func() int64 + type Source interface + type Tag struct + Name string + Source Source + type TwoStateDistribution struct + High float64 + Low float64 + State float64 + func TSD(low float64, high float64, state float64) *TwoStateDistribution + func (d *TwoStateDistribution) Advance() + func (d *TwoStateDistribution) Get() float64 + type UniformDistribution struct + High float64 + Low float64 + func UD(low, high float64) *UniformDistribution + func (d *UniformDistribution) Advance() + func (d *UniformDistribution) Get() float64