kubecost

Dec 8, 2023

Changes in this version

type AccumulateOption

+ func ParseAccumulate(acc string) AccumulateOption

type CloudCostSetRange

+ func (ccsr *CloudCostSetRange) AccumulateAll() (*CloudCostSet, error)

+ func (ccsr *CloudCostSetRange) Append(that *CloudCostSet)

+ type CostMetricName string

+ const CostMetricAmortizedCost

+ const CostMetricAmortizedNetCost

+ const CostMetricInvoicedCost

+ const CostMetricListCost

+ const CostMetricNetCost

+ const CostMetricNone

+ func ParseCostMetricName(costMetric string) (CostMetricName, error)

type Window

+ func (w Window) GetAccumulateWindow(accumOpt AccumulateOption) (Window, error)

+ func (w Window) GetAccumulateWindows(accumOpt AccumulateOption) ([]Window, error)

Oct 31, 2023

Changes in this version

+ func NewCloudCostMatchCompiler() *matcher.MatchCompiler[*CloudCost]

type AccumulateOption

+ const AccumulateOptionQuarter

type BoundaryError

+ func (be *BoundaryError) Is(target error) bool

+ type CloudCostMatcher matcher.Matcher[*CloudCost]

type CloudCostSet

+ func (ccs *CloudCostSet) Filter21(filters filter21.Filter) (*CloudCostSet, error)

type NodeOverhead

+ func (n *NodeOverhead) Clone() *NodeOverhead

+ func (n *NodeOverhead) Equal(other *NodeOverhead) bool

Oct 9, 2023

Changes in this version

type Allocation

+ UnmountedPVCost float64

+ func (a *Allocation) SetUnmountedPVCost() float64

type AllocationAggregationOptions

+ Share filter21.Filter

type AllocationSet

+ func (as *AllocationSet) GetUnmountedPVCost() float64

+ func (as *AllocationSet) SetUnmountedPVCost() float64

type AllocationTotals

+ UnmountedPVCost float64

+ func (arts *AllocationTotals) ToResponse() *AllocationTotalsResponse

+ type AllocationTotalsResponse struct

+ CPUCost *float64

+ CPUCostAdjustment *float64

+ Cluster string

+ Count int

+ End time.Time

+ GPUCost *float64

+ GPUCostAdjustment *float64

+ LoadBalancerCost *float64

+ LoadBalancerCostAdjustment *float64

+ NetworkCost *float64

+ NetworkCostAdjustment *float64

+ Node string

+ PersistentVolumeCost *float64

+ PersistentVolumeCostAdjustment *float64

+ RAMCost *float64

+ RAMCostAdjustment *float64

+ Start time.Time

+ TotalCost *float64

+ type AllocationTotalsResult struct

+ Cluster map[string]*AllocationTotals

+ Node map[string]*AllocationTotals

+ func (atr *AllocationTotalsResult) ToResponse() *AllocationTotalsResultResponse

+ type AllocationTotalsResultResponse struct

+ Cluster map[string]*AllocationTotalsResponse

+ Node map[string]*AllocationTotalsResponse

+ type AssetTotalsResult struct

+ Cluster map[string]*AssetTotals

+ Node map[string]*AssetTotals

type CloudCost

+ func (cc *CloudCost) WeightCostMetrics(weightedAverge float64)

type PVAllocation

+ ProviderID string

type SummaryAllocation

+ UnmountedPVCost float64

type SummaryAllocationResponse

+ TotalCost *float64

+ TotalEfficiency *float64

type SummaryAllocationSet

+ func (sas *SummaryAllocationSet) GetUnmountedPVCost() float64

Aug 31, 2023

Changes in this version

type Allocation

+ func (a *Allocation) SanitizeNaN()

type AllocationSet

+ func (as *AllocationSet) SanitizeNaN()

type Any

+ func (a *Any) SanitizeNaN()

type Asset

+ SanitizeNaN func()

type AssetSet

+ func (as *AssetSet) SanitizeNaN()

type Breakdown

+ func (b *Breakdown) SanitizeNaN()

type Cloud

+ func (ca *Cloud) SanitizeNaN()

type ClusterManagement

+ func (cm *ClusterManagement) SanitizeNaN()

type Disk

+ func (d *Disk) SanitizeNaN()

type LbAllocation

+ Ip string

+ func (lba *LbAllocation) SanitizeNaN()

type LbAllocations

+ func (thisLbAllocs LbAllocations) SanitizeNaN()

type LoadBalancer

+ Ip string

+ func (lb *LoadBalancer) SanitizeNaN()

type Network

+ func (n *Network) SanitizeNaN()

type Node

+ func (n *Node) SanitizeNaN()

type NodeOverhead

+ func (n *NodeOverhead) SanitizeNaN()

type PVAllocation

+ func (pva *PVAllocation) SanitizeNaN()

type PVAllocations

+ func (pvs PVAllocations) SanitizeNaN()

type ProportionalAssetResourceCost

+ PVPercentage float64

+ PVProportionalCost float64

+ PVTotalCost float64

type ProportionalAssetResourceCosts

+ func (parcs ProportionalAssetResourceCosts) SanitizeNaN()

type RawAllocationOnlyData

+ func (r *RawAllocationOnlyData) SanitizeNaN()

type SharedAsset

+ func (sa *SharedAsset) SanitizeNaN()

type SharedCostBreakdowns

+ func (scbs SharedCostBreakdowns) SanitizeNaN()

Jul 11, 2023

Changes in this version

+ func ComputePercentages(toInsert *ProportionalAssetResourceCost)

+ func NewAllocationAliasPass(config LabelConfig) transform.CompilerPass

+ func NewAllocationMatchCompiler(labelConfig *LabelConfig) *matcher.MatchCompiler[*Allocation]

+ func NewAssetMatchCompiler() *matcher.MatchCompiler[Asset]

type Allocation

+ LoadBalancers LbAllocations

type AllocationJSON

+ LoadBalancers LbAllocations

+ type AllocationMatcher matcher.Matcher[*Allocation]

type AssetAggregationOptions

+ Filter filter21.Filter

+ type AssetMatcher matcher.Matcher[Asset]

type AssetQueryOptions

+ Filter filter21.Filter

type AssetTotals

+ PrivateLoadBalancer bool

type CloudUsageQueryOptions

+ Filter filter21.Filter

+ type LbAllocation struct

+ Cost float64

+ Private bool

+ Service string

+ func (target *LbAllocation) MarshalBinary() (data []byte, err error)

+ func (target *LbAllocation) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *LbAllocation) UnmarshalBinary(data []byte) error

+ func (target *LbAllocation) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type LbAllocations map[string]*LbAllocation

+ func (orig LbAllocations) Clone() LbAllocations

+ func (thisLbAllocs LbAllocations) Add(thatLbAllocs LbAllocations) LbAllocations

type LoadBalancer

+ Private bool

type ProportionalAssetResourceCost

+ LoadBalancerPercentage float64

+ LoadBalancerProportionalCost float64

+ LoadBalancerTotalCost float64

+ Name string

+ Type string

Jun 13, 2023

Changes in this version

type AllocationProperties

+ NamespaceAnnotations AllocationAnnotations

+ NamespaceLabels AllocationLabels

Jun 8, 2023

Changes in this version

+ const AKSNodepoolLabel

+ const AmortizedCostMetric

+ const EKSNodepoolLabel

+ const GKENodePoolLabel

+ func GetNodePoolName(provider string, labels map[string]string) string

type Allocation

+ SharedCostBreakdown SharedCostBreakdowns

type AllocationAggregationOptions

+ IncludeSharedCostBreakdown bool

+ SharedLabels map[string][]string

+ SharedNamespaces []string

type AllocationJSON

+ SharedCostBreakdown *SharedCostBreakdowns

type CloudCost

+ AmortizedCost CostMetric

type CloudStatus

+ ConnectionStatus string

type Node

+ Overhead *NodeOverhead

+ type NodeOverhead struct

+ CpuOverheadFraction float64

+ OverheadCostFraction float64

+ RamOverheadFraction float64

+ func (target *NodeOverhead) MarshalBinary() (data []byte, err error)

+ func (target *NodeOverhead) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *NodeOverhead) UnmarshalBinary(data []byte) error

+ func (target *NodeOverhead) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

type ProportionalAssetResourceCost

+ CPUProportionalCost float64

+ CPUTotalCost float64

+ GPUProportionalCost float64

+ GPUTotalCost float64

+ NodeResourceCostPercentage float64

+ RAMProportionalCost float64

+ RAMTotalCost float64

type ProportionalAssetResourceCosts

+ func (parcs ProportionalAssetResourceCosts) Clone() ProportionalAssetResourceCosts

+ type SharedCostBreakdown struct

+ CPUCost float64

+ ExternalCost float64

+ GPUCost float64

+ LBCost float64

+ Name string

+ NetworkCost float64

+ PVCost float64

+ RAMCost float64

+ TotalCost float64

+ type SharedCostBreakdowns map[string]SharedCostBreakdown

+ func (scbs SharedCostBreakdowns) Add(that SharedCostBreakdowns)

+ func (scbs SharedCostBreakdowns) Clone() SharedCostBreakdowns

+ func (scbs SharedCostBreakdowns) Insert(scb SharedCostBreakdown)

May 2, 2023

Changes in this version

+ const AmortizedNetCostMetric

+ const CloudCostAccountIDProp

+ const CloudCostCategoryProp

+ const CloudCostClusterManagementCategory

+ const CloudCostCodecVersion

+ const CloudCostDiskCategory

+ const CloudCostInvoiceEntityIDProp

+ const CloudCostLoadBalancerCategory

+ const CloudCostNetworkCategory

+ const CloudCostOtherCategory

+ const CloudCostProviderIDProp

+ const CloudCostVirtualMachineCategory

+ const InvoicedCostMetric

+ const ListCostMetric

+ const NetCostMetric

type Allocation

+ ProportionalAssetResourceCosts ProportionalAssetResourceCosts

type AllocationAggregationOptions

+ IncludeAggregatedMetadata bool

+ IncludeProportionalAssetResourceCosts bool

type AllocationJSON

+ ProportionalAssetResourceCosts *ProportionalAssetResourceCosts

type AllocationProperties

+ AggregatedMetadata bool

+ type CloudCost struct

+ AmortizedNetCost CostMetric

+ InvoicedCost CostMetric

+ ListCost CostMetric

+ NetCost CostMetric

+ Properties *CloudCostProperties

+ Window Window

+ func NewCloudCost(start, end time.Time, ccProperties *CloudCostProperties, ...) *CloudCost

+ func (cc *CloudCost) Clone() *CloudCost

+ func (cc *CloudCost) Equal(that *CloudCost) bool

+ func (cc *CloudCost) GetCostMetric(costMetricName string) (CostMetric, error)

+ func (cc *CloudCost) StringMapProperty(property string) (map[string]string, error)

+ func (cc *CloudCost) StringProperty(prop string) (string, error)

+ func (target *CloudCost) MarshalBinary() (data []byte, err error)

+ func (target *CloudCost) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCost) UnmarshalBinary(data []byte) error

+ func (target *CloudCost) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostLabels map[string]string

+ func (ccl CloudCostLabels) Clone() CloudCostLabels

+ func (ccl CloudCostLabels) Equal(that CloudCostLabels) bool

+ func (ccl CloudCostLabels) Intersection(that CloudCostLabels) CloudCostLabels

+ type CloudCostProperties struct

+ AccountID string

+ Category string

+ InvoiceEntityID string

+ Labels CloudCostLabels

+ Provider string

+ ProviderID string

+ Service string

+ func (ccp *CloudCostProperties) Clone() *CloudCostProperties

+ func (ccp *CloudCostProperties) Equal(that *CloudCostProperties) bool

+ func (ccp *CloudCostProperties) GenerateKey(props []string) string

+ func (ccp *CloudCostProperties) Intersection(that *CloudCostProperties) *CloudCostProperties

+ func (target *CloudCostProperties) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostProperties) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostProperties) UnmarshalBinary(data []byte) error

+ func (target *CloudCostProperties) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostSet struct

+ AggregationProperties []string

+ CloudCosts map[string]*CloudCost

+ Integration string

+ Window Window

+ func NewCloudCostSet(start, end time.Time, cloudCosts ...*CloudCost) *CloudCostSet

+ func (ccs *CloudCostSet) Accumulate(that *CloudCostSet) (*CloudCostSet, error)

+ func (ccs *CloudCostSet) Aggregate(props []string) (*CloudCostSet, error)

+ func (ccs *CloudCostSet) Clone() *CloudCostSet

+ func (ccs *CloudCostSet) Equal(that *CloudCostSet) bool

+ func (ccs *CloudCostSet) Filter(filters filter.Filter[*CloudCost]) *CloudCostSet

+ func (ccs *CloudCostSet) GetWindow() Window

+ func (ccs *CloudCostSet) Insert(cc *CloudCost) error

+ func (ccs *CloudCostSet) IsEmpty() bool

+ func (ccs *CloudCostSet) Length() int

+ func (ccs *CloudCostSet) Merge(that *CloudCostSet) (*CloudCostSet, error)

+ func (target *CloudCostSet) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostSet) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostSet) UnmarshalBinary(data []byte) error

+ func (target *CloudCostSet) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostSetRange struct

+ CloudCostSets []*CloudCostSet

+ Window Window

+ func NewCloudCostSetRange(start time.Time, end time.Time, window time.Duration, integration string) (*CloudCostSetRange, error)

+ func (ccsr *CloudCostSetRange) Accumulate() (*CloudCostSet, error)

+ func (ccsr *CloudCostSetRange) Clone() *CloudCostSetRange

+ func (ccsr *CloudCostSetRange) IsEmpty() bool

+ func (ccsr *CloudCostSetRange) LoadCloudCost(cloudCost *CloudCost)

+ func (target *CloudCostSetRange) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostSetRange) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostSetRange) UnmarshalBinary(data []byte) error

+ func (target *CloudCostSetRange) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CostMetric struct

+ Cost float64

+ KubernetesPercent float64

+ func (cm CostMetric) Clone() CostMetric

+ func (cm CostMetric) Equal(that CostMetric) bool

+ func (target *CostMetric) MarshalBinary() (data []byte, err error)

+ func (target *CostMetric) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CostMetric) UnmarshalBinary(data []byte) error

+ func (target *CostMetric) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type ProportionalAssetResourceCost struct

+ CPUPercentage float64

+ Cluster string

+ GPUPercentage float64

+ Node string

+ ProviderID string

+ RAMPercentage float64

+ func (parc ProportionalAssetResourceCost) Key(insertByNode bool) string

+ type ProportionalAssetResourceCosts map[string]ProportionalAssetResourceCost

+ func (parcs ProportionalAssetResourceCosts) Add(that ProportionalAssetResourceCosts)

+ func (parcs ProportionalAssetResourceCosts) Insert(parc ProportionalAssetResourceCost, insertByNode bool)

Apr 4, 2023

Changes in this version

+ type AccumulateOption string

+ const AccumulateOptionAll

+ const AccumulateOptionDay

+ const AccumulateOptionHour

+ const AccumulateOptionMonth

+ const AccumulateOptionNone

+ const AccumulateOptionWeek

type AllocationSetRange

+ func (asr *AllocationSetRange) Clone() *AllocationSetRange

type AssetSetRange

+ func (asr *AssetSetRange) AccumulateToAssetSet() (*AssetSet, error)

type SummaryAllocation

+ func NewMockUnitSummaryAllocation(name string, start time.Time, resolution time.Duration, ...) *SummaryAllocation

+ func (sa *SummaryAllocation) Equal(that *SummaryAllocation) bool

+ func (sa *SummaryAllocation) ToResponse() *SummaryAllocationResponse

+ type SummaryAllocationResponse struct

+ CPUCoreRequestAverage *float64

+ CPUCoreUsageAverage *float64

+ CPUCost *float64

+ End time.Time

+ ExternalCost *float64

+ GPUCost *float64

+ LoadBalancerCost *float64

+ Name string

+ NetworkCost *float64

+ PVCost *float64

+ RAMBytesRequestAverage *float64

+ RAMBytesUsageAverage *float64

+ RAMCost *float64

+ SharedCost *float64

+ Start time.Time

type SummaryAllocationSet

+ func NewMockUnitSummaryAllocationSet(start time.Time, resolution time.Duration) *SummaryAllocationSet

+ func (sas *SummaryAllocationSet) Equal(that *SummaryAllocationSet) bool

+ func (sas *SummaryAllocationSet) ToResponse() *SummaryAllocationSetResponse

type SummaryAllocationSetRange

+ func (sasr *SummaryAllocationSetRange) Clone() *SummaryAllocationSetRange

+ func (sasr *SummaryAllocationSetRange) ToResponse() *SummaryAllocationSetRangeResponse

+ type SummaryAllocationSetRangeResponse struct

+ Step time.Duration

+ SummaryAllocationSets []*SummaryAllocationSetResponse

+ Window Window

+ func EmptySummaryAllocationSetRangeResponse() *SummaryAllocationSetRangeResponse

+ type SummaryAllocationSetResponse struct

+ SummaryAllocations map[string]*SummaryAllocationResponse

+ Window Window

type Window

+ func (w *Window) UnmarshalJSON(bs []byte) error

Mar 10, 2023

Changes in this version

+ const AWSMatchLabel1

+ const AWSMatchLabel2

+ const AlibabaMatchLabel1

+ const GCPMatchLabel1

+ type AllocationJSON struct

+ CPUCoreHours *float64

+ CPUCoreRequestAverage *float64

+ CPUCoreUsageAverage *float64

+ CPUCores *float64

+ CPUCost *float64

+ CPUCostAdjustment *float64

+ CPUEfficiency *float64

+ End string

+ ExternalCost *float64

+ GPUCost *float64

+ GPUCostAdjustment *float64

+ GPUCount *float64

+ GPUHours *float64

+ LoadBalancerCost *float64

+ LoadBalancerCostAdjustment *float64

+ Minutes *float64

+ Name string

+ NetworkCost *float64

+ NetworkCostAdjustment *float64

+ NetworkCrossRegionCost *float64

+ NetworkCrossZoneCost *float64

+ NetworkInternetCost *float64

+ NetworkReceiveBytes *float64

+ NetworkTransferBytes *float64

+ PVByteHours *float64

+ PVBytes *float64

+ PVCost *float64

+ PVCostAdjustment *float64

+ PVs PVAllocations

+ Properties *AllocationProperties

+ RAMByteHours *float64

+ RAMByteRequestAverage *float64

+ RAMByteUsageAverage *float64

+ RAMBytes *float64

+ RAMCost *float64

+ RAMCostAdjustment *float64

+ RAMEfficiency *float64

+ RawAllocationOnly *RawAllocationOnlyData

+ SharedCost *float64

+ Start string

+ TotalCost *float64

+ TotalEfficiency *float64

+ Window Window

+ func (aj *AllocationJSON) BuildFromAllocation(a *Allocation)

type AssetSet

+ func (as *AssetSet) MonitoredNodeForCloudCostItem(cci *CloudCostItem) *Node

type AssetSetRange

+ func (asr *AssetSetRange) GetWarnings() []string

+ func (asr *AssetSetRange) HasWarnings() bool

type CloudCostItem

+ func GenerateAWSMockCCIAndPID(mockProviderIDInt int, mockCloudIDInt int, labelKey string, ...) (*CloudCostItem, string)

+ func GenerateAlibabaMockCCIAndPID(mockProviderIDInt int, mockCloudIDInt int, labelKey string, ...) (*CloudCostItem, string)

+ func GenerateGCPMockCCIAndPID(mockProviderIDInt int, mockCloudIDInt int, labelKey string, ...) (*CloudCostItem, string)

+ func (cci *CloudCostItem) GetAWSCluster() string

+ func (cci *CloudCostItem) GetAlibabaCluster() string

+ func (cci *CloudCostItem) GetAzureCluster() string

+ func (cci *CloudCostItem) GetCluster() string

+ func (cci *CloudCostItem) GetGCPCluster() string

+ func (cci *CloudCostItem) MonitoringKey() string

type CloudCostItemProperties

+ func (ccip CloudCostItemProperties) MonitoringKey() string

type CloudCostItemSet

+ func (ccis *CloudCostItemSet) Accumulate(that *CloudCostItemSet) (*CloudCostItemSet, error)

type CloudCostItemSetRange

+ func (ccisr *CloudCostItemSetRange) Accumulate() (*CloudCostItemSet, error)

type Node

+ func GenerateKubecostNodeAndPID(mockProviderIDInt int, provider string, mockClusterID int, ...) (*Node, string)

+ func (n *Node) MonitoringKey() string

Feb 7, 2023

Changes in this version

+ const CloudCostBillingIDProp

+ const CloudCostWorkGroupIDProp

type Allocation

+ NetworkCrossRegionCost float64

+ NetworkCrossZoneCost float64

+ NetworkInternetCost float64

type CloudCostAggregate

+ NetCost float64

+ func NewCloudCostAggregate(properties CloudCostAggregateProperties, ...) *CloudCostAggregate

type CloudCostAggregateProperties

+ BillingID string

+ WorkGroupID string

+ func (ccap CloudCostAggregateProperties) Intersection(that CloudCostAggregateProperties) CloudCostAggregateProperties

type CloudCostAggregateSetRange

+ func NewCloudCostAggregateSetRange(start, end time.Time, window time.Duration, integration string, ...) (*CloudCostAggregateSetRange, error)

+ func (ccasr *CloudCostAggregateSetRange) Clone() *CloudCostAggregateSetRange

+ func (ccasr *CloudCostAggregateSetRange) IsEmpty() bool

+ func (ccasr *CloudCostAggregateSetRange) LoadCloudCostAggregate(window Window, cloudCostAggregate *CloudCostAggregate)

type CloudCostItem

+ NetCost float64

+ func NewCloudCostItem(start, end time.Time, cciProperties CloudCostItemProperties, isKubernetes bool, ...) *CloudCostItem

type CloudCostItemProperties

+ BillingID string

+ WorkGroupID string

type CloudCostItemSetRange

+ func NewCloudCostItemSetRange(start time.Time, end time.Time, window time.Duration, integration string) (*CloudCostItemSetRange, error)

+ func (ccisr *CloudCostItemSetRange) Clone() *CloudCostItemSetRange

+ func (ccisr *CloudCostItemSetRange) LoadCloudCostItem(cloudCostItem *CloudCostItem)

Dec 13, 2022

Changes in this version

+ const AlibabaProvider

+ const CloudCostAccountProp

+ const CloudCostAggregateCodecVersion

+ const CloudCostItemCodecVersion

+ const CloudCostLabelProp

+ const CloudCostProjectProp

+ const CloudCostProviderProp

+ const CloudCostServiceProp

+ const CustomProvider

+ func LoadCloudCostAggregateSets(itemStart time.Time, itemEnd time.Time, ...)

+ func LoadCloudCostItemSets(itemStart time.Time, itemEnd time.Time, properties CloudCostItemProperties, ...)

type Allocation

+ func (a *Allocation) GetWindow() Window

+ func (a *Allocation) StringMapProperty(property string) (map[string]string, error)

+ func (a *Allocation) StringProperty(property string) (string, error)

+ func (a *Allocation) StringSliceProperty(property string) ([]string, error)

