points

Documentation

Index

• Constants
• func Glue(exit chan bool, in chan *Points, chunkSize int, chunkTimeout time.Duration, ...)
• func ReadBinary(r io.Reader, callback func(*Points)) error
• func ReadFromFile(filename string, callback func(*Points)) error
• func ReadPlain(r io.Reader, callback func(*Points)) error
• type Point
• type Points
  • func New() *Points
  • func NowPoint(metric string, value float64) *Points
  • func OnePoint(metric string, value float64, timestamp int64) *Points
  • func ParsePickle(pkt []byte) ([]*Points, error)
  • func ParseText(line string) (*Points, error)
  • func (p *Points) Add(value float64, timestamp int64) *Points
  • func (p *Points) Append(onePoint Point) *Points
  • func (p *Points) Copy() *Points
  • func (p *Points) Eq(other *Points) bool
  • func (p *Points) WriteBinaryTo(w io.Writer) (n int, err error)
  • func (p *Points) WriteTo(w io.Writer) (n int64, err error)

Constants

const MB = 1048576

Functions

func Glue

func Glue(exit chan bool, in chan *Points, chunkSize int, chunkTimeout time.Duration, callback func([]byte))

func ReadBinary

func ReadBinary(r io.Reader, callback func(*Points)) error

func ReadFromFile

func ReadFromFile(filename string, callback func(*Points)) error

func ReadPlain

func ReadPlain(r io.Reader, callback func(*Points)) error

Types

type Point

type Point struct {
	Value     float64
	Timestamp int64
}

Point value/time pair

type Points

type Points struct {
	Metric string
	Data   []Point
}

Points from carbon clients

func New

func New() *Points

New creates new instance of Points

func NowPoint

func NowPoint(metric string, value float64) *Points

NowPoint create OnePoint with now timestamp

func OnePoint

func OnePoint(metric string, value float64, timestamp int64) *Points

OnePoint create Points instance with single point

func ParsePickle

func ParsePickle(pkt []byte) ([]*Points, error)

func ParseText

func ParseText(line string) (*Points, error)

ParseText parse text protocol Point

host.Point.value 42 1422641531\n

func (*Points) Add

func (p *Points) Add(value float64, timestamp int64) *Points

Add value/timestamp pair to points

func (*Points) Append

func (p *Points) Append(onePoint Point) *Points

Append point

func (*Points) Copy

func (p *Points) Copy() *Points

Copy returns copy of object

func (*Points) Eq

func (p *Points) Eq(other *Points) bool

Eq points check

func (*Points) WriteBinaryTo

func (p *Points) WriteBinaryTo(w io.Writer) (n int, err error)

func (*Points) WriteTo

func (p *Points) WriteTo(w io.Writer) (n int64, err error)