customcost

type CostResponse struct {
	Window          opencost.Window `json:"window"`
	TotalBilledCost float32         `json:"totalBilledCost"`
	TotalListCost   float32         `json:"totalListCost"`
	CustomCosts     []*CustomCost   `json:"customCosts"`
}

type CostTimeseriesRequest struct {
	Start       time.Time
	End         time.Time
	AggregateBy []CustomCostProperty
	Accumulate  opencost.AccumulateOption
	Filter      filter.Filter
}

type CostTimeseriesResponse struct {
	Window     opencost.Window `json:"window"`
	Timeseries []*CostResponse `json:"timeseries"`
}

type CostTotalRequest struct {
	Start       time.Time
	End         time.Time
	AggregateBy []CustomCostProperty
	Accumulate  opencost.AccumulateOption
	Filter      filter.Filter
}

type CustomCost struct {
	Id             string  `json:"id"`
	Zone           string  `json:"zone"`
	AccountName    string  `json:"account_name"`
	ChargeCategory string  `json:"charge_category"`
	Description    string  `json:"description"`
	ResourceName   string  `json:"resource_name"`
	ResourceType   string  `json:"resource_type"`
	ProviderId     string  `json:"provider_id"`
	BilledCost     float32 `json:"billedCost"`
	ListCost       float32 `json:"listCost"`
	ListUnitPrice  float32 `json:"list_unit_price"`
	UsageQuantity  float32 `json:"usage_quantity"`
	UsageUnit      string  `json:"usage_unit"`
	Domain         string  `json:"domain"`
	CostSource     string  `json:"cost_source"`
	Aggregate      string  `json:"aggregate"`
}

type CustomCostIngestor struct {
	// contains filtered or unexported fields
}

type CustomCostIngestorConfig struct {
	MonthToDateRunInterval               int
	HourlyDuration, DailyDuration        time.Duration
	DailyQueryWindow, HourlyQueryWindow  time.Duration
	PluginConfigDir, PluginExecutableDir string
}

type CustomCostProperty string

type CustomCostSet struct {
	CustomCosts []*CustomCost
	Window      opencost.Window
}

type IngestorStatus struct {
	Created     time.Time
	LastRun     time.Time
	NextRun     time.Time
	Runs        int
	Coverage    map[string]opencost.Window
	RefreshRate time.Duration
}

type MemoryRepository struct {
	// contains filtered or unexported fields
}

type PipelineService struct {
	// contains filtered or unexported fields
}

type Querier interface {
	QueryTotal(ctx context.Context, request CostTotalRequest) (*CostResponse, error)
	QueryTimeseries(ctx context.Context, request CostTimeseriesRequest) (*CostTimeseriesResponse, error)
}

type QueryService struct {
	Querier Querier
}

type Repository interface {
	Has(time.Time, string) (bool, error)
	Get(time.Time, string) (*pb.CustomCostResponse, error)
	Keys() ([]string, error)
	Put(*pb.CustomCostResponse) error
	Expire(time.Time) error
}

type RepositoryQuerier struct {
	// contains filtered or unexported fields
}

type Status struct {
	Enabled           bool                       `json:"enabled"`
	Domains           []string                   `json:"domains"`
	Key               string                     `json:"key,omitempty"`
	Source            string                     `json:"source,omitempty"`
	Provider          string                     `json:"provider,omitempty"`
	Active            bool                       `json:"active,omitempty"`
	Valid             bool                       `json:"valid,omitempty"`
	LastRun           time.Time                  `json:"lastRun,omitempty"`
	NextRun           time.Time                  `json:"nextRun,omitempty"`
	RefreshRateDaily  string                     `json:"RefreshRateDaily,omitempty"`
	RefreshRateHourly string                     `json:"RefreshRateHourly,omitempty"`
	Created           time.Time                  `json:"created,omitempty"`
	Runs              int                        `json:"runs,omitempty"`
	CoverageHourly    map[string]opencost.Window `json:"coverageHourly,omitempty"`
	CoverageDaily     map[string]opencost.Window `json:"coverageDaily,omitempty"`
	ConnectionStatus  string                     `json:"connectionStatus,omitempty"`
}