type AssetAggregationOptions

+ LabelConfig *LabelConfig

type AssetProperty

+ const AssetDepartmentProp

+ const AssetEnvironmentProp

+ const AssetOwnerProp

+ const AssetProductProp

+ const AssetTeamProp

type AssetQueryOptions

+ LabelConfig *LabelConfig

+ type CloudCostAggregate struct

+ Cost float64

+ Credit float64

+ KubernetesPercent float64

+ Properties CloudCostAggregateProperties

+ func (cca *CloudCostAggregate) Clone() *CloudCostAggregate

+ func (cca *CloudCostAggregate) Equal(that *CloudCostAggregate) bool

+ func (cca *CloudCostAggregate) Key(props []string) string

+ func (cca *CloudCostAggregate) StringProperty(prop string) (string, error)

+ func (target *CloudCostAggregate) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostAggregate) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostAggregate) UnmarshalBinary(data []byte) error

+ func (target *CloudCostAggregate) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostAggregateProperties struct

+ Account string

+ LabelValue string

+ Project string

+ Provider string

+ Service string

+ func (ccap CloudCostAggregateProperties) Equal(that CloudCostAggregateProperties) bool

+ func (ccap CloudCostAggregateProperties) Key(props []string) string

+ func (target *CloudCostAggregateProperties) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostAggregateProperties) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostAggregateProperties) UnmarshalBinary(data []byte) error

+ func (target *CloudCostAggregateProperties) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostAggregateSet struct

+ AggregationProperties []string

+ CloudCostAggregates map[string]*CloudCostAggregate

+ Integration string

+ LabelName string

+ Window Window

+ func GetCloudCostAggregateSets(start, end time.Time, windowDuration time.Duration, integration string, ...) ([]*CloudCostAggregateSet, error)

+ func NewCloudCostAggregateSet(start, end time.Time, cloudCostAggregates ...*CloudCostAggregate) *CloudCostAggregateSet

+ func (ccas *CloudCostAggregateSet) Aggregate(props []string) (*CloudCostAggregateSet, error)

+ func (ccas *CloudCostAggregateSet) Clone() *CloudCostAggregateSet

+ func (ccas *CloudCostAggregateSet) Equal(that *CloudCostAggregateSet) bool

+ func (ccas *CloudCostAggregateSet) Filter(filters filter.Filter[*CloudCostAggregate]) *CloudCostAggregateSet

+ func (ccas *CloudCostAggregateSet) GetWindow() Window

+ func (ccas *CloudCostAggregateSet) Insert(that *CloudCostAggregate) error

+ func (ccas *CloudCostAggregateSet) IsEmpty() bool

+ func (ccas *CloudCostAggregateSet) Length() int

+ func (ccas *CloudCostAggregateSet) Merge(that *CloudCostAggregateSet) (*CloudCostAggregateSet, error)

+ func (target *CloudCostAggregateSet) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostAggregateSet) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostAggregateSet) UnmarshalBinary(data []byte) error

+ func (target *CloudCostAggregateSet) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostAggregateSetRange struct

+ CloudCostAggregateSets []*CloudCostAggregateSet

+ Window Window

+ func (ccasr *CloudCostAggregateSetRange) Accumulate() (*CloudCostAggregateSet, error)

+ func (target *CloudCostAggregateSetRange) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostAggregateSetRange) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostAggregateSetRange) UnmarshalBinary(data []byte) error

+ func (target *CloudCostAggregateSetRange) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostItem struct

+ Cost float64

+ Credit float64

+ IsKubernetes bool

+ Properties CloudCostItemProperties

+ Window Window

+ func (cci *CloudCostItem) Clone() *CloudCostItem

+ func (cci *CloudCostItem) Equal(that *CloudCostItem) bool

+ func (cci *CloudCostItem) Key() string

+ func (target *CloudCostItem) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostItem) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostItem) UnmarshalBinary(data []byte) error

+ func (target *CloudCostItem) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostItemLabels map[string]string

+ func (ccil CloudCostItemLabels) Clone() CloudCostItemLabels

+ func (ccil CloudCostItemLabels) Equal(that CloudCostItemLabels) bool

+ type CloudCostItemProperties struct

+ Account string

+ Category string

+ Labels CloudCostItemLabels

+ Project string

+ Provider string

+ ProviderID string

+ Service string

+ func (ccip CloudCostItemProperties) Clone() CloudCostItemProperties

+ func (ccip CloudCostItemProperties) Equal(that CloudCostItemProperties) bool

+ func (ccip CloudCostItemProperties) Key() string

+ func (target *CloudCostItemProperties) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostItemProperties) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostItemProperties) UnmarshalBinary(data []byte) error

+ func (target *CloudCostItemProperties) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostItemSet struct

+ CloudCostItems map[string]*CloudCostItem

+ Integration string

+ Window Window

+ func GetCloudCostItemSets(start time.Time, end time.Time, window time.Duration, integration string) ([]*CloudCostItemSet, error)

+ func NewCloudCostItemSet(start, end time.Time, cloudCostItems ...*CloudCostItem) *CloudCostItemSet

+ func (ccis *CloudCostItemSet) Clone() *CloudCostItemSet

+ func (ccis *CloudCostItemSet) Equal(that *CloudCostItemSet) bool

+ func (ccis *CloudCostItemSet) Filter(filters filter.Filter[*CloudCostItem]) *CloudCostItemSet

+ func (ccis *CloudCostItemSet) GetWindow() Window

+ func (ccis *CloudCostItemSet) Insert(that *CloudCostItem) error

+ func (ccis *CloudCostItemSet) IsEmpty() bool

+ func (ccis *CloudCostItemSet) Length() int

+ func (ccis *CloudCostItemSet) Merge(that *CloudCostItemSet) (*CloudCostItemSet, error)

+ func (target *CloudCostItemSet) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostItemSet) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostItemSet) UnmarshalBinary(data []byte) error

+ func (target *CloudCostItemSet) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudCostItemSetRange struct

+ CloudCostItemSets []*CloudCostItemSet

+ Window Window

+ func (target *CloudCostItemSetRange) MarshalBinary() (data []byte, err error)

+ func (target *CloudCostItemSetRange) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CloudCostItemSetRange) UnmarshalBinary(data []byte) error

+ func (target *CloudCostItemSetRange) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

type CloudUsageQueryOptions

+ LabelConfig *LabelConfig

+ type Coverage struct

+ Count int

+ Errors []string

+ Type string

+ Updated time.Time

+ Warnings []string

+ Window Window

+ func (c *Coverage) Clone() *Coverage

+ func (c *Coverage) GetWindow() Window

+ func (c *Coverage) IsEmpty() bool

+ func (c *Coverage) Key() string

+ func (target *Coverage) MarshalBinary() (data []byte, err error)

+ func (target *Coverage) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Coverage) UnmarshalBinary(data []byte) error

+ func (target *Coverage) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CoverageSet struct

+ Items map[string]*Coverage

+ Window Window

+ func NewCoverageSet(start, end time.Time) *CoverageSet

+ func (cs *CoverageSet) Clone() *CoverageSet

+ func (cs *CoverageSet) Filter(filters filter.Filter[*Coverage]) *CoverageSet

+ func (cs *CoverageSet) GetWindow() Window

+ func (cs *CoverageSet) Insert(coverage *Coverage)

+ func (cs *CoverageSet) IsEmpty() bool

+ func (target *CoverageSet) MarshalBinary() (data []byte, err error)

+ func (target *CoverageSet) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *CoverageSet) UnmarshalBinary(data []byte) error

+ func (target *CoverageSet) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

type Window

+ func GetWindows(start time.Time, end time.Time, windowSize time.Duration) ([]Window, error)

+ func GetWindowsForQueryWindow(start time.Time, end time.Time, queryWindow time.Duration) ([]Window, error)

+ func (w Window) GetPercentInWindow(itemStart time.Time, itemEnd time.Time) float64

Nov 2, 2022

Changes in this version

+ const FilterAlias

+ func GetAssetKey(a Asset, aggregateBy []string) (string, error)

type AllocationSet

+ func (as *AllocationSet) Accumulate(that *AllocationSet) (*AllocationSet, error)

+ func (as *AllocationSet) GetWindow() Window

type AllocationSetRange

+ func (asr *AllocationSetRange) NewAccumulation() (*AllocationSet, error)

type AssetSet

+ func (as *AssetSet) GetWindow() Window

type AssetSetRange

+ func (asr *AssetSetRange) NewAccumulation() (*AssetSet, error)

type Disk

+ ByteHoursUsed *float64

+ ByteUsageMax *float64

+ ClaimName string

+ ClaimNamespace string

+ VolumeName string

type SummaryAllocationSet

+ func (sas *SummaryAllocationSet) CPUEfficiency() float64

+ func (sas *SummaryAllocationSet) RAMEfficiency() float64

+ func (sas *SummaryAllocationSet) TotalEfficiency() float64

type SummaryAllocationSetRange

+ func (sasr *SummaryAllocationSetRange) NewAccumulation() (*SummaryAllocationSet, error)

Sep 19, 2022

Changes in this version

+ const LocalStorageClass

+ const ScalewayProvider

+ const UnknownStorageClass

type Allocation

+ func (a *Allocation) UnmarshalJSON(b []byte) error

type AllocationFilter

+ Equals func(AllocationFilter) bool

type AllocationFilterAnd

+ func (left AllocationFilterAnd) Equals(right AllocationFilter) bool

type AllocationFilterCondition

+ func (left AllocationFilterCondition) Equals(right AllocationFilter) bool

type AllocationFilterNone

+ func (left AllocationFilterNone) Equals(right AllocationFilter) bool

type AllocationFilterOr

+ func (left AllocationFilterOr) Equals(right AllocationFilter) bool

type AllocationSet

+ Allocations map[string]*Allocation

+ ExternalKeys map[string]bool

+ IdleKeys map[string]bool

type AllocationSetRange

+ Allocations []*AllocationSet

+ func (asr *AllocationSetRange) StartAndEnd() (time.Time, time.Time, error)

type Any

+ func (a *Any) GetAdjustment() float64

+ func (a *Any) GetEnd() time.Time

+ func (a *Any) GetLabels() AssetLabels

+ func (a *Any) GetProperties() *AssetProperties

+ func (a *Any) GetStart() time.Time

+ func (a *Any) GetWindow() Window

+ func (a *Any) SetWindow(window Window)

type Asset

+ GetAdjustment func() float64

+ GetEnd func() time.Time

+ GetLabels func() AssetLabels

+ GetProperties func() *AssetProperties

+ GetStart func() time.Time

+ GetWindow func() Window

+ SetWindow func(Window)

type AssetSet

+ AggregationKeys []string

+ Any map[string]*Any

+ Assets map[string]Asset

+ Cloud map[string]*Cloud

+ ClusterManagement map[string]*ClusterManagement

+ Disks map[string]*Disk

+ LoadBalancers map[string]*LoadBalancer

+ Network map[string]*Network

+ Nodes map[string]*Node

+ SharedAssets map[string]*SharedAsset

type AssetSetRange

+ Assets []*AssetSet

+ func (asr *AssetSetRange) StartAndEnd() (time.Time, time.Time, error)

type Cloud

+ func (ca *Cloud) GetAdjustment() float64

+ func (ca *Cloud) GetEnd() time.Time

+ func (ca *Cloud) GetLabels() AssetLabels

+ func (ca *Cloud) GetProperties() *AssetProperties

+ func (ca *Cloud) GetStart() time.Time

+ func (ca *Cloud) GetWindow() Window

+ func (ca *Cloud) SetWindow(window Window)

type ClusterManagement

+ func (cm *ClusterManagement) GetAdjustment() float64

