logics

Documentation

Index

• func SynchronizeFindInfoParameterToQuerycondition(input *metadata.SynchronizeFindInfoParameter) *metadata.QueryCondition
• type FetchAssociation
  • func (fa *FetchAssociation) Fetch(ctx context.Context, dataClassify string, start, limit int64) (*metadata.InstDataInfo, errors.CCError)
  • func (fa *FetchAssociation) SetAppIDArr(appIDArr []int64)
• type FetchInst
  • func (fi *FetchInst) Fetch(ctx context.Context, objID string, start, limit int64) (*metadata.InstDataInfo, errors.CCError)
  • func (fi *FetchInst) Pretreatment() errors.CCError
  • func (fi *FetchInst) SetAppIDArr(appIDArr []int64)
• type FetchModel
  • func (fm *FetchModel) Fetch(ctx context.Context, dataClassify string, cond mapstr.MapStr, ...) (*metadata.InstDataInfo, errors.CCError)
  • func (fm *FetchModel) Pretreatment() errors.CCError
• type Logics
  • func NewLogics(b *backbone.Engine, header http.Header, cache *redis.Client, ...) *Logics
  • func (lgc *Logics) Find(ctx context.Context, input *metadata.SynchronizeFindInfoParameter) (*metadata.InstDataInfo, errors.CCError)
  • func (lgc *Logics) NewFetchAssociation(syncConfig *options.ConfigItem, conds mapstr.MapStr) *FetchAssociation
  • func (lgc *Logics) NewFetchInst(syncConfig *options.ConfigItem, baseConds mapstr.MapStr) *FetchInst
  • func (lgc *Logics) NewFetchModel(syncConfig *options.ConfigItem, conds mapstr.MapStr) *FetchModel
  • func (lgc *Logics) NewFromHeader(header http.Header) *Logics
  • func (lgc *Logics) NewSynchronizeItem(version int64, syncConfig *options.ConfigItem) synchronizeItemInterface
  • func (lgc *Logics) Synchronize(ctx context.Context, config *options.Config)
  • func (lgc *Logics) SynchronizeItem(ctx context.Context, syncConfig *options.ConfigItem)
  • func (lgc *Logics) TriggerSynchronize(ctx context.Context, config *options.Config)

Functions

func SynchronizeFindInfoParameterToQuerycondition

func SynchronizeFindInfoParameterToQuerycondition(input *metadata.SynchronizeFindInfoParameter) *metadata.QueryCondition

SynchronizeFindInfoParameterToQuerycondition SynchronizeFindInfoParameter to Querycondition

Types

type FetchAssociation

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

FetchInst fetch instance struct

func (*FetchAssociation) Fetch

func (fa *FetchAssociation) Fetch(ctx context.Context, dataClassify string, start, limit int64) (*metadata.InstDataInfo, errors.CCError)

Fetch fetch massociation

func (*FetchAssociation) SetAppIDArr

func (fa *FetchAssociation) SetAppIDArr(appIDArr []int64)

SetAppIDArr set app id

type FetchInst

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

FetchInst fetch instance struct

func (*FetchInst) Fetch

func (fi *FetchInst) Fetch(ctx context.Context, objID string, start, limit int64) (*metadata.InstDataInfo, errors.CCError)

Fetch fetch instance data

func (*FetchInst) Pretreatment

func (fi *FetchInst) Pretreatment() errors.CCError

Pretreatment pretreatment handle

func (*FetchInst) SetAppIDArr

func (fi *FetchInst) SetAppIDArr(appIDArr []int64)

SetAppIDArr set app id

type FetchModel

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

FetchModel fetch model description struct

func (*FetchModel) Fetch

func (fm *FetchModel) Fetch(ctx context.Context, dataClassify string, cond mapstr.MapStr, start, limit int64) (*metadata.InstDataInfo, errors.CCError)

Fetch get model info

func (*FetchModel) Pretreatment

func (fm *FetchModel) Pretreatment() errors.CCError

Pretreatment pretreatment handle

type Logics

type Logics struct {
	*backbone.Engine
	// contains filtered or unexported fields
}

func NewLogics

func NewLogics(b *backbone.Engine, header http.Header, cache *redis.Client, synchronizeSrv synchronize.SynchronizeClientInterface) *Logics

NewLogics get logics handle

func (*Logics) Find

func (lgc *Logics) Find(ctx context.Context, input *metadata.SynchronizeFindInfoParameter) (*metadata.InstDataInfo, errors.CCError)

func (*Logics) NewFetchAssociation

func (lgc *Logics) NewFetchAssociation(syncConfig *options.ConfigItem, conds mapstr.MapStr) *FetchAssociation

NewFetchAssociation fetch instance struct

func (*Logics) NewFetchInst

func (lgc *Logics) NewFetchInst(syncConfig *options.ConfigItem, baseConds mapstr.MapStr) *FetchInst

NewFetchInst fetch instance struct

func (*Logics) NewFetchModel

func (lgc *Logics) NewFetchModel(syncConfig *options.ConfigItem, conds mapstr.MapStr) *FetchModel

NewFetchModel fetch instance struct

func (*Logics) NewFromHeader

func (lgc *Logics) NewFromHeader(header http.Header) *Logics

NewFromHeader new Logic from header

func (*Logics) NewSynchronizeItem

func (lgc *Logics) NewSynchronizeItem(version int64, syncConfig *options.ConfigItem) synchronizeItemInterface

func (*Logics) Synchronize

func (lgc *Logics) Synchronize(ctx context.Context, config *options.Config)

Synchronize synchronize manager

func (*Logics) SynchronizeItem

func (lgc *Logics) SynchronizeItem(ctx context.Context, syncConfig *options.ConfigItem)

SynchronizeItem synchronize data

func (*Logics) TriggerSynchronize

func (lgc *Logics) TriggerSynchronize(ctx context.Context, config *options.Config)