webservice

Documentation

Index

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

Constants

const ApplicationDoesNotExists = "Application not found"

const GroupDoesNotExists = "Group not found"

const GroupNameMissing = "Group name is missing"

const MissingParamsName = "Missing parameters"

const NodeDoesNotExists = "Node not found"

const PartitionDoesNotExists = "Partition not found"

const QueueDoesNotExists = "Queue not found"

const UserDoesNotExists = "User not found"

const UserNameMissing = "User name is missing"

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