data_source

Documentation

Index

• func SetMetaData(config target.BaseTargetConfig, metadata data_source.MetaData) error
• type DataSourceImportConfig
• type DataSourceImportResult
• type DataSourceImporter
  • func NewDataSourceImporter(config *DataSourceImportConfig, statusUpdater job.TaskEventUpdater) DataSourceImporter
• type DataSourceSync
  • func (s *DataSourceSync) GetParts() []job.TaskPart
  • func (s *DataSourceSync) GetResultObject() interface{}
  • func (s *DataSourceSync) ProcessResults(results interface{}) error
  • func (s *DataSourceSync) StartSyncAndQueueTaskPart(client plugin.PluginClient, statusUpdater job.TaskEventUpdater) (job.JobStatus, string, error)
• type QueryResponse
• type Response

Functions

func SetMetaData

func SetMetaData(config target.BaseTargetConfig, metadata data_source.MetaData) error

Types

type DataSourceImportConfig

type DataSourceImportConfig struct {
	target.BaseTargetConfig
	TargetFile      string
	DeleteUntouched bool
	ReplaceTags     bool
}

type DataSourceImportResult

type DataSourceImportResult struct {
	DataObjectsAdded   int `json:"dataObjectsAdded"`
	DataObjectsUpdated int `json:"dataObjectsUpdated"`
	DataObjectsRemoved int `json:"dataObjectsRemoved"`

	Warnings []string `json:"warnings"`
}

type DataSourceImporter

type DataSourceImporter interface {
	TriggerImport(jobId string) (job.JobStatus, string, error)
}

func NewDataSourceImporter

func NewDataSourceImporter(config *DataSourceImportConfig, statusUpdater job.TaskEventUpdater) DataSourceImporter

type DataSourceSync

type DataSourceSync struct {
	TargetConfig *target.BaseTargetConfig
	JobId        string
}

func (*DataSourceSync) GetParts

func (s *DataSourceSync) GetParts() []job.TaskPart

func (*DataSourceSync) GetResultObject

func (s *DataSourceSync) GetResultObject() interface{}

func (*DataSourceSync) ProcessResults

func (s *DataSourceSync) ProcessResults(results interface{}) error

func (*DataSourceSync) StartSyncAndQueueTaskPart

func (s *DataSourceSync) StartSyncAndQueueTaskPart(client plugin.PluginClient, statusUpdater job.TaskEventUpdater) (job.JobStatus, string, error)

type QueryResponse

type QueryResponse struct {
	Subtask subtaskResponse `json:"subtask"`
}

type Response

type Response struct {
	Response QueryResponse `json:"importDataSourceRequest"`
}