points

package

v0.14.0 Latest Latest Go to latest Published: May 17, 2019 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const MB = 1048576

This section is empty.

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

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 struct {
	Value     float64
	Timestamp int64
}

Point value/time pair

type Points struct {
	Metric string
	Data   []Point
}

Points from carbon clients

func New() *Points

New creates new instance of Points

func NowPoint(metric string, value float64) *Points

NowPoint create OnePoint with now timestamp

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

OnePoint create Points instance with single point

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

ParseText parse text protocol Point

host.Point.value 42 1422641531\n

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

Add value/timestamp pair to points

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

Append point

func (p *Points) Copy() *Points

Copy returns copy of object

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

Eq points check

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

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