Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) Predicates ¶
func (callback *AsyncRMCallback) Predicates(args *si.PredicatesArgs) error
this callback implements scheduler plugin interface PredicatesPlugin/
func (*AsyncRMCallback) ReSyncSchedulerCache ¶
func (callback *AsyncRMCallback) ReSyncSchedulerCache(args *si.ReSyncSchedulerCacheArgs) error
this callback implements scheduler plugin interface ReconcilePlugin.
func (*AsyncRMCallback) RecvUpdateResponse ¶
func (callback *AsyncRMCallback) RecvUpdateResponse(response *si.UpdateResponse) error
Click to show internal directories.
Click to hide internal directories.