Method debugSessionResultsSnapshot

dagql/cache_debug.go:184–215

()

}

func (c *Cache) debugSessionResultsSnapshot() []CacheDebugSessionResults {
	if c == nil {
		return nil
	}
	c.sessionMu.Lock()
	defer c.sessionMu.Unlock()
	if len(c.sessionResultIDsBySession) == 0 {
		return nil
	}
	sessionIDs := make([]string, 0, len(c.sessionResultIDsBySession))
	for sessionID := range c.sessionResultIDsBySession {
		sessionIDs = append(sessionIDs, sessionID)
	}
	slices.Sort(sessionIDs)
	out := make([]CacheDebugSessionResults, 0, len(sessionIDs))
	for _, sessionID := range sessionIDs {
		resultIDs := c.sessionResultIDsBySession[sessionID]
		if len(resultIDs) == 0 {
			continue
		}
		sharedResultIDs := make([]uint64, 0, len(resultIDs))
		for resultID := range resultIDs {
			sharedResultIDs = append(sharedResultIDs, uint64(resultID))
		}
		slices.Sort(sharedResultIDs)
		out = append(out, CacheDebugSessionResults{
			SessionID:       sessionID,
			SharedResultIDs: sharedResultIDs,
		})
	}
	return out
}

func (c *Cache) nextTraceSeq() uint64 {
	return atomic.AddUint64(&c.traceSeq, 1)