Documentation ¶
Index ¶
- func MakeWorker(jobServer *jobs.JobServer, engine *bleveengine.BleveEngine) model.Worker
- type BleveIndexerWorker
- func (worker *BleveIndexerWorker) BulkIndexChannels(channels []*model.Channel, progress IndexingProgress) (*model.Channel, *model.AppError)
- func (worker *BleveIndexerWorker) BulkIndexFiles(files []*model.FileForIndexing, progress IndexingProgress) (*model.FileInfo, *model.AppError)
- func (worker *BleveIndexerWorker) BulkIndexPosts(posts []*model.PostForIndexing, progress IndexingProgress) (*model.Post, *model.AppError)
- func (worker *BleveIndexerWorker) BulkIndexUsers(users []*model.UserForIndexing, progress IndexingProgress) (*model.UserForIndexing, *model.AppError)
- func (worker *BleveIndexerWorker) DoJob(job *model.Job)
- func (worker *BleveIndexerWorker) IndexBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
- func (worker *BleveIndexerWorker) IndexChannelsBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
- func (worker *BleveIndexerWorker) IndexFilesBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
- func (worker *BleveIndexerWorker) IndexPostsBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
- func (worker *BleveIndexerWorker) IndexUsersBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
- func (worker *BleveIndexerWorker) IsEnabled(cfg *model.Config) bool
- func (worker *BleveIndexerWorker) JobChannel() chan<- model.Job
- func (worker *BleveIndexerWorker) Run()
- func (worker *BleveIndexerWorker) Stop()
- type IndexingProgress
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
Click to show internal directories.
Click to hide internal directories.