resources

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 5, 2024 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Zero = NewResource()

Never update value of Zero

Functions

func CompUsageRatio 

func CompUsageRatio(left, right, total *Resource) int

Calculate share for left of total and right of total. This returns the same value as compareShares does: 0 for equal shares 1 if the left share is larger -1 if the right share is larger

func CompUsageRatioSeparately 

func CompUsageRatioSeparately(left, leftTotal, right, rightTotal *Resource) int

Calculate share for left of total and right of total separately. This returns the same value as compareShares does: 0 for equal shares 1 if the left share is larger -1 if the right share is larger

func CompUsageShares 

func CompUsageShares(left, right *Resource) int

Compare two resources usage shares and assumes a nil total resource. The share is thus equivalent to the usage passed in. This returns the same value as compareShares does: 0 for equal shares 1 if the left share is larger -1 if the right share is larger

func Equals 

func Equals(left, right *Resource) bool

Compare the resources equal returns the specific values for following cases: left right return nil nil true nil <set> false <set> nil false <set> <set> true/false *based on the individual Quantity values

func EqualsOrEmpty 

func EqualsOrEmpty(left, right *Resource) bool

Compare the resources equal returns the specific values for following cases: left right return nil nil true nil <set> false nil zero res true <set> nil false zero res nil true <set> <set> true/false *based on the individual Quantity values

func FairnessRatio 

func FairnessRatio(left, right, total *Resource) float64

Get fairness ratio calculated by: highest share for left resource from total divided by highest share for right resource from total. If highest share for the right resource is 0 fairness is 1

func IsZero 

func IsZero(zero *Resource) bool

Check that the whole resource is zero A nil or empty resource is zero (contrary to StrictlyGreaterThanZero)

func StrictlyGreaterThan 

func StrictlyGreaterThan(larger, smaller *Resource) bool

Return true if all quantities in larger > smaller Two resources that are equal are not considered strictly larger than each other.

func StrictlyGreaterThanOrEquals 

func StrictlyGreaterThanOrEquals(larger, smaller *Resource) bool

Return true if all quantities in larger > smaller or if the two objects are exactly the same.

func StrictlyGreaterThanZero 

func StrictlyGreaterThanZero(larger *Resource) bool

Have at least one quantity > 0, and no quantities < 0 A nil resource is not strictly greater than zero.

Types

type Quantity 

type Quantity int64

No unit defined here for better performance

func ParseQuantity 

func ParseQuantity(value string) (Quantity, error)

ParseQuantity is used to parse user-provided values into int64 quantities.

func ParseVCore 

func ParseVCore(value string) (Quantity, error)

ParseVCore is similar to ParseQuantity but allows the 'm' suffix. Additionally, the base unit returned is a millicore, so values without units will be converted to milliCPUs (i.e. '10' will result in 10000, and '500m' will result in 500).

type Resource 

type Resource struct {
	Resources map[string]Quantity
}

func Add 

func Add(left, right *Resource) *Resource

Add resources returning a new resource with the result A nil resource is considered an empty resource

func CalculateAbsUsedCapacity 

func CalculateAbsUsedCapacity(capacity, used *Resource) *Resource

CalculateAbsUsedCapacity returns absolute used as a percentage, a positive integer value, for each defined resource named in the capacity comparing usage to the capacity. If usage is 0 or below 0, absolute used is always 0 if capacity is 0 or below 0, absolute used is always 100 if used is larger than capacity a value larger than 100 can be returned. The percentage value returned is capped at math.MaxInt32 (resolved value 2147483647)

func ComponentWiseMax 

func ComponentWiseMax(left, right *Resource) *Resource

Returns a new resource with the largest value for each quantity in the resources If either resource passed in is nil a zero resource is returned

func ComponentWiseMin 

func ComponentWiseMin(left, right *Resource) *Resource

Returns a new resource with the smallest value for each quantity in the resources If either resource passed in is nil a zero resource is returned If a resource type is missing from one of the Resource, it is considered 0

func ComponentWiseMinPermissive 

func ComponentWiseMinPermissive(left, right *Resource) *Resource

Returns a new Resource with the smallest value for each quantity in the Resources If either Resource passed in is nil the other Resource is returned If a Resource type is missing from one of the Resource, it is considered empty and the quantity from the other Resource is returned

func Multiply 

func Multiply(base *Resource, ratio int64) *Resource

Multiply the resource by the integer ratio returning a new resource. Result is protected from overflow (positive and negative). A nil resource passed in returns a new empty resource (zero)

func MultiplyBy 

func MultiplyBy(base *Resource, ratio float64) *Resource

Multiply the resource by the floating point ratio returning a new resource. The result is rounded down to the nearest integer value after the multiplication. Result is protected from overflow (positive and negative). A nil resource passed in returns a new empty resource (zero)

func NewResource 

func NewResource() *Resource

func NewResourceFromConf 

func NewResourceFromConf(configMap map[string]string) (*Resource, error)

Create a new resource from the config map. The config map must have been checked before being applied. The check here is just for safety so we do not crash.

func NewResourceFromMap 

func NewResourceFromMap(m map[string]Quantity) *Resource

func NewResourceFromProto 

func NewResourceFromProto(proto *si.Resource) *Resource

func NewResourceFromString 

func NewResourceFromString(str string) (*Resource, error)

Create a new resource from a string. The string must be a json marshalled si.Resource.

func Sub 

func Sub(left, right *Resource) *Resource

Subtract resource returning a new resource with the result A nil resource is considered an empty resource This might return negative values for specific quantities

