data_usage

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

type DataUsageImportConfig struct {
	target.BaseTargetConfig
	TargetFile string
}

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 interface {
	TriggerImport(ctx context.Context, jobId string) (job.JobStatus, string, error)
	GetLastUsage() (*time.Time, error)
}

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

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

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

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