usecase

Documentation

Index

• func ValidateScannerExecuteRecoveryTask(prefix string, recovery *entities.RecoveryTask) error
• type Recovery
  • func New(conf *config.Config, logger logging.Logger, ...) Recovery
• type Scanner
• type ScannerExecuteIn
  • func (in *ScannerExecuteIn) Validate() error
• type ScannerExecuteOut
• type ScannerScheduleIn
  • func (in *ScannerScheduleIn) Validate() error
• type ScannerScheduleOut

Functions

func ValidateScannerExecuteRecoveryTask

func ValidateScannerExecuteRecoveryTask(prefix string, recovery *entities.RecoveryTask) error

Types

type Recovery

type Recovery interface {
	Scanner() Scanner
}

func New

func New(
	conf *config.Config,
	logger logging.Logger,
	infra *infrastructure.Infrastructure,
	repositories repositories.Repositories,
) Recovery

type Scanner

type Scanner interface {
	Schedule(ctx context.Context, in *ScannerScheduleIn) (*ScannerScheduleOut, error)
	Execute(ctx context.Context, in *ScannerExecuteIn) (*ScannerExecuteOut, error)
}

type ScannerExecuteIn

type ScannerExecuteIn struct {
	RecoveryBatchSize int
	Tasks             map[string]*entities.RecoveryTask
}

func (*ScannerExecuteIn) Validate

func (in *ScannerExecuteIn) Validate() error

type ScannerExecuteOut

type ScannerExecuteOut struct {
	Success []string
	Error   map[string]error
}

type ScannerScheduleIn

type ScannerScheduleIn struct {
	BatchSize int
	Buckets   []config.RecoveryCronjobBucket
}

func (*ScannerScheduleIn) Validate

func (in *ScannerScheduleIn) Validate() error

type ScannerScheduleOut

type ScannerScheduleOut struct {
	Success []string
	Error   map[string]error
}