Documentation
¶
Index ¶
- Constants
- func MovingExpAvg(value, oldValue, fdtime, ftime float64) float64
- type AppStats
- type CellStats
- type ContainerStats
- type EventData
- type EventProcessor
- func (ep *EventProcessor) ClearStats() error
- func (ep *EventProcessor) GetCurrentEventData() *EventData
- func (ep *EventProcessor) GetDisplayedEventData() *EventData
- func (ep *EventProcessor) LoadCacheAndSeeData()
- func (ep *EventProcessor) LoadMetadata()
- 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 StaleContainerSeconds = 80
View Source
const (
UnknownName = "unknown"
)
Variables ¶
This section is empty.
Functions ¶
func MovingExpAvg ¶
Types ¶
type AppStats ¶
type AppStats struct {
AppUUID *events.UUID
AppId string
AppName string
SpaceName string
OrgName string
NonContainerOutCount int64
NonContainerErrCount int64
ContainerArray []*ContainerStats
ContainerTrafficMap map[string]*TrafficStats
TotalTraffic *TrafficStats
TotalCpuPercentage float64 // updated after a clone of this object
TotalUsedMemory uint64 // updated after a clone of this object
TotalUsedDisk uint64 // updated after a clone of this object
TotalReportingContainers int //updated after a clone of this object
TotalLogCount int64 //updated after a clone of this object
}
func NewAppStats ¶
func PopulateNamesIfNeeded ¶
type CellStats ¶
type CellStats struct {
Ip string
DeploymentName string
JobName string
JobIndex string
NumOfCpus int
CapacityTotalMemory int64
CapacityRemainingMemory int64
CapacityTotalDisk int64
CapacityRemainingDisk int64
CapacityTotalContainers int
CapacityRemainingContainers int
ContainerCount int
}
func NewCellStats ¶
type ContainerStats ¶
type ContainerStats struct {
Ip string
ContainerMetric *events.ContainerMetric
LastUpdate time.Time
OutCount int64
ErrCount int64
}
func NewContainerStats ¶
func NewContainerStats() *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() *EventData
func (*EventData) GetTotalEvents ¶
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) GetCurrentEventData ¶
func (ep *EventProcessor) GetCurrentEventData() *EventData
func (*EventProcessor) GetDisplayedEventData ¶
func (ep *EventProcessor) GetDisplayedEventData() *EventData
func (*EventProcessor) LoadCacheAndSeeData ¶
func (ep *EventProcessor) LoadCacheAndSeeData()
func (*EventProcessor) LoadMetadata ¶
func (ep *EventProcessor) LoadMetadata()
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.