Back to godoc.org

Package callback

v0.0.0-...-f394a37
Latest Go to latest

The highest tagged major version is .

Published: Aug 13, 2019 | License: Apache-2.0 | Module: github.com/cloudera/yunikorn-k8shim

Index

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

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier