Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + func CompareSeries(a, b seriesKeyField) int + func TagValuesLimitOption(n int) tagsValuesOption + func TagValuesSampleOption(n float64) tagsValuesOption + func WalkDown(v Visitor, node SchemaNode) + func WalkUp(v Visitor, node SchemaNode) + type BooleanValuesSequence interface + Reset func() + Write func(v []bool) + func NewBooleanArrayValuesSequence(v []bool) BooleanValuesSequence + func NewBooleanConstantValuesSequence(v bool) BooleanValuesSequence + type CountableSequence interface + Count func() int + type CounterByteSequence struct + func NewCounterByteSequence(format string, start, end int) *CounterByteSequence + func NewCounterByteSequenceCount(n int) *CounterByteSequence + func (s *CounterByteSequence) Count() int + func (s *CounterByteSequence) Next() bool + func (s *CounterByteSequence) Value() string + type Field struct + Count int64 + Name string + Source FieldSource + TimeInterval *duration + TimePrecision *precision + func (t *Field) TimeSequenceSpec() TimeSequenceSpec + func (t *Field) UnmarshalTOML(data interface{}) error + type FieldArraySource struct + Value interface{} + func (f *FieldArraySource) String() string + type FieldConstantValue struct + Value interface{} + func (f *FieldConstantValue) String() string + type FieldFloatRandomSource struct + Max float64 + Min float64 + Seed int64 + func (f *FieldFloatRandomSource) String() string + type FieldIntegerZipfSource struct + IMAX uint64 + S float64 + Seed int64 + V float64 + func (f *FieldIntegerZipfSource) String() string + type FieldSource interface + type FieldValuesSpec struct + DataType models.FieldType + Name string + Values NewTimeValuesSequenceFn + type Fields []Field + type FloatValuesSequence interface + Reset func() + Write func(v []float64) + func NewFloatArrayValuesSequence(v []float64) FloatValuesSequence + func NewFloatConstantValuesSequence(v float64) FloatValuesSequence + func NewFloatRandomValuesSequence(min, max float64, r *rand.Rand) FloatValuesSequence + type IntegerValuesSequence interface + Reset func() + Write func(v []int64) + func NewIntegerArrayValuesSequence(v []int64) IntegerValuesSequence + func NewIntegerConstantValuesSequence(v int64) IntegerValuesSequence + func NewIntegerZipfValuesSequence(s *FieldIntegerZipfSource) IntegerValuesSequence + type Measurement struct + Fields Fields + Name string + Sample *sample + SeriesLimit *SeriesLimit + Tags Tags + type MeasurementSpec struct + FieldValuesSpec *FieldValuesSpec + Name string + SeriesLimit *SeriesLimit + TagsSpec *TagsSpec + type Measurements []Measurement + type NewCountableSequenceFn func() CountableSequence + type NewTagsValuesSequenceFn func() TagsSequence + type NewTimeValuesSequenceFn func(spec TimeSequenceSpec) TimeValuesSequence + type Schema struct + Measurements Measurements + SeriesLimit *SeriesLimit + Title string + Version string + func NewSchemaFromPath(path string) (*Schema, error) + type SchemaNode interface + type Sequence interface + Next func() bool + Value func() string + type SeriesGenerator interface + Field func() []byte + Key func() []byte + Name func() []byte + Next func() bool + Tags func() models.Tags + TimeValuesGenerator func() TimeValuesSequence + func NewMergedSeriesGenerator(s []SeriesGenerator) SeriesGenerator + func NewMergedSeriesGeneratorLimit(s []SeriesGenerator, n int64) SeriesGenerator + func NewSeriesGenerator(name []byte, field []byte, vg TimeValuesSequence, tags TagsSequence) SeriesGenerator + func NewSeriesGeneratorFromSpec(s *Spec, tr TimeRange) SeriesGenerator + func NewSeriesGeneratorLimit(name []byte, field []byte, vg TimeValuesSequence, tags TagsSequence, n int64) SeriesGenerator + type SeriesLimit int64 + func (s *SeriesLimit) UnmarshalTOML(data interface{}) error + type Spec struct + Measurements []MeasurementSpec + SeriesLimit *int64 + func NewSpecFromPath(p string) (*Spec, error) + func NewSpecFromSchema(root *Schema) (*Spec, error) + func NewSpecFromToml(s string) (*Spec, error) + type StringArraySequence struct + func NewStringArraySequence(vals []string) *StringArraySequence + func (s *StringArraySequence) Count() int + func (s *StringArraySequence) Next() bool + func (s *StringArraySequence) Value() string + type StringConstantSequence struct + func NewStringConstantSequence(val string) *StringConstantSequence + func (s *StringConstantSequence) Count() int + func (s *StringConstantSequence) Next() bool + func (s *StringConstantSequence) Value() string + type StringValuesSequence interface + Reset func() + Write func(v []string) + func NewStringArrayValuesSequence(v []string) StringValuesSequence + func NewStringConstantValuesSequence(v string) StringValuesSequence + type Tag struct + Name string + Source TagSource + func (t *Tag) UnmarshalTOML(data interface{}) error + type TagArraySource struct + Values []string + func (s *TagArraySource) String() string + type TagFileSource struct + Path string + func (s *TagFileSource) String() string + type TagSequenceSource struct + Count int64 + Format string + Start int64 + func (t *TagSequenceSource) String() string + type TagSource interface + type TagValuesSpec struct + TagKey string + Values NewCountableSequenceFn + type Tags []Tag + type TagsSequence interface + Count func() int + Next func() bool + Value func() models.Tags + func NewTagsValuesSequenceCounts(prefix string, counts []int) TagsSequence + func NewTagsValuesSequenceKeysValues(keys []string, vals []CountableSequence, opts ...tagsValuesOption) TagsSequence + func NewTagsValuesSequenceValues(prefix string, vals []CountableSequence) TagsSequence + type TagsSpec struct + Sample *sample + Tags []*TagValuesSpec + type TimeRange struct + End time.Time + Start time.Time + func (t TimeRange) Truncate(d time.Duration) TimeRange + type TimeSequenceSpec struct + Count int + Delta time.Duration + Precision time.Duration + Start time.Time + func (ts TimeSequenceSpec) ForTimeRange(tr TimeRange) TimeSequenceSpec + type TimeValuesSequence interface + Next func() bool + Reset func() + Values func() Values + func NewTimeBooleanValuesSequence(count int, ts TimestampSequence, vs BooleanValuesSequence) TimeValuesSequence + func NewTimeFloatValuesSequence(count int, ts TimestampSequence, vs FloatValuesSequence) TimeValuesSequence + func NewTimeIntegerValuesSequence(count int, ts TimestampSequence, vs IntegerValuesSequence) TimeValuesSequence + func NewTimeStringValuesSequence(count int, ts TimestampSequence, vs StringValuesSequence) TimeValuesSequence + func NewTimeUnsignedValuesSequence(count int, ts TimestampSequence, vs UnsignedValuesSequence) TimeValuesSequence + type TimestampSequence interface + Reset func() + Write func(ts []int64) + func NewTimestampSequenceFromSpec(spec TimeSequenceSpec) TimestampSequence + type UnsignedValuesSequence interface + Reset func() + Write func(v []uint64) + func NewUnsignedArrayValuesSequence(v []uint64) UnsignedValuesSequence + func NewUnsignedConstantValuesSequence(v uint64) UnsignedValuesSequence + type Values interface + Encode func([]byte) ([]byte, error) + MaxTime func() int64 + MinTime func() int64 + type Visitor interface + Visit func(node SchemaNode) (w Visitor) + type VisitorFn func(node SchemaNode) bool + func (fn VisitorFn) Visit(node SchemaNode) (w Visitor)