queuejobdispatch

Documentation

Index

• type ClusterMetricsList
• type JobClusterAgent
  • func NewJobClusterAgent(config string, agentEventQueue *cache.FIFO) *JobClusterAgent
  • func (qa *JobClusterAgent) CreateJob(ctx context.Context, cqj *arbv1.AppWrapper)
  • func (qa *JobClusterAgent) DeleteJob(ctx context.Context, cqj *arbv1.AppWrapper)
  • func (qa *JobClusterAgent) Run(stopCh <-chan struct{})
  • func (qa *JobClusterAgent) UpdateAggrResources(ctx context.Context) error

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