webservice

Documentation

Index

• Constants
• type AggregatedStateInfo
• type StreamingLimiter
  • func NewStreamingLimiter() *StreamingLimiter
  • func (sl *StreamingLimiter) AddHost(host string) bool
  • func (sl *StreamingLimiter) RemoveHost(host string)
• type WebService
  • func NewWebApp(context *scheduler.ClusterContext, ...) *WebService
  • func (m *WebService) StartWebApp()
  • func (m *WebService) StopWebApp() error

Constants

const (
	PartitionDoesNotExists   = "Partition not found"
	MissingParamsName        = "Missing parameters"
	QueueDoesNotExists       = "Queue not found"
	UserDoesNotExists        = "User not found"
	GroupDoesNotExists       = "Group not found"
	UserNameMissing          = "User name is missing"
	GroupNameMissing         = "Group name is missing"
	ApplicationDoesNotExists = "Application not found"
	NodeDoesNotExists        = "Node not found"
)

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"`
	EventStreams     []events.EventStreamData         `json:"eventStreams,omitempty"`
}

type StreamingLimiter

type StreamingLimiter struct {
	locking.Mutex
	// contains filtered or unexported fields
}

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. TODO we need the port to be configurable

func (*WebService) StopWebApp

func (m *WebService) StopWebApp() error