ingest

Documentation

Overview

Copyright 2017 Applatix, Inc.

Copyright 2017 Applatix, Inc.

Index

• func GetCSVReader(file *os.File) (*csv.Reader, error)
• func IngestReportFile(repCtx *costdb.CostReportContext, job *manifestJob, reportPath string, ...) error
• type IngestSvcContext
  • func NewIngestSvcContext(userDB *userdb.UserDatabase, costDbURL string, reportDir string, workers int) (*IngestSvcContext, error)
  • func (isc *IngestSvcContext) Run(port int) error

Functions

func GetCSVReader

func GetCSVReader(file *os.File) (*csv.Reader, error)

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)