cache

Sep 10, 2024

Changes in this version

+ var ErrorNodeNotFound = errors.New("predicates were not run because node was not found in cache")

+ var ErrorPodNotFound = errors.New("predicates were not run because pod was not found in cache")

type Task

+ func (task *Task) FailWithEvent(errorMessage, actionReason string)

+ func (task *Task) GetAllocationKey() string

+ func (task *Task) GetNodeName() string

+ func (task *Task) GetTaskGroupName() string

+ func (task *Task) GetTaskTerminationType() string

+ func (task *Task) SetTaskPod(pod *v1.Pod)

type TaskGroup

+ TopologySpreadConstraints []v1.TopologySpreadConstraint

Jul 23, 2024

Changes in this version

type Context

+ func (ctx *Context) RegisterNodes(nodes []*v1.Node) ([]*v1.Node, error)

Mar 7, 2024

Changes in this version

+ func GeneratePlaceholderName(taskGroupName, appID string) string

+ func GetPlaceholderResourceRequests(resources map[string]resource.Quantity) v1.ResourceList

+ type AddApplicationRequest struct

+ Metadata ApplicationMetadata

+ type AddTaskRequest struct

+ Metadata TaskMetadata

type Application

+ func (app *Application) AreAllTasksTerminated() bool

+ func (app *Application) RemoveTask(taskID string)

+ func (app *Application) TriggerAppSubmission() error

+ type ApplicationMetadata struct

+ ApplicationID string

+ CreationTime int64

+ Groups []string

+ OwnerReferences []metav1.OwnerReference

+ QueueName string

+ SchedulingPolicyParameters *SchedulingPolicyParameters

+ Tags map[string]string

+ TaskGroups []TaskGroup

+ User string

+ type AsyncRMCallback struct

+ func NewAsyncRMCallback(ctx *Context) *AsyncRMCallback

+ func (callback *AsyncRMCallback) GetStateDump() (string, error)

+ func (callback *AsyncRMCallback) Predicates(args *si.PredicatesArgs) error

+ func (callback *AsyncRMCallback) PreemptionPredicates(args *si.PreemptionPredicatesArgs) *si.PreemptionPredicatesResponse

+ func (callback *AsyncRMCallback) SendEvent(eventRecords []*si.EventRecord)

+ func (callback *AsyncRMCallback) UpdateAllocation(response *si.AllocationResponse) error

+ func (callback *AsyncRMCallback) UpdateApplication(response *si.ApplicationResponse) error

+ func (callback *AsyncRMCallback) UpdateContainerSchedulingState(request *si.UpdateContainerSchedulingStateRequest)

+ func (callback *AsyncRMCallback) UpdateNode(response *si.NodeResponse) error

type Context

+ func (ctx *Context) AddPod(obj interface{})

+ func (ctx *Context) DeletePod(obj interface{})

+ func (ctx *Context) InitializeState() error

+ func (ctx *Context) IsTaskMaybeSchedulable(taskID string) bool

+ func (ctx *Context) UpdatePod(_, newObj interface{})

+ type SchedulingPolicyParameters struct

+ func GetSchedulingPolicyParam(pod *v1.Pod) *SchedulingPolicyParameters

+ func NewSchedulingPolicyParameters(placeholderTimeout int64, gangSchedulingStyle string) *SchedulingPolicyParameters

+ func (spp *SchedulingPolicyParameters) GetGangSchedulingStyle() string

+ func (spp *SchedulingPolicyParameters) GetPlaceholderTimeout() int64

type Task

+ func (task *Task) MarkPreviouslyAllocated(allocationID string, nodeID string)

+ type TaskGroup struct

+ Affinity *v1.Affinity

+ Annotations map[string]string

+ Labels map[string]string

+ MinMember int32

+ MinResource map[string]resource.Quantity

+ Name string

+ NodeSelector map[string]string

+ Tolerations []v1.Toleration

+ func FindAppTaskGroup(appTaskGroups []*TaskGroup, groupName string) (*TaskGroup, error)

+ func GetTaskGroupsFromAnnotation(pod *v1.Pod) ([]TaskGroup, error)

+ type TaskMetadata struct

+ ApplicationID string

+ Placeholder bool

+ Pod *v1.Pod

+ TaskGroupName string

+ TaskID string

+ type TaskSchedulingState int8

+ const TaskSchedAllocated

+ const TaskSchedFailed

+ const TaskSchedPending

+ const TaskSchedSkipped

+ func (tss TaskSchedulingState) String() string

Nov 14, 2023

Changes in this version

type Context

+ func (ctx *Context) EventsToRegister() []framework.ClusterEvent

type Task

+ func (task *Task) GetTaskSchedulingState() interfaces.TaskSchedulingState

+ func (task *Task) SetTaskSchedulingState(state interfaces.TaskSchedulingState)

+ func (task *Task) UpdatePodCondition(podCondition *v1.PodCondition) (bool, *v1.Pod)

Jun 1, 2023

Changes in this version

type Application

+ func (app *Application) GetBoundTasks() []*Task

type Context

+ func NewContextWithBootstrapConfigMaps(apis client.APIProvider, bootstrapConfigMaps []*v1.ConfigMap) *Context

+ func (ctx *Context) GetAllApplications() []*Application

+ func (ctx *Context) GetSchedulerCache() *schedulercache.SchedulerCache

+ func (ctx *Context) IsPodFitNodeViaPreemption(name, node string, allocations []string, startIndex int) (index int, ok bool)

Jan 27, 2023

Changes in this version

type Context

+ func (ctx *Context) GetStateDump() (string, error)

+ func (ctx *Context) IsPreemptSelfAllowed(priorityClassName string) bool

+ func (ctx *Context) LoadConfigMaps() ([]*v1.ConfigMap, error)

type Task

+ func (task *Task) UpdateTaskPod(pod *v1.Pod, podMutator func(pod *v1.Pod)) (*v1.Pod, error)

Aug 30, 2022

Changes in this version

+ type AStates struct

+ Accepted string

+ Completed string

+ Failed string

+ Failing string

+ Killed string

+ Killing string

+ New string

+ Recovering string

+ Rejected string

+ Reserving string

+ Resuming string

+ Running string

+ Submitted string

+ func ApplicationStates() *AStates

type Application

+ func (app *Application) GetOriginatingTask() interfaces.ManagedTask

+ func (app *Application) GetPlaceHolderTasks() []*Task

+ type ApplicationEventType int

+ const AcceptApplication

+ const AppStateChange

+ const AppTaskCompleted

+ const CompleteApplication

+ const FailApplication

+ const KillApplication

+ const KilledApplication

+ const RecoverApplication

+ const RejectApplication

+ const ReleaseAppAllocation

+ const ReleaseAppAllocationAsk

+ const ResumingApplication

+ const RunApplication

+ const SubmitApplication

+ const TryReserve

+ const UpdateReservation

+ func (ae ApplicationEventType) String() string

type MockedAMProtocol

+ func (m *MockedAMProtocol) UseAddTaskFn(fn func(request *interfaces.AddTaskRequest))

+ type NStates struct

+ Accepted string

+ Draining string

+ Healthy string

+ New string

+ Recovering string

+ Rejected string

+ func SchedulerNodeStates() *NStates

+ type SchedulerNodeEventType int

+ const DrainNode

+ const NodeAccepted

+ const NodeReady

+ const NodeRejected

+ const RecoverNode

+ const RestoreNode

+ func (ae SchedulerNodeEventType) String() string

+ type TStates struct

+ Allocated string

+ Any []string

+ Bound string

+ Completed string

+ Failed string

+ Killed string

+ Killing string

+ New string

+ Pending string

+ Rejected string

+ Scheduling string

+ Terminated []string

+ func TaskStates() *TStates

type Task

+ func (task *Task) IsOriginator() bool

+ type TaskEventType int

+ const CompleteTask

+ const InitTask

+ const KillTask

+ const SubmitTask

+ const TaskAllocated

+ const TaskBound

+ const TaskFail

+ const TaskKilled

+ const TaskRejected

+ func (ae TaskEventType) String() string

Apr 27, 2022

