resource

Documentation

Index

• func NewCPUHeadroomManager(emitter metrics.MetricEmitter, _ *metaserver.MetaServer, ...) (manager.HeadroomManager, error)
• func NewMemoryHeadroomManager(emitter metrics.MetricEmitter, _ *metaserver.MetaServer, ...) (manager.HeadroomManager, error)
• type GenericHeadroomManager
  • func NewGenericHeadroomManager(name v1.ResourceName, useMilliValue, reportMilliValue bool, ...) *GenericHeadroomManager
  • func (m *GenericHeadroomManager) GetAllocatable() (resource.Quantity, error)
  • func (m *GenericHeadroomManager) GetCapacity() (resource.Quantity, error)
  • func (m *GenericHeadroomManager) Run(ctx context.Context)
• type GenericReclaimOptions
• type GenericSlidingWindowOptions
• type GetGenericReclaimOptionsFunc

Functions

func NewCPUHeadroomManager

func NewCPUHeadroomManager(emitter metrics.MetricEmitter, _ *metaserver.MetaServer,
	conf *config.Configuration, headroomAdvisor hmadvisor.ResourceAdvisor) (manager.HeadroomManager, error)

func NewMemoryHeadroomManager

func NewMemoryHeadroomManager(emitter metrics.MetricEmitter, _ *metaserver.MetaServer,
	conf *config.Configuration, headroomAdvisor hmadvisor.ResourceAdvisor) (manager.HeadroomManager, error)

Types

type GenericHeadroomManager

type GenericHeadroomManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewGenericHeadroomManager

func NewGenericHeadroomManager(name v1.ResourceName, useMilliValue, reportMilliValue bool,
	syncPeriod time.Duration, headroomAdvisor hmadvisor.ResourceAdvisor,
	emitter metrics.MetricEmitter, slidingWindowOptions GenericSlidingWindowOptions,
	getReclaimOptions GetGenericReclaimOptionsFunc) *GenericHeadroomManager

func (*GenericHeadroomManager) GetAllocatable

func (m *GenericHeadroomManager) GetAllocatable() (resource.Quantity, error)

func (*GenericHeadroomManager) GetCapacity

func (m *GenericHeadroomManager) GetCapacity() (resource.Quantity, error)

func (*GenericHeadroomManager) Run

func (m *GenericHeadroomManager) Run(ctx context.Context)

type GenericReclaimOptions

type GenericReclaimOptions struct {
	// EnableReclaim whether enable reclaim resource
	EnableReclaim bool
	// ReservedResourceForReport reserved resource for reporting to cnr
	ReservedResourceForReport resource.Quantity
	// MinReclaimedResourceForReport min reclaimed resource for reporting to cnr
	MinReclaimedResourceForReport resource.Quantity
}

type GenericSlidingWindowOptions

type GenericSlidingWindowOptions struct {
	// SlidingWindowTime duration of sliding window
	SlidingWindowTime time.Duration
	// MinStep min step of the value change
	MinStep resource.Quantity
	// MaxStep max step of the value change
	MaxStep       resource.Quantity
	AggregateFunc string
	AggregateArgs string
}

type GetGenericReclaimOptionsFunc

type GetGenericReclaimOptionsFunc func() GenericReclaimOptions