eventApp

Documentation

Index

• Constants
• type AppStats
  • func ConvertFromMap(statsMap map[string]*AppStats, appMdMgr *app.AppMetadataManager) []*AppStats
  • func NewAppStats(appId string) *AppStats
  • func (as *AppStats) AddCrashInfo(containerIndex int, crashTime *time.Time, exitDescription string)
  • func (as *AppStats) Crash1hCount() int
  • func (as *AppStats) Crash24hCount() int
  • func (as *AppStats) CrashCountSince(since time.Duration) int
  • func (as *AppStats) CrashSince(since time.Duration) []*crashData.ContainerCrashInfo
  • func (as *AppStats) Id() string
• type ContainerStats
  • func NewContainerStats(containerIndex int) *ContainerStats
• type HttpInfo
  • func NewHttpInfo(httpMethod events.Method, httpStatusCode int32) *HttpInfo
• type TrafficStats
  • func NewTrafficStats() *TrafficStats

Constants

const (
	UnknownName = "unknown"
)

Types

type AppStats

type AppStats struct {
	AppUUID *events.UUID
	AppId   string

	NonContainerStdout int64
	NonContainerStderr int64

	ContainerArray []*ContainerStats
	// Key: instanceId
	ContainerTrafficMap map[string]*TrafficStats

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

	// We save container info in AppStats and not in ContainerStats
	// because container stats entries and come and go (scale up/down)
	// but we want to keep all crash info regardless of container status
	ContainerCrashInfo []*crashData.ContainerCrashInfo
}

func ConvertFromMap

func ConvertFromMap(statsMap map[string]*AppStats, appMdMgr *app.AppMetadataManager) []*AppStats

func NewAppStats

func NewAppStats(appId string) *AppStats

func (*AppStats) AddCrashInfo

func (as *AppStats) AddCrashInfo(containerIndex int, crashTime *time.Time, exitDescription string)

func (*AppStats) Crash1hCount

func (as *AppStats) Crash1hCount() int

Crash count in last 1 hour recorded since top started

func (*AppStats) Crash24hCount

func (as *AppStats) Crash24hCount() int

Crash count in last 24 hours recorded since top started

func (*AppStats) CrashCountSince

func (as *AppStats) CrashCountSince(since time.Duration) int

Crash count in last duration

func (*AppStats) CrashSince

func (as *AppStats) CrashSince(since time.Duration) []*crashData.ContainerCrashInfo

func (*AppStats) Id

func (as *AppStats) Id() string

type ContainerStats

type ContainerStats struct {
	ContainerIndex          int
	Ip                      string
	ContainerMetric         *events.ContainerMetric
	LastUpdateTime          *time.Time
	LastMetricUpdateTime    *time.Time
	OutCount                int64
	ErrCount                int64
	CreateCount             int64
	CellLastStartMsgText    string
	CellLastStartMsgTime    *time.Time
	CellLastCreatingMsgTime *time.Time
	CellCreatedMsgTime      *time.Time
	CellHealthyMsgTime      *time.Time
}

func NewContainerStats

func NewContainerStats(containerIndex int) *ContainerStats

type HttpInfo

type HttpInfo struct {
	HttpMethod     events.Method
	HttpStatusCode int32
	HttpCount      int64
	LastAcivity    *time.Time
	// Last response time in nano-seconds
	LastResponseTime int64
}

func NewHttpInfo

func NewHttpInfo(httpMethod events.Method, httpStatusCode int32) *HttpInfo

type TrafficStats

type TrafficStats struct {
	InstanceIndex int32

	ResponseL60Time    *util.AvgTracker
	AvgResponseL60Time float64 // updated after a clone of this object
	EventL60Rate       int     // updated after a clone of this object

	ResponseL10Time    *util.AvgTracker
	AvgResponseL10Time float64 // updated after a clone of this object
	EventL10Rate       int     // updated after a clone of this object

	ResponseL1Time    *util.AvgTracker
	AvgResponseL1Time float64 // updated after a clone of this object
	EventL1Rate       int     // updated after a clone of this object

	HttpInfoMap map[events.Method]map[int32]*HttpInfo
}

func NewTrafficStats

func NewTrafficStats() *TrafficStats