eventdata

package
v0.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 3, 2017 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Max added in v0.7.9 

func Max(x int, y int) int

func Min added in v0.7.9 

func Min(x int, y int) int

func SetMax added in v0.7.9 

func SetMax(x *int, y int)

func SetMin added in v0.7.9 

func SetMin(x *int, y int)

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
	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) Clear 

func (ed *EventData) Clear()

func (*EventData) Clone 

func (ed *EventData) Clone() *EventData

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 (ed *EventData) GetTotalEvents() int64

func (*EventData) Process 

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

func (*EventData) UpdateEventStats added in v0.7.6 

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

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) *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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.