eventdata

package
v0.8.6 Latest Latest
Warning

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

Go to latest
Published: Aug 1, 2017 License: Apache-2.0 Imports: 22 Imported by: 70

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) AssignIsolationSegment added in v0.8.2

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

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
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL