eventdata

Apr 9, 2017

Changes in this version

type EventData

+ func (ed *EventData) AssignIsolationSegment(cellStats *eventCell.CellStats)

Jan 25, 2017

Changes in this version

type EventProcessor

+ func (ep *EventProcessor) FlushCache()

Jan 16, 2017

Changes in this version

+ func Max(x int, y int) int

+ func Min(x int, y int) int

+ func SetMax(x *int, y int)

+ func SetMin(x *int, y int)

type EventProcessor

+ func (ep *EventProcessor) GetCurrentEventRateHistory() *EventRateHistory

+ type EventRate struct

+ BeginTime time.Time

+ EndTime time.Time

+ EventRateDetailMap map[events.Envelope_EventType]*EventRateDetail

+ TotalHigh int

+ type EventRateDetail struct

+ RateHigh int

+ type EventRateHistory struct

+ func NewEventRateHistory(ep *EventProcessor) *EventRateHistory

+ func (erh *EventRateHistory) GetCurrentHistory() []*EventRate

+ func (erh *EventRateHistory) GetCurrentRate() int

+ func (erh *EventRateHistory) GetDisplayedHistory() []*EventRate

+ func (erh *EventRateHistory) SetFreezeData(freezeData bool)

+ type HistoryRangeType int

+ const BY_10MINUTE

+ const BY_DAY

+ const BY_HOUR

+ const BY_MINUTE

+ const BY_SECOND

Jan 10, 2017

Changes in this version

type EventData

+ StatsTime time.Time

Jan 3, 2017

Changes in this version

+ const MaxDomainBucket

+ const MaxHostBucket

type EventData

+ DomainMap map[string]*eventRoute.DomainStats

+ EnableRouteTracking bool

+ EventTypeMap map[events.Envelope_EventType]*eventEventType.EventTypeStats

+ func (ed *EventData) FindEventTypeStats(eventType events.Envelope_EventType) *eventEventType.EventTypeStats

+ func (ed *EventData) GetAppRouteStats(uri string, domain string, host string, port string, path string, appId string) *eventRoute.AppRouteStats

+ func (ed *EventData) UpdateEventStats(msg *events.Envelope)

type EventProcessor

+ func (ep *EventProcessor) LoadCacheAndSeedData()

Dec 19, 2016

Changes in this version

type AppStats

+ NonContainerStderr int64

+ NonContainerStdout int64

+ func PopulateNamesFromMap(statsMap map[string]*AppStats, appMdMgr *metadata.AppMetadataManager) []*AppStats

type CellStats

+ StackId string

type ContainerStats

+ ContainerIndex int

+ type EventLogHttpAccess struct

+ func NewEventLogHttpAccess() *EventLogHttpAccess

type EventProcessor

+ func (ep *EventProcessor) GetCliConnection() plugin.CliConnection

+ func (ep *EventProcessor) GetMetadataManager() *metadata.Manager

Dec 13, 2016

Changes in this version

+ const StaleContainerSeconds

+ const UnknownName

+ func MovingExpAvg(value, oldValue, fdtime, ftime float64) float64

+ type AppStats struct

+ AppId string

+ AppName string

+ AppUUID *events.UUID

+ ContainerArray []*ContainerStats

+ ContainerTrafficMap map[string]*TrafficStats

+ NonContainerErrCount int64

+ NonContainerOutCount int64

+ OrgName string

+ SpaceName string

+ TotalCpuPercentage float64

+ TotalLogCount int64

+ TotalReportingContainers int

+ TotalTraffic *TrafficStats

+ TotalUsedDisk uint64

+ TotalUsedMemory uint64

+ func NewAppStats(appId string) *AppStats

+ func PopulateNamesIfNeeded(statsMap map[string]*AppStats) []*AppStats

+ func (as *AppStats) Id() string

+ type CellStats struct

+ CapacityRemainingContainers int

+ CapacityRemainingDisk int64

+ CapacityRemainingMemory int64

+ CapacityTotalContainers int

+ CapacityTotalDisk int64

+ CapacityTotalMemory int64

+ ContainerCount int

+ DeploymentName string

+ Ip string

+ JobIndex string

+ JobName string

+ NumOfCpus int

+ func NewCellStats(cellIp string) *CellStats

+ func (cs *CellStats) Id() string

+ type ContainerStats struct

+ ContainerMetric *events.ContainerMetric

+ ErrCount int64

+ Ip string

+ LastUpdate time.Time

+ OutCount int64

+ func NewContainerStats() *ContainerStats

+ type EventData struct

+ AppMap map[string]*AppStats

+ CellMap map[string]*CellStats

+ TotalEvents int64

+ func NewEventData() *EventData

+ func (ed *EventData) Clear()

+ func (ed *EventData) Clone() *EventData

+ func (ed *EventData) GetTotalEvents() int64

+ func (ed *EventData) Process(instanceId int, msg *events.Envelope)

+ type EventProcessor struct

+ func NewEventProcessor(cliConnection plugin.CliConnection) *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 struct

+ AvgResponseL10Time float64

+ AvgResponseL1Time float64

+ AvgResponseL60Time float64

+ EventL10Rate int

+ EventL1Rate int

+ EventL60Rate int

+ Http2xxCount int64

+ Http3xxCount int64

+ Http4xxCount int64

+ Http5xxCount int64

+ HttpAllCount int64

+ func NewTrafficStats() *TrafficStats