objects

Jan 19, 2026

Changes in this version

+ func SortAllocations(allocations []*Allocation)

type Allocation

+ func (a *Allocation) GetAllocationName() string

+ func (a *Allocation) MarkUnPreempted()

+ func (a *Allocation) SendPreemptedByQuotaChangeEvent(queuePath string)

+ type AppQueueMapping struct

+ func NewAppQueueMapping() *AppQueueMapping

+ func (aqm *AppQueueMapping) AddAppQueueMapping(appID string, queue *Queue)

+ func (aqm *AppQueueMapping) GetQueueByAppId(appID string) *Queue

+ func (aqm *AppQueueMapping) RemoveAppQueueMapping(appID string)

type Application

+ func (sa *Application) GetBackoffDeadline() time.Time

+ func (sa *Application) SetBackoffDeadline(deadline time.Time)

type Queue

+ func (sq *Queue) GetBackoffDelay() time.Duration

+ func (sq *Queue) GetMaxAppUnschedAskBackoff() uint64

+ func (sq *Queue) GetOutstandingRequests() []*Allocation

+ func (sq *Queue) GetQueueByAppID(appID string) *Queue

+ type QuotaPreemptionContext struct

+ func NewQuotaPreemptor(queue *Queue) *QuotaPreemptionContext

Jul 21, 2025

Changes in this version

type Allocation

+ func (a *Allocation) IsForeign() bool

+ func (a *Allocation) IsPreemptable() bool

+ func (a *Allocation) SendPreemptedBySchedulerEvent(preemptorAllocKey, preemptorAppId, preemptorQueuePath string)

type Application

+ func (sa *Application) GetSubmissionTime() time.Time

+ func (sa *Application) GetTrackedDAOMap(which string) map[string]map[string]int64

type Node

+ func (sn *Node) GetForeignAllocations() []*Allocation

+ func (sn *Node) GetYunikornAllocations() []*Allocation

+ func (sn *Node) UpdateForeignAllocation(alloc *Allocation) *Allocation

Jan 21, 2025

Changes in this version

type Allocation

+ func (a *Allocation) SendRequiredNodePreemptionFailedEvent(node string)

type AllocationResult

+ CancelledReservations int

type Application

+ func (sa *Application) NodeReservedForAsk(askKey string) string

Sep 10, 2024

Changes in this version

type Allocation

+ func (a *Allocation) ClearRelease()

+ func (a *Allocation) GetAllocationLog() []*AllocationLogEntry

+ func (a *Allocation) GetPreemptCheckTime() time.Time

+ func (a *Allocation) GetRelease() *Allocation

+ func (a *Allocation) GetRequiredNode() string

+ func (a *Allocation) GetTag(tagName string) string

+ func (a *Allocation) HasRelease() bool

+ func (a *Allocation) HasTriggeredPreemption() bool

+ func (a *Allocation) HasTriggeredScaleUp() bool

+ func (a *Allocation) IsAllocated() bool

+ func (a *Allocation) IsAllowPreemptOther() bool

+ func (a *Allocation) IsAllowPreemptSelf() bool

+ func (a *Allocation) IsOriginator() bool

+ func (a *Allocation) IsSchedulingAttempted() bool

+ func (a *Allocation) LessThan(other *Allocation) bool

+ func (a *Allocation) LogAllocationFailure(message string, allocate bool)

+ func (a *Allocation) MarkTriggeredPreemption()

+ func (a *Allocation) SendPredicatesFailedEvent(predicateErrors map[string]int)

+ func (a *Allocation) SetAllocatedResource(allocatedResource *resources.Resource)

+ func (a *Allocation) SetNodeID(nodeID string)

+ func (a *Allocation) SetRequiredNode(node string)

+ func (a *Allocation) SetScaleUpTriggered(triggered bool)

+ func (a *Allocation) SetSchedulingAttempted(attempted bool)

+ func (a *Allocation) UpdatePreemptCheckTime()

type AllocationResult

+ NodeID string

+ Request *Allocation

+ ReservedNodeID string

+ ResultType AllocationResultType

+ type AllocationResultType int

+ func (art AllocationResultType) String() string