func SubEliminateNegative 

func SubEliminateNegative(left, right *Resource) *Resource

SubEliminateNegative subtracts resource returning a new resource with the result A nil resource is considered an empty resource This will return 0 values for negative values

func SubErrorNegative 

func SubErrorNegative(left, right *Resource) (*Resource, error)

SubErrorNegative subtracts resource returning a new resource with the result. A nil resource is considered an empty resource. This will return an error if any value in the result is negative. The caller should at least log the error. The returned resource is valid and has all negative values reset to 0

func (*Resource) AddTo 

func (r *Resource) AddTo(add *Resource)

Add additional resource to the base updating the base resource Should be used by temporary computation only A nil base resource does not change A nil passed in resource is treated as a zero valued resource and leaves base unchanged

func (*Resource) Clone 

func (r *Resource) Clone() *Resource

Return a clone (copy) of the resource it is called on. This provides a deep copy of the object with the exact same member set. NOTE: this is a clone not a sparse copy of the original.

func (*Resource) DAOMap 

func (r *Resource) DAOMap() map[string]int64

func (*Resource) DominantResourceType added in v1.4.0 

func (r *Resource) DominantResourceType(capacity *Resource) string

DominantResourceType calculates the most used resource type based on the ratio of used compared to the capacity. If a capacity type is set to 0 assume full usage. Dominant type should be calculated with queue usage and capacity. Queue capacities should never contain 0 values when there is a usage also, however in the root queue this could happen. If the last node reporting that resource was removed but not everything has been updated. immediately Ignores resources types that are used but not defined in the capacity.

func (*Resource) FitIn added in v1.5.0 

func (r *Resource) FitIn(smaller *Resource) bool

FitIn checks if smaller fits in the defined resource Types not defined in resource this is called against are considered 0 for Quantity A nil resource is treated as an empty resource (no types defined)

func (*Resource) FitInMaxUndef 

func (r *Resource) FitInMaxUndef(smaller *Resource) bool

FitInMaxUndef checks if smaller fits in the defined resource Types not defined in resource this is called against are considered the maximum value for Quantity A nil resource is treated as an empty resource (no types defined)

func (*Resource) FitInScore 

func (r *Resource) FitInScore(fit *Resource) float64

Calculate how well the receiver fits in "fit"

  • A score of 0 is a fit (similar to FitIn)
  • The score is calculated only using resource type defined in the fit resource.
  • The score has a range between 0..#fit-res (the number of resource types in fit)
  • Same score means same fit
  • The lower the score the better the fit (0 is a fit)
  • Each individual score is calculated as follows: score = (fitVal - resVal) / fitVal That calculation per type is summed up for all resource types in fit. example 1: fit memory 1000; resource 100; score = 0.9 example 2: fit memory 150; resource 15; score = 0.9 example 3: fit memory 100, cpu 1; resource memory 10; score = 1.9
  • A nil receiver gives back the maximum score (number of resources types in fit)

func (*Resource) HasNegativeValue 

func (r *Resource) HasNegativeValue() bool

func (*Resource) IsEmpty added in v1.4.0 

func (r *Resource) IsEmpty() bool

IsEmpty returns true if the resource is nil or has no component resources specified.

func (*Resource) MultiplyTo 

func (r *Resource) MultiplyTo(ratio float64)

Multiply the resource by the ratio updating the resource it is called on. Should be used by temporary computation only.

func (*Resource) String 

func (r *Resource) String() string

func (*Resource) SubFrom 

func (r *Resource) SubFrom(sub *Resource)

Subtract from the resource the passed in resource by updating the resource it is called on. Should be used by temporary computation only A nil base resource does not change A nil passed in resource is treated as a zero valued resource and leaves the base unchanged.

func (*Resource) SubOnlyExisting added in v1.3.0 

func (r *Resource) SubOnlyExisting(delta *Resource)

SubOnlyExisting subtract delta from defined resource. Ignore any type not defined in the base resource (ie receiver). Used as part of the headroom updates as undefined resources are unlimited

func (*Resource) ToProto 

func (r *Resource) ToProto() *si.Resource

Convert to a protobuf implementation a nil resource passes back an empty proto object

type TrackedResource added in v1.4.0 

type TrackedResource struct {
	// TrackedResourceMap is a two-level map for aggregated resource usage.
	// The top-level key is the instance type, and the value is a map:
	//   resource type (CPU, memory, etc.) -> aggregated used time (in seconds) of the resource type.
	TrackedResourceMap map[string]map[string]int64

	sync.RWMutex
}

TrackedResource is a utility struct to keep track of application resource usage.

func NewTrackedResource added in v1.4.0 

func NewTrackedResource() *TrackedResource

NewTrackedResource creates a new instance of TrackedResource.

func NewTrackedResourceFromMap added in v1.5.0 

func NewTrackedResourceFromMap(m map[string]map[string]int64) *TrackedResource

NewTrackedResourceFromMap creates NewTrackedResource from the given map. Using for Testing purpose only.

func (*TrackedResource) AggregateTrackedResource added in v1.4.0 

func (tr *TrackedResource) AggregateTrackedResource(instType string,
	resource *Resource, bindTime time.Time)

AggregateTrackedResource aggregates resource usage to TrackedResourceMap[instType]. The time the given resource used is the delta between the resource createTime and currentTime.

func (*TrackedResource) Clone added in v1.4.0 

func (tr *TrackedResource) Clone() *TrackedResource

Clone creates a deep copy of TrackedResource.

func (*TrackedResource) String added in v1.5.0 

func (tr *TrackedResource) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.