callback

Documentation

Index

• type AsyncRMCallback
  • func NewAsyncRMCallback(ctx *cache.Context) *AsyncRMCallback
  • func (callback *AsyncRMCallback) GetStateDump() (string, error)
  • func (callback *AsyncRMCallback) Predicates(args *si.PredicatesArgs) error
  • func (callback *AsyncRMCallback) PreemptionPredicates(args *si.PreemptionPredicatesArgs) *si.PreemptionPredicatesResponse
  • func (callback *AsyncRMCallback) SendEvent(eventRecords []*si.EventRecord)
  • func (callback *AsyncRMCallback) UpdateAllocation(response *si.AllocationResponse) error
  • func (callback *AsyncRMCallback) UpdateApplication(response *si.ApplicationResponse) error
  • func (callback *AsyncRMCallback) UpdateContainerSchedulingState(request *si.UpdateContainerSchedulingStateRequest)
  • func (callback *AsyncRMCallback) UpdateNode(response *si.NodeResponse) error

Types

type AsyncRMCallback

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

RM callback is called from the scheduler core, we need to ensure the response is handled asynchronously to avoid blocking the scheduler.

func NewAsyncRMCallback

func NewAsyncRMCallback(ctx *cache.Context) *AsyncRMCallback

func (*AsyncRMCallback) GetStateDump

func (callback *AsyncRMCallback) GetStateDump() (string, error)

func (*AsyncRMCallback) Predicates

func (callback *AsyncRMCallback) Predicates(args *si.PredicatesArgs) error

func (*AsyncRMCallback) PreemptionPredicates

func (callback *AsyncRMCallback) PreemptionPredicates(args *si.PreemptionPredicatesArgs) *si.PreemptionPredicatesResponse

func (*AsyncRMCallback) SendEvent

func (callback *AsyncRMCallback) SendEvent(eventRecords []*si.EventRecord)

func (*AsyncRMCallback) UpdateAllocation

func (callback *AsyncRMCallback) UpdateAllocation(response *si.AllocationResponse) error

func (*AsyncRMCallback) UpdateApplication

func (callback *AsyncRMCallback) UpdateApplication(response *si.ApplicationResponse) error

func (*AsyncRMCallback) UpdateContainerSchedulingState

func (callback *AsyncRMCallback) UpdateContainerSchedulingState(request *si.UpdateContainerSchedulingStateRequest)

func (*AsyncRMCallback) UpdateNode

func (callback *AsyncRMCallback) UpdateNode(response *si.NodeResponse) error