Changes in this version

+ const AddOccupiedResource

+ const SubOccupiedResource

+ type AllocatedTaskEvent struct

+ func NewAllocateTaskEvent(appID string, taskID string, allocUUID string, nid string) AllocatedTaskEvent

+ func (ae AllocatedTaskEvent) GetApplicationID() string

+ func (ae AllocatedTaskEvent) GetArgs() []interface{}

+ func (ae AllocatedTaskEvent) GetEvent() events.TaskEventType

+ func (ae AllocatedTaskEvent) GetTaskID() string

+ type Application struct

+ func NewApplication(appID, queueName, user string, tags map[string]string, ...) *Application

+ func (app *Application) GetAllocatedTasks() []*Task

+ func (app *Application) GetApplicationID() string

+ func (app *Application) GetApplicationState() string

+ func (app *Application) GetNewTasks() []*Task

+ func (app *Application) GetPendingTasks() []*Task

+ func (app *Application) GetQueue() string

+ func (app *Application) GetSchedulingParamsDefinition() string

+ func (app *Application) GetTags() map[string]string

+ func (app *Application) GetTask(taskID string) (interfaces.ManagedTask, error)

+ func (app *Application) GetTaskGroupsDefinition() string

+ func (app *Application) GetUser() string

+ func (app *Application) Schedule() bool

+ func (app *Application) SetPlaceholderTimeout(timeout int64)

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

+ func (app *Application) String() string

+ func (app *Application) TriggerAppRecovery() error

+ type ApplicationEvent struct

+ func NewApplicationEvent(appID string, eventType events.ApplicationEventType, msg string) ApplicationEvent

+ func (st ApplicationEvent) GetApplicationID() string

+ func (st ApplicationEvent) GetArgs() []interface{}

+ func (st ApplicationEvent) GetEvent() events.ApplicationEventType

+ type ApplicationStatusChangeEvent struct

+ func NewApplicationStatusChangeEvent(appID string, eventType events.ApplicationEventType, state string) ApplicationStatusChangeEvent

+ func (st ApplicationStatusChangeEvent) GetApplicationID() string

+ func (st ApplicationStatusChangeEvent) GetArgs() []interface{}

+ func (st ApplicationStatusChangeEvent) GetEvent() events.ApplicationEventType

+ func (st ApplicationStatusChangeEvent) GetState() string

+ type BindTaskEvent struct

+ func NewBindTaskEvent(appID string, taskID string) BindTaskEvent

+ func (bt BindTaskEvent) GetApplicationID() string

+ func (bt BindTaskEvent) GetArgs() []interface{}

+ func (bt BindTaskEvent) GetEvent() events.TaskEventType

+ func (bt BindTaskEvent) GetTaskID() string

+ type CachedSchedulerNodeEvent struct

+ Arguments []interface{}

+ Event events.SchedulerNodeEventType

+ NodeID string

+ func (sn CachedSchedulerNodeEvent) GetArgs() []interface{}

+ func (sn CachedSchedulerNodeEvent) GetEvent() events.SchedulerNodeEventType

+ func (sn CachedSchedulerNodeEvent) GetNodeID() string

+ type Context struct

+ func NewContext(apis client.APIProvider) *Context

+ func (ctx *Context) AddApplication(request *interfaces.AddApplicationRequest) interfaces.ManagedApp

+ func (ctx *Context) AddPendingPodAllocation(podKey string, nodeID string)

+ func (ctx *Context) AddSchedulingEventHandlers()

+ func (ctx *Context) AddTask(request *interfaces.AddTaskRequest) interfaces.ManagedTask

+ func (ctx *Context) ApplicationEventHandler() func(obj interface{})

+ func (ctx *Context) AssumePod(name string, node string) error

+ func (ctx *Context) ForgetPod(name string)

+ func (ctx *Context) GetApplication(appID string) interfaces.ManagedApp

+ func (ctx *Context) GetInProgressPodAllocation(podKey string) (nodeID string, ok bool)

+ func (ctx *Context) GetPendingPodAllocation(podKey string) (nodeID string, ok bool)

+ func (ctx *Context) HandleContainerStateUpdate(request *si.UpdateContainerSchedulingStateRequest)

+ func (ctx *Context) IsPluginMode() bool

+ func (ctx *Context) IsPodFitNode(name, node string, allocate bool) error

+ func (ctx *Context) NotifyApplicationComplete(appID string)

+ func (ctx *Context) NotifyApplicationFail(appID string)

+ func (ctx *Context) NotifyTaskComplete(appID, taskID string)

+ func (ctx *Context) PublishEvents(eventRecords []*si.EventRecord)

+ func (ctx *Context) RemoveApplication(appID string) error

+ func (ctx *Context) RemoveApplicationInternal(appID string)

+ func (ctx *Context) RemovePodAllocation(podKey string)

+ func (ctx *Context) RemoveTask(appID, taskID string)

+ func (ctx *Context) SaveConfigmap(request *si.UpdateConfigurationRequest) *si.UpdateConfigurationResponse

+ func (ctx *Context) SchedulerNodeEventHandler() func(obj interface{})

+ func (ctx *Context) SelectApplications(filter func(app *Application) bool) []*Application

+ func (ctx *Context) SetPluginMode(pluginMode bool)

+ func (ctx *Context) StartPodAllocation(podKey string, nodeID string) bool

+ func (ctx *Context) TaskEventHandler() func(obj interface{})

+ func (ctx *Context) UpdateApplication(app *Application)

+ func (ctx *Context) WaitForRecovery(recoverableAppManagers []interfaces.Recoverable, maxTimeout time.Duration) error

+ type FailApplicationEvent struct

+ func NewFailApplicationEvent(appID, message string) FailApplicationEvent

+ func (fe FailApplicationEvent) GetApplicationID() string

+ func (fe FailApplicationEvent) GetArgs() []interface{}

+ func (fe FailApplicationEvent) GetEvent() events.ApplicationEventType

+ type FailTaskEvent struct

+ func NewFailTaskEvent(appID string, taskID string, failedMessage string) FailTaskEvent

+ func (fe FailTaskEvent) GetApplicationID() string

+ func (fe FailTaskEvent) GetArgs() []interface{}

+ func (fe FailTaskEvent) GetEvent() events.TaskEventType

+ func (fe FailTaskEvent) GetTaskID() string

+ type MockedAMProtocol struct

+ func NewMockedAMProtocol() *MockedAMProtocol

+ func (m *MockedAMProtocol) AddApplication(request *interfaces.AddApplicationRequest) interfaces.ManagedApp

+ func (m *MockedAMProtocol) AddTask(request *interfaces.AddTaskRequest) interfaces.ManagedTask

+ func (m *MockedAMProtocol) GetApplication(appID string) interfaces.ManagedApp

+ func (m *MockedAMProtocol) NotifyApplicationComplete(appID string)

+ func (m *MockedAMProtocol) NotifyApplicationFail(appID string)

+ func (m *MockedAMProtocol) NotifyTaskComplete(appID, taskID string)

+ func (m *MockedAMProtocol) RemoveApplication(appID string) error

+ func (m *MockedAMProtocol) RemoveTask(appID, taskID string)

+ type Placeholder struct

+ func (p *Placeholder) String() string

+ type PlaceholderManager struct

+ func NewPlaceholderManager(clients *client.Clients) *PlaceholderManager

+ func (mgr *PlaceholderManager) Start()

+ func (mgr *PlaceholderManager) Stop()

+ type RejectTaskEvent struct

+ func NewRejectTaskEvent(appID string, taskID string, rejectedMessage string) RejectTaskEvent

+ func (re RejectTaskEvent) GetApplicationID() string

+ func (re RejectTaskEvent) GetArgs() []interface{}

+ func (re RejectTaskEvent) GetEvent() events.TaskEventType

+ func (re RejectTaskEvent) GetTaskID() string

+ type ReleaseAppAllocationAskEvent struct

+ func NewReleaseAppAllocationAskEvent(appID string, allocTermination si.TerminationType, taskID string) ReleaseAppAllocationAskEvent

+ func (re ReleaseAppAllocationAskEvent) GetApplicationID() string

