cloudcost

Dec 18, 2025

Changes in this version

type CloudCostIntegration

+ RefreshStatus func() cloud.ConnectionStatus

type IngestionManager

+ func (im *IngestionManager) GetIngestors() map[string]*ingestor

type PipelineService

+ func (s *PipelineService) GetCloudCostQuerier() Querier

type ViewTableRow

+ Names []string

+ Token string

Jun 25, 2024

Changes in this version

type ViewQueryRequest

+ func ParseCloudCostViewRequest(qp httputil.QueryParams) (*ViewQueryRequest, error)

Feb 27, 2024

Changes in this version

type ViewTableRow

+ Labels map[string]string

+ type ViewTotals struct

+ Combined *ViewTableRow

+ NumResults int

Dec 8, 2023

Changes in this version

+ const DefaultChartItemsLength

+ func CloudCostViewTableRowsToCSV(writer *csv.Writer, ctr ViewTableRows, window string) error

+ func DefaultMockCloudCostSet(start, end time.Time, provider, integration string) *kubecost.CloudCostSet

+ func NewIngestor(ingestorConfig IngestorConfig, repo Repository, config cloud.KeyedConfig) (*ingestor, error)

+ func ParseCloudCostProperty(text string) (string, error)

+ type CloudCostIntegration interface

+ GetCloudCost func(time.Time, time.Time) (*kubecost.CloudCostSetRange, error)

+ GetStatus func() cloud.ConnectionStatus

+ func GetIntegrationFromConfig(kc cloud.KeyedConfig) CloudCostIntegration

+ type CloudCostViewTotalsResponse struct

+ Combined *ViewTableRow

+ NumResults int

+ type IngestionManager struct

+ func NewIngestionManager(controller *config.Controller, repo Repository, ingConf IngestorConfig) *IngestionManager

+ func (im *IngestionManager) DeleteConfig(key string)

+ func (im *IngestionManager) PutConfig(kc cloud.KeyedConfig)

+ func (im *IngestionManager) Rebuild(integrationKey string) error

+ func (im *IngestionManager) RebuildAll()

+ func (im *IngestionManager) Repair(integrationKey string, start, end time.Time) error

+ func (im *IngestionManager) RepairAll(start, end time.Time) error

+ func (im *IngestionManager) SetConfigs(configs map[string]cloud.KeyedConfig)

+ func (im *IngestionManager) StartAll()

+ func (im *IngestionManager) StopAll()

+ type IngestorConfig struct

+ Duration time.Duration

+ MonthToDateRunInterval int

+ QueryWindow time.Duration

+ RefreshRate time.Duration

+ Resolution time.Duration

+ RunWindow time.Duration

+ func DefaultIngestorConfiguration() IngestorConfig

+ type IngestorStatus struct

+ ConnectionStatus cloud.ConnectionStatus

+ Coverage kubecost.Window

+ Created time.Time

+ LastRun time.Time

+ NextRun time.Time

+ Runs int

+ type MemoryRepository struct

+ func NewMemoryRepository() *MemoryRepository

+ func (m *MemoryRepository) Expire(limit time.Time) error

+ func (m *MemoryRepository) Get(startTime time.Time, billingIntegration string) (*kubecost.CloudCostSet, error)

+ func (m *MemoryRepository) Has(startTime time.Time, billingIntegration string) (bool, error)

+ func (m *MemoryRepository) Keys() ([]string, error)

+ func (m *MemoryRepository) Put(ccs *kubecost.CloudCostSet) error

+ type PipelineService struct

+ func NewPipelineService(repo Repository, ic *config.Controller, ingConf IngestorConfig) *PipelineService

+ func (dp *PipelineService) Status() []Status

+ func (s *PipelineService) GetCloudCostRebuildHandler() func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *PipelineService) GetCloudCostRepairHandler() func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *PipelineService) GetCloudCostStatusHandler() func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ type Querier interface

+ Query func(QueryRequest, context.Context) (*kubecost.CloudCostSetRange, error)

