Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterMetricsList ¶
type ClusterMetricsList struct {
Kind string `json:"kind"`
APIVersion string `json:"apiVersion"`
Metadata struct {
SelfLink string `json:"selfLink"`
} `json:"metadata"`
Items []struct {
MetricName string `json:"metricName"`
MetricLabels map[string]string `json:"metriclabels"`
Timestamp string `json:"timestamp"`
Value string `json:"value"`
} `json:"items"`
}
type JobClusterAgent ¶
type JobClusterAgent struct {
AgentId string
DeploymentName string
AggrResources *clusterstateapi.Resource
// contains filtered or unexported fields
}
func NewJobClusterAgent ¶
func NewJobClusterAgent(config string, agentEventQueue *cache.FIFO) *JobClusterAgent
func (*JobClusterAgent) CreateJob ¶
func (qa *JobClusterAgent) CreateJob(ctx context.Context, cqj *arbv1.AppWrapper)
func (*JobClusterAgent) DeleteJob ¶
func (qa *JobClusterAgent) DeleteJob(ctx context.Context, cqj *arbv1.AppWrapper)
func (*JobClusterAgent) Run ¶
func (qa *JobClusterAgent) Run(stopCh <-chan struct{})
func (*JobClusterAgent) UpdateAggrResources ¶
func (qa *JobClusterAgent) UpdateAggrResources(ctx context.Context) error
Click to show internal directories.
Click to hide internal directories.