Versions in this module Expand all Collapse all v1 v1.1.0 Aug 30, 2017 Changes in this version + const EventIngestError + const EventIngestFinished + const EventIngestStart + type CostDatabase struct + ServerURL string + func NewCostDatabase(dbURL string) (costDb *CostDatabase, err error) + func (db *CostDatabase) Close() + func (db *CostDatabase) CreateDatabase() error + func (db *CostDatabase) DropDatabase() error + func (db *CostDatabase) GetIngestStatus(assemblyID string) (*IngestStatus, error) + func (db *CostDatabase) GetIngestStatusByBillingPeriod(bucket, reportPath, billingPeriod string) (*IngestStatus, error) + func (db *CostDatabase) GetReportIDs() ([]string, error) + func (db *CostDatabase) NewCostReportContext(reportID string) *CostReportContext + func (db *CostDatabase) Query(cmd string, args ...interface{}) ([]client.Result, error) + func (db *CostDatabase) Wait() + func (db *CostDatabase) Write(bp client.BatchPoints) error + type CostQuery struct + Aggregator string + Blended bool + Field string + Filters map[string][]string + From time.Time + GroupBy string + Interval Interval + To time.Time + type CostReportContext struct + CostDB *CostDatabase + ReportID string + func (ctx *CostReportContext) Cost(params *CostQuery) ([]models.Row, error) + func (ctx *CostReportContext) CountRecords() (int64, error) + func (ctx *CostReportContext) CreateRetentionPolicy(days int) error + func (ctx *CostReportContext) DeleteAllIngestHistory() error + func (ctx *CostReportContext) DeleteAssemblyIngestHistory(assemblyID string) error + func (ctx *CostReportContext) DeleteBillingBucketHistory(bucketname, reportPath string) error + func (ctx *CostReportContext) DeleteReportBillingBucketData(bucketname, reportPath string) error + func (ctx *CostReportContext) DeleteReportData() error + func (ctx *CostReportContext) DropRetentionPolicy() error + func (ctx *CostReportContext) GetDimension(dimension string, filters map[string][]string) (*Dimension, error) + func (ctx *CostReportContext) GetReportBuckets() ([]*billingbucket.AWSBillingBucket, error) + func (ctx *CostReportContext) GetReportIngestStatuses() ([]*IngestStatus, error) + func (ctx *CostReportContext) GetResourceTagDimension(filters map[string][]string) (*Dimension, error) + func (ctx *CostReportContext) GetRetentionPolicy() (int, error) + func (ctx *CostReportContext) GetServiceDimension(filters map[string][]string) (*Dimension, error) + func (ctx *CostReportContext) GetUsageUnits(serviceName string) ([]*UsageUnit, error) + func (ctx *CostReportContext) NewBatchPoints() (client.BatchPoints, error) + func (ctx *CostReportContext) NewPoint(tags map[string]string, fields map[string]interface{}, t ...time.Time) (*client.Point, error) + func (ctx *CostReportContext) PurgeBillingPeriodSeries(bucketname, reportPath, billingPeriod string) error + func (ctx *CostReportContext) RecordIngestError(manifest billingbucket.Manifest, errorMsg string) error + func (ctx *CostReportContext) RecordIngestFinish(manifest billingbucket.Manifest) error + func (ctx *CostReportContext) RecordIngestStart(manifest billingbucket.Manifest) error + func (ctx *CostReportContext) SeriesCardinality() (int, error) + func (ctx *CostReportContext) TagValues(column parser.Column, filters map[string][]string) ([]string, error) + func (ctx *CostReportContext) UpdateRetentionPolicy(days int) (bool, error) + type Dimension struct + Dimensions []*Dimension + DisplayName string + Name string + UsageUnits []*UsageUnit + type IngestStatus struct + AssemblyID string + BillingPeriod string + Bucket string + ErrorMessage string + FinishTime *time.Time + ParserVersion int + ReportID string + ReportPath string + StartTime *time.Time + func (is *IngestStatus) StatusDetail() (claudia.ReportStatus, string) + type Interval string + const Day + const Hour + const Month + const Week + func ParseInterval(intervalString string) (Interval, error) + type UsageUnit struct + Name string + UsageFamilies []string