type Application

+ func (sa *Application) AllocateAsk(allocKey string) (*resources.Resource, error)

+ func (sa *Application) DeallocateAsk(allocKey string) (*resources.Resource, error)

+ func (sa *Application) GetGuaranteedResource() *resources.Resource

+ func (sa *Application) GetMaxApps() uint64

+ func (sa *Application) GetMaxResource() *resources.Resource

+ func (sa *Application) UpdateAllocationResources(alloc *Allocation) error

type Node

+ func (sn *Node) TryAddAllocation(alloc *Allocation) bool

+ func (sn *Node) UpdateAllocatedResource(delta *resources.Resource)

type Queue

+ func (sq *Queue) GetFairMaxResource() *resources.Resource

+ func (sq *Queue) GetMaxApps() uint64

+ func (sq *Queue) SetResources(guaranteedResource, maxResource *resources.Resource)

+ func (sq *Queue) TryIncAllocatedResource(alloc *resources.Resource) error

type QueuePreemptionSnapshot

+ AskQueue *QueuePreemptionSnapshot

+ func (qps *QueuePreemptionSnapshot) GetPreemptableResource() *resources.Resource

+ func (qps *QueuePreemptionSnapshot) GetRemainingGuaranteedResource() *resources.Resource

Mar 5, 2024

Changes in this version

+ const NotEnoughQueueQuota

+ const NotEnoughUserQuota

type Allocation

+ func (a *Allocation) GetAllocationID() string

+ func (a *Allocation) SetAllocationID(allocationID string)

type AllocationAsk

+ func (aa *AllocationAsk) HasTriggeredScaleUp() bool

+ func (aa *AllocationAsk) IsSchedulingAttempted() bool

+ func (aa *AllocationAsk) SendPredicateFailedEvent(message string)

+ func (aa *AllocationAsk) SetScaleUpTriggered(triggered bool)

+ func (aa *AllocationAsk) SetSchedulingAttempted(attempted bool)

type ApplicationSummary

+ PlaceholderResource *resources.TrackedResource

+ func (as *ApplicationSummary) String() string

Nov 14, 2023

Changes in this version

+ func NewTreeIterator(accept func(*Node) bool, getTree func() *btree.BTree) *treeIterator

type Allocation

+ func (a *Allocation) SetInstanceType(instType string)

type AllocationAsk

+ func (aa *AllocationAsk) LessThan(other *AllocationAsk) bool

type Application

+ func (sa *Application) CleanupTrackedResource()

+ func (sa *Application) HasPlaceholderAllocation() bool

+ func (sa *Application) IsCreateForced() bool

type ApplicationSummary

+ PreemptedResource *resources.TrackedResource

type Node

+ func (sn *Node) SendNodeAddedEvent()

+ func (sn *Node) SendNodeRemovedEvent()

type NodeIterator

+ ForEachNode func(func(*Node) bool)

type Queue

+ func NewRecoveryQueue(parent *Queue) (*Queue, error)

+ func (sq *Queue) SendRemoveQueueEvent()

type QueuePreemptionSnapshot

+ Leaf bool

May 31, 2023

Changes in this version

+ const UnknownInstanceType

type Allocation

+ func (a *Allocation) GetBindTime() time.Time

+ func (a *Allocation) GetInstanceType() string

+ func (a *Allocation) SetBindTime(bindTime time.Time)

type AllocationAsk

+ func (aa *AllocationAsk) GetPreemptCheckTime() time.Time

+ func (aa *AllocationAsk) IsAllowPreemptOther() bool

+ func (aa *AllocationAsk) IsAllowPreemptSelf() bool

+ func (aa *AllocationAsk) UpdatePreemptCheckTime()

type Application

+ func (sa *Application) CleanupUsedResource()

+ func (sa *Application) GetApplicationSummary(rmID string) *ApplicationSummary

+ func (sa *Application) LogAppSummary(rmID string)

+ func (sa *Application) StartTime() time.Time

+ type ApplicationSummary struct

+ ApplicationID string

+ FinishTime time.Time

+ Queue string

+ ResourceUsage *resources.UsedResource

+ RmID string

+ StartTime time.Time

+ State string

+ SubmissionTime time.Time

+ User string

+ func (as *ApplicationSummary) DoLogging()

type Node

+ func (sn *Node) GetAttributes() map[string]string

+ func (sn *Node) GetFitInScoreForAvailableResource(res *resources.Resource) float64

+ func (sn *Node) GetInstanceType() string

type NodeCollection

+ GetFullNodeIterator func() NodeIterator

+ type Preemptor struct

+ func NewPreemptor(application *Application, headRoom *resources.Resource, ...) *Preemptor

+ func (p *Preemptor) CheckPreconditions() bool

+ func (p *Preemptor) TryPreemption() (*Allocation, bool)

type Queue

+ func (sq *Queue) DecPreemptingResource(alloc *resources.Resource)

+ func (sq *Queue) FindEligiblePreemptionVictims(queuePath string, ask *AllocationAsk) map[string]*QueuePreemptionSnapshot

+ func (sq *Queue) FindQueueByAppID(appID string) *Queue

+ func (sq *Queue) GetActualGuaranteedResource() *resources.Resource

+ func (sq *Queue) GetPreemptionDelay() time.Duration

+ func (sq *Queue) GetPreemptionPolicy() policies.PreemptionPolicy

+ func (sq *Queue) GetPriorityPolicyAndOffset() (policies.PriorityPolicy, int32)

+ type QueuePreemptionSnapshot struct

+ AllocatedResource *resources.Resource

+ GuaranteedResource *resources.Resource

+ MaxResource *resources.Resource

+ Parent *QueuePreemptionSnapshot

+ PotentialVictims []*Allocation

+ PreemptingResource *resources.Resource

+ QueuePath string

+ func (qps *QueuePreemptionSnapshot) AddAllocation(alloc *resources.Resource)

+ func (qps *QueuePreemptionSnapshot) Duplicate(copy map[string]*QueuePreemptionSnapshot) *QueuePreemptionSnapshot

+ func (qps *QueuePreemptionSnapshot) GetGuaranteedResource() *resources.Resource

+ func (qps *QueuePreemptionSnapshot) GetMaxResource() *resources.Resource

+ func (qps *QueuePreemptionSnapshot) GetRemainingGuaranteed() *resources.Resource

+ func (qps *QueuePreemptionSnapshot) IsAtOrAboveGuaranteedResource() bool

+ func (qps *QueuePreemptionSnapshot) IsWithinGuaranteedResource() bool

+ func (qps *QueuePreemptionSnapshot) RemoveAllocation(alloc *resources.Resource)

Jan 27, 2023

Changes in this version

+ const EventNotNeeded

type Allocation

+ func (a *Allocation) IsPreempted() bool

+ func (a *Allocation) MarkPreempted()

type AllocationAsk

+ func (aa *AllocationAsk) HasTriggeredPreemption() bool

+ func (aa *AllocationAsk) MarkTriggeredPreemption()

type Application

+ func (sa *Application) GetAllocationMinPriority() int32

+ func (sa *Application) GetAskMaxPriority() int32

+ func (sa *Application) HasReserved() bool

type Node

+ func (sn *Node) GetReservationKeys() []string

type PreemptionContext

+ func NewRequiredNodePreemptor(node *Node, requiredAsk *AllocationAsk) *PreemptionContext

type Queue

+ func (sq *Queue) GetCurrentPriority() int32

+ func (sq *Queue) GetPreemptionPriority() int32

+ func (sq *Queue) GetReservedApps() map[string]int

+ func (sq *Queue) IsPrioritySortEnabled() bool

+ func (sq *Queue) SetMaxRunningApps(max int)

+ func (sq *Queue) UpdateApplicationPreemptionPriority(applicationID string, priority int32)

+ func (sq *Queue) UpdateApplicationPriority(applicationID string, priority int32)

+ func (sq *Queue) UpdateQueuePreemptionPriority(queueName string, priority int32)

+ func (sq *Queue) UpdateQueuePriority(queueName string, priority int32)

+ func (sq *Queue) UpdateQueueProperties()

Aug 22, 2022

Changes in this version

+ func CloneAllocationTags(tags map[string]string) map[string]string

type Allocation

+ func (a *Allocation) AddRelease(release *Allocation)

+ func (a *Allocation) ClearReleases()

+ func (a *Allocation) GetAllocatedResource() *resources.Resource

+ func (a *Allocation) GetAllocationKey() string

+ func (a *Allocation) GetApplicationID() string

+ func (a *Allocation) GetAsk() *AllocationAsk

+ func (a *Allocation) GetFirstRelease() *Allocation

+ func (a *Allocation) GetNodeID() string

+ func (a *Allocation) GetPartitionName() string

+ func (a *Allocation) GetPriority() int32

+ func (a *Allocation) GetReleaseCount() int

+ func (a *Allocation) GetReleasesClone() []*Allocation

+ func (a *Allocation) GetReservedNodeID() string

+ func (a *Allocation) GetResult() AllocationResult

+ func (a *Allocation) GetTagsClone() map[string]string

+ func (a *Allocation) GetTaskGroup() string

+ func (a *Allocation) GetUUID() string

+ func (a *Allocation) IsPlaceholderUsed() bool

+ func (a *Allocation) SetCreateTime(createTime time.Time)

+ func (a *Allocation) SetPlaceholderCreateTime(placeholdereCreateTime time.Time)

+ func (a *Allocation) SetPlaceholderUsed(placeholderUsed bool)

+ func (a *Allocation) SetRelease(release *Allocation)

+ func (a *Allocation) SetReleased(released bool)

+ func (a *Allocation) SetReservedNodeID(reservedNodeID string)

+ func (a *Allocation) SetResult(result AllocationResult)

type AllocationAsk

+ func NewAllocationAskFromSI(ask *si.AllocationAsk) *AllocationAsk

+ func (aa *AllocationAsk) GetAllocatedResource() *resources.Resource

+ func (aa *AllocationAsk) GetAllocationKey() string

+ func (aa *AllocationAsk) GetAllocationLog() []*AllocationLogEntry

+ func (aa *AllocationAsk) GetApplicationID() string

+ func (aa *AllocationAsk) GetPartitionName() string

+ func (aa *AllocationAsk) GetPriority() int32

+ func (aa *AllocationAsk) GetTag(tagName string) string

+ func (aa *AllocationAsk) GetTagsClone() map[string]string

+ func (aa *AllocationAsk) GetTaskGroup() string

+ func (aa *AllocationAsk) GetTimeout() time.Duration

+ func (aa *AllocationAsk) IsAllowPreemption() bool

+ func (aa *AllocationAsk) IsOriginator() bool

+ func (aa *AllocationAsk) IsPlaceholder() bool

+ func (aa *AllocationAsk) LogAllocationFailure(message string, allocate bool)

+ func (aa *AllocationAsk) SetRequiredNode(node string)

+ type AllocationLogEntry struct

+ Count int32

+ LastOccurrence time.Time

+ Message string

+ type AllocationResult int

+ func (ar AllocationResult) String() string

type Application

+ func (sa *Application) GetAllRequests() []*AllocationAsk

+ func (sa *Application) SetTimedOutPlaceholder(taskGroupName string, timedOut int64)

type PlaceholderData

+ TimedOut int64

+ type PreemptionContext struct

+ func NewSimplePreemptor(node *Node, requiredAsk *AllocationAsk) *PreemptionContext

+ func (p *PreemptionContext) GetVictims() []*Allocation

type Queue

+ func (sq *Queue) GetApplication(appID string) *Application

Apr 26, 2022

Changes in this version

+ const Accepted

+ const Allocated

+ const AllocatedReserved

+ const AppTagNamespaceResourceQuota

+ const AppTagStateAwareDisable

+ const CompleteApplication

+ const Completed

+ const Completing

+ const ExpireApplication

+ const Expired

+ const FailApplication

+ const Failed

+ const Failing

+ const Hard

+ const New

+ const None

+ const ReadyFlag

+ const RejectApplication

+ const Rejected

+ const Replaced

+ const Reserved

+ const ResumeApplication

+ const Resuming

+ const RunApplication

+ const Running

+ const Soft

+ const Starting

+ const Unreserved

+ func NewAppState() *fsm.FSM

+ func NewObjectState() *fsm.FSM

+ func SetCompletingTimeout(duration time.Duration)

+ func SetReservationDelay(delay time.Duration)

+ type Allocation struct

+ AllocatedResource *resources.Resource

+ AllocationKey string

+ ApplicationID string

+ Ask *AllocationAsk

+ NodeID string

+ PartitionName string

+ Priority int32

+ QueueName string

+ Releases []*Allocation

+ ReservedNodeID string

+ Result allocationResult

+ Tags map[string]string

+ UUID string

+ func NewAllocation(uuid, nodeID string, ask *AllocationAsk) *Allocation

+ func NewAllocationFromSI(alloc *si.Allocation) *Allocation

+ func (a *Allocation) GetCreateTime() time.Time

+ func (a *Allocation) GetPlaceholderCreateTime() time.Time

+ func (a *Allocation) GetPlaceholderUsed() bool

+ func (a *Allocation) IsPlaceholder() bool

+ func (a *Allocation) IsReleased() bool

+ func (a *Allocation) NewSIFromAllocation() *si.Allocation

+ func (a *Allocation) String() string

+ type AllocationAsk struct

+ AllocatedResource *resources.Resource

+ AllocationKey string

+ ApplicationID string

+ PartitionName string

+ QueueName string

+ Tags map[string]string

+ func NewAllocationAsk(ask *si.AllocationAsk) *AllocationAsk

+ func (aa *AllocationAsk) GetCreateTime() time.Time

+ func (aa *AllocationAsk) GetPendingAskRepeat() int32

+ func (aa *AllocationAsk) GetRequiredNode() string

+ func (aa *AllocationAsk) SetPendingAskRepeat(pendingRepeatAsk int32)

+ func (aa *AllocationAsk) String() string

+ type Application struct

+ ApplicationID string

+ Partition string

+ SubmissionTime time.Time

+ func NewApplication(siApp *si.AddApplicationRequest, ugi security.UserGroup, ...) *Application

+ func (sa *Application) AddAllocation(info *Allocation)

+ func (sa *Application) AddAllocationAsk(ask *AllocationAsk) error

+ func (sa *Application) CurrentState() string

+ func (sa *Application) FailApplication(failureMessage string) error

+ func (sa *Application) FinishedTime() time.Time

+ func (sa *Application) GetAllAllocations() []*Allocation

+ func (sa *Application) GetAllPlaceholderData() []*PlaceholderData

+ func (sa *Application) GetAllocatedResource() *resources.Resource

+ func (sa *Application) GetAllocationAsk(allocationKey string) *AllocationAsk

+ func (sa *Application) GetAskReservations(allocKey string) []string

+ func (sa *Application) GetMaxAllocatedResource() *resources.Resource

+ func (sa *Application) GetPendingResource() *resources.Resource

+ func (sa *Application) GetPlaceholderAsk() *resources.Resource

+ func (sa *Application) GetPlaceholderResource() *resources.Resource

+ func (sa *Application) GetQueue() *Queue

+ func (sa *Application) GetQueuePath() string

+ func (sa *Application) GetRejectedMessage() string

+ func (sa *Application) GetReservations() []string

+ func (sa *Application) GetStateLog() []*StateLogEntry

+ func (sa *Application) GetTag(tag string) string

+ func (sa *Application) GetUser() security.UserGroup

+ func (sa *Application) HandleApplicationEvent(event applicationEvent) error

+ func (sa *Application) HandleApplicationEventWithInfo(event applicationEvent, eventInfo string) error

+ func (sa *Application) IsAccepted() bool

+ func (sa *Application) IsAllocationAssignedToApp(alloc *Allocation) bool

+ func (sa *Application) IsCompleted() bool

+ func (sa *Application) IsCompleting() bool

+ func (sa *Application) IsExpired() bool

+ func (sa *Application) IsFailed() bool

+ func (sa *Application) IsFailing() bool

+ func (sa *Application) IsNew() bool

+ func (sa *Application) IsRejected() bool

