data_usage

Documentation

Index

• type DataSourceLastUsed
• type DataUsageImportConfig
• type DataUsageImportResult
• type DataUsageImporter
  • func NewDataUsageImporter(config *DataUsageImportConfig, statusUpdater job.TaskEventUpdater) DataUsageImporter
• type DataUsageSync
  • func (s *DataUsageSync) GetParts() []job.TaskPart
  • func (s *DataUsageSync) GetResultObject() interface{}
  • func (s *DataUsageSync) ProcessResults(results interface{}) error
  • func (s *DataUsageSync) StartSyncAndQueueTaskPart(client plugin.PluginClient, statusUpdater job.TaskEventUpdater) (job.JobStatus, string, error)
• type LastUsedResponse
• type QueryResponse
• type Response

Types

type DataSourceLastUsed

type DataSourceLastUsed struct {
	Id       string `json:"id"`
	LastUsed string `json:"usageLastUsed"`
}

type DataUsageImportConfig

type DataUsageImportConfig struct {
	target.BaseTargetConfig
	TargetFile string
}

type DataUsageImportResult

type DataUsageImportResult struct {
	StatementsAdded       int `json:"statementsAdded"`
	StatementsFailed      int `json:"statementsFailed"`
	StatementsSkipped     int `json:"statementsSkipped"`
	EdgesCreatedOrUpdated int `json:"edgesCreatedOrUpdated"`
	EdgesRemoved          int `json:"edgesRemoved"`

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

type DataUsageImporter

type DataUsageImporter interface {
	TriggerImport(jobId string) (job.JobStatus, string, error)
	GetLastUsage() (*time.Time, error)
}

func NewDataUsageImporter

func NewDataUsageImporter(config *DataUsageImportConfig, statusUpdater job.TaskEventUpdater) DataUsageImporter

type DataUsageSync

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

func (*DataUsageSync) GetParts

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

func (*DataUsageSync) GetResultObject

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

func (*DataUsageSync) ProcessResults

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

func (*DataUsageSync) StartSyncAndQueueTaskPart

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

type LastUsedResponse

type LastUsedResponse struct {
	DataSourceInfo DataSourceLastUsed `json:"dataSource"`
}

type QueryResponse

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

type Response

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