ebleveengine

Documentation

Index

• Constants
• type BleveIndexerInterfaceImpl
  • func (bi *BleveIndexerInterfaceImpl) MakeWorker() model.Worker
• 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
  • func (ip *IndexingProgress) CurrentProgress() int64
  • func (ip *IndexingProgress) IsDone() bool

Constants

const (
	BatchSize             = 1000
	TimeBetweenBatches    = 100
	EstimatedPostCount    = 10000000
	EstimatedFilesCount   = 100000
	EstimatedChannelCount = 100000
	EstimatedUserCount    = 10000
)

Types

type BleveIndexerInterfaceImpl

type BleveIndexerInterfaceImpl struct {
	Server *app.Server
}

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

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

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