Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

letarette

package

Go to main page

Versions in this module

v0

v0.2.2

May 5, 2022

v0.2.1

Mar 26, 2022

v0.2.0

Sep 1, 2021

Changes in this version

+ func CompressIndex(ctx context.Context, dbo Database) error

+ func InitializeShard(ctx context.Context, conn *nats.Conn, db Database, cfg Config, ...) error

+ func LoadShardClone(ctx context.Context, db Database, source io.Reader) error

+ func SQL(path string) (string, error)

+ func SetSynonyms(ctx context.Context, dbo Database, synonyms []Synonyms) error

+ func ShardIndexFromDocumentID(docID protocol.DocumentID, shardGroupSize int) int

+ func VacuumIndex(dbo Database) error

+ type BulkLoader struct

+ func StartBulkLoad(dbo Database, space string) (*BulkLoader, error)

+ func (bl *BulkLoader) Commit() error

+ func (bl *BulkLoader) Load(doc protocol.Document) error

+ func (bl *BulkLoader) LoadedBytes() uint32

+ func (bl *BulkLoader) Rollback() error

type Cache

+ func (cache *Cache) Invalidate(doc protocol.DocumentID)

+ type Cloner struct

+ func StartCloner(nc *nats.Conn, db Database, cfg Config) (*Cloner, error)

+ func (cs *Cloner) Close() error

+ func (cs *Cloner) ServeHTTP(w http.ResponseWriter, req *http.Request)

type Config

+ CloningHost string

+ CloningPort uint16

+ DB struct{ ... }

+ Profile struct{ ... }

+ Shard string

+ ShardIndex uint16

type Database

+ RawExec func(q string, args ...interface{}) error

+ type MetricsCollector interface

+ Close func()

+ func StartMetricsCollector(nc *nats.Conn, db Database, cfg Config) (MetricsCollector, error)

+ type Profiler struct

+ func StartProfiler(cfg Config) (*Profiler, error)

+ func (p *Profiler) Close() error

+ type ShardCloner struct

+ func StartShardClone(ctx context.Context, db *database, shardGroup string, dest io.Writer) (*ShardCloner, error)

+ func (s *ShardCloner) Close() (int, error)

+ func (s *ShardCloner) Step(ctx context.Context) (bool, error)

+ type ShardInfo struct

+ DocCount uint64

+ ShardIndex uint16

+ ShardgroupSize uint16

type Stats

+ TotalTerms int

+ UniqueTerms int

type StatusMonitor

+ GetHealthyShards func() []ShardInfo

+ ShardInitDone func()

+ type Synonyms struct

+ Description string

+ Words []string

v0.1.1

Jan 5, 2020

v0.1.0

Jan 1, 2020

Changes in this version

+ var ErrStemmerSettingsMismatch = fmt.Errorf("Config does not match index state")

+ var Revision = ""

+ var Tag = ""

+ func CheckIndex(dbo Database) error

+ func CheckStemmerSettings(db Database, cfg Config) error

+ func ExposeMetrics(port uint16)

+ func ForceIndexStemmerState(state snowball.Settings, dbo Database) error

+ func GetSpellfixLag(ctx context.Context, dbo Database, minCount int) (int, error)

+ func RebuildIndex(dbo Database) error

+ func ResetMigration(cfg Config, version int) error

+ func SetIndexPageSize(dbo Database, pageSize int) error

+ func UpdateSpellfix(ctx context.Context, dbo Database, minCount int) error

+ func Usage()

+ type Cache struct

+ func NewCache(timeout time.Duration, maxSize uint64) *Cache

+ func (cache *Cache) Get(query string, spaces []string, limit uint16, offset uint16) (protocol.SearchResult, bool)

+ func (cache *Cache) Put(query string, spaces []string, limit uint16, offset uint16, ...)

+ type Config struct

+ Db struct{ ... }

+ Index struct{ ... }

+ MetricsPort uint16

+ Nats struct{ ... }

+ Search struct{ ... }

+ Shardgroup string

+ ShardgroupIndex uint16

+ ShardgroupSize uint16

+ Spelling struct{ ... }

+ Stemmer struct{ ... }

+ func LoadConfig() (cfg Config, err error)

+ type Database interface

+ Close func() error

+ RawQuery func(string) ([]string, error)

+ func OpenDatabase(cfg Config) (Database, error)

+ type IndexOptimizer struct

+ func StartIndexOptimization(dbo Database, pageIncrement int) (*IndexOptimizer, error)

+ func (o IndexOptimizer) Close() error

+ func (o IndexOptimizer) Step() (bool, error)

+ type Indexer interface

+ Close func()

+ func StartIndexer(nc *nats.Conn, db Database, cfg Config) (Indexer, error)

+ type Interest struct

+ DocID protocol.DocumentID

+ State InterestState

+ Updated int64

+ type InterestListState struct

+ CreatedAt int64

+ LastUpdated int64

+ LastUpdatedDocID protocol.DocumentID

+ type InterestState int

+ type Phrase struct

+ Exclude bool

+ Text string

+ Wildcard bool

+ func CanonicalizePhraseList(phrases []Phrase) []Phrase

+ func ParseQuery(query string) []Phrase

+ func ReducePhraseList(phrases []Phrase) []Phrase

+ func (p Phrase) String() string

+ type Searcher interface

+ Close func()

+ func StartSearcher(nc *nats.Conn, db Database, cfg Config) (Searcher, error)

+ type Stats struct

+ CommonTerms []struct{ ... }

+ Docs int

+ Spaces []struct{ ... }

+ Stemmer snowball.Settings

+ Terms int

+ func GetIndexStats(dbo Database) (Stats, error)

+ type StatusMonitor interface

+ Close func()

+ func StartStatusMonitor(nc *nats.Conn, db Database, cfg Config) (StatusMonitor, error)