ebleveengine

package
v0.0.0-...-16753fb Latest Latest
Warning

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

Go to latest
Published: Jul 13, 2021 License: AGPL-3.0, Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	BatchSize             = 1000
	TimeBetweenBatches    = 100
	EstimatedPostCount    = 10000000
	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

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

Jump to

Keyboard shortcuts

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