output

Documentation

Index

• func RunProvider(version Version, store Provider) error
• type JobParams
• type Params
• type Provider
• type ProviderMaster
  • func (pm *ProviderMaster) CheckVersion(version string) (matched bool, err error)
  • func (pm *ProviderMaster) Init(setting map[string]interface{}) error
  • func (pm *ProviderMaster) Run(params Params) (replay Replay, err error)
  • func (pm *ProviderMaster) UpdateDeleted(params Params) (replay int32, err error)
  • func (pm *ProviderMaster) UpdateSyncJob(params JobParams) (jobId string, err error)
• type Replay
• type SyncJobInfo
• type Version

Functions

func RunProvider

func RunProvider(version Version, store Provider) error

Types

type JobParams

type JobParams struct {
	Setting  map[string]interface{}
	SyncJob  SyncJobInfo
	Resource string
}

type Params

type Params struct {
	Timestamp int64
	Resource  string
	Setting   map[string]interface{}
	Input     []map[string]interface{}
	Query     map[string]interface{}
}

type Provider

type Provider interface {
	Push(params Params, replay *Replay) (err error)
	UpdateDeleted(params Params, replay *int32) (err error)
	UpdateSyncJob(params JobParams, jobId *string) (err error)
}

type ProviderMaster

type ProviderMaster struct {
	Path string
	// contains filtered or unexported fields
}

func (*ProviderMaster) CheckVersion

func (pm *ProviderMaster) CheckVersion(version string) (matched bool, err error)

func (*ProviderMaster) Init

func (pm *ProviderMaster) Init(setting map[string]interface{}) error

func (*ProviderMaster) Run

func (pm *ProviderMaster) Run(params Params) (replay Replay, err error)

func (*ProviderMaster) UpdateDeleted

func (pm *ProviderMaster) UpdateDeleted(params Params) (replay int32, err error)

func (*ProviderMaster) UpdateSyncJob

func (pm *ProviderMaster) UpdateSyncJob(params JobParams) (jobId string, err error)

type Replay

type Replay struct {
	Status int32
	Output interface{}
}

type SyncJobInfo

type SyncJobInfo struct {
	Index    string
	Resource string
	Type     string
	Value    string
	Status   string
	StartAt  string
	EndAt    string
}

type Version

type Version interface {
	Check(version string, matched *bool) error
}