indexer

Oct 12, 2021

Changes in this version

+ func GetFile(schema string, rowid int64) (SQStatement, []interface{}, []reflect.Type)

+ func UpsertDoc(txn SQTransaction, doc *Doc) (int64, error)

+ type Doc struct

+ Description string

+ Name string

+ Path string

+ Shortform string

+ Tags []string

+ Title string

+ type DocTag struct

+ Name string

+ Path string

+ Tag string

+ type File struct

+ Ext string

+ Filename string

+ IsDir bool

+ ModTime time.Time

+ Name string

+ Parent string

+ Path string

+ Size int64

+ type RenderFunc func(context.Context, string, string) (Document, error)

+ type Search struct

+ Description string

+ Filename string

+ Name string

+ Parent string

+ Shortform string

+ Title string

+ type View struct

+ Description string

+ Filename string

+ Name string

+ Parent string

+ Shortform string

+ Title string

Oct 9, 2021

Changes in this version

+ func Query(schema string, snippet bool) SQSelect

Oct 8, 2021

Changes in this version

+ func CreateSchema(ctx context.Context, conn SQConnection, schema string, tokenizer string) error

+ func Delete(schema string, evt *QueueEvent) (SQStatement, []interface{})

+ func ListIndexWithCount(ctx context.Context, conn SQConnection, schema string) (map[string]int64, error)

+ func Replace(schema string, evt *QueueEvent) (SQStatement, []interface{})

+ type EventType uint

+ const EventReindexCompleted

+ const EventReindexStarted

type Indexer

+ func (i *Indexer) IsIndexing() bool

+ func (i *Indexer) Queue() *Queue

type Queue

+ func NewQueue() *Queue

+ func (q *Queue) Mark(name, path string, flag bool)

type QueueEvent

+ Info fs.FileInfo

+ type Store struct

+ func NewStore(pool SQPool, schema string, queue *Queue, r Renderer, workers uint) *Store

+ func (s *Store) Run(ctx context.Context, errs chan<- error) error

+ func (s *Store) Schema() string

+ func (s *Store) String() string

Oct 1, 2021

Changes in this version

+ type Event uint

+ const EventAdd

+ const EventNone

+ const EventRemove

+ type Indexer struct

+ func NewIndexer(name, path string) (*Indexer, error)

+ func (i *Indexer) Name() string

+ func (i *Indexer) Path() string

+ func (i *Indexer) Run(ctx context.Context, errs chan<- error) error

+ func (i *Indexer) String() string

+ func (i *Indexer) Walk(ctx context.Context, fn WalkFunc) error

+ type Queue struct

+ func NewQueueWithCapacity(cap int) *Queue

+ func (q *Queue) Add(name, path string)

+ func (q *Queue) Count() int

+ func (q *Queue) Get(name, path string) *QueueEvent

+ func (q *Queue) Next() *QueueEvent

+ func (q *Queue) Remove(name, path string)

+ func (this *Queue) String() string

+ type QueueEvent struct

+ Name string

+ Path string

+ type WalkFunc func(err error)