models

Documentation

Index

• func MakeKey(name []byte, tags Tags) []byte
• type Fields
  • func (p Fields) MarshalBinary() []byte
• type Point
  • func NewPoint(name string, tags Tags, fields Fields, time time.Time) Point
  • 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
  • func (a Points) Len() int
  • func (a Points) Less(i, j int) bool
  • func (a Points) Swap(i, j int)
• type Row
  • func (r *Row) SameSeries(o *Row) bool
• type Rows
  • func (p Rows) Len() int
  • func (p Rows) Less(i, j int) bool
  • func (p Rows) Swap(i, j int)
• type Tags
  • func (t Tags) HashKey() []byte

Functions

func MakeKey

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

Types

type Fields

type Fields map[string]interface{}

func (Fields) MarshalBinary

func (p Fields) MarshalBinary() []byte

MarshalBinary encodes all the fields to their proper type and returns the binary represenation NOTE: uint64 is specifically not supported due to potential overflow when we decode again later to an int64

type Point

type Point interface {
	Name() string
	SetName(string)

	Tags() Tags
	AddTag(key, value string)
	SetTags(tags Tags)

	Fields() Fields
	AddField(name string, value interface{})

	Time() time.Time
	SetTime(t time.Time)
	UnixNano() int64

	HashID() uint64
	Key() []byte

	Data() []byte
	SetData(buf []byte)

	// String returns a string representation of the point object, if there is a
	// timestamp associated with the point then it will be specified with the default
	// precision of nanoseconds
	String() string

	// PrecisionString returns a string representation of the point object, if there
	// is a timestamp associated with the point then it will be specified in the
	// given unit
	PrecisionString(precision string) string
}

Point defines the values that will be written to the database

func NewPoint

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

NewPoint returns a new point with the given measurement name, tags, fields and timestamp

func ParsePoints

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

ParsePoints returns a slice of Points from a text representation of a point with each point separated by newlines.

func ParsePointsString

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

func ParsePointsWithPrecision

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

type Points

type Points []Point

Points represents a sortable list of points by timestamp.

func (Points) Len

func (a Points) Len() int

func (Points) Less

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

func (Points) Swap

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

type Row

type Row struct {
	Name    string            `json:"name,omitempty"`
	Tags    map[string]string `json:"tags,omitempty"`
	Columns []string          `json:"columns,omitempty"`
	Values  [][]interface{}   `json:"values,omitempty"`
	Err     error             `json:"err,omitempty"`
}

Row represents a single row returned from the execution of a statement.

func (*Row) SameSeries

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

SameSeries returns true if r contains values for the same series as o.

type Rows

type Rows []*Row

func (Rows) Len

func (p Rows) Len() int

func (Rows) Less

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

func (Rows) Swap

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

type Tags

type Tags map[string]string

func (Tags) HashKey

func (t Tags) HashKey() []byte