checker

package

v1.0.0-alpha Latest Latest Go to latest Published: Jan 21, 2019 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

func CheckSyncConfig(ctx context.Context, cfgs []*config.SubTaskConfig) error

CheckSyncConfig checks synchronization configuration

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

Checker performs pre-check of data synchronization

func NewChecker(cfgs []*config.SubTaskConfig) *Checker

NewChecker returns a checker

func (c *Checker) Close()

Close implements Unit interface

func (c *Checker) Error() interface{}

Error implements Unit interface

func (c *Checker) Init() error

Init implements Unit interface

func (c *Checker) IsFreshTask() (bool, error)

IsFreshTask implements Unit.IsFreshTask

func (c *Checker) Pause()

Pause implements Unit interface

func (c *Checker) Process(ctx context.Context, pr chan pb.ProcessResult)

Process implements Unit interface

func (c *Checker) Resume(ctx context.Context, pr chan pb.ProcessResult)

Resume resumes the paused process

func (c *Checker) Status() interface{}

Status implements Unit interface

func (c *Checker) Type() pb.UnitType

Type implements Unit interface

func (c *Checker) Update(cfg *config.SubTaskConfig) error

Update implements Unit.Update