+ func (cm *ClusterManagement) GetEnd() time.Time

+ func (cm *ClusterManagement) GetLabels() AssetLabels

+ func (cm *ClusterManagement) GetProperties() *AssetProperties

+ func (cm *ClusterManagement) GetStart() time.Time

+ func (cm *ClusterManagement) GetWindow() Window

+ func (cm *ClusterManagement) SetWindow(window Window)

type Disk

+ StorageClass string

+ func (d *Disk) GetAdjustment() float64

+ func (d *Disk) GetEnd() time.Time

+ func (d *Disk) GetLabels() AssetLabels

+ func (d *Disk) GetProperties() *AssetProperties

+ func (d *Disk) GetStart() time.Time

+ func (d *Disk) GetWindow() Window

+ func (d *Disk) SetWindow(window Window)

type LoadBalancer

+ func (lb *LoadBalancer) GetAdjustment() float64

+ func (lb *LoadBalancer) GetEnd() time.Time

+ func (lb *LoadBalancer) GetLabels() AssetLabels

+ func (lb *LoadBalancer) GetProperties() *AssetProperties

+ func (lb *LoadBalancer) GetStart() time.Time

+ func (lb *LoadBalancer) GetWindow() Window

+ func (lb *LoadBalancer) SetWindow(window Window)

type Network

+ func (n *Network) GetAdjustment() float64

+ func (n *Network) GetEnd() time.Time

+ func (n *Network) GetLabels() AssetLabels

+ func (n *Network) GetProperties() *AssetProperties

+ func (n *Network) GetStart() time.Time

+ func (n *Network) GetWindow() Window

+ func (n *Network) SetWindow(window Window)

type Node

+ func (n *Node) GetAdjustment() float64

+ func (n *Node) GetEnd() time.Time

+ func (n *Node) GetLabels() AssetLabels

+ func (n *Node) GetProperties() *AssetProperties

+ func (n *Node) GetStart() time.Time

+ func (n *Node) GetWindow() Window

+ func (n *Node) SetWindow(window Window)

type PVAllocation

+ func (pva *PVAllocation) Equal(that *PVAllocation) bool

type PVAllocations

+ func (pv PVAllocations) MarshalJSON() (b []byte, err error)

+ func (this PVAllocations) Equal(that PVAllocations) bool

type PVKey

+ func (pvk *PVKey) FromString(key string) error

+ func (pvk *PVKey) String() string

+ func (pvk *PVKey) UnmarshalText(text []byte) error

+ func (pvk PVKey) MarshalText() (text []byte, err error)

type RawAllocationOnlyData

+ func (r *RawAllocationOnlyData) Equal(that *RawAllocationOnlyData) bool

type SharedAsset

+ func (sa *SharedAsset) GetAdjustment() float64

+ func (sa *SharedAsset) GetEnd() time.Time

+ func (sa *SharedAsset) GetLabels() AssetLabels

+ func (sa *SharedAsset) GetProperties() *AssetProperties

+ func (sa *SharedAsset) GetStart() time.Time

+ func (sa *SharedAsset) GetWindow() Window

+ func (sa *SharedAsset) SetWindow(window Window)

Aug 11, 2022

Changes in this version

+ const AWSProvider

+ const AllocationAnnotationProp

+ const AllocationClusterProp

+ const AllocationCodecVersion

+ const AllocationContainerProp

+ const AllocationControllerKindProp

+ const AllocationControllerProp

+ const AllocationDaemonSetProp

+ const AllocationDepartmentProp

+ const AllocationDeploymentProp

+ const AllocationEnvironmentProp

+ const AllocationJobProp

+ const AllocationLabelProp

+ const AllocationNamespaceProp

+ const AllocationNilProp

+ const AllocationNodeProp

+ const AllocationOwnerProp

+ const AllocationPodProp

+ const AllocationProductProp

+ const AllocationProviderIDProp

+ const AllocationServiceProp

+ const AllocationStatefulSetProp

+ const AllocationTeamProp

+ const AssetsCodecVersion

+ const AuditCodecVersion

+ const AzureProvider

+ const BinaryTagStringTable

+ const CSVProvider

+ const ComputeCategory

+ const DefaultCodecVersion

+ const DiffAdded

+ const DiffChanged

+ const DiffRemoved

+ const ExternalSuffix

+ const FailedStatus

+ const FilterAnnotation

+ const FilterClusterID

+ const FilterContainer

+ const FilterContains

+ const FilterContainsPrefix

+ const FilterControllerKind

+ const FilterControllerName

+ const FilterEquals

+ const FilterLabel

+ const FilterNamespace

+ const FilterNode

+ const FilterNotContains

+ const FilterNotEquals

+ const FilterPod

+ const FilterServices

+ const FilterStartsWith

+ const GCPProvider

+ const GeneratorPackageName

+ const IdleSuffix

+ const KubernetesService

+ const ManagementCategory

+ const NetworkCategory

+ const NilProvider

+ const OtherCategory

+ const PassedStatus

+ const ShareEven

+ const ShareNone

+ const ShareWeighted

+ const SharedCategory

+ const SharedSuffix

+ const StorageCategory

+ const UnallocatedSuffix

+ const UndefinedKey

+ const UnmountedSuffix

+ const WarningStatus

+ func ComputeAllocationTotals(as *AllocationSet, prop string) map[string]*AllocationTotals

+ func ComputeAssetTotals(as *AssetSet, prop AssetProperty) map[string]*AssetTotals

+ func ComputeIdleCoefficients(shareSplit, key string, cpuCost, gpuCost, ramCost float64, ...) (float64, float64, float64)

+ func DiffAsset(before, after *AssetSet, ratioCostChange float64) (map[string]Diff[Asset], error)

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

+ func ParseProvider(str string) string

+ func QueryAllocationAsync(allocationQuerier AllocationQuerier, start, end time.Time, ...) (chan *AllocationSetRange, chan error)

+ func QueryAssetAsync(assetQuerier AssetQuerier, start, end time.Time, opts *AssetQueryOptions) (chan *AssetSetRange, chan error)

+ func QueryCloudUsageAsync(cloudUsageQuerier CloudUsageQuerier, start, end time.Time, ...) (chan *CloudUsageSetRange, chan error)

+ func QuerySummaryAllocationAsync(summaryAllocationQuerier SummaryAllocationQuerier, start, end time.Time, ...) (chan *SummaryAllocationSetRange, chan error)

+ func RoundBack(t time.Time, resolution time.Duration) time.Time

+ func RoundForward(t time.Time, resolution time.Duration) time.Time

+ type AggAudit struct

+ Description string

+ LastRun time.Time

+ MissingValues []*AuditMissingValue

+ Results map[string]map[string]*AuditFloatResult

+ Status AuditStatus

+ func (aa *AggAudit) Clone() *AggAudit

+ func (target *AggAudit) MarshalBinary() (data []byte, err error)

+ func (target *AggAudit) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AggAudit) UnmarshalBinary(data []byte) error

+ func (target *AggAudit) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type Allocation struct

+ CPUCoreHours float64

+ CPUCoreRequestAverage float64

+ CPUCoreUsageAverage float64

+ CPUCost float64

+ CPUCostAdjustment float64

+ End time.Time

+ ExternalCost float64

+ GPUCost float64

+ GPUCostAdjustment float64

+ GPUHours float64

+ LoadBalancerCost float64

+ LoadBalancerCostAdjustment float64

+ Name string

+ NetworkCost float64

+ NetworkCostAdjustment float64

+ NetworkReceiveBytes float64

+ NetworkTransferBytes float64

+ PVCostAdjustment float64

+ PVs PVAllocations

+ Properties *AllocationProperties

+ RAMByteHours float64

+ RAMBytesRequestAverage float64

+ RAMBytesUsageAverage float64

+ RAMCost float64

+ RAMCostAdjustment float64

+ RawAllocationOnly *RawAllocationOnlyData

+ SharedCost float64

+ Start time.Time

+ Window Window

+ func AssetToExternalAllocation(asset Asset, aggregateBy []string, labelConfig *LabelConfig) (*Allocation, error)

+ func NewMockUnitAllocation(name string, start time.Time, resolution time.Duration, ...) *Allocation

+ func (a *Allocation) Add(that *Allocation) (*Allocation, error)

+ func (a *Allocation) CPUCores() float64

+ func (a *Allocation) CPUEfficiency() float64

+ func (a *Allocation) CPUTotalCost() float64

+ func (a *Allocation) Clone() *Allocation

+ func (a *Allocation) Equal(that *Allocation) bool

+ func (a *Allocation) GPUTotalCost() float64

+ func (a *Allocation) GPUs() float64

+ func (a *Allocation) IsAggregated() bool

+ func (a *Allocation) IsExternal() bool

+ func (a *Allocation) IsIdle() bool

+ func (a *Allocation) IsUnallocated() bool

+ func (a *Allocation) IsUnmounted() bool

+ func (a *Allocation) LBTotalCost() float64

+ func (a *Allocation) LoadBalancerTotalCost() float64

+ func (a *Allocation) MarshalJSON() ([]byte, error)

+ func (a *Allocation) Minutes() float64

+ func (a *Allocation) NetworkTotalCost() float64

+ func (a *Allocation) PVByteHours() float64

+ func (a *Allocation) PVBytes() float64

+ func (a *Allocation) PVCost() float64

+ func (a *Allocation) PVTotalCost() float64

+ func (a *Allocation) RAMBytes() float64

+ func (a *Allocation) RAMEfficiency() float64

+ func (a *Allocation) RAMTotalCost() float64

+ func (a *Allocation) ResetAdjustments()

+ func (a *Allocation) Resolution() time.Duration

+ func (a *Allocation) Share(that *Allocation) (*Allocation, error)

+ func (a *Allocation) SharedTotalCost() float64

+ func (a *Allocation) String() string

+ func (a *Allocation) TotalCost() float64

+ func (a *Allocation) TotalEfficiency() float64

+ func (target *Allocation) MarshalBinary() (data []byte, err error)

+ func (target *Allocation) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Allocation) UnmarshalBinary(data []byte) error

+ func (target *Allocation) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AllocationAggregationOptions struct

+ AllocationTotalsStore AllocationTotalsStore

+ Filter AllocationFilter

+ IdleByNode bool

+ LabelConfig *LabelConfig

+ MergeUnallocated bool

+ Reconcile bool

+ ReconcileNetwork bool

+ ShareFuncs []AllocationMatchFunc

+ ShareIdle string

+ ShareSplit string

+ SharedHourlyCosts map[string]float64

+ SplitIdle bool

+ type AllocationAnnotations map[string]string

+ type AllocationFilter interface

+ Flattened func() AllocationFilter

+ Matches func(a *Allocation) bool

+ String func() string

+ type AllocationFilterAnd struct

+ Filters []AllocationFilter

+ func (af AllocationFilterAnd) String() string

+ func (and AllocationFilterAnd) Matches(a *Allocation) bool

+ func (filter AllocationFilterAnd) Flattened() AllocationFilter

+ type AllocationFilterCondition struct

+ Field FilterField

+ Key string

+ Op FilterOp

+ Value string

+ func (afc AllocationFilterCondition) String() string

+ func (filter AllocationFilterCondition) Flattened() AllocationFilter

+ func (filter AllocationFilterCondition) Matches(a *Allocation) bool

+ type AllocationFilterNone struct

+ func (afn AllocationFilterNone) Flattened() AllocationFilter

+ func (afn AllocationFilterNone) Matches(a *Allocation) bool

+ func (afn AllocationFilterNone) String() string

+ type AllocationFilterOr struct

+ Filters []AllocationFilter

+ func (af AllocationFilterOr) String() string

+ func (filter AllocationFilterOr) Flattened() AllocationFilter

