demands

Documentation

Index

• type Manager
  • func NewDefaultManager(demands *cache.SafeDemandCache, binpacker *binpacker.Binpacker, ...) Manager

Types

type Manager

type Manager interface {
	DeleteDemandIfExists(ctx context.Context, pod *v1.Pod, source string)
	CreateDemandForApplicationInAnyZone(ctx context.Context, driverPod *v1.Pod, applicationResources *types.SparkApplicationResources)
	CreateDemandForExecutorInAnyZone(ctx context.Context, executorPod *v1.Pod, executorResources *resources.Resources)
	CreateDemandForExecutorInSpecificZone(ctx context.Context, executorPod *v1.Pod, executorResources *resources.Resources, zone *demandapi.Zone)
}

Manager holds the types of demand operations that are available

func NewDefaultManager

func NewDefaultManager(
	demands *cache.SafeDemandCache,
	binpacker *binpacker.Binpacker,
	instanceGroupLabel string) Manager

NewDefaultManager creates the default implementation of the Manager