+ func (re ReleaseAppAllocationAskEvent) GetArgs() []interface{}

+ func (re ReleaseAppAllocationAskEvent) GetEvent() events.ApplicationEventType

+ type ReleaseAppAllocationEvent struct

+ func NewReleaseAppAllocationEvent(appID string, allocTermination si.TerminationType, uuid string) ReleaseAppAllocationEvent

+ func (re ReleaseAppAllocationEvent) GetApplicationID() string

+ func (re ReleaseAppAllocationEvent) GetArgs() []interface{}

+ func (re ReleaseAppAllocationEvent) GetEvent() events.ApplicationEventType

+ type ResumingApplicationEvent struct

+ func NewResumingApplicationEvent(appID string) ResumingApplicationEvent

+ func (re ResumingApplicationEvent) GetApplicationID() string

+ func (re ResumingApplicationEvent) GetArgs() []interface{}

+ func (re ResumingApplicationEvent) GetEvent() events.ApplicationEventType

+ type RunApplicationEvent struct

+ func NewRunApplicationEvent(appID string) RunApplicationEvent

+ func (re RunApplicationEvent) GetApplicationID() string

+ func (re RunApplicationEvent) GetArgs() []interface{}

+ func (re RunApplicationEvent) GetEvent() events.ApplicationEventType

+ type SchedulerNode struct

+ type SimpleApplicationEvent struct

+ func NewSimpleApplicationEvent(appID string, eventType events.ApplicationEventType) SimpleApplicationEvent

+ func (st SimpleApplicationEvent) GetApplicationID() string

+ func (st SimpleApplicationEvent) GetArgs() []interface{}

+ func (st SimpleApplicationEvent) GetEvent() events.ApplicationEventType

+ type SimpleTaskEvent struct

+ func NewSimpleTaskEvent(appID string, taskID string, taskType events.TaskEventType) SimpleTaskEvent

+ func (st SimpleTaskEvent) GetApplicationID() string

+ func (st SimpleTaskEvent) GetArgs() []interface{}

+ func (st SimpleTaskEvent) GetEvent() events.TaskEventType

+ func (st SimpleTaskEvent) GetTaskID() string

+ type SubmitApplicationEvent struct

+ func NewSubmitApplicationEvent(appID string) SubmitApplicationEvent

+ func (se SubmitApplicationEvent) GetApplicationID() string

+ func (se SubmitApplicationEvent) GetArgs() []interface{}

+ func (se SubmitApplicationEvent) GetEvent() events.ApplicationEventType

+ type SubmitTaskEvent struct

+ func NewSubmitTaskEvent(appID string, taskID string) SubmitTaskEvent

+ func (st SubmitTaskEvent) GetApplicationID() string

+ func (st SubmitTaskEvent) GetArgs() []interface{}

+ func (st SubmitTaskEvent) GetEvent() events.TaskEventType

+ func (st SubmitTaskEvent) GetTaskID() string

+ type Task struct

+ func NewFromTaskMeta(tid string, app *Application, ctx *Context, metadata interfaces.TaskMetadata) *Task

+ func NewTask(tid string, app *Application, ctx *Context, pod *v1.Pod) *Task

+ func NewTaskPlaceholder(tid string, app *Application, ctx *Context, pod *v1.Pod) *Task

+ func (task *Task) DeleteTaskPod(pod *v1.Pod) error

+ func (task *Task) GetTaskID() string

+ func (task *Task) GetTaskPod() *v1.Pod

+ func (task *Task) GetTaskState() string

+ func (task *Task) IsPlaceholder() bool

+ func (task *Task) UpdateTaskPodStatus(pod *v1.Pod) (*v1.Pod, error)

+ type UpdateApplicationReservationEvent struct

+ func NewUpdateApplicationReservationEvent(appID string) UpdateApplicationReservationEvent

+ func (ue UpdateApplicationReservationEvent) GetApplicationID() string

+ func (ue UpdateApplicationReservationEvent) GetArgs() []interface{}

+ func (ue UpdateApplicationReservationEvent) GetEvent() events.ApplicationEventType