scheduler

Documentation

Index

• type Scheduler
  • func NewScheduler[T migrator.Entity](src *gorm.DB, dst *gorm.DB, pool *connpool.DoubleWritePool, l logger.Logger, ...) *Scheduler[T]
  • func (s *Scheduler[T]) DstFirst(c *gin.Context) (ginx.Result, error)
  • func (s *Scheduler[T]) DstOnly(c *gin.Context) (ginx.Result, error)
  • func (s *Scheduler[T]) RegisterRoutes(server *gin.RouterGroup)
  • func (s *Scheduler[T]) SrcFirst(c *gin.Context) (ginx.Result, error)
  • func (s *Scheduler[T]) SrcOnly(c *gin.Context) (ginx.Result, error)
  • func (s *Scheduler[T]) StartFullvalidation(c *gin.Context) (ginx.Result, error)
  • func (s *Scheduler[T]) StartIncrementValidation(c *gin.Context, req StartIncrRequest) (ginx.Result, error)
  • func (s *Scheduler[T]) StopFullValidation(c *gin.Context) (ginx.Result, error)
  • func (s *Scheduler[T]) StopIncrementValidation(c *gin.Context) (ginx.Result, error)
• type StartIncrRequest

Types

type Scheduler

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

func NewScheduler

func NewScheduler[T migrator.Entity](src *gorm.DB, dst *gorm.DB,
	pool *connpool.DoubleWritePool, l logger.Logger, producer events.Producer) *Scheduler[T]

func (*Scheduler[T]) DstFirst

func (s *Scheduler[T]) DstFirst(c *gin.Context) (ginx.Result, error)

func (*Scheduler[T]) DstOnly

func (s *Scheduler[T]) DstOnly(c *gin.Context) (ginx.Result, error)

func (*Scheduler[T]) RegisterRoutes

func (s *Scheduler[T]) RegisterRoutes(server *gin.RouterGroup)

func (*Scheduler[T]) SrcFirst

func (s *Scheduler[T]) SrcFirst(c *gin.Context) (ginx.Result, error)

func (*Scheduler[T]) SrcOnly

func (s *Scheduler[T]) SrcOnly(c *gin.Context) (ginx.Result, error)

func (*Scheduler[T]) StartFullvalidation

func (s *Scheduler[T]) StartFullvalidation(c *gin.Context) (ginx.Result, error)

StartFullvalidation 开启全量校验

func (*Scheduler[T]) StartIncrementValidation

func (s *Scheduler[T]) StartIncrementValidation(c *gin.Context,
	req StartIncrRequest) (ginx.Result, error)

StartIncrementValidation 开启增量校验

func (*Scheduler[T]) StopFullValidation

func (s *Scheduler[T]) StopFullValidation(c *gin.Context) (ginx.Result, error)

StopFullValidation 停止全量校验

func (*Scheduler[T]) StopIncrementValidation

func (s *Scheduler[T]) StopIncrementValidation(c *gin.Context) (ginx.Result, error)

StopIncrementValidation 停止增量校验

type StartIncrRequest

type StartIncrRequest struct {
	Utime    int64 `json:"utime"`
	Interval int64 `json:"interval"` // [毫秒数] json 不能正确处理 time.Duration 类型
}