Documentation
¶
Overview ¶
Copyright 2017 Applatix, Inc.
Copyright 2017 Applatix, Inc.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCSVReader ¶
GetCSVReader returns a CSV reader given a file
func IngestReportFile ¶
func IngestReportFile(repCtx *costdb.CostReportContext, job *manifestJob, reportPath string, run *bool) error
IngestReportFile ingests a report file into the cost database
Types ¶
type IngestSvcContext ¶
type IngestSvcContext struct {
// contains filtered or unexported fields
}
IngestSvcContext is the context wrapper around the ingestd service
func NewIngestSvcContext ¶
func NewIngestSvcContext(userDB *userdb.UserDatabase, costDbURL string, reportDir string, workers int) (*IngestSvcContext, error)
NewIngestSvcContext returns a new ingestd service context
func (*IngestSvcContext) Run ¶
func (isc *IngestSvcContext) Run(port int) error
Run is the main function of the ingestd service. It spawns a background goroutine to periodically check for updates and then has an API endpoint to be notified of new updates (such as a new report being added, or a change in buckets/credentials)
Source Files
Click to show internal directories.
Click to hide internal directories.