eventdata

Documentation

Index

• Constants
• func MovingExpAvg(value, oldValue, fdtime, ftime float64) float64
• type AppStats
  • func NewAppStats(appId string) *AppStats
  • func PopulateNamesIfNeeded(statsMap map[string]*AppStats) []*AppStats
  • func (as *AppStats) Id() string
• type CellStats
  • func NewCellStats(cellIp string) *CellStats
  • func (cs *CellStats) Id() string
• type ContainerStats
  • func NewContainerStats() *ContainerStats
• type EventData
  • func NewEventData() *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 EventProcessor
  • func NewEventProcessor(cliConnection plugin.CliConnection) *EventProcessor
  • func (ep *EventProcessor) ClearStats() error
  • func (ep *EventProcessor) GetCurrentEventData() *EventData
  • func (ep *EventProcessor) GetDisplayedEventData() *EventData
  • func (ep *EventProcessor) LoadCacheAndSeeData()
  • func (ep *EventProcessor) LoadMetadata()
  • 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 StaleContainerSeconds = 80

const (
	UnknownName = "unknown"
)

Functions

func MovingExpAvg

func MovingExpAvg(value, oldValue, fdtime, ftime float64) float64

Types

type AppStats

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

	NonContainerOutCount int64
	NonContainerErrCount int64

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

	TotalCpuPercentage float64 // updated after a clone of this object
	TotalUsedMemory    uint64  // updated after a clone of this object
	TotalUsedDisk      uint64  // updated after a clone of this object

	TotalReportingContainers int   //updated after a clone of this object
	TotalLogCount            int64 //updated after a clone of this object
}

func NewAppStats

func NewAppStats(appId string) *AppStats

func PopulateNamesIfNeeded

func PopulateNamesIfNeeded(statsMap map[string]*AppStats) []*AppStats

func (*AppStats) Id

func (as *AppStats) Id() string

type CellStats

type CellStats struct {
	Ip string

	DeploymentName string
	JobName        string
	JobIndex       string

	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 {
	Ip              string
	ContainerMetric *events.ContainerMetric
	LastUpdate      time.Time
	OutCount        int64
	ErrCount        int64
}

func NewContainerStats

func NewContainerStats() *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() *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 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) GetCurrentEventData

func (ep *EventProcessor) GetCurrentEventData() *EventData

func (*EventProcessor) GetDisplayedEventData

func (ep *EventProcessor) GetDisplayedEventData() *EventData

func (*EventProcessor) LoadCacheAndSeeData

func (ep *EventProcessor) LoadCacheAndSeeData()

func (*EventProcessor) LoadMetadata

func (ep *EventProcessor) LoadMetadata()

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