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) 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) JobChannel() chan<- model.Job
- func (worker *BleveIndexerWorker) Run()
- func (worker *BleveIndexerWorker) Stop()
- type IndexingProgress
Constants ¶
View Source
const ( BatchSize = 1000 TimeBetweenBatches = 100 EstimatedPostCount = 10000000 EstimatedFilesCount = 100000 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) IndexFilesBatch ¶ added in v5.34.0
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) 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 TotalFilesCount int64 DoneFilesCount int64 DoneFiles 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.