+ func (or AllocationFilterOr) Matches(a *Allocation) bool

+ type AllocationLabels map[string]string

+ type AllocationMatchFunc func(*Allocation) bool

+ type AllocationProperties struct

+ Annotations AllocationAnnotations

+ Cluster string

+ Container string

+ Controller string

+ ControllerKind string

+ Labels AllocationLabels

+ Namespace string

+ Node string

+ Pod string

+ ProviderID string

+ Services []string

+ func (p *AllocationProperties) Clone() *AllocationProperties

+ func (p *AllocationProperties) Equal(that *AllocationProperties) bool

+ func (p *AllocationProperties) GenerateKey(aggregateBy []string, labelConfig *LabelConfig) string

+ func (p *AllocationProperties) Intersection(that *AllocationProperties) *AllocationProperties

+ func (p *AllocationProperties) String() string

+ func (target *AllocationProperties) MarshalBinary() (data []byte, err error)

+ func (target *AllocationProperties) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AllocationProperties) UnmarshalBinary(data []byte) error

+ func (target *AllocationProperties) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AllocationQuerier interface

+ QueryAllocation func(start, end time.Time, opts *AllocationQueryOptions) (*AllocationSetRange, error)

+ type AllocationQueryOptions struct

+ Accumulate bool

+ AccumulateBy time.Duration

+ AggregateBy []string

+ Compute bool

+ DisableAggregatedStores bool

+ Filter AllocationFilter

+ IdleByNode bool

+ IncludeExternal bool

+ IncludeIdle bool

+ LabelConfig *LabelConfig

+ MergeUnallocated bool

+ Reconcile bool

+ ReconcileNetwork bool

+ ShareFuncs []AllocationMatchFunc

+ ShareIdle string

+ ShareSplit string

+ ShareTenancyCosts bool

+ SharedHourlyCosts map[string]float64

+ SplitIdle bool

+ Step time.Duration

+ type AllocationReconciliationAudit struct

+ Description string

+ LastRun time.Time

+ MissingValues []*AuditMissingValue

+ Resources map[string]map[string]*AuditFloatResult

+ Status AuditStatus

+ func (ara *AllocationReconciliationAudit) Clone() *AllocationReconciliationAudit

+ func (target *AllocationReconciliationAudit) MarshalBinary() (data []byte, err error)

+ func (target *AllocationReconciliationAudit) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AllocationReconciliationAudit) UnmarshalBinary(data []byte) error

+ func (target *AllocationReconciliationAudit) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AllocationSet struct

+ Errors []string

+ FromSource string

+ Warnings []string

+ Window Window

+ func GenerateMockAllocationSet(start time.Time) *AllocationSet

+ func GenerateMockAllocationSetClusterIdle(start time.Time) *AllocationSet

+ func GenerateMockAllocationSetNodeIdle(start time.Time) *AllocationSet

+ func GenerateMockAllocationSetWithAssetProperties(start time.Time) *AllocationSet

+ func NewAllocationSet(start, end time.Time, allocs ...*Allocation) *AllocationSet

+ func (as *AllocationSet) AggregateBy(aggregateBy []string, options *AllocationAggregationOptions) error

+ func (as *AllocationSet) Clone() *AllocationSet

+ func (as *AllocationSet) Delete(name string)

+ func (as *AllocationSet) Each(f func(string, *Allocation))

+ func (as *AllocationSet) End() time.Time

+ func (as *AllocationSet) ExternalAllocations() map[string]*Allocation

+ func (as *AllocationSet) ExternalCost() float64

+ func (as *AllocationSet) Get(key string) *Allocation

+ func (as *AllocationSet) IdleAllocations() map[string]*Allocation

+ func (as *AllocationSet) Insert(that *Allocation) error

+ func (as *AllocationSet) IsEmpty() bool

+ func (as *AllocationSet) Length() int

+ func (as *AllocationSet) Map() map[string]*Allocation

+ func (as *AllocationSet) MarshalJSON() ([]byte, error)

+ func (as *AllocationSet) ResetAdjustments()

+ func (as *AllocationSet) Resolution() time.Duration

+ func (as *AllocationSet) Set(alloc *Allocation) error

+ func (as *AllocationSet) Start() time.Time

+ func (as *AllocationSet) String() string

+ func (as *AllocationSet) TotalCost() float64

+ func (as *AllocationSet) UTCOffset() time.Duration

+ func (target *AllocationSet) MarshalBinary() (data []byte, err error)

+ func (target *AllocationSet) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AllocationSet) UnmarshalBinary(data []byte) error

+ func (target *AllocationSet) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AllocationSetRange struct

+ FromStore string

+ func NewAllocationSetRange(allocs ...*AllocationSet) *AllocationSetRange

+ func (asr *AllocationSetRange) Accumulate() (*AllocationSet, error)

+ func (asr *AllocationSetRange) AccumulateBy(resolution time.Duration) (*AllocationSetRange, error)

+ func (asr *AllocationSetRange) AggregateBy(aggregateBy []string, options *AllocationAggregationOptions) error

+ func (asr *AllocationSetRange) Append(that *AllocationSet)

+ func (asr *AllocationSetRange) Each(f func(int, *AllocationSet))

+ func (asr *AllocationSetRange) End() (time.Time, error)

+ func (asr *AllocationSetRange) Get(i int) (*AllocationSet, error)

+ func (asr *AllocationSetRange) InsertRange(that *AllocationSetRange) error

+ func (asr *AllocationSetRange) Length() int

+ func (asr *AllocationSetRange) MarshalJSON() ([]byte, error)

+ func (asr *AllocationSetRange) Minutes() float64

+ func (asr *AllocationSetRange) Slice() []*AllocationSet

+ func (asr *AllocationSetRange) Start() (time.Time, error)

+ func (asr *AllocationSetRange) String() string

+ func (asr *AllocationSetRange) TotalCost() float64

+ func (asr *AllocationSetRange) UTCOffset() time.Duration

+ func (asr *AllocationSetRange) Window() Window

+ func (target *AllocationSetRange) MarshalBinary() (data []byte, err error)

+ func (target *AllocationSetRange) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AllocationSetRange) UnmarshalBinary(data []byte) error

+ func (target *AllocationSetRange) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AllocationTotals struct

+ CPUCost float64

+ CPUCostAdjustment float64

+ Cluster string

+ Count int

+ End time.Time

+ GPUCost float64

+ GPUCostAdjustment float64

+ LoadBalancerCost float64

+ LoadBalancerCostAdjustment float64

+ NetworkCost float64

+ NetworkCostAdjustment float64

+ Node string

+ PersistentVolumeCost float64

+ PersistentVolumeCostAdjustment float64

+ RAMCost float64

+ RAMCostAdjustment float64

+ Start time.Time

+ func (art *AllocationTotals) ClearAdjustments()

+ func (art *AllocationTotals) Clone() *AllocationTotals

+ func (art *AllocationTotals) TotalCPUCost() float64

+ func (art *AllocationTotals) TotalCost() float64

+ func (art *AllocationTotals) TotalGPUCost() float64

+ func (art *AllocationTotals) TotalLoadBalancerCost() float64

+ func (art *AllocationTotals) TotalNetworkCost() float64

+ func (art *AllocationTotals) TotalPersistentVolumeCost() float64

+ func (art *AllocationTotals) TotalRAMCost() float64

+ type AllocationTotalsSet struct

+ Cluster map[string]*AllocationTotals

+ Node map[string]*AllocationTotals

+ Window Window

+ func NewAllocationTotalsSet(window Window, byCluster, byNode map[string]*AllocationTotals) *AllocationTotalsSet

+ func UpdateAllocationTotalsStore(arts AllocationTotalsStore, as *AllocationSet) (*AllocationTotalsSet, error)

+ type AllocationTotalsStore interface

+ GetAllocationTotalsByCluster func(start, end time.Time) (map[string]*AllocationTotals, bool)

+ GetAllocationTotalsByNode func(start, end time.Time) (map[string]*AllocationTotals, bool)

+ SetAllocationTotalsByCluster func(start, end time.Time, rts map[string]*AllocationTotals)

+ SetAllocationTotalsByNode func(start, end time.Time, rts map[string]*AllocationTotals)

+ type Any struct

+ Cost float64

+ func NewAsset(start, end time.Time, window Window) *Any

+ func (a *Any) Add(that Asset) Asset

+ func (a *Any) Adjustment() float64

+ func (a *Any) Clone() Asset

+ func (a *Any) End() time.Time

+ func (a *Any) Equal(that Asset) bool

+ func (a *Any) ExpandWindow(window Window)

+ func (a *Any) InterfaceToAny(itf interface{}) error

+ func (a *Any) Labels() AssetLabels

+ func (a *Any) MarshalJSON() ([]byte, error)

+ func (a *Any) Minutes() float64

+ func (a *Any) Properties() *AssetProperties

+ func (a *Any) SetAdjustment(adj float64)

+ func (a *Any) SetLabels(labels AssetLabels)

+ func (a *Any) SetProperties(props *AssetProperties)

+ func (a *Any) SetStartEnd(start, end time.Time)

+ func (a *Any) Start() time.Time

+ func (a *Any) String() string

+ func (a *Any) TotalCost() float64

+ func (a *Any) Type() AssetType

+ func (a *Any) UnmarshalJSON(b []byte) error

+ func (a *Any) Window() Window

+ func (target *Any) MarshalBinary() (data []byte, err error)

+ func (target *Any) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Any) UnmarshalBinary(data []byte) error

+ func (target *Any) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type Asset interface

+ Add func(Asset) Asset

+ Adjustment func() float64

+ Clone func() Asset

+ End func() time.Time

+ Equal func(Asset) bool

+ ExpandWindow func(Window)

+ Labels func() AssetLabels

+ Minutes func() float64

+ Properties func() *AssetProperties

+ SetAdjustment func(float64)

+ SetLabels func(AssetLabels)

+ SetProperties func(*AssetProperties)

+ SetStartEnd func(time.Time, time.Time)

+ Start func() time.Time

+ TotalCost func() float64

+ Type func() AssetType

+ Window func() Window

+ type AssetAPIResponse struct

+ Code int

+ Data AssetSetRangeResponse

+ type AssetAggregationOptions struct

+ FilterFuncs []AssetMatchFunc

+ SharedHourlyCosts map[string]float64

+ type AssetLabels map[string]string

+ func (al AssetLabels) Append(newLabels map[string]string, overwrite bool)

+ func (al AssetLabels) Clone() AssetLabels

+ func (al AssetLabels) Equal(that AssetLabels) bool

+ func (al AssetLabels) Merge(that AssetLabels) AssetLabels

+ type AssetMatchFunc func(Asset) bool

+ type AssetProperties struct

+ Account string

+ Category string

+ Cluster string

+ Name string

+ Project string

+ Provider string

+ ProviderID string

+ Service string

+ func (ap *AssetProperties) Clone() *AssetProperties

+ func (ap *AssetProperties) Equal(that *AssetProperties) bool

+ func (ap *AssetProperties) Keys(props []AssetProperty) []string

+ func (ap *AssetProperties) Merge(that *AssetProperties) *AssetProperties

+ func (ap *AssetProperties) String() string

+ func (target *AssetProperties) MarshalBinary() (data []byte, err error)

+ func (target *AssetProperties) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AssetProperties) UnmarshalBinary(data []byte) error

+ func (target *AssetProperties) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AssetProperty string

+ const AssetAccountProp

+ const AssetCategoryProp

+ const AssetClusterProp

+ const AssetNameProp

+ const AssetNilProp

+ const AssetNodeProp

+ const AssetProjectProp

+ const AssetProviderIDProp

+ const AssetProviderProp

+ const AssetServiceProp

+ const AssetTypeProp

+ func ParseAssetProperty(text string) (AssetProperty, error)

+ type AssetQuerier interface

+ QueryAsset func(start, end time.Time, opts *AssetQueryOptions) (*AssetSetRange, error)

+ type AssetQueryOptions struct

+ Accumulate bool

+ AggregateBy []string

+ Compute bool

+ DisableAdjustments bool

+ DisableAggregatedStores bool

+ FilterFuncs []AssetMatchFunc

+ IncludeCloud bool

+ SharedHourlyCosts map[string]float64

+ Step time.Duration

+ type AssetReconciliationAudit struct

+ Description string

+ LastRun time.Time

+ MissingValues []*AuditMissingValue

+ Results map[string]map[string]*AuditFloatResult

+ Status AuditStatus

+ func (ara *AssetReconciliationAudit) Clone() *AssetReconciliationAudit

+ func (target *AssetReconciliationAudit) MarshalBinary() (data []byte, err error)

+ func (target *AssetReconciliationAudit) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AssetReconciliationAudit) UnmarshalBinary(data []byte) error

+ func (target *AssetReconciliationAudit) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AssetSet struct

+ Errors []string

+ FromSource string

+ Warnings []string

+ Window Window

+ func GenerateMockAssetSet(start time.Time) *AssetSet

+ func GenerateMockAssetSets(start, end time.Time) []*AssetSet

+ func NewAssetSet(start, end time.Time, assets ...Asset) *AssetSet

+ func (as *AssetSet) AggregateBy(aggregateBy []string, opts *AssetAggregationOptions) error

+ func (as *AssetSet) Clone() *AssetSet

+ func (as *AssetSet) Each(f func(string, Asset))

+ func (as *AssetSet) End() time.Time

+ func (as *AssetSet) FindMatch(query Asset, aggregateBy []string) (Asset, error)

+ func (as *AssetSet) Get(key string) (Asset, bool)

+ func (as *AssetSet) Insert(asset Asset) error

+ func (as *AssetSet) IsEmpty() bool

+ func (as *AssetSet) Length() int

+ func (as *AssetSet) Map() map[string]Asset

+ func (as *AssetSet) MarshalJSON() ([]byte, error)

+ func (as *AssetSet) ReconciliationMatch(query Asset) (Asset, bool, error)

+ func (as *AssetSet) ReconciliationMatchMap() map[string]map[string]Asset

+ func (as *AssetSet) Resolution() time.Duration

+ func (as *AssetSet) Set(asset Asset, aggregateBy []string) error

+ func (as *AssetSet) Start() time.Time

+ func (as *AssetSet) TotalCost() float64

+ func (as *AssetSet) UTCOffset() time.Duration

+ func (target *AssetSet) MarshalBinary() (data []byte, err error)

+ func (target *AssetSet) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AssetSet) UnmarshalBinary(data []byte) error

+ func (target *AssetSet) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AssetSetRange struct

+ FromStore string

+ func NewAssetSetRange(assets ...*AssetSet) *AssetSetRange

+ func (asr *AssetSetRange) Accumulate() (*AssetSet, error)

+ func (asr *AssetSetRange) AggregateBy(aggregateBy []string, opts *AssetAggregationOptions) error

+ func (asr *AssetSetRange) Append(that *AssetSet)

+ func (asr *AssetSetRange) Each(f func(int, *AssetSet))

+ func (asr *AssetSetRange) End() (time.Time, error)

+ func (asr *AssetSetRange) Get(i int) (*AssetSet, error)

+ func (asr *AssetSetRange) InsertRange(that *AssetSetRange) error

+ func (asr *AssetSetRange) IsEmpty() bool

+ func (asr *AssetSetRange) Length() int

+ func (asr *AssetSetRange) MarshalJSON() ([]byte, error)

+ func (asr *AssetSetRange) Minutes() float64

+ func (asr *AssetSetRange) Start() (time.Time, error)

+ func (asr *AssetSetRange) TotalCost() float64

+ func (asr *AssetSetRange) UTCOffset() time.Duration

+ func (asr *AssetSetRange) Window() Window

+ func (target *AssetSetRange) MarshalBinary() (data []byte, err error)

+ func (target *AssetSetRange) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AssetSetRange) UnmarshalBinary(data []byte) error

+ func (target *AssetSetRange) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AssetSetRangeResponse struct

+ Assets []*AssetSetResponse

+ func (asrr *AssetSetRangeResponse) UnmarshalJSON(b []byte) error

+ type AssetSetResponse struct

+ Assets map[string]Asset

+ func (asr *AssetSetResponse) RawMessageToAssetSetResponse(assetMap map[string]*json.RawMessage) error

+ func (asr *AssetSetResponse) UnmarshalJSON(b []byte) error

+ type AssetTotals struct

+ AttachedVolumeCost float64

+ AttachedVolumeCostAdjustment float64

+ CPUCost float64

+ CPUCostAdjustment float64

+ Cluster string

+ ClusterManagementCost float64

+ ClusterManagementCostAdjustment float64

+ Count int

+ End time.Time

+ GPUCost float64

+ GPUCostAdjustment float64

+ LoadBalancerCost float64

+ LoadBalancerCostAdjustment float64

+ Node string

+ PersistentVolumeCost float64

+ PersistentVolumeCostAdjustment float64

+ RAMCost float64

+ RAMCostAdjustment float64

+ Start time.Time

+ func (art *AssetTotals) ClearAdjustments()

+ func (art *AssetTotals) Clone() *AssetTotals

+ func (art *AssetTotals) TotalAttachedVolumeCost() float64

+ func (art *AssetTotals) TotalCPUCost() float64

+ func (art *AssetTotals) TotalClusterManagementCost() float64

+ func (art *AssetTotals) TotalCost() float64

+ func (art *AssetTotals) TotalGPUCost() float64

+ func (art *AssetTotals) TotalLoadBalancerCost() float64

+ func (art *AssetTotals) TotalPersistentVolumeCost() float64

+ func (art *AssetTotals) TotalRAMCost() float64

+ type AssetTotalsSet struct

+ Cluster map[string]*AssetTotals

+ Node map[string]*AssetTotals

+ Window Window

+ func NewAssetTotalsSet(window Window, byCluster, byNode map[string]*AssetTotals) *AssetTotalsSet

+ func UpdateAssetTotalsStore(arts AssetTotalsStore, as *AssetSet) (*AssetTotalsSet, error)

+ type AssetTotalsStore interface

+ GetAssetTotalsByCluster func(start, end time.Time) (map[string]*AssetTotals, bool)

+ GetAssetTotalsByNode func(start, end time.Time) (map[string]*AssetTotals, bool)

+ SetAssetTotalsByCluster func(start, end time.Time, rts map[string]*AssetTotals)

+ SetAssetTotalsByNode func(start, end time.Time, rts map[string]*AssetTotals)

+ type AssetType int

+ const AnyAssetType

+ const CloudAssetType

+ const ClusterManagementAssetType

+ const DiskAssetType

+ const LoadBalancerAssetType

+ const NetworkAssetType

+ const NodeAssetType

+ const SharedAssetType

+ func ParseAssetType(text string) (AssetType, error)

+ func (at AssetType) String() string

+ type AuditCoverage struct

+ AllocationAgg Window

+ AllocationReconciliation Window

+ AllocationTotal Window

+ AssetReconciliation Window

+ AssetTotal Window

+ ClusterEquality Window

+ func NewAuditCoverage() *AuditCoverage

+ func (ac *AuditCoverage) Update(as *AuditSet)

+ type AuditFloatResult struct

+ Actual float64

+ Expected float64

+ func (afr *AuditFloatResult) Clone() *AuditFloatResult

+ func (target *AuditFloatResult) MarshalBinary() (data []byte, err error)

+ func (target *AuditFloatResult) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AuditFloatResult) UnmarshalBinary(data []byte) error

+ func (target *AuditFloatResult) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AuditMissingValue struct

+ Description string

+ Key string

+ func (target *AuditMissingValue) MarshalBinary() (data []byte, err error)

+ func (target *AuditMissingValue) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AuditMissingValue) UnmarshalBinary(data []byte) error

+ func (target *AuditMissingValue) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AuditSet struct

+ AllocationAgg *AggAudit

+ AllocationReconciliation *AllocationReconciliationAudit

+ AllocationTotal *TotalAudit

+ AssetReconciliation *AssetReconciliationAudit

+ AssetTotal *TotalAudit

+ ClusterEquality *EqualityAudit

+ Window Window

+ func NewAuditSet(start, end time.Time) *AuditSet

+ func (as *AuditSet) Clone() *AuditSet

+ func (as *AuditSet) CloneSet() ETLSet

+ func (as *AuditSet) ConstructSet() ETLSet

+ func (as *AuditSet) GetWindow() Window

+ func (as *AuditSet) IsEmpty() bool

+ func (as *AuditSet) UpdateAuditSet(that *AuditSet) *AuditSet

+ func (target *AuditSet) MarshalBinary() (data []byte, err error)

+ func (target *AuditSet) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AuditSet) UnmarshalBinary(data []byte) error

+ func (target *AuditSet) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AuditSetRange struct

+ func (target *AuditSetRange) MarshalBinary() (data []byte, err error)

+ func (target *AuditSetRange) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *AuditSetRange) UnmarshalBinary(data []byte) error

+ func (target *AuditSetRange) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type AuditStatus string

+ type AuditType string

+ const AuditAll

+ const AuditAllocationAggStore

+ const AuditAllocationReconciliation

+ const AuditAllocationTotalStore

+ const AuditAssetAggStore

+ const AuditAssetReconciliation

+ const AuditAssetTotalStore

+ const AuditClusterEquality

+ const AuditInvalidType

+ func ToAuditType(check string) AuditType

+ type BinDecoder interface

+ UnmarshalBinaryWithContext func(*DecodingContext) error

+ type BinEncoder interface

+ MarshalBinaryWithContext func(*EncodingContext) error

+ type BoundaryError struct

+ Message string

+ Requested Window

+ Supported Window

+ func NewBoundaryError(req, sup Window, msg string) *BoundaryError

+ func (be *BoundaryError) Error() string

+ type Breakdown struct

+ Idle float64

+ Other float64

+ System float64

+ User float64

+ func (b *Breakdown) Clone() *Breakdown

+ func (b *Breakdown) Equal(that *Breakdown) bool

+ func (target *Breakdown) MarshalBinary() (data []byte, err error)

+ func (target *Breakdown) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Breakdown) UnmarshalBinary(data []byte) error

+ func (target *Breakdown) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type Cloud struct

+ Cost float64

+ Credit float64

+ func NewCloud(category, providerID string, start, end time.Time, window Window) *Cloud

+ func (ca *Cloud) Add(a Asset) Asset

+ func (ca *Cloud) Adjustment() float64

+ func (ca *Cloud) Clone() Asset

+ func (ca *Cloud) End() time.Time

+ func (ca *Cloud) Equal(a Asset) bool

+ func (ca *Cloud) ExpandWindow(window Window)

+ func (ca *Cloud) InterfaceToCloud(itf interface{}) error

+ func (ca *Cloud) Labels() AssetLabels

+ func (ca *Cloud) MarshalJSON() ([]byte, error)

+ func (ca *Cloud) Minutes() float64

+ func (ca *Cloud) Properties() *AssetProperties

+ func (ca *Cloud) SetAdjustment(adj float64)

+ func (ca *Cloud) SetLabels(labels AssetLabels)

+ func (ca *Cloud) SetProperties(props *AssetProperties)

+ func (ca *Cloud) SetStartEnd(start, end time.Time)

+ func (ca *Cloud) Start() time.Time

+ func (ca *Cloud) String() string

+ func (ca *Cloud) TotalCost() float64

+ func (ca *Cloud) Type() AssetType

