indexer

package
v6.7.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 14, 2022 License: AGPL-3.0, Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeWorker added in v6.5.0

func MakeWorker(jobServer *jobs.JobServer, engine *bleveengine.BleveEngine) model.Worker

Types

type BleveIndexerWorker

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

func (*BleveIndexerWorker) BulkIndexChannels

func (worker *BleveIndexerWorker) BulkIndexChannels(channels []*model.Channel, progress IndexingProgress) (*model.Channel, *model.AppError)

func (*BleveIndexerWorker) BulkIndexFiles

func (worker *BleveIndexerWorker) BulkIndexFiles(files []*model.FileForIndexing, progress IndexingProgress) (*model.FileInfo, *model.AppError)

func (*BleveIndexerWorker) BulkIndexPosts

func (worker *BleveIndexerWorker) BulkIndexPosts(posts []*model.PostForIndexing, progress IndexingProgress) (*model.Post, *model.AppError)

func (*BleveIndexerWorker) BulkIndexUsers

func (worker *BleveIndexerWorker) BulkIndexUsers(users []*model.UserForIndexing, progress IndexingProgress) (*model.UserForIndexing, *model.AppError)

func (*BleveIndexerWorker) DoJob

func (worker *BleveIndexerWorker) DoJob(job *model.Job)

func (*BleveIndexerWorker) IndexBatch

func (worker *BleveIndexerWorker) IndexBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)

func (*BleveIndexerWorker) IndexChannelsBatch

func (worker *BleveIndexerWorker) IndexChannelsBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)

func (*BleveIndexerWorker) IndexFilesBatch

func (worker *BleveIndexerWorker) IndexFilesBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)

func (*BleveIndexerWorker) IndexPostsBatch

func (worker *BleveIndexerWorker) IndexPostsBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)

func (*BleveIndexerWorker) IndexUsersBatch

func (worker *BleveIndexerWorker) IndexUsersBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)

func (*BleveIndexerWorker) IsEnabled added in v6.5.0

func (worker *BleveIndexerWorker) IsEnabled(cfg *model.Config) bool

func (*BleveIndexerWorker) JobChannel

func (worker *BleveIndexerWorker) JobChannel() chan<- model.Job

func (*BleveIndexerWorker) Run

func (worker *BleveIndexerWorker) Run()

func (*BleveIndexerWorker) Stop

func (worker *BleveIndexerWorker) Stop()

type IndexingProgress

type IndexingProgress struct {
	Now            time.Time
	StartAtTime    int64
	EndAtTime      int64
	LastEntityTime int64

	TotalPostsCount int64
	DonePostsCount  int64
	DonePosts       bool
	LastPostID      string

	TotalFilesCount int64
	DoneFilesCount  int64
	DoneFiles       bool
	LastFileID      string

	TotalChannelsCount int64
	DoneChannelsCount  int64
	DoneChannels       bool
	LastChannelID      string

	TotalUsersCount int64
	DoneUsersCount  int64
	DoneUsers       bool
	LastUserID      string
}

func (*IndexingProgress) CurrentProgress

func (ip *IndexingProgress) CurrentProgress() int64

func (*IndexingProgress) IsDone

func (ip *IndexingProgress) IsDone() bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL