gen

Documentation

Index

• type BooleanArray
  • func NewBooleanArrayLen(sz int) *BooleanArray
  • func (a *BooleanArray) Encode(b []byte) ([]byte, error)
• type BooleanConstantValuesSequence
  • func NewBooleanConstantValuesSequence(n int, start time.Time, delta time.Duration, v bool) *BooleanConstantValuesSequence
  • func (g *BooleanConstantValuesSequence) Next() bool
  • func (g *BooleanConstantValuesSequence) Reset()
  • func (g *BooleanConstantValuesSequence) Values() Values
• type ConstantStringSequence
  • func (s ConstantStringSequence) Count() int
  • func (s ConstantStringSequence) Next() bool
  • func (s ConstantStringSequence) Value() string
• type CountableSequence
• type CounterByteSequence
  • 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 FloatArray
  • func NewFloatArrayLen(sz int) *FloatArray
  • func (a *FloatArray) Encode(b []byte) ([]byte, error)
• type FloatConstantValuesSequence
  • func NewFloatConstantValuesSequence(n int, start time.Time, delta time.Duration, v float64) *FloatConstantValuesSequence
  • func (g *FloatConstantValuesSequence) Next() bool
  • func (g *FloatConstantValuesSequence) Reset()
  • func (g *FloatConstantValuesSequence) Values() Values
• type FloatRandomValuesSequence
  • func NewFloatRandomValuesSequence(n int, start time.Time, delta time.Duration, scale float64) *FloatRandomValuesSequence
  • func (g *FloatRandomValuesSequence) Next() bool
  • func (g *FloatRandomValuesSequence) Reset()
  • func (g *FloatRandomValuesSequence) Values() Values
• type IntegerArray
  • func NewIntegerArrayLen(sz int) *IntegerArray
  • func (a *IntegerArray) Encode(b []byte) ([]byte, error)
• type IntegerConstantValuesSequence
  • func NewIntegerConstantValuesSequence(n int, start time.Time, delta time.Duration, v int64) *IntegerConstantValuesSequence
  • func (g *IntegerConstantValuesSequence) Next() bool
  • func (g *IntegerConstantValuesSequence) Reset()
  • func (g *IntegerConstantValuesSequence) Values() Values
• type Sequence
• type SeriesGenerator
• type StringArray
  • func NewStringArrayLen(sz int) *StringArray
  • func (a *StringArray) Encode(b []byte) ([]byte, error)
• type StringConstantValuesSequence
  • func NewStringConstantValuesSequence(n int, start time.Time, delta time.Duration, v string) *StringConstantValuesSequence
  • func (g *StringConstantValuesSequence) Next() bool
  • func (g *StringConstantValuesSequence) Reset()
  • func (g *StringConstantValuesSequence) Values() Values
• type TagsSequence
• type TagsValuesSequence
  • func NewTagsValuesSequenceKeysValues(keys []string, vals []CountableSequence) *TagsValuesSequence
  • func NewTagsValuesSequenceValues(prefix string, vals []CountableSequence) *TagsValuesSequence
  • func (s *TagsValuesSequence) Count() int
  • func (s *TagsValuesSequence) Next() bool
  • func (s *TagsValuesSequence) Value() models.Tags
• type UnsignedArray
  • func NewUnsignedArrayLen(sz int) *UnsignedArray
  • func (a *UnsignedArray) Encode(b []byte) ([]byte, error)
• type UnsignedConstantValuesSequence
  • func NewUnsignedConstantValuesSequence(n int, start time.Time, delta time.Duration, v uint64) *UnsignedConstantValuesSequence
  • func (g *UnsignedConstantValuesSequence) Next() bool
  • func (g *UnsignedConstantValuesSequence) Reset()
  • func (g *UnsignedConstantValuesSequence) Values() Values
• type Values
• type ValuesSequence

Types

type BooleanArray

type BooleanArray struct {
	cursors.BooleanArray
}

func NewBooleanArrayLen

func NewBooleanArrayLen(sz int) *BooleanArray

func (*BooleanArray) Encode

func (a *BooleanArray) Encode(b []byte) ([]byte, error)

type BooleanConstantValuesSequence

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

func NewBooleanConstantValuesSequence

func NewBooleanConstantValuesSequence(n int, start time.Time, delta time.Duration, v bool) *BooleanConstantValuesSequence

func (*BooleanConstantValuesSequence) Next

func (g *BooleanConstantValuesSequence) Next() bool

func (*BooleanConstantValuesSequence) Reset

func (g *BooleanConstantValuesSequence) Reset()

func (*BooleanConstantValuesSequence) Values

func (g *BooleanConstantValuesSequence) Values() Values

type ConstantStringSequence

type ConstantStringSequence string

func (ConstantStringSequence) Count

func (s ConstantStringSequence) Count() int

func (ConstantStringSequence) Next

func (s ConstantStringSequence) Next() bool

func (ConstantStringSequence) Value

func (s ConstantStringSequence) Value() string

type CountableSequence

type CountableSequence interface {
	Sequence
	Count() int
}

type CounterByteSequence

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

func NewCounterByteSequence

func NewCounterByteSequence(format string, start, end int) *CounterByteSequence

func NewCounterByteSequenceCount

func NewCounterByteSequenceCount(n int) *CounterByteSequence

func (*CounterByteSequence) Count

func (s *CounterByteSequence) Count() int

func (*CounterByteSequence) Next

func (s *CounterByteSequence) Next() bool