+ func (ca *Cloud) UnmarshalJSON(b []byte) error

+ func (ca *Cloud) Window() Window

+ func (target *Cloud) MarshalBinary() (data []byte, err error)

+ func (target *Cloud) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Cloud) UnmarshalBinary(data []byte) error

+ func (target *Cloud) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type CloudAssetStatus struct

+ Coverage Window

+ LastRun time.Time

+ NextRun time.Time

+ Progress float64

+ RefreshRate string

+ Resolution string

+ StartTime time.Time

+ type CloudStatus struct

+ CloudConnectionStatus string

+ CloudUsage *CloudAssetStatus

+ ProviderType string

+ Reconciliation *ReconciliationStatus

+ type CloudUsage = Cloud

+ type CloudUsageAggregationOptions = AssetAggregationOptions

+ type CloudUsageFilter struct

+ Accounts []string

+ Categories []string

+ Labels map[string][]string

+ Projects []string

+ ProviderIDs []string

+ Providers []string

+ Services []string

+ type CloudUsageMatchFunc = AssetMatchFunc

+ type CloudUsageQuerier interface

+ QueryCloudUsage func(start, end time.Time, opts *CloudUsageQueryOptions) (*CloudUsageSetRange, error)

+ type CloudUsageQueryOptions struct

+ Accumulate bool

+ AggregateBy []string

+ Compute bool

+ FilterFuncs []CloudUsageMatchFunc

+ FilterValues CloudUsageFilter

+ type CloudUsageSet = AssetSet

+ type CloudUsageSetRange = AssetSetRange

+ type ClusterManagement struct

+ Cost float64

+ func NewClusterManagement(provider, cluster string, window Window) *ClusterManagement

+ func (cm *ClusterManagement) Add(a Asset) Asset

+ func (cm *ClusterManagement) Adjustment() float64

+ func (cm *ClusterManagement) Clone() Asset

+ func (cm *ClusterManagement) End() time.Time

+ func (cm *ClusterManagement) Equal(a Asset) bool

+ func (cm *ClusterManagement) ExpandWindow(window Window)

+ func (cm *ClusterManagement) InterfaceToClusterManagement(itf interface{}) error

+ func (cm *ClusterManagement) Labels() AssetLabels

+ func (cm *ClusterManagement) MarshalJSON() ([]byte, error)

+ func (cm *ClusterManagement) Minutes() float64

+ func (cm *ClusterManagement) Properties() *AssetProperties

+ func (cm *ClusterManagement) SetAdjustment(adj float64)

+ func (cm *ClusterManagement) SetLabels(props AssetLabels)

+ func (cm *ClusterManagement) SetProperties(props *AssetProperties)

+ func (cm *ClusterManagement) SetStartEnd(start, end time.Time)

+ func (cm *ClusterManagement) Start() time.Time

+ func (cm *ClusterManagement) String() string

+ func (cm *ClusterManagement) TotalCost() float64

+ func (cm *ClusterManagement) Type() AssetType

+ func (cm *ClusterManagement) UnmarshalJSON(b []byte) error

+ func (cm *ClusterManagement) Window() Window

+ func (target *ClusterManagement) MarshalBinary() (data []byte, err error)

+ func (target *ClusterManagement) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *ClusterManagement) UnmarshalBinary(data []byte) error

+ func (target *ClusterManagement) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type DecodingContext struct

+ Buffer *util.Buffer

+ Table []string

+ func (dc *DecodingContext) IsStringTable() bool

+ type Diff struct

+ After T

+ Before T

+ Kind DiffKind

+ type DiffKind string

+ type DirectoryStatus struct

+ FileCount int

+ Files []FileStatus

+ LastModified time.Time

+ Path string

+ Size string

+ type Disk struct

+ Breakdown *Breakdown

+ ByteHours float64

+ Cost float64

+ Local float64

+ func NewDisk(name, cluster, providerID string, start, end time.Time, window Window) *Disk

+ func (d *Disk) Add(a Asset) Asset

+ func (d *Disk) Adjustment() float64

+ func (d *Disk) Bytes() float64

+ func (d *Disk) Clone() Asset

+ func (d *Disk) End() time.Time

+ func (d *Disk) Equal(a Asset) bool

+ func (d *Disk) ExpandWindow(window Window)

+ func (d *Disk) InterfaceToDisk(itf interface{}) error

+ func (d *Disk) Labels() AssetLabels

+ func (d *Disk) MarshalJSON() ([]byte, error)

+ func (d *Disk) Minutes() float64

+ func (d *Disk) Properties() *AssetProperties

+ func (d *Disk) SetAdjustment(adj float64)

+ func (d *Disk) SetLabels(labels AssetLabels)

+ func (d *Disk) SetProperties(props *AssetProperties)

+ func (d *Disk) SetStartEnd(start, end time.Time)

+ func (d *Disk) Start() time.Time

+ func (d *Disk) String() string

+ func (d *Disk) TotalCost() float64

+ func (d *Disk) Type() AssetType

+ func (d *Disk) UnmarshalJSON(b []byte) error

+ func (d *Disk) Window() Window

+ func (target *Disk) MarshalBinary() (data []byte, err error)

+ func (target *Disk) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Disk) UnmarshalBinary(data []byte) error

+ func (target *Disk) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type ETLSet interface

+ CloneSet func() ETLSet

+ ConstructSet func() ETLSet

+ GetWindow func() Window

+ IsEmpty func() bool

+ type ETLStatus struct

+ Backup *DirectoryStatus

+ Coverage Window

+ LastRun time.Time

+ MaxPrometheusQueryDuration string

+ Progress float64

+ RefreshRate string

+ Resolution string

+ StartTime time.Time

+ UTCOffset string

+ type EncodingContext struct

+ Buffer *util.Buffer

+ Table *StringTable

+ func (ec *EncodingContext) IsStringTable() bool

+ type EqualityAudit struct

+ Clusters map[string]*AuditFloatResult

+ Description string

+ LastRun time.Time

+ MissingValues []*AuditMissingValue

+ Status AuditStatus

+ func (ea *EqualityAudit) Clone() *EqualityAudit

+ func (target *EqualityAudit) MarshalBinary() (data []byte, err error)

+ func (target *EqualityAudit) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *EqualityAudit) UnmarshalBinary(data []byte) error

+ func (target *EqualityAudit) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type FileStatus struct

+ Details map[string]string

+ Errors []string

+ IsRepairing bool

+ LastModified time.Time

+ Name string

+ Size string

+ Warnings []string

+ type FilterField string

+ type FilterOp string

+ type LabelConfig struct

+ ClusterExternalLabel string

+ ControllerExternalLabel string

+ DaemonsetExternalLabel string

+ DepartmentExternalLabel string

+ DepartmentLabel string

+ DeploymentExternalLabel string

+ EnvironmentExternalLabel string

+ EnvironmentLabel string

+ NamespaceExternalLabel string

+ OwnerExternalLabel string

+ OwnerLabel string

+ PodExternalLabel string

+ ProductExternalLabel string

+ ProductLabel string

+ ServiceExternalLabel string

+ StatefulsetExternalLabel string

+ TeamExternalLabel string

+ TeamLabel string

+ func NewLabelConfig() *LabelConfig

+ func (lc *LabelConfig) GetExternalAllocationName(labels map[string]string, aggregateBy string) string

+ func (lc *LabelConfig) Map() map[string]string

+ func (lc *LabelConfig) Sanitize(label string) string

+ type LoadBalancer struct

+ Cost float64

+ func NewLoadBalancer(name, cluster, providerID string, start, end time.Time, window Window) *LoadBalancer

+ func (lb *LoadBalancer) Add(a Asset) Asset

+ func (lb *LoadBalancer) Adjustment() float64

+ func (lb *LoadBalancer) Clone() Asset

+ func (lb *LoadBalancer) End() time.Time

+ func (lb *LoadBalancer) Equal(a Asset) bool

+ func (lb *LoadBalancer) ExpandWindow(w Window)

+ func (lb *LoadBalancer) InterfaceToLoadBalancer(itf interface{}) error

+ func (lb *LoadBalancer) Labels() AssetLabels

+ func (lb *LoadBalancer) MarshalJSON() ([]byte, error)

+ func (lb *LoadBalancer) Minutes() float64

+ func (lb *LoadBalancer) Properties() *AssetProperties

+ func (lb *LoadBalancer) SetAdjustment(adj float64)

+ func (lb *LoadBalancer) SetLabels(labels AssetLabels)

+ func (lb *LoadBalancer) SetProperties(props *AssetProperties)

+ func (lb *LoadBalancer) SetStartEnd(start, end time.Time)

+ func (lb *LoadBalancer) Start() time.Time

+ func (lb *LoadBalancer) String() string

+ func (lb *LoadBalancer) TotalCost() float64

+ func (lb *LoadBalancer) Type() AssetType

+ func (lb *LoadBalancer) UnmarshalJSON(b []byte) error

+ func (lb *LoadBalancer) Window() Window

+ func (target *LoadBalancer) MarshalBinary() (data []byte, err error)

+ func (target *LoadBalancer) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *LoadBalancer) UnmarshalBinary(data []byte) error

+ func (target *LoadBalancer) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type MemoryTotalsStore struct

+ func NewMemoryTotalsStore() *MemoryTotalsStore

+ func (mts *MemoryTotalsStore) GetAllocationTotalsByCluster(start time.Time, end time.Time) (map[string]*AllocationTotals, bool)

+ func (mts *MemoryTotalsStore) GetAllocationTotalsByNode(start time.Time, end time.Time) (map[string]*AllocationTotals, bool)

+ func (mts *MemoryTotalsStore) GetAssetTotalsByCluster(start time.Time, end time.Time) (map[string]*AssetTotals, bool)

+ func (mts *MemoryTotalsStore) GetAssetTotalsByNode(start time.Time, end time.Time) (map[string]*AssetTotals, bool)

+ func (mts *MemoryTotalsStore) SetAllocationTotalsByCluster(start time.Time, end time.Time, arts map[string]*AllocationTotals)

+ func (mts *MemoryTotalsStore) SetAllocationTotalsByNode(start time.Time, end time.Time, arts map[string]*AllocationTotals)

+ func (mts *MemoryTotalsStore) SetAssetTotalsByCluster(start time.Time, end time.Time, arts map[string]*AssetTotals)

+ func (mts *MemoryTotalsStore) SetAssetTotalsByNode(start time.Time, end time.Time, arts map[string]*AssetTotals)

+ type Network struct

+ Cost float64

+ func NewNetwork(name, cluster, providerID string, start, end time.Time, window Window) *Network

+ func (n *Network) Add(a Asset) Asset

+ func (n *Network) Adjustment() float64

+ func (n *Network) Clone() Asset

+ func (n *Network) End() time.Time

+ func (n *Network) Equal(a Asset) bool

+ func (n *Network) ExpandWindow(window Window)

+ func (n *Network) InterfaceToNetwork(itf interface{}) error

+ func (n *Network) Labels() AssetLabels

+ func (n *Network) MarshalJSON() ([]byte, error)

+ func (n *Network) Minutes() float64

+ func (n *Network) Properties() *AssetProperties

+ func (n *Network) SetAdjustment(adj float64)

+ func (n *Network) SetLabels(labels AssetLabels)

+ func (n *Network) SetProperties(props *AssetProperties)

+ func (n *Network) SetStartEnd(start, end time.Time)

+ func (n *Network) Start() time.Time

+ func (n *Network) String() string

+ func (n *Network) TotalCost() float64

+ func (n *Network) Type() AssetType

+ func (n *Network) UnmarshalJSON(b []byte) error

+ func (n *Network) Window() Window

+ func (target *Network) MarshalBinary() (data []byte, err error)

+ func (target *Network) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Network) UnmarshalBinary(data []byte) error

