compare

Documentation

Index

• func CompareSets(dbSet interface{}, extSet interface{}, removed interface{}, ...) error
• func CompareSets2(dbSet interface{}, extSet interface{}, removed interface{}, ...) error
• func CompareSetsFunc(cs SCompareSet, removed interface{}, commonDB interface{}, ...) error
• type SCompareSet
• type SyncResult
  • func (self *SyncResult) Add()
  • func (self *SyncResult) AddError(msg error)
  • func (self *SyncResult) AllError() error
  • func (self *SyncResult) Delete()
  • func (self *SyncResult) DeleteError(msg error)
  • func (self *SyncResult) Error(msg error)
  • func (self *SyncResult) IsError() bool
  • func (self *SyncResult) Result() string
  • func (self *SyncResult) Update()
  • func (self *SyncResult) UpdateError(msg error)

Functions

func CompareSets

func CompareSets(dbSet interface{}, extSet interface{}, removed interface{}, commonDB interface{}, commonExt interface{}, added interface{}) error

func CompareSets2

func CompareSets2(dbSet interface{}, extSet interface{}, removed interface{}, commonDB interface{}, commonExt interface{}, added interface{}, duplicated interface{}) error

func CompareSetsFunc

func CompareSetsFunc(cs SCompareSet, removed interface{}, commonDB interface{}, commonExt interface{}, added interface{}, duplicated interface{}) error

Types

type SCompareSet

type SCompareSet struct {
	DBFunc  string
	DBSet   interface{}
	ExtFunc string
	ExtSet  interface{}
}

type SyncResult

type SyncResult struct {
	AddCnt       int `json:"add_cnt,omitzero"`
	AddErrCnt    int `json:"add_err_cnt,omitzero"`
	UpdateCnt    int `json:"update_cnt,omitzero"`
	UpdateErrCnt int `json:"update_err_cnt,omitzero"`
	DelCnt       int `json:"del_cnt,omitzero"`
	DelErrCnt    int `json:"del_err_cnt,omitzero"`
	// contains filtered or unexported fields
}

func (*SyncResult) Add

func (self *SyncResult) Add()

func (*SyncResult) AddError

func (self *SyncResult) AddError(msg error)

func (*SyncResult) AllError

func (self *SyncResult) AllError() error

func (*SyncResult) Delete

func (self *SyncResult) Delete()

func (*SyncResult) DeleteError

func (self *SyncResult) DeleteError(msg error)

func (*SyncResult) Error

func (self *SyncResult) Error(msg error)

func (*SyncResult) IsError

func (self *SyncResult) IsError() bool

func (*SyncResult) Result

func (self *SyncResult) Result() string

func (*SyncResult) Update

func (self *SyncResult) Update()

func (*SyncResult) UpdateError

func (self *SyncResult) UpdateError(msg error)