points

package
v0.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 10, 2015 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ThrottleChan added in v0.4.3

func ThrottleChan(in chan *Points, ratePerSec int) chan *Points

ThrottleChan creates new points channel with limited throughput

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 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)

ParsePickle ...

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL