Documentation
¶
Index ¶
- Constants
- func PopulateNamesIfNeeded(appStats *AppStats, appMdMgr *metadata.AppMetadataManager)
- type AppStats
- type CellStats
- type ContainerStats
- type EventData
- type EventLogHttpAccess
- type EventProcessor
- func (ep *EventProcessor) ClearStats() error
- func (ep *EventProcessor) GetCliConnection() plugin.CliConnection
- func (ep *EventProcessor) GetCurrentEventData() *EventData
- func (ep *EventProcessor) GetDisplayedEventData() *EventData
- func (ep *EventProcessor) GetMetadataManager() *metadata.Manager
- func (ep *EventProcessor) LoadCacheAndSeeData()
- func (ep *EventProcessor) Process(instanceId int, msg *events.Envelope)
- func (ep *EventProcessor) SeedStatsFromMetadata()
- func (ep *EventProcessor) Start()
- func (ep *EventProcessor) UpdateData()
- type TrafficStats
Constants ¶
View Source
const (
UnknownName = "unknown"
)
Variables ¶
This section is empty.
Functions ¶
func PopulateNamesIfNeeded ¶
func PopulateNamesIfNeeded(appStats *AppStats, appMdMgr *metadata.AppMetadataManager)
Types ¶
type AppStats ¶
type AppStats struct {
AppUUID *events.UUID
AppId string
AppName string
SpaceName string
OrgName string
NonContainerStdout int64
NonContainerStderr int64
ContainerArray []*ContainerStats
ContainerTrafficMap map[string]*TrafficStats
// ISSUE: Must do this at clone time because of AvgTracker counter
TotalTraffic *TrafficStats
}
func NewAppStats ¶
func PopulateNamesFromMap ¶ added in v0.7.3
func PopulateNamesFromMap(statsMap map[string]*AppStats, appMdMgr *metadata.AppMetadataManager) []*AppStats
type CellStats ¶
type CellStats struct {
Ip string
StackId string
DeploymentName string
JobName string
JobIndex int
NumOfCpus int
CapacityTotalMemory int64
CapacityRemainingMemory int64
CapacityTotalDisk int64
CapacityRemainingDisk int64
CapacityTotalContainers int
CapacityRemainingContainers int
ContainerCount int
}
func NewCellStats ¶
type ContainerStats ¶
type ContainerStats struct {
ContainerIndex int
Ip string
ContainerMetric *events.ContainerMetric
LastUpdate time.Time
OutCount int64
ErrCount int64
}
func NewContainerStats ¶
func NewContainerStats(containerIndex int) *ContainerStats
type EventData ¶
type EventData struct {
AppMap map[string]*AppStats
CellMap map[string]*CellStats
TotalEvents int64
// contains filtered or unexported fields
}
func NewEventData ¶
func NewEventData(mu *sync.Mutex, eventProcessor *EventProcessor) *EventData
func (*EventData) GetTotalEvents ¶
type EventLogHttpAccess ¶ added in v0.7.3
type EventLogHttpAccess struct {
// contains filtered or unexported fields
}
func NewEventLogHttpAccess ¶ added in v0.7.3
func NewEventLogHttpAccess() *EventLogHttpAccess
type EventProcessor ¶
type EventProcessor struct {
// contains filtered or unexported fields
}
func NewEventProcessor ¶
func NewEventProcessor(cliConnection plugin.CliConnection) *EventProcessor
func (*EventProcessor) ClearStats ¶
func (ep *EventProcessor) ClearStats() error
func (*EventProcessor) GetCliConnection ¶ added in v0.7.3
func (ep *EventProcessor) GetCliConnection() plugin.CliConnection
func (*EventProcessor) GetCurrentEventData ¶
func (ep *EventProcessor) GetCurrentEventData() *EventData
func (*EventProcessor) GetDisplayedEventData ¶
func (ep *EventProcessor) GetDisplayedEventData() *EventData
func (*EventProcessor) GetMetadataManager ¶ added in v0.7.3
func (ep *EventProcessor) GetMetadataManager() *metadata.Manager
func (*EventProcessor) LoadCacheAndSeeData ¶
func (ep *EventProcessor) LoadCacheAndSeeData()
func (*EventProcessor) Process ¶
func (ep *EventProcessor) Process(instanceId int, msg *events.Envelope)
func (*EventProcessor) SeedStatsFromMetadata ¶
func (ep *EventProcessor) SeedStatsFromMetadata()
func (*EventProcessor) Start ¶
func (ep *EventProcessor) Start()
func (*EventProcessor) UpdateData ¶
func (ep *EventProcessor) UpdateData()
type TrafficStats ¶
type TrafficStats struct {
AvgResponseL60Time float64 // updated after a clone of this object
EventL60Rate int // updated after a clone of this object
AvgResponseL10Time float64 // updated after a clone of this object
EventL10Rate int // updated after a clone of this object
AvgResponseL1Time float64 // updated after a clone of this object
EventL1Rate int // updated after a clone of this object
HttpAllCount int64
Http2xxCount int64
Http3xxCount int64
Http4xxCount int64
Http5xxCount int64
// contains filtered or unexported fields
}
func NewTrafficStats ¶
func NewTrafficStats() *TrafficStats
Click to show internal directories.
Click to hide internal directories.