queue

Nov 11, 2024

Changes in this version

+ type CancelAPI func(string, []string, []api.JobState) error

+ func Cancel(getConnectionDetails client.ConnectionDetails) CancelAPI

+ type PreemptAPI func(string, []string) error

+ func Preempt(getConnectionDetails client.ConnectionDetails) PreemptAPI

Aug 2, 2024

Changes in this version

+ type CordonAPI func(string) error

+ func Cordon(getConnectionDetails client.ConnectionDetails) CordonAPI

+ type GetAllAPI func() ([]*api.Queue, error)

+ func GetAll(getConnectionDetails client.ConnectionDetails) GetAllAPI

type Queue

+ Cordoned bool

+ Labels []string

+ type UncordonAPI func(string) error

+ func Uncordon(getConnectionDetails client.ConnectionDetails) UncordonAPI

Apr 16, 2024

Changes in this version

type PermissionVerb

+ const PermissionVerbPreempt

Mar 4, 2024

Changes in this version

type Queue

+ ResourceLimitsByPriorityClassName map[string]api.PriorityClassResourceLimits

Oct 30, 2023

Changes in this version

+ type GetAPI func(string) (*api.Queue, error)

+ func Get(getConnectionDetails client.ConnectionDetails) GetAPI

Jan 23, 2023

Changes in this version

+ func QueuesToAPI(queues []Queue) []*api.Queue

+ type CreateAPI func(Queue) error

+ func Create(getConnectionDetails client.ConnectionDetails) CreateAPI

+ type DeleteAPI func(string) error

+ func Delete(getConnectionDetails client.ConnectionDetails) DeleteAPI

+ type GetInfoAPI func(string) (*api.QueueInfo, error)

+ func GetInfo(getConnectionDetails client.ConnectionDetails) GetInfoAPI

+ type PermissionSubject struct

+ Kind PermissionSubjectKind

+ Name string

+ type PermissionSubjectKind string

+ const PermissionSubjectKindGroup

+ const PermissionSubjectKindUser

+ func NewPermissionSubjectKind(in string) (PermissionSubjectKind, error)

+ func (kind *PermissionSubjectKind) UnmarshalJSON(data []byte) error

+ func (kind PermissionSubjectKind) Generate(rand *rand.Rand, size int) reflect.Value

+ type PermissionSubjects []PermissionSubject

+ func NewPermissionSubjects(subjects []*api.Queue_Permissions_Subject) (PermissionSubjects, error)

+ func NewPermissionSubjectsFromOwners(users, groups []string) PermissionSubjects

+ type PermissionVerb string

+ const PermissionVerbCancel

+ const PermissionVerbReprioritize

+ const PermissionVerbSubmit

+ const PermissionVerbWatch

+ func NewPermissionVerb(in string) (PermissionVerb, error)

+ func (verb *PermissionVerb) UnmarshalJSON(data []byte) error

+ func (verb PermissionVerb) Generate(rand *rand.Rand, size int) reflect.Value

+ type PermissionVerbs []PermissionVerb

+ func AllPermissionVerbs() PermissionVerbs

+ func NewPermissionVerbs(verbs []string) (PermissionVerbs, error)

+ type Permissions struct

+ Subjects PermissionSubjects

+ Verbs PermissionVerbs

+ func NewPermissions(perm *api.Queue_Permissions) (Permissions, error)

+ func NewPermissionsFromOwners(users, groups []string) Permissions

+ func (p Permissions) ToAPI() *api.Queue_Permissions

+ type PriorityFactor float64

+ func NewPriorityFactor(in float64) (PriorityFactor, error)

+ func (f *PriorityFactor) UnmarshalJSON(data []byte) error

+ func (f PriorityFactor) Generate(rand *rand.Rand, size int) reflect.Value

+ type Queue struct

+ Name string

+ Permissions []Permissions

+ PriorityFactor PriorityFactor

+ ResourceLimits ResourceLimits

+ func NewQueue(in *api.Queue) (Queue, error)

+ func (q Queue) HasPermission(inputSubject PermissionSubject, inputVerb PermissionVerb) bool

+ func (q Queue) ToAPI() *api.Queue

+ type ResourceLimit float64

+ func NewResourceLimit(in float64) (ResourceLimit, error)

+ func (ResourceLimit) Generate(rand *rand.Rand, size int) reflect.Value

+ func (rl *ResourceLimit) UnmarshalJSON(data []byte) error

+ type ResourceLimits map[ResourceName]ResourceLimit

+ func NewResourceLimits(in map[string]float64) (ResourceLimits, error)

+ type ResourceName string

+ const ResourceNameCPU

+ const ResourceNameMemory

+ func NewResourceName(in string) (ResourceName, error)

+ func (ResourceName) Generate(rand *rand.Rand, size int) reflect.Value

+ func (rn *ResourceName) UnmarshalJSON(data []byte) error

+ type UpdateAPI func(queue Queue) error

+ func Update(getConnectionDetails client.ConnectionDetails) UpdateAPI