indexing

package

v0.8.1 Latest Latest Go to latest Published: Oct 21, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrBackfillRunning = errors.New("backfill already running (use force flag to override it)")
)

View Source

var (
	ErrPurgingDisabled = errors.New("purging disabled")
)

View Source

var (
	ErrRunningSequentialReindex = errors.New("indexing skipped because sequential reindex hasn't finished yet")
)

func NewBackfillUseCase(cfg *config.Config, db *store.Store, c *client.Client) *backfillUseCase

func NewIndexUseCase(cfg *config.Config, db *store.Store, c *client.Client) *indexUseCase

func NewIndexWorkerHandler(cfg *config.Config, db *store.Store, c *client.Client) *indexWorkerHandler

func NewPurgeUseCase(cfg *config.Config, db *store.Store) *purgeUseCase

func NewPurgeWorkerHandler(cfg *config.Config, db *store.Store, c *client.Client) *purgeWorkerHandler

func NewSummarizeUseCase(cfg *config.Config, db *store.Store) *summarizeUseCase

func NewSummarizeWorkerHandler(cfg *config.Config, db *store.Store, c *client.Client) *summarizeWorkerHandler

type BackfillCmdHandler struct {
	// contains filtered or unexported fields
}

func NewBackfillCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *BackfillCmdHandler

func (h *BackfillCmdHandler) Handle(ctx context.Context, parallel bool, force bool)

type BackfillUseCaseConfig struct {
	Parallel bool
	Force    bool
}

type IndexCmdHandler struct {
	// contains filtered or unexported fields
}

func NewIndexCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *IndexCmdHandler

func (h *IndexCmdHandler) Handle(ctx context.Context, batchSize int64)

type PurgeCmdHandler struct {
	// contains filtered or unexported fields
}

func NewPurgeCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *PurgeCmdHandler

func (h *PurgeCmdHandler) Handle(ctx context.Context)

type SummarizeCmdHandler struct {
	// contains filtered or unexported fields
}

func NewSummarizeCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *SummarizeCmdHandler

func (h *SummarizeCmdHandler) Handle(ctx context.Context)