indexer

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
  • func (ip *IndexingProgress) CurrentProgress() int64
  • func (ip *IndexingProgress) IsDone() bool

Functions

func MakeWorker

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

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