shards

Documentation

Index

• func Format(shard uint64) string
• func Parse(str string) uint64
• type DB
  • func New(base string) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) Get() *pebble.DB
  • func (db *DB) Iter(re encoding.Resolution, start, end time.Time, filters []models.Field, ...) error
  • func (db *DB) Shard(shard uint64) *Shard
• type Shard
  • func NewShard(base string, shard uint64) *Shard
• type Views
  • func (v *Views) Init()
  • func (v *Views) Reset()

Functions

func Format

func Format(shard uint64) string

func Parse

func Parse(str string) uint64

Types

type DB

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

func New

func New(base string) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) Get

func (db *DB) Get() *pebble.DB

func (*DB) Iter

func (db *DB) Iter(re encoding.Resolution,
	start, end time.Time,
	filters []models.Field,
	f func(cu *cursor.Cursor, shard uint64, from, to int64, match *ro2.Bitmap, exists map[models.Field]*ro2.Bitmap) error) error

func (*DB) Shard

func (db *DB) Shard(shard uint64) *Shard

type Shard

type Shard struct {
	ID uint64
	DB *pebble.DB
}

func NewShard

func NewShard(base string, shard uint64) *Shard

type Views

type Views [encoding.Month + 1]*ro2.Bitmap

func (*Views) Init

func (v *Views) Init()

func (*Views) Reset

func (v *Views) Reset()