eventdata

Documentation

Index

• type EventData
  • func NewEventData(mu *sync.Mutex, eventProcessor *EventProcessor) *EventData
  • 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
  • func NewEventLogHttpAccess() *EventLogHttpAccess
• type EventProcessor
  • func NewEventProcessor(cliConnection plugin.CliConnection, privileged bool) *EventProcessor
  • func (ep *EventProcessor) ClearStats() error
  • func (ep *EventProcessor) GetCliConnection() plugin.CliConnection
  • func (ep *EventProcessor) GetCurrentEventData() *EventData
  • func (ep *EventProcessor) GetDisplayedEventData() *EventData
  • func (ep *EventProcessor) GetMetadataManager() *metadata.Manager
  • 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()

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

func (*EventData) FindEventTypeStats

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

func (*EventData) GetAppRouteStats

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

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

type EventLogHttpAccess

type EventLogHttpAccess struct {
	// contains filtered or unexported fields
}

func NewEventLogHttpAccess

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

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

func (*EventProcessor) GetCurrentEventData

func (ep *EventProcessor) GetCurrentEventData() *EventData

func (*EventProcessor) GetDisplayedEventData

func (ep *EventProcessor) GetDisplayedEventData() *EventData

func (*EventProcessor) GetMetadataManager

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

func (*EventProcessor) LoadCacheAndSeedData

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