server

Documentation

Index

• func NewBlock(size uint64, blockID string) *cpuadvisor.Block
• func NewBlockSet() blockSet
• func NewCPUServer(recvCh chan types.InternalCPUCalculationResult, sendCh chan struct{}, ...) (*cpuServer, error)
• func NewInnerBlock(block *cpuadvisor.Block, numaID int64, poolName string, ...) *internalBlock
• func NewMemoryServer(recvCh chan types.InternalMemoryCalculationResult, sendCh chan struct{}, ...) (*memoryServer, error)
• func NewPoolCalculationEntries(poolName string) *cpuadvisor.CalculationEntries
• type QRMServer
  • func NewQRMServer(advisorWrapper resource.ResourceAdvisor, conf *config.Configuration, ...) (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(recvCh chan types.InternalCPUCalculationResult, sendCh chan struct{}, conf *config.Configuration,
	metaCache metacache.MetaCache, 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(recvCh chan types.InternalMemoryCalculationResult, sendCh chan struct{}, conf *config.Configuration,
	metaCache metacache.MetaCache, 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, conf *config.Configuration,
	metaCache metacache.MetaCache, emitter metrics.MetricEmitter) (QRMServer, error)

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