Documentation ¶
Overview ¶
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- type AllocationAskDAOInfo
- type AllocationAskLogDAOInfo
- type AllocationDAOInfo
- type ApplicationDAOInfo
- type ApplicationHistoryDAOInfo
- type ApplicationsDAOInfo
- type ClusterDAOInfo
- type ClusterUtilDAOInfo
- type ClustersUtilDAOInfo
- type ContainerHistoryDAOInfo
- type GroupResourceUsageDAOInfo
- type HealthCheckInfo
- type NodeDAOInfo
- type NodeSortingPolicy
- type NodeUtilDAOInfo
- type NodesDAOInfo
- type NodesUtilDAOInfo
- type PartitionCapacity
- type PartitionInfo
- type PartitionQueueDAOInfo
- type PlaceholderDAOInfo
- type QueueCapacity
- type QueueDAOInfo
- type ResourceUsageDAOInfo
- type SchedulerHealthDAOInfo
- type StateDAOInfo
- type TemplateInfo
- type UserResourceUsageDAOInfo
- type ValidateConfResponse
- type YAPIError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AllocationAskDAOInfo ¶ added in v1.1.0
type AllocationAskDAOInfo struct { AllocationKey string `json:"allocationKey"` AllocationTags map[string]string `json:"allocationTags"` RequestTime int64 `json:"requestTime"` ResourcePerAlloc map[string]int64 `json:"resource"` PendingCount int32 `json:"pendingCount"` Priority string `json:"priority"` RequiredNodeID string `json:"requiredNodeId"` ApplicationID string `json:"applicationId"` Partition string `json:"partition"` Placeholder bool `json:"placeholder"` PlaceholderTimeout int64 `json:"placeholderTimeout"` TaskGroupName string `json:"taskGroupName"` AllocationLog []*AllocationAskLogDAOInfo `json:"allocationLog"` TriggeredPreemption bool `json:"triggeredPreemption"` Originator bool `json:"originator"` }
type AllocationAskLogDAOInfo ¶ added in v1.1.0
type AllocationDAOInfo ¶
type AllocationDAOInfo struct { AllocationKey string `json:"allocationKey"` AllocationTags map[string]string `json:"allocationTags"` RequestTime int64 `json:"requestTime"` // Allocation ask's createTime if PlaceholderUsed is false, otherwise equivalent to placeholder allocation's createTime AllocationTime int64 `json:"allocationTime"` // Allocation's createTime AllocationDelay int64 `json:"allocationDelay"` // Difference between AllocationTime and RequestTime UUID string `json:"uuid"` ResourcePerAlloc map[string]int64 `json:"resource"` Priority string `json:"priority"` NodeID string `json:"nodeId"` ApplicationID string `json:"applicationId"` Partition string `json:"partition"` Placeholder bool `json:"placeholder"` PlaceholderUsed bool `json:"placeholderUsed"` TaskGroupName string `json:"taskGroupName"` Preempted bool `json:"preempted"` }
type ApplicationDAOInfo ¶
type ApplicationDAOInfo struct { ApplicationID string `json:"applicationID"` UsedResource map[string]int64 `json:"usedResource"` MaxUsedResource map[string]int64 `json:"maxUsedResource"` PendingResource map[string]int64 `json:"pendingResource"` Partition string `json:"partition"` QueueName string `json:"queueName"` SubmissionTime int64 `json:"submissionTime"` FinishedTime *int64 `json:"finishedTime"` Requests []*AllocationAskDAOInfo `json:"requests"` Allocations []*AllocationDAOInfo `json:"allocations"` State string `json:"applicationState"` User string `json:"user"` Groups []string `json:"groups"` RejectedMessage string `json:"rejectedMessage"` StateLog []*StateDAOInfo `json:"stateLog"` PlaceholderData []*PlaceholderDAOInfo `json:"placeholderData"` HasReserved bool `json:"hasReserved"` Reservations []string `json:"reservations"` MaxRequestPriority int32 `json:"maxRequestPriority"` }
type ApplicationsDAOInfo ¶
type ApplicationsDAOInfo struct {
Applications []ApplicationDAOInfo `json:"applications"`
}
type ClusterDAOInfo ¶
type ClusterUtilDAOInfo ¶
type ClustersUtilDAOInfo ¶
type ClustersUtilDAOInfo struct { PartitionName string `json:"partition"` ClustersUtil []*ClusterUtilDAOInfo `json:"utilization"` }
type ContainerHistoryDAOInfo ¶
type GroupResourceUsageDAOInfo ¶ added in v1.2.0
type GroupResourceUsageDAOInfo struct { GroupName string `json:"groupName"` Applications []string `json:"applications"` Queues *ResourceUsageDAOInfo `json:"queues"` }
type HealthCheckInfo ¶
type NodeDAOInfo ¶
type NodeDAOInfo struct { NodeID string `json:"nodeID"` HostName string `json:"hostName"` RackName string `json:"rackName"` Attributes map[string]string `json:"attributes"` Capacity map[string]int64 `json:"capacity"` Allocated map[string]int64 `json:"allocated"` Occupied map[string]int64 `json:"occupied"` Available map[string]int64 `json:"available"` Utilized map[string]int64 `json:"utilized"` Allocations []*AllocationDAOInfo `json:"allocations"` Schedulable bool `json:"schedulable"` IsReserved bool `json:"isReserved"` Reservations []string `json:"reservations"` }
type NodeSortingPolicy ¶
type NodeUtilDAOInfo ¶
type NodesDAOInfo ¶
type NodesDAOInfo struct { PartitionName string `json:"partitionName"` Nodes []*NodeDAOInfo `json:"nodesInfo"` }
type NodesUtilDAOInfo ¶
type NodesUtilDAOInfo struct { ResourceType string `json:"type"` NodesUtil []*NodeUtilDAOInfo `json:"utilization"` }
type PartitionCapacity ¶
type PartitionInfo ¶
type PartitionInfo struct { ClusterID string `json:"clusterId"` Name string `json:"name"` Capacity PartitionCapacity `json:"capacity"` NodeSortingPolicy NodeSortingPolicy `json:"nodeSortingPolicy"` TotalNodes int `json:"totalNodes"` Applications map[string]int `json:"applications"` TotalContainers int `json:"totalContainers"` State string `json:"state"` LastStateTransitionTime int64 `json:"lastStateTransitionTime"` }
type PartitionQueueDAOInfo ¶
type PartitionQueueDAOInfo struct { QueueName string `json:"queuename"` Status string `json:"status"` Partition string `json:"partition"` PendingResource map[string]int64 `json:"pendingResource"` MaxResource map[string]int64 `json:"maxResource"` GuaranteedResource map[string]int64 `json:"guaranteedResource"` AllocatedResource map[string]int64 `json:"allocatedResource"` PreemptingResource map[string]int64 `json:"preemptingResource"` IsLeaf bool `json:"isLeaf"` IsManaged bool `json:"isManaged"` Properties map[string]string `json:"properties"` Parent string `json:"parent"` TemplateInfo *TemplateInfo `json:"template"` Children []PartitionQueueDAOInfo `json:"children"` AbsUsedCapacity map[string]int64 `json:"absUsedCapacity"` MaxRunningApps uint64 `json:"maxRunningApps"` RunningApps uint64 `json:"runningApps"` CurrentPriority int32 `json:"currentPriority"` AllocatingAcceptedApps []string `json:"allocatingAcceptedApps"` }
type PlaceholderDAOInfo ¶
type QueueCapacity ¶
type QueueDAOInfo ¶
type QueueDAOInfo struct { QueueName string `json:"queuename"` Status string `json:"status"` Capacities QueueCapacity `json:"capacities"` ChildQueues []QueueDAOInfo `json:"queues"` Properties map[string]string `json:"properties"` }
type ResourceUsageDAOInfo ¶ added in v1.2.0
type ResourceUsageDAOInfo struct { QueuePath string `json:"queuePath"` ResourceUsage *resources.Resource `json:"resourceUsage"` RunningApplications []string `json:"runningApplications"` Children []*ResourceUsageDAOInfo `json:"children"` }
type SchedulerHealthDAOInfo ¶
type SchedulerHealthDAOInfo struct { Healthy bool HealthChecks []HealthCheckInfo }
func (*SchedulerHealthDAOInfo) AddHealthCheckInfo ¶
func (s *SchedulerHealthDAOInfo) AddHealthCheckInfo(succeeded bool, name, description, diagnosis string)
func (*SchedulerHealthDAOInfo) SetHealthStatus ¶
func (s *SchedulerHealthDAOInfo) SetHealthStatus()
type StateDAOInfo ¶
type TemplateInfo ¶
type UserResourceUsageDAOInfo ¶ added in v1.2.0
type UserResourceUsageDAOInfo struct { UserName string `json:"userName"` Groups map[string]string `json:"groups"` Queues *ResourceUsageDAOInfo `json:"queues"` }