Documentation
¶
Index ¶
- 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 EventData
- func (ed *EventData) AssignIsolationSegment(cellStats *eventCell.CellStats)
- func (ed *EventData) Clear()
- func (ed *EventData) Clone() *EventData
- 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) GetTotalEvents() int64
- func (ed *EventData) Process(instanceId int, msg *events.Envelope)
- func (ed *EventData) UpdateEventStats(msg *events.Envelope)
- type EventLogHttpAccess
- type EventProcessor
- func (ep *EventProcessor) ClearStats() error
- func (ep *EventProcessor) FlushCache()
- func (ep *EventProcessor) GetCliConnection() plugin.CliConnection
- func (ep *EventProcessor) GetCurrentEventData() *EventData
- func (ep *EventProcessor) GetCurrentEventRateHistory() *EventRateHistory
- func (ep *EventProcessor) GetDisplayedEventData() *EventData
- func (ep *EventProcessor) GetMetadataManager() *metadata.GlobalManager
- func (ep *EventProcessor) LoadCacheAndSeedData()
- func (ep *EventProcessor) Process(instanceId int, msg *events.Envelope)
- func (ep *EventProcessor) SeedStatsFromMetadata()
- func (ep *EventProcessor) Start()
- func (ep *EventProcessor) UpdateData()
- type EventRate
- type EventRateDetail
- type EventRateHistory
- type HistoryRangeType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type EventData ¶
type EventData struct {
// This time it set at clone time
StatsTime time.Time
// Key: appId
AppMap map[string]*eventApp.AppStats
CellMap map[string]*eventCell.CellStats
// Domain name: Both shared + private
DomainMap map[string]*eventRoute.DomainStats
// ***** TODO BEGIN: Track AppRouteStats in a map here (as well as in DomainMap object tree)
// So that we have easy access to the data for use on AppDetail: HTTP Info Views
// ISSUE: If we hold onto a objecct pointer to AppRouteStats from two different loccations:
// AppRouteStatsMap and downstream from DomainMap, if we do a "deepcopy" during clone, do
// we end up with two complete copies of the data?? That would be bad (time/memory footprint)
//
// IDEA: To fix the above problem, what if we change eventRoute.RouteStats object to just
// hold onto an array of AppIds and not a map of the real AppRouteStats object? The code
// code would just use the AppId and lookup the AppRouteStats object from map in EventData
// object. Example change in eventRoute.RouteStats object:
// from: AppRouteStatsMap map[string]*AppRouteStats
// to: AppIds []*string
//
// ISSUE2: I just realized why the above will not work -- the current solution of having
// a map of *AppRouteStats within each route is to handle tracking how much traffic comes
// in through that route -- meaning an app can have multiple route and we want to track
// traffic seperately for each route even though its going to the same app.
//
// Key: appId
AppRouteStatsMap map[string]*eventRoute.AppRouteStats
EventTypeMap map[events.Envelope_EventType]*eventEventType.EventTypeStats
EnableRouteTracking bool
TotalEvents int64
// contains filtered or unexported fields
}
func NewEventData ¶
func NewEventData(mu *sync.Mutex, eventProcessor *EventProcessor) *EventData
func (*EventData) AssignIsolationSegment ¶ added in v0.8.2
func (*EventData) Clone ¶
Yuck -- need to figure out a getter way to clone the current data object Specifically around RateCounter and AvgTracker object
func (*EventData) FindEventTypeStats ¶ added in v0.7.6
func (ed *EventData) FindEventTypeStats(eventType events.Envelope_EventType) *eventEventType.EventTypeStats
func (*EventData) GetAppRouteStats ¶ added in v0.7.6
func (ed *EventData) GetAppRouteStats(uri string, domain string, host string, port string, path string, appId string) *eventRoute.AppRouteStats
func (*EventData) GetTotalEvents ¶
func (*EventData) UpdateEventStats ¶ added in v0.7.6
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, privileged bool, statusMsg chan string) *EventProcessor
func (*EventProcessor) ClearStats ¶
func (ep *EventProcessor) ClearStats() error
func (*EventProcessor) FlushCache ¶ added in v0.8.0
func (ep *EventProcessor) FlushCache()
func (*EventProcessor) GetCliConnection ¶ added in v0.7.3
func (ep *EventProcessor) GetCliConnection() plugin.CliConnection
func (*EventProcessor) GetCurrentEventData ¶
func (ep *EventProcessor) GetCurrentEventData() *EventData
func (*EventProcessor) GetCurrentEventRateHistory ¶ added in v0.7.9
func (ep *EventProcessor) GetCurrentEventRateHistory() *EventRateHistory
func (*EventProcessor) GetDisplayedEventData ¶
func (ep *EventProcessor) GetDisplayedEventData() *EventData
func (*EventProcessor) GetMetadataManager ¶ added in v0.7.3
func (ep *EventProcessor) GetMetadataManager() *metadata.GlobalManager
func (*EventProcessor) LoadCacheAndSeedData ¶ added in v0.7.6
func (ep *EventProcessor) LoadCacheAndSeedData()
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 EventRate ¶ added in v0.7.9
type EventRate struct {
BeginTime time.Time
EndTime time.Time
EventRateDetailMap map[events.Envelope_EventType]*EventRateDetail
TotalHigh int
}
type EventRateDetail ¶ added in v0.7.9
type EventRateDetail struct {
RateHigh int
}
type EventRateHistory ¶ added in v0.7.9
type EventRateHistory struct {
// contains filtered or unexported fields
}
func NewEventRateHistory ¶ added in v0.7.9
func NewEventRateHistory(ep *EventProcessor) *EventRateHistory
func (*EventRateHistory) GetCurrentHistory ¶ added in v0.7.9
func (erh *EventRateHistory) GetCurrentHistory() []*EventRate
func (*EventRateHistory) GetCurrentRate ¶ added in v0.7.9
func (erh *EventRateHistory) GetCurrentRate() int
func (*EventRateHistory) GetDisplayedHistory ¶ added in v0.7.9
func (erh *EventRateHistory) GetDisplayedHistory() []*EventRate
func (*EventRateHistory) SetFreezeData ¶ added in v0.7.9
func (erh *EventRateHistory) SetFreezeData(freezeData bool)
SetFreezeData is called when user pauses/unpauses display
type HistoryRangeType ¶ added in v0.7.9
type HistoryRangeType int
const ( BY_SECOND HistoryRangeType = iota BY_MINUTE BY_10MINUTE BY_HOUR BY_DAY )
Source Files
¶
Click to show internal directories.
Click to hide internal directories.