ebleveengine

package
v5.34.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2021 License: AGPL-3.0, Apache-2.0 Imports: 10 Imported by: 3

Documentation

Index

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

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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL