events

Documentation

Index

• type ApplicationEvents
  • func NewApplicationEvents(es events.EventSystem) *ApplicationEvents
  • func (ae *ApplicationEvents) SendAppNotRunnableInQueueEvent(appID string)
  • func (ae *ApplicationEvents) SendAppNotRunnableQuotaEvent(appID string)
  • func (ae *ApplicationEvents) SendAppRunnableInQueueEvent(appID string)
  • func (ae *ApplicationEvents) SendAppRunnableQuotaEvent(appID string)
  • func (ae *ApplicationEvents) SendNewAllocationEvent(appID, allocKey string, allocated *resources.Resource)
  • func (ae *ApplicationEvents) SendNewApplicationEvent(appID string)
  • func (ae *ApplicationEvents) SendNewAskEvent(appID, allocKey string, allocated *resources.Resource)
  • func (ae *ApplicationEvents) SendPlaceholderLargerEvent(taskGroup, appID, phAllocKey string, askRes, phRes *resources.Resource)
  • func (ae *ApplicationEvents) SendRemoveAllocationEvent(appID, allocKey string, allocated *resources.Resource, ...)
  • func (ae *ApplicationEvents) SendRemoveApplicationEvent(appID string)
  • func (ae *ApplicationEvents) SendRemoveAskEvent(appID, allocKey string, allocated *resources.Resource, ...)
  • func (ae *ApplicationEvents) SendStateChangeEvent(appID string, changeDetail si.EventRecord_ChangeDetail, eventInfo string)
• type AskEvents
  • func NewAskEvents(evt events.EventSystem) *AskEvents
  • func (ae *AskEvents) SendPredicatesFailed(allocKey, appID string, predicateErrors map[string]int, ...)
  • func (ae *AskEvents) SendRequestExceedsQueueHeadroom(allocKey, appID string, headroom, allocatedResource *resources.Resource, ...)
  • func (ae *AskEvents) SendRequestExceedsUserQuota(allocKey, appID string, headroom, allocatedResource *resources.Resource)
  • func (ae *AskEvents) SendRequestFitsInQueue(allocKey, appID, queuePath string, allocatedResource *resources.Resource)
  • func (ae *AskEvents) SendRequestFitsInUserQuota(allocKey, appID string, allocatedResource *resources.Resource)
• type NodeEvents
  • func NewNodeEvents(evt events.EventSystem) *NodeEvents
  • func (n *NodeEvents) SendAllocationAddedEvent(nodeID, allocKey string, res *resources.Resource)
  • func (n *NodeEvents) SendAllocationRemovedEvent(nodeID, allocKey string, res *resources.Resource)
  • func (n *NodeEvents) SendNodeAddedEvent(nodeID string, capacity *resources.Resource)
  • func (n *NodeEvents) SendNodeCapacityChangedEvent(nodeID string, total *resources.Resource)
  • func (n *NodeEvents) SendNodeOccupiedResourceChangedEvent(nodeID string, occupied *resources.Resource)
  • func (n *NodeEvents) SendNodeRemovedEvent(nodeID string)
  • func (n *NodeEvents) SendNodeSchedulableChangedEvent(nodeID string, ready bool)
  • func (n *NodeEvents) SendReservedEvent(nodeID string, res *resources.Resource, askID string)
  • func (n *NodeEvents) SendUnreservedEvent(nodeID string, res *resources.Resource, askID string)
• type QueueEvents
  • func NewQueueEvents(evt events.EventSystem) *QueueEvents
  • func (q *QueueEvents) SendGuaranteedResourceChangedEvent(queuePath string, guaranteed *resources.Resource)
  • func (q *QueueEvents) SendMaxResourceChangedEvent(queuePath string, maxResource *resources.Resource)
  • func (q *QueueEvents) SendNewApplicationEvent(queuePath, appID string)
  • func (q *QueueEvents) SendNewQueueEvent(queuePath string, managed bool)
  • func (q *QueueEvents) SendRemoveApplicationEvent(queuePath, appID string)
  • func (q *QueueEvents) SendRemoveQueueEvent(queuePath string, managed bool)
  • func (q *QueueEvents) SendTypeChangedEvent(queuePath string, isLeaf bool)

Types

type ApplicationEvents

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

func NewApplicationEvents

func NewApplicationEvents(es events.EventSystem) *ApplicationEvents

func (*ApplicationEvents) SendAppNotRunnableInQueueEvent

func (ae *ApplicationEvents) SendAppNotRunnableInQueueEvent(appID string)

func (*ApplicationEvents) SendAppNotRunnableQuotaEvent

func (ae *ApplicationEvents) SendAppNotRunnableQuotaEvent(appID string)

func (*ApplicationEvents) SendAppRunnableInQueueEvent

func (ae *ApplicationEvents) SendAppRunnableInQueueEvent(appID string)

func (*ApplicationEvents) SendAppRunnableQuotaEvent

func (ae *ApplicationEvents) SendAppRunnableQuotaEvent(appID string)

func (*ApplicationEvents) SendNewAllocationEvent

func (ae *ApplicationEvents) SendNewAllocationEvent(appID, allocKey string, allocated *resources.Resource)

func (*ApplicationEvents) SendNewApplicationEvent

func (ae *ApplicationEvents) SendNewApplicationEvent(appID string)

func (*ApplicationEvents) SendNewAskEvent

func (ae *ApplicationEvents) SendNewAskEvent(appID, allocKey string, allocated *resources.Resource)

func (*ApplicationEvents) SendPlaceholderLargerEvent

func (ae *ApplicationEvents) SendPlaceholderLargerEvent(taskGroup, appID, phAllocKey string, askRes, phRes *resources.Resource)

func (*ApplicationEvents) SendRemoveAllocationEvent

func (ae *ApplicationEvents) SendRemoveAllocationEvent(appID, allocKey string, allocated *resources.Resource, terminationType si.TerminationType)

func (*ApplicationEvents) SendRemoveApplicationEvent

func (ae *ApplicationEvents) SendRemoveApplicationEvent(appID string)

func (*ApplicationEvents) SendRemoveAskEvent

func (ae *ApplicationEvents) SendRemoveAskEvent(appID, allocKey string, allocated *resources.Resource, detail si.EventRecord_ChangeDetail)

func (*ApplicationEvents) SendStateChangeEvent

func (ae *ApplicationEvents) SendStateChangeEvent(appID string, changeDetail si.EventRecord_ChangeDetail, eventInfo string)

type AskEvents

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

AskEvents Request-specific events. These events are of REQUEST type, so they are eventually sent to the respective pods in K8s.

func NewAskEvents

func NewAskEvents(evt events.EventSystem) *AskEvents

func (*AskEvents) SendPredicatesFailed

func (ae *AskEvents) SendPredicatesFailed(allocKey, appID string, predicateErrors map[string]int, allocatedResource *resources.Resource)

func (*AskEvents) SendRequestExceedsQueueHeadroom

func (ae *AskEvents) SendRequestExceedsQueueHeadroom(allocKey, appID string, headroom, allocatedResource *resources.Resource, queuePath string)

func (*AskEvents) SendRequestExceedsUserQuota

func (ae *AskEvents) SendRequestExceedsUserQuota(allocKey, appID string, headroom, allocatedResource *resources.Resource)

func (*AskEvents) SendRequestFitsInQueue

func (ae *AskEvents) SendRequestFitsInQueue(allocKey, appID, queuePath string, allocatedResource *resources.Resource)

func (*AskEvents) SendRequestFitsInUserQuota

func (ae *AskEvents) SendRequestFitsInUserQuota(allocKey, appID string, allocatedResource *resources.Resource)

type NodeEvents

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

func NewNodeEvents

func NewNodeEvents(evt events.EventSystem) *NodeEvents

func (*NodeEvents) SendAllocationAddedEvent

func (n *NodeEvents) SendAllocationAddedEvent(nodeID, allocKey string, res *resources.Resource)

func (*NodeEvents) SendAllocationRemovedEvent

func (n *NodeEvents) SendAllocationRemovedEvent(nodeID, allocKey string, res *resources.Resource)

func (*NodeEvents) SendNodeAddedEvent

func (n *NodeEvents) SendNodeAddedEvent(nodeID string, capacity *resources.Resource)

func (*NodeEvents) SendNodeCapacityChangedEvent

func (n *NodeEvents) SendNodeCapacityChangedEvent(nodeID string, total *resources.Resource)

func (*NodeEvents) SendNodeOccupiedResourceChangedEvent

func (n *NodeEvents) SendNodeOccupiedResourceChangedEvent(nodeID string, occupied *resources.Resource)

func (*NodeEvents) SendNodeRemovedEvent

func (n *NodeEvents) SendNodeRemovedEvent(nodeID string)

func (*NodeEvents) SendNodeSchedulableChangedEvent

func (n *NodeEvents) SendNodeSchedulableChangedEvent(nodeID string, ready bool)

func (*NodeEvents) SendReservedEvent

func (n *NodeEvents) SendReservedEvent(nodeID string, res *resources.Resource, askID string)

func (*NodeEvents) SendUnreservedEvent

func (n *NodeEvents) SendUnreservedEvent(nodeID string, res *resources.Resource, askID string)

type QueueEvents

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

func NewQueueEvents

func NewQueueEvents(evt events.EventSystem) *QueueEvents

func (*QueueEvents) SendGuaranteedResourceChangedEvent

func (q *QueueEvents) SendGuaranteedResourceChangedEvent(queuePath string, guaranteed *resources.Resource)

func (*QueueEvents) SendMaxResourceChangedEvent

func (q *QueueEvents) SendMaxResourceChangedEvent(queuePath string, maxResource *resources.Resource)

func (*QueueEvents) SendNewApplicationEvent

func (q *QueueEvents) SendNewApplicationEvent(queuePath, appID string)

func (*QueueEvents) SendNewQueueEvent

func (q *QueueEvents) SendNewQueueEvent(queuePath string, managed bool)

func (*QueueEvents) SendRemoveApplicationEvent

func (q *QueueEvents) SendRemoveApplicationEvent(queuePath, appID string)

func (*QueueEvents) SendRemoveQueueEvent

func (q *QueueEvents) SendRemoveQueueEvent(queuePath string, managed bool)

func (*QueueEvents) SendTypeChangedEvent

func (q *QueueEvents) SendTypeChangedEvent(queuePath string, isLeaf bool)