queuejobdispatch

Jun 7, 2023

Changes in this version

+ type ClusterMetricsList struct

+ APIVersion string

+ Items []struct{ ... }

+ Kind string

+ Metadata struct{ ... }

+ type JobClusterAgent struct

+ AgentId string

+ AggrResources *clusterstateapi.Resource

+ DeploymentName string

+ func NewJobClusterAgent(config string, agentEventQueue *cache.FIFO) *JobClusterAgent

+ func (qa *JobClusterAgent) CreateJob(cqj *arbv1.AppWrapper)

+ func (qa *JobClusterAgent) DeleteJob(cqj *arbv1.AppWrapper)

+ func (qa *JobClusterAgent) Run(stopCh chan struct{})

+ func (qa *JobClusterAgent) UpdateAggrResources() error