apppeer

type AppRunPeer struct {
	AppRunId                   string
	AppInfo                    *ds.AppInfo
	Status                     string // Current status of the application
	LastModTime                int64  // Last modification time in milliseconds
	FirstGoRoutineCollectionTs int64  // Timestamp of first goroutine collection

	Logs            *LogLinePeer
	GoRoutines      *GoRoutinePeer
	Watches         *WatchesPeer
	RuntimeStats    *RuntimeStatsPeer
	CollectorStatus map[string]ds.CollectorStatus // Collector statuses by name

	TotalBytesReceived atomic.Int64 // Total bytes received from client
	// contains filtered or unexported fields
}

type GoRoutine struct {
	GoId                int64
	Name                string
	Tags                []string
	CreatedByGoId       int64                // ID of the goroutine that created this one
	CreatedByFrame      *rpctypes.StackFrame // Frame information for the creation point
	StackTraces         *utilds.CirBuf[ds.GoRoutineStack]
	TimeSpan            rpctypes.TimeSpan // Time span when the goroutine was active
	LastActiveIteration int64             // Iteration when the goroutine was last active
	Decl                *ds.GoDecl        // Declaration information for this goroutine
}

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

type GoRoutinesAtTimestampResult struct {
	GoRoutines         []rpctypes.ParsedGoRoutine
	TotalCount         int   // Total count of all goroutines (not filtered by activeOnly)
	TotalNonOutrig     int   // Total count of non-outrig goroutines (not filtered by activeOnly)
	EffectiveTimestamp int64 // The timestamp that was actually used for the query
}

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

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

type Watch struct {
	WatchNum  int64
	Decl      ds.WatchDecl
	WatchVals *utilds.CirBuf[ds.WatchSample]
}

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