models

Mar 6, 2018

Changes in this version

+ func EnableUintSupport()

+ func EscapeMeasurement(in []byte) []byte

type FieldIterator

+ UnsignedValue func() (uint64, error)

type FieldType

+ const Unsigned

type Tags

+ func ParseKeyBytes(buf []byte) ([]byte, Tags)

+ func (a Tags) Keys() []string

+ func (a Tags) Values() []string

Aug 4, 2017

Changes in this version

+ func CompareTags(a, b Tags) int

+ func ParseName(buf []byte) ([]byte, error)

+ type FieldIterator interface

+ BooleanValue func() (bool, error)

+ FieldKey func() []byte

+ FloatValue func() (float64, error)

+ IntegerValue func() (int64, error)

+ Next func() bool

+ Reset func()

+ StringValue func() string

+ Type func() FieldType

+ type FieldType int

+ const Boolean

+ const Empty

+ const Float

+ const Integer

+ const String

+ type InlineFNV64a uint64

+ func NewInlineFNV64a() InlineFNV64a

+ func (s *InlineFNV64a) Sum64() uint64

+ func (s *InlineFNV64a) Write(data []byte) (int, error)

type Point

+ AppendString func(buf []byte) []byte

+ FieldIterator func() FieldIterator

+ HasTag func(tag []byte) bool

+ Round func(d time.Duration)

+ Split func(size int) []Point

+ StringSize func() int

type Row

+ Partial bool

type Statistic

+ func NewStatistic(name string) Statistic

+ type StatisticTags map[string]string

+ func (t StatisticTags) Merge(tags map[string]string) map[string]string

+ type Tag struct

+ Key []byte

+ Value []byte

+ func NewTag(key, value []byte) Tag

+ func (t *Tag) String() string

+ func (t Tag) Clone() Tag

+ func (t Tag) Size() int

type Tags

+ func CopyTags(a Tags) Tags

+ func DeepCopyTags(a Tags) Tags

+ func NewTags(m map[string]string) Tags

+ func ParseTags(buf []byte) (Tags, error)

+ func (a *Tags) Delete(key []byte)

+ func (a *Tags) Set(key, value []byte)

+ func (a *Tags) SetString(key, value string)

+ func (a Tags) Clone() Tags

+ func (a Tags) Equal(other Tags) bool

+ func (a Tags) Get(key []byte) []byte

+ func (a Tags) GetString(key string) string

+ func (a Tags) Len() int

+ func (a Tags) Less(i, j int) bool

+ func (a Tags) Map() map[string]string

+ func (a Tags) Size() int

+ func (a Tags) String() string

+ func (a Tags) Swap(i, j int)

Sep 26, 2016

Changes in this version

+ var ErrInvalidPoint = errors.New("point is invalid")

+ func EscapeStringField(in string) string

+ type Statistic struct

+ Name string

+ Tags Tags

+ Values map[string]interface{}

type Tags

+ func (t Tags) Merge(other map[string]string) Tags

Apr 7, 2016

Changes in this version

+ const MaxKeyLength

+ var ErrInvalidConsistencyLevel = errors.New("invalid consistency level")

+ var ErrMaxKeyLengthExceeded = errors.New("max key length exceeded")

+ type ConsistencyLevel int

+ const ConsistencyLevelAll

+ const ConsistencyLevelAny

+ const ConsistencyLevelOne

+ const ConsistencyLevelQuorum

+ func ParseConsistencyLevel(level string) (ConsistencyLevel, error)

Mar 22, 2016

Changes in this version

+ var ErrInvalidNumber = errors.New("invalid number")

Mar 9, 2016

Changes in this version

+ var ErrPointMustHaveAField = errors.New("point without fields is unsupported")

+ var ErrTimeOutOfRange = fmt.Errorf("time outside range %s - %s", MinNanoTime, MaxNanoTime)

+ var MaxNanoTime = time.Unix(0, math.MaxInt64).UTC()

+ var MinNanoTime = time.Unix(0, math.MinInt64).UTC()

+ func CheckTime(t time.Time) error

+ func GetPrecisionMultiplier(precision string) int64

+ func SafeCalcTime(timestamp int64, precision string) (time.Time, error)

Dec 8, 2015

Changes in this version

type Point

+ func NewPointFromBytes(b []byte) (Point, error)

+ MarshalBinary func() ([]byte, error)

type Tags

+ func ParseKey(buf string) (string, Tags, error)

Nov 17, 2015

Changes in this version

+ func MakeKey(name []byte, tags Tags) []byte

+ type Fields map[string]interface

+ func (p Fields) MarshalBinary() []byte

+ type Point interface

+ AddField func(name string, value interface{})

+ AddTag func(key, value string)

+ Data func() []byte

+ Fields func() Fields

+ HashID func() uint64

+ Key func() []byte

+ Name func() string

+ PrecisionString func(precision string) string

+ RoundedString func(d time.Duration) string

+ SetData func(buf []byte)

+ SetName func(string)

+ SetTags func(tags Tags)

+ SetTime func(t time.Time)

+ String func() string

+ Tags func() Tags

+ Time func() time.Time

+ UnixNano func() int64

+ func MustNewPoint(name string, tags Tags, fields Fields, time time.Time) Point

+ func NewPoint(name string, tags Tags, fields Fields, time time.Time) (Point, error)

+ func ParsePoints(buf []byte) ([]Point, error)

+ func ParsePointsString(buf string) ([]Point, error)

+ func ParsePointsWithPrecision(buf []byte, defaultTime time.Time, precision string) ([]Point, error)

+ type Points []Point

+ func (a Points) Len() int

+ func (a Points) Less(i, j int) bool

+ func (a Points) Swap(i, j int)

+ type Row struct

+ Columns []string

+ Err error

+ Name string

+ Tags map[string]string

+ Values [][]interface{}

+ func (r *Row) SameSeries(o *Row) bool

+ type Rows []*Row

+ func (p Rows) Len() int

+ func (p Rows) Less(i, j int) bool

+ func (p Rows) Swap(i, j int)

+ type Tags map[string]string

+ func (t Tags) HashKey() []byte