Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + const FieldKeyTagKey + const MaxKeyLength + const MaxNanoTime + const MeasurementTagKey + const MinNanoTime + var ErrInvalidConsistencyLevel = errors.New("invalid consistency level") + var ErrInvalidNumber = errors.New("invalid number") + var ErrInvalidPoint = errors.New("point is invalid") + var ErrPointMustHaveAField = errors.New("point without fields is unsupported") + var ErrTimeOutOfRange = fmt.Errorf("time outside range %d - %d", MinNanoTime, MaxNanoTime) + var FieldKeyTagKeyBytes = []byte(FieldKeyTagKey) + var MeasurementTagKeyBytes = []byte(MeasurementTagKey) + func AppendMakeKey(dst []byte, name []byte, tags Tags) []byte + func CheckTime(t time.Time) error + func CompareTags(a, b Tags) int + func EnableUintSupport() + func EscapeMeasurement(in []byte) []byte + func EscapeStringField(in string) string + func GetPrecisionMultiplier(precision string) int64 + func MakeKey(name []byte, tags Tags) []byte + func ParseName(buf []byte) []byte + func SafeCalcTime(timestamp int64, precision string) (time.Time, error) + func ValidKeyToken(s string) bool + func ValidKeyTokens(name string, tags Tags) bool + type ConsistencyLevel int + const ConsistencyLevelAll + const ConsistencyLevelAny + const ConsistencyLevelOne + const ConsistencyLevelQuorum + func ParseConsistencyLevel(level string) (ConsistencyLevel, 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 + UnsignedValue func() (uint64, error) + type FieldType int + const Boolean + const Empty + const Float + const Integer + const String + const Unsigned + func (i FieldType) String() string + type Fields map[string]interface + func (p Fields) MarshalBinary() []byte + type InlineFNV64a uint64 + func NewInlineFNV64a() InlineFNV64a + func (s *InlineFNV64a) Sum64() uint64 + func (s *InlineFNV64a) Write(data []byte) (int, error) + type Point interface + AddTag func(key, value string) + AppendString func(buf []byte) []byte + FieldIterator func() FieldIterator + Fields func() (Fields, error) + ForEachTag func(fn func(k, v []byte) bool) + HasTag func(tag []byte) bool + HashID func() uint64 + Key func() []byte + MarshalBinary func() ([]byte, error) + Name func() []byte + PrecisionString func(precision string) string + Round func(d time.Duration) + RoundedString func(d time.Duration) string + SetName func(string) + SetTags func(tags Tags) + SetTime func(t time.Time) + Split func(size int) []Point + String func() string + StringSize func() int + 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, t time.Time) (Point, error) + func NewPointFromBytes(b []byte) (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 + Name string + Partial bool + 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 Statistic struct + Name string + Tags map[string]string + Values map[string]interface{} + 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 TagKeysSet struct + func (set *TagKeysSet) Clear() + func (set *TagKeysSet) IsSupersetBytes(other [][]byte) bool + func (set *TagKeysSet) IsSupersetKeys(other Tags) bool + func (set *TagKeysSet) Keys() []string + func (set *TagKeysSet) KeysBytes() [][]byte + func (set *TagKeysSet) String() string + func (set *TagKeysSet) UnionBytes(other [][]byte) + func (set *TagKeysSet) UnionKeys(other Tags) + type Tags []Tag + func CopyTags(a Tags) Tags + func DeepCopyTags(a Tags) Tags + func NewTags(m map[string]string) Tags + func ParseKey(buf []byte) (string, Tags) + func ParseKeyBytes(buf []byte) ([]byte, Tags) + func ParseKeyBytesWithTags(buf []byte, tags Tags) ([]byte, Tags) + func ParseTags(buf []byte) Tags + func (a *Tags) Delete(key []byte) + func (a *Tags) Set(key, value []byte) + func (a *Tags) SetString(key, value string) + func (a Tags) AppendHashKey(dst []byte) []byte + 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) HashKey() []byte + func (a Tags) Keys() []string + func (a Tags) Len() int + func (a Tags) Less(i, j int) bool + func (a Tags) Map() map[string]string + func (a Tags) Merge(other map[string]string) Tags + func (a Tags) Size() int + func (a Tags) String() string + func (a Tags) Swap(i, j int) + func (a Tags) Values() []string