Documentation ¶
Index ¶
- Constants
- type BleveIndexerInterfaceImpl
- type BleveIndexerWorker
- func (worker *BleveIndexerWorker) BulkIndexChannels(channels []*model.Channel, 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 ( BATCH_SIZE = 1000 TIME_BETWEEN_BATCHES = 100 ESTIMATED_POST_COUNT = 10000000 ESTIMATED_CHANNEL_COUNT = 100000 ESTIMATED_USER_COUNT = 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) 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.