data_usage

Documentation

Index

• type DataSourceUsageInfo
• type DataUsageImportConfig
• type DataUsageImportRequest
• type DataUsageImportResult
• type DataUsageImportSettings
• type DataUsageImporter
  • func NewDataUsageImporter(config *DataUsageImportConfig, statusUpdater job.TaskEventUpdater) DataUsageImporter
• type DataUsageSync
  • func (s *DataUsageSync) GetMaxBytesPerFile() uint64
  • func (s *DataUsageSync) GetParts() []job.TaskPart
  • func (s *DataUsageSync) GetResultObject() interface{}
  • func (s *DataUsageSync) GetTaskResults() []job.TaskResult
  • func (s *DataUsageSync) IsClientValid(ctx context.Context, c plugin.PluginClient) (bool, error)
  • func (s *DataUsageSync) ProcessResults(results interface{}) error
  • func (s *DataUsageSync) StartSyncAndQueueTaskPart(ctx context.Context, client plugin.PluginClient, ...) (job.JobStatus, string, error)
• type ID
• type LastUsedResponse

Types

type DataSourceUsageInfo

type DataSourceUsageInfo struct {
	Id        string `json:"id"`
	LastUsed  string `json:"usageLastUsed"`
	FirstUsed string `json:"usageFirstUsed"`
}

type DataUsageImportConfig

type DataUsageImportConfig struct {
	types.BaseTargetConfig
	TargetFile string
}

type DataUsageImportRequest

type DataUsageImportRequest struct {
	JobId          ID                      `json:"jobId"`
	ImportSettings DataUsageImportSettings `json:"importSettings"`
}

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 DataUsageImportSettings

type DataUsageImportSettings struct {
	DataSource ID       `json:"dataSource"`
	FileKeys   []string `json:"fileKeys"`
}

type DataUsageImporter

type DataUsageImporter interface {
	TriggerImport(ctx context.Context, jobId string, files []string) (job.JobStatus, string, error)
	GetLastAndFirstUsage() (*time.Time, *time.Time, error)
}

func NewDataUsageImporter

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

type DataUsageSync

type DataUsageSync struct {
	TargetConfig *types.BaseTargetConfig
	JobId        string
	// contains filtered or unexported fields
}

func (*DataUsageSync) GetMaxBytesPerFile

func (s *DataUsageSync) GetMaxBytesPerFile() uint64

func (*DataUsageSync) GetParts

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

func (*DataUsageSync) GetResultObject

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

func (*DataUsageSync) GetTaskResults

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

func (*DataUsageSync) IsClientValid

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

func (*DataUsageSync) ProcessResults

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

func (*DataUsageSync) StartSyncAndQueueTaskPart

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

type ID

type ID string

type LastUsedResponse

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