clustermanager

Documentation

Index

• type ClusterManager
  • func NewClusterManager(wg *sync.WaitGroup, configFile string) (ClusterManager, error)

Types

type ClusterManager

type ClusterManager interface {
	Init(wg *sync.WaitGroup, configFile string) error
	AddCluster(cluster string)
	AddInput(input chan lp.CCMessage)
	AddOutput(output chan lp.CCMessage)
	CheckPowerBudget(cluster string, diff int) bool
	NewJob(meta ccspecs.BaseJob) error
	CloseJob(meta ccspecs.BaseJob) error
	Start()
	Close()
}

func NewClusterManager

func NewClusterManager(wg *sync.WaitGroup, configFile string) (ClusterManager, error)