indexing

Documentation

Index

• Variables
• 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 NewReindexUseCase(cfg *config.Config, db *store.Store, c *client.Client) *reindexUseCase
• func NewSummarizeUseCase(cfg *config.Config, db *store.Store) *summarizeUseCase
• func NewSummarizeWorkerHandler(cfg *config.Config, db *store.Store, c *client.Client) *summarizeWorkerHandler
• type BackfillCmdHandler
  • 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
• type IndexCmdHandler
  • func NewIndexCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *IndexCmdHandler
  • func (h *IndexCmdHandler) Handle(ctx context.Context, batchSize int64)
• type PurgeCmdHandler
  • func NewPurgeCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *PurgeCmdHandler
  • func (h *PurgeCmdHandler) Handle(ctx context.Context)
• type ReindexCmdHandler
  • func NewReindexCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *ReindexCmdHandler
  • func (h *ReindexCmdHandler) Handle(ctx context.Context, parallel bool, startHeight, endHeight int64, ...)
• type ReindexUseCaseConfig
• type SummarizeCmdHandler
  • func NewSummarizeCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *SummarizeCmdHandler
  • func (h *SummarizeCmdHandler) Handle(ctx context.Context)

Variables

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

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

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

Functions

func NewBackfillUseCase

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

func NewIndexUseCase

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

func NewIndexWorkerHandler

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

func NewPurgeUseCase

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

func NewPurgeWorkerHandler

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

func NewReindexUseCase

func NewReindexUseCase(cfg *config.Config, db *store.Store, c *client.Client) *reindexUseCase

func NewSummarizeUseCase

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

func NewSummarizeWorkerHandler

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

Types

type BackfillCmdHandler

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

func NewBackfillCmdHandler

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

func (*BackfillCmdHandler) Handle

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

type BackfillUseCaseConfig

type BackfillUseCaseConfig struct {
	Parallel bool
	Force    bool
}

type IndexCmdHandler

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

func NewIndexCmdHandler

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

func (*IndexCmdHandler) Handle

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

type PurgeCmdHandler

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

func NewPurgeCmdHandler

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

func (*PurgeCmdHandler) Handle

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

type ReindexCmdHandler

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

func NewReindexCmdHandler

func NewReindexCmdHandler(cfg *config.Config, db *store.Store, c *client.Client) *ReindexCmdHandler

func (*ReindexCmdHandler) Handle

func (h *ReindexCmdHandler) Handle(ctx context.Context, parallel bool, startHeight, endHeight int64, targetIds []int64)

type ReindexUseCaseConfig

type ReindexUseCaseConfig struct {
	Parallel    bool
	StartHeight int64
	EndHeight   int64
	TargetIds   []int64
}

type SummarizeCmdHandler

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

func NewSummarizeCmdHandler

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

func (*SummarizeCmdHandler) Handle

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