placement

Documentation

Index

• type AppPlacementManager
  • func NewPlacementManager(rules []configs.PlacementRule, queueFunc func(string) *objects.Queue) *AppPlacementManager
  • func (m *AppPlacementManager) IsInitialised() bool
  • func (m *AppPlacementManager) PlaceApplication(app *objects.Application) error
  • func (m *AppPlacementManager) UpdateRules(rules []configs.PlacementRule) error
• type Filter

Types

type AppPlacementManager

type AppPlacementManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPlacementManager

func NewPlacementManager(rules []configs.PlacementRule, queueFunc func(string) *objects.Queue) *AppPlacementManager

func (*AppPlacementManager) IsInitialised

func (m *AppPlacementManager) IsInitialised() bool

Return the state of the placement manager

func (*AppPlacementManager) PlaceApplication

func (m *AppPlacementManager) PlaceApplication(app *objects.Application) error

func (*AppPlacementManager) UpdateRules

func (m *AppPlacementManager) UpdateRules(rules []configs.PlacementRule) error

Update the rules for an active placement manager Note that this will only be called when the manager is created earlier and the config is updated.

type Filter

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