server

Documentation

Index

• func NewBlock(size uint64, blockID string) *cpuadvisor.Block
• func NewBlockSet() blockSet
• func NewCPUServer(conf *config.Configuration, ...) (*cpuServer, error)
• func NewInnerBlock(block *cpuadvisor.Block, numaID int64, poolName string, ...) *internalBlock
• func NewMemoryServer(conf *config.Configuration, ...) (*memoryServer, error)
• func NewPoolCalculationEntries(poolName string) *cpuadvisor.CalculationEntries
• type QRMServer
  • func NewQRMServer(advisorWrapper resource.ResourceAdvisor, ...) (QRMServer, error)

Functions

func NewBlock

func NewBlock(size uint64, blockID string) *cpuadvisor.Block

NewBlock constructs a Block structure; generate a new one if blockID is missed

func NewBlockSet

func NewBlockSet() blockSet

func NewCPUServer

func NewCPUServer(
	conf *config.Configuration,
	headroomResourceManager reporter.HeadroomResourceManager,
	metaCache metacache.MetaCache,
	metaServer *metaserver.MetaServer,
	advisor subResourceAdvisor,
	emitter metrics.MetricEmitter,
) (*cpuServer, error)

func NewInnerBlock

func NewInnerBlock(block *cpuadvisor.Block, numaID int64, poolName string, containerInfo *types.ContainerInfo,
	numaCalculationResult *cpuadvisor.NumaCalculationResult,
) *internalBlock

func NewMemoryServer

func NewMemoryServer(
	conf *config.Configuration,
	headroomResourceManager reporter.HeadroomResourceManager,
	metaCache metacache.MetaCache,
	metaServer *metaserver.MetaServer,
	advisor subResourceAdvisor,
	emitter metrics.MetricEmitter,
) (*memoryServer, error)

func NewPoolCalculationEntries

func NewPoolCalculationEntries(poolName string) *cpuadvisor.CalculationEntries

NewPoolCalculationEntries returns CalculationEntries, and it will only fill up with OwnerPoolName and leaves numa info empty.

Types

type QRMServer

type QRMServer interface {
	Run(ctx context.Context)
}

QRMServer is a wrapper of all qrm plugin servers, which synchronize and merge pod and container lifecycle information, resource allocation and provision result with QRM plugins

func NewQRMServer

func NewQRMServer(advisorWrapper resource.ResourceAdvisor, headroomResourceGetter reporter.HeadroomResourceGetter, conf *config.Configuration,
	metaCache metacache.MetaCache, metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter,
) (QRMServer, error)

NewQRMServer returns a qrm server wrapper, which instantiates all required qrm plugin servers according to config