+ func (sa *Application) IsReservedOnNode(nodeID string) bool

+ func (sa *Application) IsResuming() bool

+ func (sa *Application) IsRunning() bool

+ func (sa *Application) IsStarting() bool

+ func (sa *Application) OnStateChange(event *fsm.Event, eventInfo string)

+ func (sa *Application) RecoverAllocationAsk(ask *AllocationAsk)

+ func (sa *Application) RejectApplication(rejectedMessage string) error

+ func (sa *Application) RemoveAllAllocations() []*Allocation

+ func (sa *Application) RemoveAllocation(uuid string) *Allocation

+ func (sa *Application) RemoveAllocationAsk(allocKey string) int

+ func (sa *Application) ReplaceAllocation(uuid string) *Allocation

+ func (sa *Application) Reserve(node *Node, ask *AllocationAsk) error

+ func (sa *Application) SetQueue(queue *Queue)

+ func (sa *Application) SetQueuePath(queuePath string)

+ func (sa *Application) SetState(state string)

+ func (sa *Application) SetTerminatedCallback(callback func(appID string))

+ func (sa *Application) String() string

+ func (sa *Application) UnReserve(node *Node, ask *AllocationAsk) (int, error)

+ func (sa *Application) UnSetQueue()

+ func (sa *Application) UpdateAskRepeat(allocKey string, delta int32) (*resources.Resource, error)

+ type Node struct

+ Hostname string

+ NodeID string

+ Partition string

+ Rackname string

+ func NewNode(proto *si.NodeInfo) *Node

+ func (sn *Node) AddAllocation(alloc *Allocation) bool

+ func (sn *Node) AddListener(listener NodeListener)

+ func (sn *Node) CanAllocate(res *resources.Resource, preemptionPhase bool) bool

+ func (sn *Node) FitInNode(resRequest *resources.Resource) bool

+ func (sn *Node) GetAllAllocations() []*Allocation

+ func (sn *Node) GetAllocatedResource() *resources.Resource

+ func (sn *Node) GetAllocation(uuid string) *Allocation

+ func (sn *Node) GetAttribute(key string) string

+ func (sn *Node) GetAvailableResource() *resources.Resource

+ func (sn *Node) GetCapacity() *resources.Resource

+ func (sn *Node) GetOccupiedResource() *resources.Resource

+ func (sn *Node) GetReservations() []string

+ func (sn *Node) GetResourceUsageShares() map[string]float64

+ func (sn *Node) GetUtilizedResource() *resources.Resource

+ func (sn *Node) IncPreemptingResource(preempting *resources.Resource)

+ func (sn *Node) IsReady() bool

+ func (sn *Node) IsReserved() bool

+ func (sn *Node) IsSchedulable() bool

+ func (sn *Node) IsValidFor(ask *AllocationAsk) error

+ func (sn *Node) RemoveAllocation(uuid string) *Allocation

+ func (sn *Node) RemoveListener(listener NodeListener)

+ func (sn *Node) ReplaceAllocation(uuid string, replace *Allocation, delta *resources.Resource)

+ func (sn *Node) Reserve(app *Application, ask *AllocationAsk) error

+ func (sn *Node) SetCapacity(newCapacity *resources.Resource) *resources.Resource

+ func (sn *Node) SetOccupiedResource(occupiedResource *resources.Resource)

+ func (sn *Node) SetReady(ready bool)

+ func (sn *Node) SetSchedulable(schedulable bool)

+ func (sn *Node) String() string

+ func (sn *Node) UnReserveApps() ([]string, []int)

+ type NodeCollection interface

+ AddNode func(node *Node) error

+ GetNode func(nodeID string) *Node

+ GetNodeCount func() int

+ GetNodeIterator func() NodeIterator

+ GetNodeSortingPolicy func() NodeSortingPolicy

+ GetNodes func() []*Node

+ RemoveNode func(nodeID string) *Node

+ SetNodeSortingPolicy func(policy NodeSortingPolicy)

+ func NewNodeCollection(partition string) NodeCollection

+ type NodeIterator interface

+ HasNext func() bool

+ Next func() *Node

+ Reset func()

