index

package

v0.1.46 Latest Latest Go to latest Published: Jul 7, 2025 License: MIT Imports: 36 Imported by: 0

Details

View Source

const CurrentSchemaVersion = 5

View Source

const DefaultPageSize = 100

This section is empty.

func OpenOrCreate(
	dataRoot string,
	force bool,
	options *Options,
) (*ReadIndex, *WriteIndex, bool, errors.E)

type BatchError struct {
	errors.E
}

func (e *BatchError) Error() string

type DocumentMatch struct {
	*search.DocumentMatch
	Data nix.Importable
}

type Meta struct {
	// contains filtered or unexported fields
}

func (i *Meta) GetSourceMeta(source string) *SourceMeta

func (i *Meta) IsSchemaOutdated() bool

func (i *Meta) LastUpdated() time.Time

func (i *Meta) Save() errors.E

func (i *Meta) SetSourceMeta(source string, meta *SourceMeta)

type Options struct {
	LowMemory bool
	BatchSize int
	Logger    *log.Logger
}

type ReadIndex struct {
	// contains filtered or unexported fields
}

func (index *ReadIndex) Close() error

func (index *ReadIndex) GetDocument(
	ctx context.Context,
	source *config.Source,
	id string,
) (*nix.Importable, errors.E)

func (index *ReadIndex) GetEnabledSources() ([]string, errors.E)

func (index *ReadIndex) LastUpdated() time.Time

func (index *ReadIndex) Search(
	ctx context.Context,
	source *config.Source,
	keyword string,
	from int,
	pageSize int,
) (*Result, errors.E)

type Result struct {
	*bleve.SearchResult
	Hits iter.Seq[DocumentMatch]
}

type SourceMeta struct {
	Updated time.Time
	Path    string
	Rev     string
}

type WriteIndex struct {
	Meta *Meta
	// contains filtered or unexported fields
}

func (i *WriteIndex) Close() (err errors.E)

func (i *WriteIndex) DeleteBySource(source string) errors.E

func (i *WriteIndex) Flush(batch *bleve.Batch) errors.E

func (i *WriteIndex) Import(
	ctx context.Context,
	objects <-chan nix.Importable,
) <-chan errors.E

func (i *WriteIndex) SaveMeta() errors.E

Path	Synopsis
nixattr