Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ResourceManagerCallback ¶
type ResourceManagerCallback interface { //Receive Allocation Update Response UpdateAllocation(response *si.AllocationResponse) error //Receive Application Update Response UpdateApplication(response *si.ApplicationResponse) error //Receive Node Update Response UpdateNode(response *si.NodeResponse) error // Run a certain set of predicate functions to determine if a proposed allocation // can be allocated onto a node. Predicates(args *si.PredicatesArgs) error // Run predicate functions to determine if a proposed allocation can be allocated // onto a node after preemption. The request contains a list of allocations to // speculatively remove. PreemptionPredicates(args *si.PreemptionPredicatesArgs) *si.PreemptionPredicatesResponse // This plugin is responsible for transmitting events to the shim side. // Events can be further exposed from the shim. SendEvent(events []*si.EventRecord) // update container scheduling state to the shim side // this might be called even the container scheduling state is unchanged // the shim side cannot assume to only receive updates on state changes // the shim side implementation must be thread safe UpdateContainerSchedulingState(request *si.UpdateContainerSchedulingStateRequest) }
RM side needs to implement this API
type SchedulerAPI ¶
type SchedulerAPI interface { // Register a new RM, if it is a reconnect from previous RM, cleanup // all in-memory data and resync with RM. RegisterResourceManager(request *si.RegisterResourceManagerRequest, callback ResourceManagerCallback) (*si.RegisterResourceManagerResponse, error) // Update allocation request UpdateAllocation(request *si.AllocationRequest) error // Update application request UpdateApplication(request *si.ApplicationRequest) error // Update node info UpdateNode(request *si.NodeRequest) error // Notify scheduler to reload configuration and hot-refresh in-memory state based on configuration changes UpdateConfiguration(request *si.UpdateConfigurationRequest) error // Stops the scheduler API service Stop() }
type StateDumpPlugin ¶ added in v1.2.0
type StateDumpPlugin interface { // This plugin is responsible for returning a JSON representation of the state of the shim GetStateDump() (string, error) }
RM can additionally implement this API to provide information during state dumps
Click to show internal directories.
Click to hide internal directories.