+ func NewDefaultNodeIterator(schedulerNodes []*Node) NodeIterator

+ func NewRoundRobinNodeIterator(schedulerNodes []*Node) NodeIterator

+ type NodeListener interface

+ NodeUpdated func(sn *Node)

+ type NodeSortingPolicy interface

+ PolicyType func() policies.SortingPolicy

+ ResourceWeights func() map[string]float64

+ ScoreNode func(node *Node) float64

+ func NewNodeSortingPolicy(policyType string, resourceWeights map[string]float64) NodeSortingPolicy

+ type ObjectEvent int

+ const Remove

+ const Start

+ const Stop

+ func (oe ObjectEvent) String() string

+ type ObjectState int

+ const Active

+ const Draining

+ const Stopped

+ func (os ObjectState) String() string

+ type PlaceholderData struct

+ Count int64

+ MinResource *resources.Resource

+ Replaced int64

+ RequiredNode string

+ TaskGroupName string

+ type Queue struct

+ Name string

+ QueuePath string

+ func NewConfiguredQueue(conf configs.QueueConfig, parent *Queue) (*Queue, error)

+ func NewDynamicQueue(name string, leaf bool, parent *Queue) (*Queue, error)

+ func (sq *Queue) AddApplication(app *Application)

+ func (sq *Queue) ApplyConf(conf configs.QueueConfig) error

+ func (sq *Queue) CheckAdminAccess(user security.UserGroup) bool

+ func (sq *Queue) CheckSubmitAccess(user security.UserGroup) bool

+ func (sq *Queue) CurrentState() string

+ func (sq *Queue) DecAllocatedResource(alloc *resources.Resource) error

+ func (sq *Queue) GetAllocatedResource() *resources.Resource

+ func (sq *Queue) GetChildQueue(name string) *Queue

+ func (sq *Queue) GetCopyOfApps() map[string]*Application

+ func (sq *Queue) GetCopyOfChildren() map[string]*Queue

+ func (sq *Queue) GetCopyOfCompletedApps() map[string]*Application

+ func (sq *Queue) GetGuaranteedResource() *resources.Resource

+ func (sq *Queue) GetMaxQueueSet() *resources.Resource

+ func (sq *Queue) GetMaxResource() *resources.Resource

+ func (sq *Queue) GetPartitionQueueDAOInfo() dao.PartitionQueueDAOInfo

+ func (sq *Queue) GetPendingResource() *resources.Resource

+ func (sq *Queue) GetPreemptingResource() *resources.Resource

+ func (sq *Queue) GetQueueInfo() dao.QueueDAOInfo

+ func (sq *Queue) GetQueueOutstandingRequests(total *[]*AllocationAsk)

+ func (sq *Queue) GetQueuePath() string

+ func (sq *Queue) IncAllocatedResource(alloc *resources.Resource, nodeReported bool) error

+ func (sq *Queue) IncPreemptingResource(newAlloc *resources.Resource)

+ func (sq *Queue) IsDraining() bool

+ func (sq *Queue) IsEmpty() bool

+ func (sq *Queue) IsLeafQueue() bool

+ func (sq *Queue) IsManaged() bool

+ func (sq *Queue) IsRunning() bool

+ func (sq *Queue) IsStopped() bool

+ func (sq *Queue) MarkQueueForRemoval()

+ func (sq *Queue) RemoveApplication(app *Application)

+ func (sq *Queue) RemoveQueue() bool

+ func (sq *Queue) Reserve(appID string)

+ func (sq *Queue) SetMaxResource(max *resources.Resource)

+ func (sq *Queue) String() string

+ func (sq *Queue) SupportTaskGroup() bool

+ func (sq *Queue) TryAllocate(iterator func() NodeIterator) *Allocation

+ func (sq *Queue) TryPlaceholderAllocate(iterator func() NodeIterator, getnode func(string) *Node) *Allocation

+ func (sq *Queue) TryReservedAllocate(iterator func() NodeIterator) *Allocation

+ func (sq *Queue) UnReserve(appID string, releases int)

+ func (sq *Queue) UpdateSortType()

+ type StateLogEntry struct

+ ApplicationState string

+ Time time.Time