+ func (target *Network) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type Node struct

+ CPUBreakdown *Breakdown

+ CPUCoreHours float64

+ CPUCost float64

+ Discount float64

+ GPUCost float64

+ GPUCount float64

+ GPUHours float64

+ NodeType string

+ Preemptible float64

+ RAMBreakdown *Breakdown

+ RAMByteHours float64

+ RAMCost float64

+ func NewNode(name, cluster, providerID string, start, end time.Time, window Window) *Node

+ func (n *Node) Add(a Asset) Asset

+ func (n *Node) Adjustment() float64

+ func (n *Node) CPUCores() float64

+ func (n *Node) Clone() Asset

+ func (n *Node) End() time.Time

+ func (n *Node) Equal(a Asset) bool

+ func (n *Node) ExpandWindow(window Window)

+ func (n *Node) GPUs() float64

+ func (n *Node) InterfaceToNode(itf interface{}) error

+ func (n *Node) IsPreemptible() bool

+ func (n *Node) Labels() AssetLabels

+ func (n *Node) MarshalJSON() ([]byte, error)

+ func (n *Node) Minutes() float64

+ func (n *Node) Properties() *AssetProperties

+ func (n *Node) RAMBytes() float64

+ func (n *Node) SetAdjustment(adj float64)

+ func (n *Node) SetLabels(labels AssetLabels)

+ func (n *Node) SetProperties(props *AssetProperties)

+ func (n *Node) SetStartEnd(start, end time.Time)

+ func (n *Node) Start() time.Time

+ func (n *Node) String() string

+ func (n *Node) TotalCost() float64

+ func (n *Node) Type() AssetType

+ func (n *Node) UnmarshalJSON(b []byte) error

+ func (n *Node) Window() Window

+ func (target *Node) MarshalBinary() (data []byte, err error)

+ func (target *Node) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Node) UnmarshalBinary(data []byte) error

+ func (target *Node) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type PVAllocation struct

+ ByteHours float64

+ Cost float64

+ func (target *PVAllocation) MarshalBinary() (data []byte, err error)

+ func (target *PVAllocation) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *PVAllocation) UnmarshalBinary(data []byte) error

+ func (target *PVAllocation) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type PVAllocations map[PVKey]*PVAllocation

+ func (pv *PVAllocations) Add(that PVAllocations) PVAllocations

+ func (pv *PVAllocations) Clone() PVAllocations

+ type PVKey struct

+ Cluster string

+ Name string

+ func (target *PVKey) MarshalBinary() (data []byte, err error)

+ func (target *PVKey) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *PVKey) UnmarshalBinary(data []byte) error

+ func (target *PVKey) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type Pair struct

+ First T

+ Second U

+ func NewPair(first T, second U) Pair[T, U]

+ type Querier interface

+ type RawAllocationOnlyData struct

+ CPUCoreUsageMax float64

+ RAMBytesUsageMax float64

+ func (r *RawAllocationOnlyData) Clone() *RawAllocationOnlyData

+ func (target *RawAllocationOnlyData) MarshalBinary() (data []byte, err error)

+ func (target *RawAllocationOnlyData) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *RawAllocationOnlyData) UnmarshalBinary(data []byte) error

+ func (target *RawAllocationOnlyData) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type ReconciliationStatus struct

+ Coverage Window

+ LastRun time.Time

+ NextRun time.Time

+ Progress float64

+ RefreshRate string

+ Resolution string

+ StartTime time.Time

+ type SetRange struct

+ func (r *SetRange[T]) Append(that T)

+ func (r *SetRange[T]) Each(f func(int, T))

+ func (r *SetRange[T]) Get(i int) (T, error)

+ func (r *SetRange[T]) IsEmpty() bool

+ func (r *SetRange[T]) Length() int

+ func (r *SetRange[T]) MarshalJSON() ([]byte, error)

+ type SharedAsset struct

+ Cost float64

+ func NewSharedAsset(name string, window Window) *SharedAsset

+ func (sa *SharedAsset) Add(a Asset) Asset

+ func (sa *SharedAsset) Adjustment() float64

+ func (sa *SharedAsset) Clone() Asset

+ func (sa *SharedAsset) End() time.Time

+ func (sa *SharedAsset) Equal(a Asset) bool

+ func (sa *SharedAsset) ExpandWindow(w Window)

+ func (sa *SharedAsset) InterfaceToSharedAsset(itf interface{}) error

+ func (sa *SharedAsset) Labels() AssetLabels

+ func (sa *SharedAsset) MarshalJSON() ([]byte, error)

+ func (sa *SharedAsset) Minutes() float64

+ func (sa *SharedAsset) Properties() *AssetProperties

+ func (sa *SharedAsset) SetAdjustment(float64)

+ func (sa *SharedAsset) SetLabels(labels AssetLabels)

+ func (sa *SharedAsset) SetProperties(props *AssetProperties)

+ func (sa *SharedAsset) SetStartEnd(start, end time.Time)

+ func (sa *SharedAsset) Start() time.Time

+ func (sa *SharedAsset) String() string

+ func (sa *SharedAsset) TotalCost() float64

+ func (sa *SharedAsset) Type() AssetType

+ func (sa *SharedAsset) UnmarshalJSON(b []byte) error

+ func (sa *SharedAsset) Window() Window

+ func (target *SharedAsset) MarshalBinary() (data []byte, err error)

+ func (target *SharedAsset) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *SharedAsset) UnmarshalBinary(data []byte) error

+ func (target *SharedAsset) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type StringTable struct

+ func NewStringTable(contents ...string) *StringTable

+ func (st *StringTable) AddOrGet(s string) int

+ func (st *StringTable) ToBytes() []byte

+ func (st *StringTable) ToSlice() []string

+ type SummaryAllocation struct

+ CPUCoreRequestAverage float64

+ CPUCoreUsageAverage float64

+ CPUCost float64

+ End time.Time

+ ExternalCost float64

+ GPUCost float64

+ LoadBalancerCost float64

+ Name string

+ NetworkCost float64

+ PVCost float64

+ Properties *AllocationProperties

+ RAMBytesRequestAverage float64

+ RAMBytesUsageAverage float64

+ RAMCost float64

+ Share bool

+ SharedCost float64

+ Start time.Time

+ func NewSummaryAllocation(alloc *Allocation, reconcile, reconcileNetwork bool) *SummaryAllocation

+ func (sa *SummaryAllocation) Add(that *SummaryAllocation) error

+ func (sa *SummaryAllocation) CPUEfficiency() float64

+ func (sa *SummaryAllocation) Clone() *SummaryAllocation

+ func (sa *SummaryAllocation) IsExternal() bool

+ func (sa *SummaryAllocation) IsIdle() bool

+ func (sa *SummaryAllocation) IsUnallocated() bool

+ func (sa *SummaryAllocation) IsUnmounted() bool

+ func (sa *SummaryAllocation) Minutes() float64

+ func (sa *SummaryAllocation) RAMEfficiency() float64

+ func (sa *SummaryAllocation) TotalCost() float64

+ func (sa *SummaryAllocation) TotalEfficiency() float64

+ type SummaryAllocationQuerier interface

+ QuerySummaryAllocation func(start, end time.Time, opts *AllocationQueryOptions) (*SummaryAllocationSetRange, error)

+ type SummaryAllocationSet struct

+ SummaryAllocations map[string]*SummaryAllocation

+ Window Window

+ func NewSummaryAllocationSet(as *AllocationSet, filter AllocationFilter, kfs []AllocationMatchFunc, ...) *SummaryAllocationSet

+ func (sas *SummaryAllocationSet) Add(that *SummaryAllocationSet) (*SummaryAllocationSet, error)

+ func (sas *SummaryAllocationSet) AggregateBy(aggregateBy []string, options *AllocationAggregationOptions) error

+ func (sas *SummaryAllocationSet) Clone() *SummaryAllocationSet

+ func (sas *SummaryAllocationSet) Delete(name string)

+ func (sas *SummaryAllocationSet) Each(f func(string, *SummaryAllocation))

+ func (sas *SummaryAllocationSet) Insert(sa *SummaryAllocation) error

+ func (sas *SummaryAllocationSet) TotalCost() float64

+ type SummaryAllocationSetRange struct

+ Message string

+ Step time.Duration

+ SummaryAllocationSets []*SummaryAllocationSet

+ Window Window

+ func NewSummaryAllocationSetRange(sass ...*SummaryAllocationSet) *SummaryAllocationSetRange

+ func (sasr *SummaryAllocationSetRange) Accumulate() (*SummaryAllocationSet, error)

+ func (sasr *SummaryAllocationSetRange) AggregateBy(aggregateBy []string, options *AllocationAggregationOptions) error

+ func (sasr *SummaryAllocationSetRange) Append(sas *SummaryAllocationSet) error

+ func (sasr *SummaryAllocationSetRange) Each(f func(int, *SummaryAllocationSet))

+ func (sasr *SummaryAllocationSetRange) InsertExternalAllocations(that *AllocationSetRange) error

+ func (sasr *SummaryAllocationSetRange) Print(verbose bool)

+ func (sasr *SummaryAllocationSetRange) TotalCost() float64

+ type TotalAudit struct

+ Description string

+ LastRun time.Time

+ MissingValues []*AuditMissingValue

+ Status AuditStatus

+ TotalByCluster map[string]*AuditFloatResult

+ TotalByNode map[string]*AuditFloatResult

+ func (ta *TotalAudit) Clone() *TotalAudit

+ func (target *TotalAudit) MarshalBinary() (data []byte, err error)

+ func (target *TotalAudit) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *TotalAudit) UnmarshalBinary(data []byte) error

+ func (target *TotalAudit) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ type TotalsStore interface

+ type Window struct

+ func NewClosedWindow(start, end time.Time) Window

+ func NewWindow(start, end *time.Time) Window

+ func ParseWindowUTC(window string) (Window, error)

+ func ParseWindowWithOffset(window string, offset time.Duration) (Window, error)

+ func ParseWindowWithOffsetString(window string, offset string) (Window, error)

+ func (target *Window) MarshalBinary() (data []byte, err error)

+ func (target *Window) MarshalBinaryWithContext(ctx *EncodingContext) (err error)

+ func (target *Window) UnmarshalBinary(data []byte) error

+ func (target *Window) UnmarshalBinaryWithContext(ctx *DecodingContext) (err error)

+ func (w Window) ApproximatelyEqual(that Window, threshold time.Duration) bool

+ func (w Window) Clone() Window

+ func (w Window) Contains(t time.Time) bool

+ func (w Window) ContainsWindow(that Window) bool

+ func (w Window) Contract(that Window) Window

+ func (w Window) ContractEnd(end time.Time) Window

+ func (w Window) ContractStart(start time.Time) Window

+ func (w Window) Duration() time.Duration

+ func (w Window) DurationOffset() (time.Duration, time.Duration, error)

+ func (w Window) DurationOffsetForPrometheus() (string, string, error)

+ func (w Window) DurationOffsetStrings() (string, string)

+ func (w Window) End() *time.Time

+ func (w Window) Equal(that Window) bool

+ func (w Window) Expand(that Window) Window

+ func (w Window) ExpandEnd(end time.Time) Window

+ func (w Window) ExpandStart(start time.Time) Window

+ func (w Window) HasDuration() bool

+ func (w Window) Hours() float64

+ func (w Window) IsEmpty() bool

+ func (w Window) IsNegative() bool

+ func (w Window) IsOpen() bool

+ func (w Window) MarshalJSON() ([]byte, error)

+ func (w Window) Minutes() float64

+ func (w Window) Set(start, end *time.Time)

+ func (w Window) Shift(dur time.Duration) Window

+ func (w Window) Start() *time.Time

+ func (w Window) String() string