Documentation
¶
Index ¶
- Constants
- type UnavailableOfferings
- func (u *UnavailableOfferings) Flush()
- func (u *UnavailableOfferings) IsUnavailable(sku *skewer.SKU, zone, capacityType string) bool
- func (u *UnavailableOfferings) MarkFamilyUnavailable(ctx context.Context, sku *skewer.SKU, zone, capacityType string, ...)
- func (u *UnavailableOfferings) MarkSpotUnavailableWithTTL(ctx context.Context, ttl time.Duration)
- func (u *UnavailableOfferings) MarkUnavailable(ctx context.Context, unavailableReason string, sku *skewer.SKU, ...)
- func (u *UnavailableOfferings) MarkUnavailableWithTTL(ctx context.Context, unavailableReason string, sku *skewer.SKU, ...)
Constants ¶
const ( // KubernetesVersionTTL is the time before the detected Kubernetes version is removed from cache, // to be re-detected next time it is needed. KubernetesVersionTTL = 15 * time.Minute // are removed from the cache and are available for launch again UnavailableOfferingsTTL = 3 * time.Minute // DefaultCleanupInterval triggers cache cleanup (lazy eviction) at this interval. DefaultCleanupInterval = 1 * time.Minute // We drop the cleanup interval down for the ICE cache to get quicker reactivity to offerings // that become available after they get evicted from the cache UnavailableOfferingsCleanupInterval = time.Second * 10 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type UnavailableOfferings ¶
type UnavailableOfferings struct {
// contains filtered or unexported fields
}
UnavailableOfferings stores any offerings that return ICE (insufficient capacity errors) when attempting to launch the capacity. These offerings are ignored as long as they are in the cache on GetInstanceTypes responses Information available from skewer.SKU is used to determine details about the VM SKU for which we encountered allocation errors.
func NewUnavailableOfferings ¶
func NewUnavailableOfferings() *UnavailableOfferings
func NewUnavailableOfferingsWithCache ¶
func NewUnavailableOfferingsWithCache(singleOfferingCache, vmFamilyCache *cache.Cache) *UnavailableOfferings
func (*UnavailableOfferings) Flush ¶
func (u *UnavailableOfferings) Flush()
func (*UnavailableOfferings) IsUnavailable ¶
func (u *UnavailableOfferings) IsUnavailable(sku *skewer.SKU, zone, capacityType string) bool
IsUnavailable returns true if the offering appears in the cache
func (*UnavailableOfferings) MarkFamilyUnavailable ¶ added in v1.6.1
func (u *UnavailableOfferings) MarkFamilyUnavailable(ctx context.Context, sku *skewer.SKU, zone, capacityType string, ttl time.Duration)
MarkFamilyUnavailable marks the entire VM family as unavailable in a specific zone for a specific capacity type with custom TTL. Family name is derived from the provided skewer.SKU.
func (*UnavailableOfferings) MarkSpotUnavailableWithTTL ¶
func (u *UnavailableOfferings) MarkSpotUnavailableWithTTL(ctx context.Context, ttl time.Duration)
MarkSpotUnavailable communicates recently observed temporary capacity shortages for spot
func (*UnavailableOfferings) MarkUnavailable ¶
func (u *UnavailableOfferings) MarkUnavailable(ctx context.Context, unavailableReason string, sku *skewer.SKU, zone, capacityType string)
MarkUnavailable communicates recently observed temporary capacity shortages in the provided offerings
func (*UnavailableOfferings) MarkUnavailableWithTTL ¶
func (u *UnavailableOfferings) MarkUnavailableWithTTL(ctx context.Context, unavailableReason string, sku *skewer.SKU, zone, capacityType string, ttl time.Duration)
MarkUnavailableWithTTL allows us to mark an offering unavailable with a custom TTL. In addition to marking the specific instance type unavailable, it also marks the VM family unavailable at the SKU's vCPU count, so that larger sizes of the same family are also blocked.
Source Files