indexing

Documentation

Index

• Variables
• func NewBackfillUseCase(cfg *config.Config, cli *client.Client, accountDb store.Accounts, ...) *backfillUseCase
• func NewPurgeUseCase(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *purgeUseCase
• func NewPurgeWorkerHandler(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *purgeWorkerHandler
• func NewRunWorkerHandler(cfg *config.Config, cli *client.Client, accountDb store.Accounts, ...) *runWorkerHandler
• func NewStartUseCase(cfg *config.Config, cli *client.Client, accountDb store.Accounts, ...) *startUseCase
• func NewSummarizeUseCase(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *summarizeUseCase
• func NewSummarizeWorkerHandler(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *summarizeWorkerHandler
• type BackfillCmdHandler
  • func NewBackfillCmdHandler(cfg *config.Config, cli *client.Client, accountDb store.Accounts, ...) *BackfillCmdHandler
  • func (h *BackfillCmdHandler) Handle(ctx context.Context, parallel bool, force bool, targetIds []int64)
• type BackfillUseCaseConfig
• type PurgeCmdHandler
  • func NewPurgeCmdHandler(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *PurgeCmdHandler
  • func (h *PurgeCmdHandler) Handle(ctx context.Context)
• type StartCmdHandler
  • func NewStartCmdHandler(cfg *config.Config, cli *client.Client, accountDb store.Accounts, ...) *StartCmdHandler
  • func (h *StartCmdHandler) Handle(ctx context.Context, batchSize int64)
• type SummarizeCmdHandler
  • func NewSummarizeCmdHandler(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *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, cli *client.Client, accountDb store.Accounts, blockDb store.Blocks, databaseDb store.Database, eventDb store.Events,
	reportDb store.Reports, rewardDb store.Rewards, syncableDb store.Syncables, systemEventDb store.SystemEvents, transactionDb store.Transactions, validatorDb store.Validators,
) *backfillUseCase

func NewPurgeUseCase

func NewPurgeUseCase(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *purgeUseCase

func NewPurgeWorkerHandler

func NewPurgeWorkerHandler(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *purgeWorkerHandler

func NewRunWorkerHandler

func NewRunWorkerHandler(cfg *config.Config, cli *client.Client, accountDb store.Accounts, blockDb store.Blocks, databaseDb store.Database, eventDb store.Events, reportDb store.Reports,
	rewardDb store.Rewards, syncableDb store.Syncables, systemEventDb store.SystemEvents, transactionDb store.Transactions, validatorDb store.Validators,
) *runWorkerHandler

func NewStartUseCase

func NewStartUseCase(cfg *config.Config, cli *client.Client, accountDb store.Accounts, blockDb store.Blocks, databaseDb store.Database, eventDb store.Events, reportDb store.Reports,
	rewardDb store.Rewards, syncableDb store.Syncables, systemEventDb store.SystemEvents, transactionDb store.Transactions, validatorDb store.Validators,
) *startUseCase

func NewSummarizeUseCase

func NewSummarizeUseCase(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *summarizeUseCase

func NewSummarizeWorkerHandler

func NewSummarizeWorkerHandler(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *summarizeWorkerHandler

Types

type BackfillCmdHandler

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

func NewBackfillCmdHandler

func NewBackfillCmdHandler(cfg *config.Config, cli *client.Client, accountDb store.Accounts, blockDb store.Blocks, databaseDb store.Database, eventDb store.Events, reportDb store.Reports,
	rewardDb store.Rewards, syncableDb store.Syncables, systemEventDb store.SystemEvents, transactionDb store.Transactions, validatorDb store.Validators,
) *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 PurgeCmdHandler

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

func NewPurgeCmdHandler

func NewPurgeCmdHandler(cfg *config.Config, blockDb store.Blocks, validatorDb store.Validators) *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, cli *client.Client, accountDb store.Accounts, blockDb store.Blocks, databaseDb store.Database, eventDb store.Events, reportDb store.Reports,
	rewardDb store.Rewards, syncableDb store.Syncables, systemEventDb store.SystemEvents, transactionDb store.Transactions, validatorDb store.Validators,
) *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, blockDb store.Blocks, validatorDb store.Validators) *SummarizeCmdHandler

func (*SummarizeCmdHandler) Handle

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