api

type Arguments map[string]string

type ClusterID string

type FinishedJobInfo struct {
	Namespace        string
	Name             string
	Duration         time.Duration
	FrameworkVersion schema.FrameworkVersion
}

type GetStatusFunc func(interface{}) (StatusInfo, error)

type JobQueue struct {
	sync.RWMutex
	StopCh chan struct{}
	Queue  *QueueInfo

	Jobs *PriorityQueue
	// contains filtered or unexported fields
}

type JobQueues struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type JobSyncInfo struct {
	ID               string
	Namespace        string
	ParentJobID      string
	FrameworkVersion schema.FrameworkVersion
	Status           schema.JobStatus
	RuntimeInfo      interface{}
	RuntimeStatus    interface{}
	Annotations      map[string]string
	Message          string
	Action           schema.ActionType
	RetryTimes       int
}

type LessFn func(interface{}, interface{}) bool

type NodeSyncInfo struct {
	Name       string
	Status     string
	Capacity   map[string]string
	Labels     map[string]string
	Action     schema.ActionType
	RetryTimes int
}

type NodeTaskSyncInfo struct {
	ID         string
	Name       string
	NodeName   string
	Status     model.TaskAllocateStatus
	Resources  map[string]int64
	Labels     map[string]string
	Action     schema.ActionType
	RetryTimes int
}

type PFJob struct {
	ID        string
	Name      string
	Namespace string
	UserName  string
	// JobType of job, such as TypeSingle, TypeDistributed, and TypeWorkflow
	JobType   schema.JobType
	Framework schema.Framework
	// TODO: use Framework and Tasks.Role instead of JobMode
	JobMode string
	Status  string
	// compute resource request resource for job
	// ClusterID and QueueID of job
	ClusterID    ClusterID
	QueueID      QueueID
	QueueName    string
	Resource     *resources.Resource
	Priority     int32
	MinAvailable int32
	// PriorityClassName defines job info on cluster
	PriorityClassName string

	// Tasks for TypeDistributed job
	Tasks []schema.Member
	// ExtRuntimeConf define extra runtime conf
	ExtRuntimeConf []byte
	// ExtensionTemplate records the extension template of job
	ExtensionTemplate []byte
	IsCustomYaml      bool
	// Conf for job
	Conf schema.Conf

	// Labels for job to update
	Labels      map[string]string
	Annotations map[string]string

	// extend field
	Tags   []string
	LogUrl string

	WaitingTime *time.Duration
	CreateTime  time.Time
	StartTime   time.Time
	EndTIme     time.Time
}

type PFJobInterface interface {
	CreateJob() (string, error)
	StopJobByID(string) error
	UpdateJob([]byte) error
	GetID() string
}

type PolicyFactory = func(configuration Arguments) (SortPolicy, error)

type PriorityQueue struct {
	// contains filtered or unexported fields
}

type QueueID string

type QueueInfo struct {
	UID       QueueID
	Name      string
	Namespace string
	// ClusterID for queue
	ClusterID ClusterID
	Type      string
	Status    string

	// Priority for queue
	Priority int32
	Weight   int32

	// SortPolicy for queue job
	SortPolicyNames []string
	SortPolicies    []SortPolicy
	// Location for queue affinity
	Location map[string]string

	// SchedulerName for queue job
	SchedulerName string

	//
	Permissions []string

	// Resource range of queue
	MaxResources  *resources.Resource
	MinResources  *resources.Resource
	UsedResources *resources.Resource
}

type QueueSyncInfo struct {
	Name        string
	Namespace   string
	Labels      map[string]string
	Status      string
	QuotaType   string
	MaxResource *resources.Resource
	MinResource *resources.Resource
	Action      schema.ActionType
	Message     string
	RetryTimes  int
}

type Registry map[string]PolicyFactory

type SortPolicy interface {
	Name() string
	OrderFn(interface{}, interface{}) int
}

type StatusInfo struct {
	OriginStatus string
	Status       schema.JobStatus
	Message      string
}

type TaskSyncInfo struct {
	ID         string
	Name       string
	Namespace  string
	JobID      string
	NodeName   string
	MemberRole schema.MemberRole
	Status     schema.TaskStatus
	Message    string
	PodStatus  interface{}
	Action     schema.ActionType
	RetryTimes int
}