rmevent

Documentation

Index

• type RMApplicationUpdateEvent
• type RMConfigUpdateEvent
• type RMNewAllocationsEvent
• type RMNodeUpdateEvent
• type RMPartitionsRemoveEvent
• type RMRegistrationEvent
• type RMRejectedAllocationAskEvent
• type RMRejectedAllocationEvent
• type RMReleaseAllocationAskEvent
• type RMReleaseAllocationEvent
• type RMUpdateAllocationEvent
• type RMUpdateApplicationEvent
• type RMUpdateNodeEvent
• type Result

Types

type RMApplicationUpdateEvent

type RMApplicationUpdateEvent struct {
	RmID                 string
	AcceptedApplications []*si.AcceptedApplication
	RejectedApplications []*si.RejectedApplication
	UpdatedApplications  []*si.UpdatedApplication
}

type RMConfigUpdateEvent

type RMConfigUpdateEvent struct {
	RmID        string
	PolicyGroup string
	Config      string
	ExtraConfig map[string]string
	Channel     chan *Result `json:"-"`
}

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 RMPartitionsRemoveEvent struct {
	RmID    string
	Channel chan *Result `json:"-"`
}

type RMRegistrationEvent

type RMRegistrationEvent struct {
	Registration *si.RegisterResourceManagerRequest
	Channel      chan *Result `json:"-"`
}

Incoming events from the RM to the scheduler (sync)

type RMRejectedAllocationAskEvent

type RMRejectedAllocationAskEvent struct {
	RmID                   string
	RejectedAllocationAsks []*si.RejectedAllocationAsk
}

type RMRejectedAllocationEvent

type RMRejectedAllocationEvent struct {
	RmID                string
	RejectedAllocations []*si.RejectedAllocation
}

type RMReleaseAllocationAskEvent

type RMReleaseAllocationAskEvent struct {
	RmID                   string
	ReleasedAllocationAsks []*si.AllocationAskRelease
}

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)

type Result

type Result struct {
	Succeeded bool
	Reason    string
}