apppeer

package

Go to main page

Versions in this module

v0

v0.9.1

Aug 14, 2025

v0.9.0

Aug 6, 2025

Changes in this version

type AppRunPeer

+ FirstGoRoutineCollectionTs int64

type GoRoutine

+ CreatedByFrame *rpctypes.StackFrame

+ CreatedByGoId int64

+ Decl *ds.GoDecl

+ TimeSpan rpctypes.TimeSpan

type GoRoutinePeer

+ func (gp *GoRoutinePeer) GetParsedGoRoutinesAtTimestamp(moduleName string, timestamp int64, activeOnly bool) GoRoutinesAtTimestampResult

+ func (gp *GoRoutinePeer) GetTimeSpansSinceTickIdx(sinceTickIdx int64, showOutrig bool) rpctypes.GoRoutineTimeSpansResponse

+ type GoRoutinesAtTimestampResult struct

+ EffectiveTimestamp int64

+ GoRoutines []rpctypes.ParsedGoRoutine

+ TotalCount int

+ TotalNonOutrig int

v0.7.4

Jun 12, 2025

Changes in this version

+ func ClearNonActiveAppRuns() error

type AppRunPeer

+ TotalBytesReceived atomic.Int64

v0.6.0

May 27, 2025

Changes in this version

+ const AppStatusDisconnected

+ const AppStatusDone

+ const AppStatusRunning

+ const GoRoutinePruneThreshold

+ const GoRoutineStackBufferSize

+ const LogLineBufferSize

+ const MaxAppRunPeers

+ const PruneInterval

+ const RuntimeStatsBufferSize

+ const WatchBufferSize

+ func ConvertToRuntimeStatData(stat ds.RuntimeStatsInfo) rpctypes.RuntimeStatData

+ func GetAllAppRunPeerInfos(since int64) []rpctypes.AppRunInfo

+ func GetAppRunStatsDelta() (tevent.AppRunStats, int)

+ func PruneAppRunPeers() int

+ type AppRunPeer struct

+ AppInfo *ds.AppInfo

+ AppRunId string

+ CollectorStatus map[string]ds.CollectorStatus

+ GoRoutines *GoRoutinePeer

+ LastModTime int64

+ Logs *LogLinePeer

+ RuntimeStats *RuntimeStatsPeer

+ Status string

+ Watches *WatchesPeer

+ func GetAllAppRunPeers() []*AppRunPeer

+ func GetAppRunPeer(appRunId string, incRefCount bool) *AppRunPeer

+ func (p *AppRunPeer) GetAppRunInfo() rpctypes.AppRunInfo

+ func (p *AppRunPeer) GetPeerStats() (tevent.AppRunStats, string)

+ func (p *AppRunPeer) GetRefCount() int

+ func (p *AppRunPeer) HandlePacket(packetType string, packetData json.RawMessage) error

+ func (p *AppRunPeer) Release()

+ type GoRoutine struct

+ FirstSeen int64

+ GoId int64

+ LastActiveIteration int64

+ LastSeen int64

+ Name string

+ StackTraces *utilds.CirBuf[ds.GoRoutineStack]

+ Tags []string

+ type GoRoutinePeer struct

+ func MakeGoRoutinePeer(appRunId string) *GoRoutinePeer

+ func (gp *GoRoutinePeer) GetGoRoutineCounts() (int, int, int)

+ func (gp *GoRoutinePeer) GetMaxGoId() int64

+ func (gp *GoRoutinePeer) GetParsedGoRoutines(moduleName string) []rpctypes.ParsedGoRoutine

+ func (gp *GoRoutinePeer) GetParsedGoRoutinesByIds(moduleName string, goIds []int64) []rpctypes.ParsedGoRoutine

+ func (gp *GoRoutinePeer) ProcessGoroutineStacks(info ds.GoroutineInfo)

+ type LogLinePeer struct

+ func MakeLogLinePeer() *LogLinePeer

+ func (lp *LogLinePeer) GetLogLines() ([]ds.LogLine, int)

+ func (lp *LogLinePeer) GetTotalCount() int

+ func (lp *LogLinePeer) NotifySearchManagers(line ds.LogLine)

+ func (lp *LogLinePeer) ProcessLogLine(line ds.LogLine)

+ func (lp *LogLinePeer) ProcessMultiLogLines(lines []ds.LogLine)

+ func (lp *LogLinePeer) RegisterSearchManager(manager gensearch.SearchManagerInterface)

+ func (lp *LogLinePeer) UnregisterSearchManager(manager gensearch.SearchManagerInterface)

+ type RuntimeStatsPeer struct

+ func MakeRuntimeStatsPeer() *RuntimeStatsPeer

+ func (rsp *RuntimeStatsPeer) GetFilteredStats(sinceTs int64) []ds.RuntimeStatsInfo

+ func (rsp *RuntimeStatsPeer) GetRuntimeStats(sinceTs int64) []rpctypes.RuntimeStatData

+ func (rsp *RuntimeStatsPeer) GetTotalCollectionCount() int

+ func (rsp *RuntimeStatsPeer) IsEmpty() bool

+ func (rsp *RuntimeStatsPeer) ProcessRuntimeStats(stats ds.RuntimeStatsInfo)

+ type Watch struct

+ Decl ds.WatchDecl

+ WatchNum int64

+ WatchVals *utilds.CirBuf[ds.WatchSample]

+ type WatchesPeer struct

+ func MakeWatchesPeer(appRunId string) *WatchesPeer

+ func (wp *WatchesPeer) GetActiveWatchCount() int

+ func (wp *WatchesPeer) GetAllWatches() []rpctypes.CombinedWatchSample

+ func (wp *WatchesPeer) GetTotalWatchCount() int

+ func (wp *WatchesPeer) GetWatchesByIds(watchIds []int64) []rpctypes.CombinedWatchSample

+ func (wp *WatchesPeer) ProcessWatchInfo(watchInfo ds.WatchInfo)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL