webservice

Documentation

Index

• type AggregatedStateInfo
• type WebService
  • func NewWebApp(context *scheduler.ClusterContext, ...) *WebService
  • func (m *WebService) StartWebApp()
  • func (m *WebService) StopWebApp() error

Types

type AggregatedStateInfo

type AggregatedStateInfo struct {
	Timestamp          string
	Partitions         []*dao.PartitionInfo
	Applications       []*dao.ApplicationDAOInfo
	AppHistory         []*dao.ApplicationHistoryDAOInfo
	Nodes              []*dao.NodesDAOInfo
	NodesUtilization   []*dao.NodesUtilDAOInfo
	ClusterInfo        []*dao.ClusterDAOInfo
	ClusterUtilization []*dao.ClustersUtilDAOInfo
	ContainerHistory   []*dao.ContainerHistoryDAOInfo
	Queues             []*dao.PartitionDAOInfo
	LogLevel           string
}

type WebService

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

func NewWebApp

func NewWebApp(context *scheduler.ClusterContext, internalMetrics *history.InternalMetricsHistory) *WebService

func (*WebService) StartWebApp

func (m *WebService) StartWebApp()

TODO we need the port to be configurable

func (*WebService) StopWebApp

func (m *WebService) StopWebApp() error