Documentation
¶
Index ¶
Constants ¶
View Source
const ApplicationDoesNotExists = "Application not found"
View Source
const GroupDoesNotExists = "Group not found"
View Source
const GroupNameMissing = "Group name is missing"
View Source
const MissingParamsName = "Missing parameters"
View Source
const NodeDoesNotExists = "Node not found"
View Source
const PartitionDoesNotExists = "Partition not found"
View Source
const QueueDoesNotExists = "Queue not found"
View Source
const UserDoesNotExists = "User not found"
View Source
const UserNameMissing = "User name is missing"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
RMDiagnostics map[string]interface{}
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.