timeseries

Documentation

Index

• type And
  • func (a And) Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap
• type Filter
• type Key
  • func (k *Key) Encode(co uint64, b []byte) []byte
• type No
  • func (f *No) Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap
• type Or
  • func (o Or) Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap
• type ScanCall
• type Timeseries
  • func New(db *shards.DB, lo *location.Location) *Timeseries
  • func (ts *Timeseries) Add(m *models.Model) error
  • func (ts *Timeseries) Close() error
  • func (ts *Timeseries) Find(ctx context.Context, field models.Field, id uint64) (value string)
  • func (ts *Timeseries) Get() *shards.DB
  • func (ts *Timeseries) Location() *location.Location
  • func (ts *Timeseries) Save() error
  • func (ts *Timeseries) Scan(domainId uint64, res encoding.Resolution, start, end time.Time, filter Filter, ...) error
  • func (ts *Timeseries) Search(field models.Field, prefix []byte, f func(key []byte, value uint64))
  • func (ts *Timeseries) SearchKeys(field models.Field, prefix []byte, f func(key []byte) error) error
  • func (ts *Timeseries) Select(ctx context.Context, values models.BitSet, domain string, start, end time.Time, ...) error
  • func (ts *Timeseries) Translate(field models.Field, value []byte) uint64
  • func (ts *Timeseries) Visitors(start, end time.Time, resolution encoding.Resolution, domain string) (visitors uint64)
• type Yes
  • func (f *Yes) Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap

Types

type And

type And struct {
	Left, Right Filter
}

func (And) Apply

func (a And) Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap

type Filter

type Filter interface {
	Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap
}

type Key

type Key struct {
	View       uint64
	Domain     uint64
	Resolution encoding.Resolution
	Field      models.Field
	Existence  bool
}

func (*Key) Encode

func (k *Key) Encode(co uint64, b []byte) []byte

type No

type No struct {
	Field  models.Field
	Values []uint64
}

func (*No) Apply

func (f *No) Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap

type Or

type Or struct {
	Left, Right Filter
}

func (Or) Apply

func (o Or) Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap

type ScanCall

type ScanCall func(cu *cursor.Cursor, field models.Field, view, shard uint64, columns *ro2.Bitmap) error

type Timeseries

type Timeseries struct {
	// contains filtered or unexported fields
}

func New

func New(db *shards.DB, lo *location.Location) *Timeseries

func (*Timeseries) Add

func (ts *Timeseries) Add(m *models.Model) error

Add process m and batches it. It must be called in the same goroutine as (*Timeseries)Save

When we reach a shard boundary, existing batch will be saved before adding m. m []byte fields must not be modified because we use reference during translation A safe usage is to release m imediately after calling this method and reset it by calling

*m = models.Model{}

func (*Timeseries) Close

func (ts *Timeseries) Close() error

Close releases resources and removes buffers used.

func (*Timeseries) Find

func (ts *Timeseries) Find(ctx context.Context, field models.Field, id uint64) (value string)

func (*Timeseries) Get

func (ts *Timeseries) Get() *shards.DB

func (*Timeseries) Location

func (ts *Timeseries) Location() *location.Location

func (*Timeseries) Save

func (ts *Timeseries) Save() error

Save persist all buffered events into pebble key value store. This method is not safe for cocunrrent use. It is intended to be called in the same goroutine that calls (*Timeseries)Add.

The goal is to ensure almost lock free ingestion path ( with exception of translation with uses RWMutex)

func (*Timeseries) Scan

func (ts *Timeseries) Scan(
	domainId uint64,
	res encoding.Resolution,
	start, end time.Time,
	filter Filter,
	valueSet models.BitSet,
	cb ScanCall,
) error

func (*Timeseries) Search

func (ts *Timeseries) Search(field models.Field, prefix []byte, f func(key []byte, value uint64))

func (*Timeseries) SearchKeys

func (ts *Timeseries) SearchKeys(field models.Field, prefix []byte, f func(key []byte) error) error

func (*Timeseries) Select

func (ts *Timeseries) Select(
	ctx context.Context,
	values models.BitSet,
	domain string, start,
	end time.Time,
	intrerval query.Interval,
	filters query.Filters,
	cb ScanCall) error

func (*Timeseries) Translate

func (ts *Timeseries) Translate(field models.Field, value []byte) uint64

func (*Timeseries) Visitors

func (ts *Timeseries) Visitors(start, end time.Time, resolution encoding.Resolution, domain string) (visitors uint64)

Realtime computes total visitors in the last 5 minutes.

type Yes

type Yes struct {
	Field  models.Field
	Values []uint64
}

func (*Yes) Apply

func (f *Yes) Apply(cu *cursor.Cursor, re encoding.Resolution, shard, view uint64) *ro2.Bitmap

Apply searches for columns matching conditions in f for ra bitmap. ra must be mutex encoded.