go-tsz: github.com/dgryski/go-tsz Index | Files | Directories

package tsz

import "github.com/dgryski/go-tsz"

Package tsz implement time-series compression

http://www.vldb.org/pvldb/vol8/p1816-teller.pdf

Index

Package Files

bstream.go tsz.go

type Iter Uses

type Iter struct {
    T0 uint32
    // contains filtered or unexported fields
}

Iter lets you iterate over a series. It is not concurrency-safe.

func NewIterator Uses

func NewIterator(b []byte) (*Iter, error)

NewIterator for the series

func (*Iter) Err Uses

func (it *Iter) Err() error

Err error at the current iterator position

func (*Iter) Next Uses

func (it *Iter) Next() bool

Next iteration of the series iterator

func (*Iter) Values Uses

func (it *Iter) Values() (uint32, float64)

Values at the current iterator position

type Series Uses

type Series struct {
    sync.Mutex

    // TODO(dgryski): timestamps in the paper are uint64
    T0  uint32
    // contains filtered or unexported fields
}

Series is the basic series primitive you can concurrently put values, finish the stream, and create iterators

func New Uses

func New(t0 uint32) *Series

New series

func (*Series) Bytes Uses

func (s *Series) Bytes() []byte

Bytes value of the series stream

func (*Series) Finish Uses

func (s *Series) Finish()

Finish the series by writing an end-of-stream record

func (*Series) Iter Uses

func (s *Series) Iter() *Iter

Iter lets you iterate over a series. It is not concurrency-safe.

func (*Series) MarshalBinary Uses

func (s *Series) MarshalBinary() ([]byte, error)

MarshalBinary implements the encoding.BinaryMarshaler interface

func (*Series) Push Uses

func (s *Series) Push(t uint32, v float64)

Push a timestamp and value to the series

func (*Series) UnmarshalBinary Uses

func (s *Series) UnmarshalBinary(b []byte) error

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface

Directories

PathSynopsis
eval

Package tsz imports 6 packages (graph) and is imported by 6 packages. Updated 2018-02-27. Refresh now. Tools for package owners.