Documentation ¶
Index ¶
- Constants
- type BleveIndexerInterfaceImpl
- type BleveIndexerWorker
- func (worker *BleveIndexerWorker) BulkIndexChannels(channels []*model.Channel, progress IndexingProgress) (int64, *model.AppError)
- func (worker *BleveIndexerWorker) BulkIndexFiles(files []*model.FileForIndexing, progress IndexingProgress) (int64, *model.AppError)
- func (worker *BleveIndexerWorker) BulkIndexPosts(posts []*model.PostForIndexing, progress IndexingProgress) (int64, *model.AppError)
- func (worker *BleveIndexerWorker) BulkIndexUsers(users []*model.UserForIndexing, progress IndexingProgress) (int64, *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) IndexPostsBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
- func (worker *BleveIndexerWorker) IndexUsersBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
- func (worker *BleveIndexerWorker) JobChannel() chan<- model.Job
- func (worker *BleveIndexerWorker) Run()
- func (worker *BleveIndexerWorker) Stop()
- type IndexingProgress
Constants ¶
View Source
const ( BatchSize = 1000 TimeBetweenBatches = 100 EstimatedPostCount = 10000000 EstimatedChannelCount = 100000 EstimatedUserCount = 10000 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BleveIndexerInterfaceImpl ¶
func (*BleveIndexerInterfaceImpl) MakeWorker ¶
func (bi *BleveIndexerInterfaceImpl) MakeWorker() model.Worker
type BleveIndexerWorker ¶
type BleveIndexerWorker struct {
// contains filtered or unexported fields
}
func (*BleveIndexerWorker) BulkIndexChannels ¶
func (worker *BleveIndexerWorker) BulkIndexChannels(channels []*model.Channel, progress IndexingProgress) (int64, *model.AppError)
func (*BleveIndexerWorker) BulkIndexFiles ¶ added in v5.32.0
func (worker *BleveIndexerWorker) BulkIndexFiles(files []*model.FileForIndexing, progress IndexingProgress) (int64, *model.AppError)
func (*BleveIndexerWorker) BulkIndexPosts ¶
func (worker *BleveIndexerWorker) BulkIndexPosts(posts []*model.PostForIndexing, progress IndexingProgress) (int64, *model.AppError)
func (*BleveIndexerWorker) BulkIndexUsers ¶
func (worker *BleveIndexerWorker) BulkIndexUsers(users []*model.UserForIndexing, progress IndexingProgress) (int64, *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) IndexPostsBatch ¶
func (worker *BleveIndexerWorker) IndexPostsBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
func (*BleveIndexerWorker) IndexUsersBatch ¶
func (worker *BleveIndexerWorker) IndexUsersBatch(progress IndexingProgress) (IndexingProgress, *model.AppError)
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 TotalChannelsCount int64 DoneChannelsCount int64 DoneChannels bool TotalUsersCount int64 DoneUsersCount int64 DoneUsers bool }
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.