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        int64
	Partitions       []*dao.PartitionInfo
	Applications     []*dao.ApplicationDAOInfo
	AppHistory       []*dao.ApplicationHistoryDAOInfo
	Nodes            []*dao.NodesDAOInfo
	ClusterInfo      []*dao.ClusterDAOInfo
	ContainerHistory []*dao.ContainerHistoryDAOInfo
	Queues           []dao.PartitionQueueDAOInfo
	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