indexing

package

v0.3.1 Latest Latest Go to latest Published: Sep 4, 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 NewPurgeUseCase(cfg *config.Config, db *store.Store) *purgeUseCase

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

func NewRunWorkerHandler(cfg *config.Config, db *store.Store, c *client.Client) *runWorkerHandler

func NewStartUseCase(cfg *config.Config, db *store.Store, c *client.Client) *startUseCase

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, targetIds []int64)

type BackfillUseCaseConfig struct {
	Parallel  bool
	Force     bool
	TargetIds []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 StartCmdHandler struct {
	// contains filtered or unexported fields
}

func NewStartCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *StartCmdHandler

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

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)