func (*CounterByteSequence) Value

func (s *CounterByteSequence) Value() string

type FloatArray

type FloatArray struct {
	cursors.FloatArray
}

func NewFloatArrayLen

func NewFloatArrayLen(sz int) *FloatArray

func (*FloatArray) Encode

func (a *FloatArray) Encode(b []byte) ([]byte, error)

type FloatConstantValuesSequence

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

func NewFloatConstantValuesSequence

func NewFloatConstantValuesSequence(n int, start time.Time, delta time.Duration, v float64) *FloatConstantValuesSequence

func (*FloatConstantValuesSequence) Next

func (g *FloatConstantValuesSequence) Next() bool

func (*FloatConstantValuesSequence) Reset

func (g *FloatConstantValuesSequence) Reset()

func (*FloatConstantValuesSequence) Values

func (g *FloatConstantValuesSequence) Values() Values

type FloatRandomValuesSequence

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

func NewFloatRandomValuesSequence

func NewFloatRandomValuesSequence(n int, start time.Time, delta time.Duration, scale float64) *FloatRandomValuesSequence

func (*FloatRandomValuesSequence) Next

func (g *FloatRandomValuesSequence) Next() bool

func (*FloatRandomValuesSequence) Reset

func (g *FloatRandomValuesSequence) Reset()

func (*FloatRandomValuesSequence) Values

func (g *FloatRandomValuesSequence) Values() Values

type IntegerArray

type IntegerArray struct {
	cursors.IntegerArray
}

func NewIntegerArrayLen

func NewIntegerArrayLen(sz int) *IntegerArray

func (*IntegerArray) Encode

func (a *IntegerArray) Encode(b []byte) ([]byte, error)

type IntegerConstantValuesSequence

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

func NewIntegerConstantValuesSequence

func NewIntegerConstantValuesSequence(n int, start time.Time, delta time.Duration, v int64) *IntegerConstantValuesSequence

func (*IntegerConstantValuesSequence) Next

func (g *IntegerConstantValuesSequence) Next() bool

func (*IntegerConstantValuesSequence) Reset

func (g *IntegerConstantValuesSequence) Reset()

func (*IntegerConstantValuesSequence) Values

func (g *IntegerConstantValuesSequence) Values() Values

type Sequence

type Sequence interface {
	Next() bool
	Value() string
}

type SeriesGenerator

type SeriesGenerator interface {
	// Next advances the series generator to the next series key.
	Next() bool

	// Name returns the name of the measurement.
	// The returned value may be modified by a subsequent call to Next.
	Name() []byte

	// Tags returns the tag set.
	// The returned value may be modified by a subsequent call to Next.
	Tags() models.Tags

	// Field returns the name of the field.
	// The returned value may be modified by a subsequent call to Next.
	Field() []byte

	// ValuesGenerator returns a values sequence for the current series.
	ValuesGenerator() ValuesSequence
}

type StringArray

type StringArray struct {
	cursors.StringArray
}

func NewStringArrayLen

func NewStringArrayLen(sz int) *StringArray

func (*StringArray) Encode

func (a *StringArray) Encode(b []byte) ([]byte, error)

type StringConstantValuesSequence

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

func NewStringConstantValuesSequence

func NewStringConstantValuesSequence(n int, start time.Time, delta time.Duration, v string) *StringConstantValuesSequence

func (*StringConstantValuesSequence) Next

func (g *StringConstantValuesSequence) Next() bool

func (*StringConstantValuesSequence) Reset

func (g *StringConstantValuesSequence) Reset()

func (*StringConstantValuesSequence) Values

func (g *StringConstantValuesSequence) Values() Values

type TagsSequence

type TagsSequence interface {
	Next() bool
	Value() models.Tags
	Count() int
}

type TagsValuesSequence

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

func NewTagsValuesSequenceKeysValues

func NewTagsValuesSequenceKeysValues(keys []string, vals []CountableSequence) *TagsValuesSequence

func NewTagsValuesSequenceValues

func NewTagsValuesSequenceValues(prefix string, vals []CountableSequence) *TagsValuesSequence

func (*TagsValuesSequence) Count

func (s *TagsValuesSequence) Count() int

func (*TagsValuesSequence) Next

func (s *TagsValuesSequence) Next() bool

func (*TagsValuesSequence) Value

func (s *TagsValuesSequence) Value() models.Tags

type UnsignedArray

type UnsignedArray struct {
	cursors.UnsignedArray
}

func NewUnsignedArrayLen

func NewUnsignedArrayLen(sz int) *UnsignedArray

func (*UnsignedArray) Encode

func (a *UnsignedArray) Encode(b []byte) ([]byte, error)

type UnsignedConstantValuesSequence

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

func NewUnsignedConstantValuesSequence

func NewUnsignedConstantValuesSequence(n int, start time.Time, delta time.Duration, v uint64) *UnsignedConstantValuesSequence

func (*UnsignedConstantValuesSequence) Next

func (g *UnsignedConstantValuesSequence) Next() bool

func (*UnsignedConstantValuesSequence) Reset

func (g *UnsignedConstantValuesSequence) Reset()

func (*UnsignedConstantValuesSequence) Values

func (g *UnsignedConstantValuesSequence) Values() Values

type Values

type Values interface {
	MinTime() int64
	MaxTime() int64
	Encode([]byte) ([]byte, error)
}

type ValuesSequence

type ValuesSequence interface {
	Reset()
	Next() bool
	Values() Values
}