webservice

Sep 10, 2024

Changes in this version

+ const AppStateActive

+ const AppStateCompleted

+ const AppStateRejected

+ const InvalidGroupName

+ const InvalidUserName

type AggregatedStateInfo

+ PlacementRules []*dao.RuleDAOInfo

Mar 5, 2024

Changes in this version

type AggregatedStateInfo

+ EventStreams []events.EventStreamData

+ type StreamingLimiter struct

+ func NewStreamingLimiter() *StreamingLimiter

+ func (sl *StreamingLimiter) AddHost(host string) bool

+ func (sl *StreamingLimiter) RemoveHost(host string)

Nov 14, 2023

Changes in this version

type AggregatedStateInfo

+ Config *dao.ConfigDAOInfo

May 31, 2023

Changes in this version

+ const ApplicationDoesNotExists

+ const MissingParamsName

+ const NodeDoesNotExists

Jan 27, 2023

Changes in this version

+ const GroupDoesNotExists

+ const GroupNameMissing

+ const UserDoesNotExists

+ const UserNameMissing

type AggregatedStateInfo

+ RMDiagnostics map[string]interface{}

Aug 22, 2022

Changes in this version

+ const PartitionDoesNotExists

+ const QueueDoesNotExists

Apr 26, 2022

Changes in this version

+ type AggregatedStateInfo struct

+ AppHistory []*dao.ApplicationHistoryDAOInfo

+ Applications []*dao.ApplicationDAOInfo

+ ClusterInfo []*dao.ClusterDAOInfo

+ ContainerHistory []*dao.ContainerHistoryDAOInfo

+ LogLevel string

+ Nodes []*dao.NodesDAOInfo

+ Partitions []*dao.PartitionInfo

+ Queues []dao.PartitionQueueDAOInfo

+ Timestamp int64

+ type WebService struct

+ func NewWebApp(context *scheduler.ClusterContext, ...) *WebService

+ func (m *WebService) StartWebApp()

+ func (m *WebService) StopWebApp() error