indexing

Documentation

Index

• Variables
• func NewBackfillUseCase(cfg *config.Config, db *psql.Store, c figmentclient.Client) *backfillUseCase
• func NewFetchIdentitiesUseCase(db *psql.Store, client figmentclient.Client) *fetchIdentitiesUseCase
• func NewFetchIdentitiesWorkerHandler(db *psql.Store, c figmentclient.Client) *fetchIdentitiesWorkerHandler
• func NewPurgeUseCase(cfg *config.Config, db *psql.Store) *purgeUseCase
• func NewPurgeWorkerHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *purgeWorkerHandler
• func NewRunWorkerHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client, ...) *runWorkerHandler
• func NewStartUseCase(cfg *config.Config, db *psql.Store, c figmentclient.Client, ...) *startUseCase
• func NewSummarizeUseCase(cfg *config.Config, db *psql.Store) *summarizeUseCase
• func NewSummarizeWorkerHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *summarizeWorkerHandler
• type BackfillCmdHandler
  • func NewBackfillCmdHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *BackfillCmdHandler
  • func (h *BackfillCmdHandler) Handle(ctx context.Context, parallel bool, force bool, targetIds []int64)
• type BackfillUseCaseConfig
• type FetchIdentitiesCmdHandler
  • func NewFetchIdentitiesCmdHandler(db *psql.Store, c figmentclient.Client) *FetchIdentitiesCmdHandler
  • func (h *FetchIdentitiesCmdHandler) Handle(ctx context.Context)
• type PurgeCmdHandler
  • func NewPurgeCmdHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *PurgeCmdHandler
  • func (h *PurgeCmdHandler) Handle(ctx context.Context)
• type StartCmdHandler
  • func NewStartCmdHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client, ...) *StartCmdHandler
  • func (h *StartCmdHandler) Handle(ctx context.Context, batchSize int64)
• type SummarizeCmdHandler
  • func NewSummarizeCmdHandler(cfg *config.Config, db *psql.Store, c figmentclient.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 *psql.Store, c figmentclient.Client) *backfillUseCase

func NewFetchIdentitiesUseCase

func NewFetchIdentitiesUseCase(db *psql.Store, client figmentclient.Client) *fetchIdentitiesUseCase

func NewFetchIdentitiesWorkerHandler

func NewFetchIdentitiesWorkerHandler(db *psql.Store, c figmentclient.Client) *fetchIdentitiesWorkerHandler

func NewPurgeUseCase

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

func NewPurgeWorkerHandler

func NewPurgeWorkerHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *purgeWorkerHandler

func NewRunWorkerHandler

func NewRunWorkerHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client, dl *datalake.DataLake) *runWorkerHandler

func NewStartUseCase

func NewStartUseCase(cfg *config.Config, db *psql.Store, c figmentclient.Client, dl *datalake.DataLake) *startUseCase

func NewSummarizeUseCase

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

func NewSummarizeWorkerHandler

func NewSummarizeWorkerHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *summarizeWorkerHandler

Types

type BackfillCmdHandler

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

func NewBackfillCmdHandler

func NewBackfillCmdHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *BackfillCmdHandler

func (*BackfillCmdHandler) Handle

func (h *BackfillCmdHandler) Handle(ctx context.Context, parallel bool, force bool, targetIds []int64)

type BackfillUseCaseConfig

type BackfillUseCaseConfig struct {
	Parallel  bool
	Force     bool
	TargetIds []int64
}

type FetchIdentitiesCmdHandler

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

func NewFetchIdentitiesCmdHandler

func NewFetchIdentitiesCmdHandler(db *psql.Store, c figmentclient.Client) *FetchIdentitiesCmdHandler

func (*FetchIdentitiesCmdHandler) Handle

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

type PurgeCmdHandler

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

func NewPurgeCmdHandler

func NewPurgeCmdHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *PurgeCmdHandler

func (*PurgeCmdHandler) Handle

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

type StartCmdHandler

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

func NewStartCmdHandler

func NewStartCmdHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client, dl *datalake.DataLake) *StartCmdHandler

func (*StartCmdHandler) Handle

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

type SummarizeCmdHandler

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

func NewSummarizeCmdHandler

func NewSummarizeCmdHandler(cfg *config.Config, db *psql.Store, c figmentclient.Client) *SummarizeCmdHandler

func (*SummarizeCmdHandler) Handle

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