queuejobdispatch

package
v1.40.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 18, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL