Documentation ¶
Index ¶
- func SynchronizeFindInfoParameterToQuerycondition(input *metadata.SynchronizeFindInfoParameter) *metadata.QueryCondition
- type FetchAssociation
- type FetchInst
- type FetchModel
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
Pretreatment pretreatment handle
func (*FetchInst) SetAppIDArr ¶
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 ¶
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 ¶
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 ¶
NewFromHeader new Logic from header
func (*Logics) NewSynchronizeItem ¶
func (lgc *Logics) NewSynchronizeItem(version int64, syncConfig *options.ConfigItem) synchronizeItemInterface
func (*Logics) Synchronize ¶
Synchronize synchronize manager
func (*Logics) SynchronizeItem ¶
func (lgc *Logics) SynchronizeItem(ctx context.Context, syncConfig *options.ConfigItem)
SynchronizeItem synchronize data
Source Files ¶
Click to show internal directories.
Click to hide internal directories.