eventdata

Documentation

Index

• Constants
• func PopulateNamesIfNeeded(appStats *AppStats, appMdMgr *metadata.AppMetadataManager)
• type AppStats
  • func NewAppStats(appId string) *AppStats
  • func PopulateNamesFromMap(statsMap map[string]*AppStats, appMdMgr *metadata.AppMetadataManager) []*AppStats
  • func (as *AppStats) Id() string
• type CellStats
  • func NewCellStats(cellIp string) *CellStats
  • func (cs *CellStats) Id() string
• type ContainerStats
  • func NewContainerStats(containerIndex int) *ContainerStats
• type EventData
  • func NewEventData(mu *sync.Mutex, eventProcessor *EventProcessor) *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 EventLogHttpAccess
  • func NewEventLogHttpAccess() *EventLogHttpAccess
• type EventProcessor
  • func NewEventProcessor(cliConnection plugin.CliConnection) *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) LoadCacheAndSeeData()
  • func (ep *EventProcessor) Process(instanceId int, msg *events.Envelope)
  • func (ep *EventProcessor) SeedStatsFromMetadata()
  • func (ep *EventProcessor) Start()
  • func (ep *EventProcessor) UpdateData()
• type TrafficStats
  • func NewTrafficStats() *TrafficStats

Constants

const (
	UnknownName = "unknown"
)

Functions

func PopulateNamesIfNeeded

func PopulateNamesIfNeeded(appStats *AppStats, appMdMgr *metadata.AppMetadataManager)

Types

type AppStats

type AppStats struct {
	AppUUID   *events.UUID
	AppId     string
	AppName   string
	SpaceName string
	OrgName   string

	NonContainerStdout int64
	NonContainerStderr int64

	ContainerArray      []*ContainerStats
	ContainerTrafficMap map[string]*TrafficStats

	// ISSUE: Must do this at clone time because of AvgTracker counter
	TotalTraffic *TrafficStats
}

func NewAppStats

func NewAppStats(appId string) *AppStats

func PopulateNamesFromMap

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

func (*AppStats) Id

func (as *AppStats) Id() string

type CellStats

type CellStats struct {
	Ip             string
	StackId        string
	DeploymentName string
	JobName        string
	JobIndex       int

	NumOfCpus                   int
	CapacityTotalMemory         int64
	CapacityRemainingMemory     int64
	CapacityTotalDisk           int64
	CapacityRemainingDisk       int64
	CapacityTotalContainers     int
	CapacityRemainingContainers int
	ContainerCount              int
}

func NewCellStats

func NewCellStats(cellIp string) *CellStats

func (*CellStats) Id

func (cs *CellStats) Id() string

type ContainerStats

type ContainerStats struct {
	ContainerIndex  int
	Ip              string
	ContainerMetric *events.ContainerMetric
	LastUpdate      time.Time
	OutCount        int64
	ErrCount        int64
}

func NewContainerStats

func NewContainerStats(containerIndex int) *ContainerStats

type EventData

type EventData struct {
	AppMap      map[string]*AppStats
	CellMap     map[string]*CellStats
	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) GetTotalEvents

func (ed *EventData) GetTotalEvents() int64

func (*EventData) Process

func (ed *EventData) Process(instanceId int, 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) *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) LoadCacheAndSeeData

func (ep *EventProcessor) LoadCacheAndSeeData()

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 TrafficStats

type TrafficStats struct {
	AvgResponseL60Time float64 // updated after a clone of this object
	EventL60Rate       int     // updated after a clone of this object

	AvgResponseL10Time float64 // updated after a clone of this object
	EventL10Rate       int     // updated after a clone of this object

	AvgResponseL1Time float64 // updated after a clone of this object
	EventL1Rate       int     // updated after a clone of this object

	HttpAllCount int64
	Http2xxCount int64
	Http3xxCount int64
	Http4xxCount int64
	Http5xxCount int64
	// contains filtered or unexported fields
}

func NewTrafficStats

func NewTrafficStats() *TrafficStats