+ type QueryRequest struct

+ Accumulate kubecost.AccumulateOption

+ AggregateBy []string

+ End time.Time

+ Filter filter.Filter

+ Start time.Time

+ func ParseCloudCostRequest(qp httputil.QueryParams) (*QueryRequest, error)

+ type QueryService struct

+ Querier Querier

+ ViewQuerier ViewQuerier

+ func NewQueryService(querier Querier, viewQuerier ViewQuerier) *QueryService

+ func (s *QueryService) GetCloudCostHandler() func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *QueryService) GetCloudCostViewGraphHandler() func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *QueryService) GetCloudCostViewTableHandler() func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *QueryService) GetCloudCostViewTotalsHandler() func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ type Repository interface

+ Expire func(time.Time) error

+ Get func(time.Time, string) (*kubecost.CloudCostSet, error)

+ Has func(time.Time, string) (bool, error)

+ Keys func() ([]string, error)

+ Put func(*kubecost.CloudCostSet) error

+ type RepositoryQuerier struct

+ func NewRepositoryQuerier(repo Repository) *RepositoryQuerier

+ func (rq *RepositoryQuerier) Query(request QueryRequest, ctx context.Context) (*kubecost.CloudCostSetRange, error)

+ func (rq *RepositoryQuerier) QueryViewGraph(request ViewQueryRequest, ctx context.Context) (ViewGraphData, error)

+ func (rq *RepositoryQuerier) QueryViewTable(request ViewQueryRequest, ctx context.Context) (ViewTableRows, error)

+ func (rq *RepositoryQuerier) QueryViewTotals(request ViewQueryRequest, ctx context.Context) (*ViewTableRow, int, error)

+ type SortDirection string

+ const SortDirectionAscending

+ const SortDirectionDescending

+ const SortDirectionNone

+ func ParseSortDirection(sortDirection string) (SortDirection, error)

+ type SortField string

+ const SortFieldCost

+ const SortFieldKubernetesPercent

+ const SortFieldName

+ const SortFieldNone

+ func ParseSortField(sortColumn string) (SortField, error)

+ type Status struct

+ Active bool

+ Config cloudconfig.Config

+ ConnectionStatus string

+ Coverage string

+ Created time.Time

+ Key string

+ LastRun time.Time

+ NextRun time.Time

+ Provider string

+ RefreshRate string

+ Runs int

+ Source string

+ Valid bool

+ type View struct

+ GraphData ViewGraphData

+ TableRows ViewTableRows

+ TableTotal *ViewTableRow

+ type ViewGraphData []*ViewGraphDataSet

+ func (vgd ViewGraphData) Equal(that ViewGraphData) bool

+ type ViewGraphDataSet struct

+ End time.Time

+ Items []ViewGraphDataSetItem

+ Start time.Time

+ func (vgds *ViewGraphDataSet) Equal(that *ViewGraphDataSet) bool

+ type ViewGraphDataSetItem struct

+ Name string

+ Value float64

+ func (vgdsi ViewGraphDataSetItem) Equal(that ViewGraphDataSetItem) bool

+ type ViewQuerier interface

+ QueryViewGraph func(ViewQueryRequest, context.Context) (ViewGraphData, error)

+ QueryViewTable func(ViewQueryRequest, context.Context) (ViewTableRows, error)

+ QueryViewTotals func(ViewQueryRequest, context.Context) (*ViewTableRow, int, error)

+ type ViewQueryRequest struct

+ ChartItemsLength int

+ CostMetricName kubecost.CostMetricName

+ Limit int

+ Offset int

+ SortColumn SortField

+ SortDirection SortDirection

+ type ViewTableRow struct

+ Cost float64

+ KubernetesPercent float64

+ Name string

+ func (vtr *ViewTableRow) Equal(that *ViewTableRow) bool

+ type ViewTableRows []*ViewTableRow

+ func (vtrs ViewTableRows) Equal(that ViewTableRows) bool