callback

Documentation

Index

• type AsyncRMCallback
  • func NewAsyncRMCallback(ctx *cache.Context) *AsyncRMCallback
  • func (callback *AsyncRMCallback) Predicates(args *si.PredicatesArgs) error
  • func (callback *AsyncRMCallback) ReSyncSchedulerCache(args *si.ReSyncSchedulerCacheArgs) error
  • func (callback *AsyncRMCallback) RecvUpdateResponse(response *si.UpdateResponse) 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) 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