handlers

Documentation

Index

• type DataHandler
  • func NewDataHandler(cmgr *clientmgr.ClientMgr) *DataHandler
  • func (handler *DataHandler) GetClusterRequestResource(podPhase string) (utils.ClusterRequestResource, error)
  • func (handler *DataHandler) GetClusterTotalResource() (utils.ClusterTotalResources, error)
  • func (handler *DataHandler) GetConfig() (utils.MorphlingConfig, error)
  • func (handler *DataHandler) GetNamespaces() ([]string, error)
  • func (handler *DataHandler) GetNodesInfo() (utils.NodeInfoList, error)
• type ExperimentHandler
  • func NewExperimentHandler(cmgr *clientmgr.ClientMgr) *ExperimentHandler
  • func (handler *ExperimentHandler) DeleteJobFromBackend(ns, name string) error
  • func (handler *ExperimentHandler) GetExperimentDetail(query *utils.Query) (utils.ProfilingExperimentDetail, error)
  • func (handler *ExperimentHandler) GetExperimentList(query *utils.Query) ([]utils.ProfilingExperimentInfo, error)
  • func (handler *ExperimentHandler) SubmitExperiment(data []byte) error
  • func (handler *ExperimentHandler) SubmitExperimentPars(dataRaw []byte) error

Types

type DataHandler

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

func NewDataHandler

func NewDataHandler(cmgr *clientmgr.ClientMgr) *DataHandler

func (*DataHandler) GetClusterRequestResource

func (handler *DataHandler) GetClusterRequestResource(podPhase string) (utils.ClusterRequestResource, error)

sum all pods request resource(cpu/memory/gpu)

func (*DataHandler) GetClusterTotalResource

func (handler *DataHandler) GetClusterTotalResource() (utils.ClusterTotalResources, error)

Sum all pods request resource(cpu/memory/gpu)

func (*DataHandler) GetConfig

func (handler *DataHandler) GetConfig() (utils.MorphlingConfig, error)

Get config from configMap

func (*DataHandler) GetNamespaces

func (handler *DataHandler) GetNamespaces() ([]string, error)

GetNamespaces gets namespaces, ignoring system-ones

func (*DataHandler) GetNodesInfo

func (handler *DataHandler) GetNodesInfo() (utils.NodeInfoList, error)

Get Nodes information

type ExperimentHandler

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

func NewExperimentHandler

func NewExperimentHandler(cmgr *clientmgr.ClientMgr) *ExperimentHandler

func (*ExperimentHandler) DeleteJobFromBackend

func (handler *ExperimentHandler) DeleteJobFromBackend(ns, name string) error

DeleteJobFromBackend deletes job

func (*ExperimentHandler) GetExperimentDetail

func (handler *ExperimentHandler) GetExperimentDetail(query *utils.Query) (utils.ProfilingExperimentDetail, error)

GetExperimentDetail Get experiment detail

func (*ExperimentHandler) GetExperimentList

func (handler *ExperimentHandler) GetExperimentList(query *utils.Query) ([]utils.ProfilingExperimentInfo, error)

GetExperimentList Get experiments

func (*ExperimentHandler) SubmitExperiment

func (handler *ExperimentHandler) SubmitExperiment(data []byte) error

SubmitExperiment Submit experiment

func (*ExperimentHandler) SubmitExperimentPars

func (handler *ExperimentHandler) SubmitExperimentPars(dataRaw []byte) error

SubmitExperimentPars submits experiment with parameters