Documentation
¶
Index ¶
Constants ¶
View Source
const ( PartitionDoesNotExists = "Partition not found" MissingParamsName = "Missing parameters" QueueDoesNotExists = "Queue not found" InvalidUserName = "Invalid user name" InvalidGroupName = "Invalid group name" UserDoesNotExists = "User not found" GroupDoesNotExists = "Group not found" ApplicationDoesNotExists = "Application not found" NodeDoesNotExists = "Node not found" AppStateActive = "active" AppStateRejected = "rejected" AppStateCompleted = "completed" )
Variables ¶
This section is empty.
Functions ¶
func GetApplicationDAO ¶
func GetApplicationDAO(app *objects.Application, summary *objects.ApplicationSummary) *dao.ApplicationDAOInfo
Types ¶
type AggregatedStateInfo ¶
type AggregatedStateInfo struct {
Timestamp int64 `json:"timestamp,omitempty"`
Partitions []*dao.PartitionInfo `json:"partitions,omitempty"`
Applications []*dao.ApplicationDAOInfo `json:"applications,omitempty"`
AppHistory []*dao.ApplicationHistoryDAOInfo `json:"appHistory,omitempty"`
Nodes []*dao.NodesDAOInfo `json:"nodes,omitempty"`
ClusterInfo []*dao.ClusterDAOInfo `json:"clusterInfo,omitempty"`
ContainerHistory []*dao.ContainerHistoryDAOInfo `json:"containerHistory,omitempty"`
Queues []dao.PartitionQueueDAOInfo `json:"queues,omitempty"`
RMDiagnostics map[string]interface{} `json:"rmDiagnostics,omitempty"`
LogLevel string `json:"logLevel,omitempty"`
Config *dao.ConfigDAOInfo `json:"config,omitempty"`
PlacementRules []*dao.RuleDAOInfo `json:"placementRules,omitempty"`
EventStreams []events.EventStreamData `json:"eventStreams,omitempty"`
}
type StreamingLimiter ¶
StreamingLimiter tracks the concurrent streaming connections.
func NewStreamingLimiter ¶
func NewStreamingLimiter() *StreamingLimiter
func (*StreamingLimiter) AddHost ¶
func (sl *StreamingLimiter) AddHost(host string) bool
func (*StreamingLimiter) RemoveHost ¶
func (sl *StreamingLimiter) RemoveHost(host 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()
StartWebApp starts the web app on the default port.
func (*WebService) StopWebApp ¶
func (m *WebService) StopWebApp() error
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.