Documentation
¶
Index ¶
- type RMApplicationUpdateEvent
- type RMConfigUpdateEvent
- type RMNewAllocationsEvent
- type RMNodeUpdateEvent
- type RMPartitionsRemoveEvent
- type RMRegistrationEvent
- type RMRejectedAllocationEvent
- type RMReleaseAllocationEvent
- type RMUpdateAllocationEvent
- type RMUpdateApplicationEvent
- type RMUpdateNodeEvent
- type Result
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RMApplicationUpdateEvent ¶
type RMApplicationUpdateEvent struct {
RmID string
AcceptedApplications []*si.AcceptedApplication
RejectedApplications []*si.RejectedApplication
UpdatedApplications []*si.UpdatedApplication
}
type RMConfigUpdateEvent ¶
type RMNewAllocationsEvent ¶
type RMNewAllocationsEvent struct {
RmID string
Allocations []*si.Allocation
Channel chan *Result `json:"-"`
}
Outgoing events from the scheduler to the RM
type RMNodeUpdateEvent ¶
type RMNodeUpdateEvent struct {
RmID string
AcceptedNodes []*si.AcceptedNode
RejectedNodes []*si.RejectedNode
}
type RMPartitionsRemoveEvent ¶
type RMRegistrationEvent ¶
type RMRegistrationEvent struct {
Registration *si.RegisterResourceManagerRequest
Channel chan *Result `json:"-"`
}
Incoming events from the RM to the scheduler (sync)
type RMRejectedAllocationEvent ¶ added in v1.4.0
type RMRejectedAllocationEvent struct {
RmID string
RejectedAllocations []*si.RejectedAllocation
}
type RMReleaseAllocationEvent ¶
type RMReleaseAllocationEvent struct {
RmID string
ReleasedAllocations []*si.AllocationRelease
Channel chan *Result `json:"-"`
}
type RMUpdateAllocationEvent ¶
type RMUpdateAllocationEvent struct {
// The generic UpdateAllocation does not wait for a result,
// results are communicated back via the outgoing events.
Request *si.AllocationRequest
}
Incoming UpdateAllocation events from the RM to the scheduler (async)
type RMUpdateApplicationEvent ¶
type RMUpdateApplicationEvent struct {
// The generic UpdateApplication does not wait for a result,
// results are communicated back via the outgoing events.
Request *si.ApplicationRequest
}
Incoming UpdateApplication events from the RM to the scheduler (async)
type RMUpdateNodeEvent ¶
type RMUpdateNodeEvent struct {
// The generic UpdateNode does not wait for a result,
// results are communicated back via the outgoing events.
Request *si.NodeRequest
}
Incoming UpdateNode events from the RM to the scheduler (async)
Click to show internal directories.
Click to hide internal directories.