dupi

Sep 20, 2021

Changes in this version

type Index

+ func (x *Index) FindBlots(m map[uint32][]byte, doc *Doc) (map[uint32][]byte, error)

Sep 16, 2021

Changes in this version

type Index

+ func (x *Index) Stats() (*Stats, error)

+ type Stats struct

+ BlotMean float64

+ BlotSigma float64

+ NumBlots uint64

+ NumDocs uint64

+ NumPaths uint64

+ NumPosts uint64

+ Root string

+ func (st *Stats) String() string

Sep 16, 2021

Changes in this version

type Doc

+ func (doc *Doc) Load() error

type Index

+ func (x *Index) BlotDoc(dst []uint32, doc *Doc) []uint32

+ func (x *Index) FindBlot(theBlot uint32, doc *Doc) (start, end uint32, err error)

+ func (x *Index) JoinBlot(shard uint32, sblot uint16) uint32

+ func (x *Index) SplitBlot(b uint32) (shard uint32, sblot uint16)

Sep 16, 2021

Changes in this version

type Config

+ NumShards int

type Index

+ func (x *Index) Blotter() blotter.T

+ func (x *Index) NumShards() int

+ func (x *Index) NumShatters() int

+ func (x *Index) SeqLen() int

+ func (x *Index) TokenFunc() token.TokenizerFunc

type Query

+ func (q *Query) Get(blot *Blot) error

Sep 15, 2021

Changes in this version

+ var ErrInvalidQueryState = errors.New("query state invalid")

+ func RemoveIndex(idx *Index) error

+ func RemoveIndexer(idx *Indexer) error

+ type Blot struct

+ Blot uint32

+ Docs []Doc

+ func (b *Blot) Cap() int

+ func (b *Blot) Doc(i int) *Doc

+ func (b *Blot) Len() int

+ func (b *Blot) Next() *Doc

+ type Config struct

+ BlotConfig blotter.Config

+ DocFlushRate int

+ IndexRoot string

+ NumBuckets int

+ NumShatters int

+ SeqLen int

+ TokenConfig token.Config

+ func DefaultConfig(root string) (*Config, error)

+ func NewConfig(root string, nbuckets, seqLen int) (*Config, error)

+ func ReadConfig(root string) (*Config, error)

+ func (cfg *Config) DmdPath() string

+ func (cfg *Config) FnamesPath() string

+ func (cfg *Config) IixPath(i int) string

+ func (cfg *Config) LockPath() string

+ func (cfg *Config) Path() string

+ func (cfg *Config) PostPath(i int) string

+ func (cfg *Config) Write() error

+ type Doc struct

+ Dat []byte

+ End uint32

+ Path string

+ Start uint32

+ func NewDoc(path, body string) *Doc

+ type Index struct

+ func OpenIndex(root string) (*Index, error)

+ func (x *Index) Close() error

+ func (x *Index) Root() string

+ func (x *Index) StartQuery(s QueryStrategy) *Query

+ type Indexer struct

+ func CreateIndexer(root string, nbuckets, seqLen int) (*Indexer, error)

+ func IndexerFromConfig(cfg *Config) (*Indexer, error)

+ func OpenIndexer(root string) (*Indexer, error)

+ func (x *Indexer) Add(doc *Doc) error

+ func (x *Indexer) Close() error

+ func (x *Indexer) Root() string

+ type Query struct

+ func (q *Query) Next(dst []Blot) (n int, err error)

+ type QueryStrategy int

+ const QueryMaxBlot

+ const QueryMaxDoc

+ const QueryRandom