mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-09-06 16:45:55 +00:00
34fa1afad0
This commit refactors the pilosa codebase. It makes several major changes: * Removes bitmap handles * Removes dispatch/hold/transport * Removes etcd dependency * Adds consistent hash ring for slice placement * Refactors parser/lexer * Adds strong typing to PQL AST * Flattens package hierarchy
53 lines
1.1 KiB
Go
53 lines
1.1 KiB
Go
package pilosa
|
|
|
|
import (
|
|
"sync"
|
|
)
|
|
|
|
// Index represents a container for fragments.
|
|
type Index struct {
|
|
mu sync.Mutex
|
|
sliceN uint64
|
|
fragments map[fragmentKey]*Fragment
|
|
}
|
|
|
|
// NewIndex returns a new instance of Index.
|
|
func NewIndex() *Index {
|
|
return &Index{
|
|
fragments: make(map[fragmentKey]*Fragment),
|
|
}
|
|
}
|
|
|
|
// SliceN returs the total number of slices managed by the index.
|
|
func (i *Index) SliceN() uint64 {
|
|
i.mu.Lock()
|
|
defer i.mu.Unlock()
|
|
return i.sliceN
|
|
}
|
|
|
|
// Fragment returns the fragment for a database, frame & slice.
|
|
// The fragment is created if it doesn't already exist.
|
|
func (i *Index) Fragment(db, frame string, slice uint64) *Fragment {
|
|
i.mu.Lock()
|
|
defer i.mu.Unlock()
|
|
|
|
// Track the highest slice.
|
|
if slice > i.sliceN {
|
|
i.sliceN = slice
|
|
}
|
|
|
|
// Create fragment, if not exists.
|
|
key := fragmentKey{db, frame, slice}
|
|
if i.fragments[key] == nil {
|
|
i.fragments[key] = NewFragment(db, frame, slice)
|
|
}
|
|
|
|
return i.fragments[key]
|
|
}
|
|
|
|
// fragmentKey is the map key for fragment look ups.
|
|
type fragmentKey struct {
|
|
db string
|
|
frame string
|
|
slice uint64
|
|
}
|