ugm

Nov 14, 2023

Changes in this version

type GroupTracker

+ func (gt *GroupTracker) IsQueuePathTrackedCompletely(hierarchy []string) bool

+ func (gt *GroupTracker) IsUnlinkRequired(hierarchy []string) bool

+ func (gt *GroupTracker) UnlinkQT(hierarchy []string) bool

+ type LimitConfig struct

type Manager

+ func (m *Manager) CanRunApp(queuePath, applicationID string, user security.UserGroup) bool

+ func (m *Manager) ClearConfigLimits()

+ func (m *Manager) Headroom(queuePath, applicationID string, user security.UserGroup) *resources.Resource

+ func (m *Manager) UpdateConfig(config configs.QueueConfig, queuePath string) error

type QueueTracker

+ func (qt *QueueTracker) IsQueuePathTrackedCompletely(hierarchy []string) bool

+ func (qt *QueueTracker) IsUnlinkRequired(hierarchy []string) bool

+ func (qt *QueueTracker) UnlinkQT(hierarchy []string) bool

type UserTracker

+ func (ut *UserTracker) IsQueuePathTrackedCompletely(hierarchy []string) bool

+ func (ut *UserTracker) IsUnlinkRequired(hierarchy []string) bool

+ func (ut *UserTracker) UnlinkQT(hierarchy []string) bool

Jan 27, 2023

Changes in this version

+ type GroupTracker struct

+ func (gt *GroupTracker) GetGroupResourceUsageDAOInfo() *dao.GroupResourceUsageDAOInfo

+ type Manager struct

+ func GetUserManager() *Manager

+ func (m *Manager) ClearGroupTrackers()

+ func (m *Manager) ClearUserTrackers()

+ func (m *Manager) DecreaseTrackedResource(queuePath string, applicationID string, usage *resources.Resource, ...) error

+ func (m *Manager) GetGroupResources(group string) *resources.Resource

+ func (m *Manager) GetGroupTracker(group string) *GroupTracker

+ func (m *Manager) GetGroupsResources() []*GroupTracker

+ func (m *Manager) GetUserResources(user security.UserGroup) *resources.Resource

+ func (m *Manager) GetUserTracker(user string) *UserTracker

+ func (m *Manager) GetUsersResources() []*UserTracker

+ func (m *Manager) IncreaseTrackedResource(queuePath string, applicationID string, usage *resources.Resource, ...) error

+ type QueueTracker struct

+ type Tracker interface

+ DecreaseTrackedResource func(queuePath, applicationID string, usage *resources.Resource, ...) error

+ GetGroupResources func(group string) *resources.Resource

+ GetGroupsResources func() []*GroupTracker

+ GetUserResources func(user security.UserGroup) *resources.Resource

+ GetUsersResources func() []*UserTracker

+ IncreaseTrackedResource func(queuePath, applicationID string, usage *resources.Resource, ...) error

+ type UserTracker struct

+ func (ut *UserTracker) GetUserResourceUsageDAOInfo() *dao.UserResourceUsageDAOInfo