validator

Documentation

Index

• type CanalIncrValidator
  • func NewCanalIncrValidator[T migrator.Entity](base *gorm.DB, target *gorm.DB, direction string, l logger.LoggerV1, ...) *CanalIncrValidator[T]
  • func (v *CanalIncrValidator[T]) Validate(ctx context.Context, id int64) error
• type Validator
  • func NewValidator[T migrator.Entity](base *gorm.DB, target *gorm.DB, direction string, l logger.LoggerV1, ...) *Validator[T]
  • func (v *Validator[T]) SleepInterval(i time.Duration) *Validator[T]
  • func (v *Validator[T]) Utime(utime int64) *Validator[T]
  • func (v *Validator[T]) Validate(ctx context.Context) error

Types

type CanalIncrValidator

type CanalIncrValidator[T migrator.Entity] struct {
	// contains filtered or unexported fields
}

func NewCanalIncrValidator

func NewCanalIncrValidator[T migrator.Entity](
	base *gorm.DB,
	target *gorm.DB,
	direction string,
	l logger.LoggerV1,
	producer events2.Producer,
) *CanalIncrValidator[T]

func (*CanalIncrValidator[T]) Validate

func (v *CanalIncrValidator[T]) Validate(ctx context.Context, id int64) error

Validate 一次校验一条

type Validator

type Validator[T migrator.Entity] struct {
	// contains filtered or unexported fields
}

func NewValidator

func NewValidator[T migrator.Entity](
	base *gorm.DB,
	target *gorm.DB,
	direction string,
	l logger.LoggerV1,
	producer events2.Producer,
) *Validator[T]

func (*Validator[T]) SleepInterval

func (v *Validator[T]) SleepInterval(i time.Duration) *Validator[T]

func (*Validator[T]) Utime

func (v *Validator[T]) Utime(utime int64) *Validator[T]

func (*Validator[T]) Validate

func (v *Validator[T]) Validate(ctx context.Context) error

Validate 执行校验。 分成两步： 1. from => to