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

watertower

package module

Go to main page

Versions in this module

v0

v0.1.2

Jun 3, 2021

v0.1.1

May 31, 2021

Changes in this version

+ var ErrBatchGet = errors.New("batch get error")

+ type Storage interface

+ BatchDocGet func(ctx context.Context, docs []*Document) (map[int]bool, error)

+ BatchTagGet func(ctx context.Context, tags []*tagEntity) (map[int]bool, error)

+ BatchTokenGet func(ctx context.Context, tokens []*tokenEntity) (map[int]bool, error)

+ Close func() error

+ Context func() context.Context

+ Create func(id string, doc interface{}) error

+ DecrementDocCount func() error

+ DeleteDoc func(doc *Document) error

+ DeleteDocKey func(docKey *documentKey) error

+ DeleteTag func(tag *tagEntity) error

+ DeleteToken func(token *tokenEntity) error

+ DocCount func() (int, error)

+ GetDoc func(doc *Document) error

+ GetDocKey func(docKey *documentKey) error

+ GetTag func(tag *tagEntity) error

+ GetToken func(token *tokenEntity) error

+ IncrementDocCount func() (int, error)

+ IncrementDocID func() (int, error)

+ ReadIndex func(r io.Reader) error

+ Replace func(id string, doc interface{}) error

+ WriteIndex func(w io.Writer) error

type WaterTower

+ func (wt *WaterTower) ReadIndex(w io.Reader) error

+ func (wt *WaterTower) WriteIndex(w io.Writer) error

v0.1.0

May 18, 2021

Changes in this version

+ func DefaultCollectionOpener(ctx context.Context, opt Option) (*docstore.Collection, error)

+ func DefaultCollectionURL(opt ...Option) (string, error)

+ type CombinedError struct

+ Errors []error

+ Message string

+ func (c CombinedError) Error() string

+ type Document struct

+ Comment string

+ Content string

+ ID string

+ Language string

+ Metadata map[string]string

+ Schema string

+ Score float64

+ Tags []string

+ Title string

+ TitleWordCount int

+ UniqueKey string

+ UpdatedAt time.Time

+ WordCount int

+ func (d Document) DocumentID() (uint32, error)

+ type Option struct

+ CollectionOpener func(ctx context.Context, opt Option) (*docstore.Collection, error)

+ CounterConcurrency int

+ DefaultLanguage string

+ DocumentUrl string

+ Index string

+ LocalFolder string

+ TitleScoreRatio float64

+ type WaterTower struct

+ func NewWaterTower(ctx context.Context, opt ...Option) (*WaterTower, error)

+ func (wt *WaterTower) AddTagToDocument(tag, uniqueKey string) error

+ func (wt *WaterTower) Close() (err error)

+ func (wt *WaterTower) FindDocumentByKey(uniqueKey string) (*Document, error)

+ func (wt *WaterTower) FindDocuments(ids ...uint32) ([]*Document, error)

+ func (wt *WaterTower) FindTags(tagNames ...string) ([]*tag, error)

+ func (wt *WaterTower) FindTagsWithContext(ctx context.Context, tagNames ...string) ([]*tag, error)

+ func (wt *WaterTower) FindTokens(words ...string) ([]*token, error)

+ func (wt *WaterTower) FindTokensWithContext(ctx context.Context, words ...string) ([]*token, error)

+ func (wt *WaterTower) PostDocument(uniqueKey string, document *Document) (uint32, error)

+ func (wt *WaterTower) RemoveDocumentByID(docID uint32) error

+ func (wt *WaterTower) RemoveDocumentByKey(uniqueKey string) error

+ func (wt *WaterTower) RemoveDocumentFromTag(tag string, docID uint32) error

+ func (wt *WaterTower) Search(searchWord string, tags []string, lang string) ([]*Document, error)