data_source

Documentation

Index

• func SetMetaData(ctx context.Context, config *target.BaseTargetConfig, ...) 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) GetTaskResults() []job.TaskResult
  • func (s *DataSourceSync) IsClientValid(ctx context.Context, c plugin.PluginClient) (bool, error)
  • func (s *DataSourceSync) ProcessResults(results interface{}) error
  • func (s *DataSourceSync) StartSyncAndQueueTaskPart(ctx context.Context, client plugin.PluginClient, ...) (job.JobStatus, string, error)
• type QueryResponse
• type Response

Functions

func SetMetaData

func SetMetaData(ctx context.Context, config *target.BaseTargetConfig, metadata *data_source.MetaData) error

Types

type DataSourceImportConfig

type DataSourceImportConfig struct {
	target.BaseTargetConfig
	TargetFile      string
	DeleteUntouched 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(ctx context.Context, 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
	// contains filtered or unexported fields
}

func (*DataSourceSync) GetParts

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

func (*DataSourceSync) GetResultObject

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

func (*DataSourceSync) GetTaskResults

func (s *DataSourceSync) GetTaskResults() []job.TaskResult

func (*DataSourceSync) IsClientValid

func (s *DataSourceSync) IsClientValid(ctx context.Context, c plugin.PluginClient) (bool, error)

func (*DataSourceSync) ProcessResults

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

func (*DataSourceSync) StartSyncAndQueueTaskPart

func (s *DataSourceSync) StartSyncAndQueueTaskPart(ctx context.Context, 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"`
}