@@ -513,6 +513,12 @@ func (su *SessionUploader) uploadSessionFile(fileInfo *SessionFileInfo) error {
513513 return fmt .Errorf ("failed to read SSH session file: %w" , err )
514514 }
515515
516+ log .Debug ().
517+ Str ("sessionId" , fileInfo .SessionID ).
518+ Str ("resourceType" , fileInfo .ResourceType ).
519+ Int ("eventCount" , len (terminalEvents )).
520+ Msg ("Uploading terminal session events" )
521+
516522 var logs []api.UploadTerminalEvent
517523 for _ , event := range terminalEvents {
518524 logs = append (logs , api.UploadTerminalEvent {
@@ -533,6 +539,12 @@ func (su *SessionUploader) uploadSessionFile(fileInfo *SessionFileInfo) error {
533539 return fmt .Errorf ("failed to read Kubernetes session file: %w" , err )
534540 }
535541
542+ log .Debug ().
543+ Str ("sessionId" , fileInfo .SessionID ).
544+ Str ("resourceType" , fileInfo .ResourceType ).
545+ Int ("eventCount" , len (httpEvents )).
546+ Msg ("Uploading terminal session events" )
547+
536548 var logs []api.UploadHttpEvent
537549 for _ , event := range httpEvents {
538550 logs = append (logs , api.UploadHttpEvent {
@@ -556,6 +568,17 @@ func (su *SessionUploader) uploadSessionFile(fileInfo *SessionFileInfo) error {
556568 return fmt .Errorf ("failed to read session file: %w" , err )
557569 }
558570
571+ resourceTypeMsg := fileInfo .ResourceType
572+ if resourceTypeMsg == "" {
573+ resourceTypeMsg = "legacy"
574+ }
575+
576+ log .Debug ().
577+ Str ("sessionId" , fileInfo .SessionID ).
578+ Str ("resourceType" , resourceTypeMsg ).
579+ Int ("entryCount" , len (entries )).
580+ Msg ("Uploading database session logs" )
581+
559582 var logs []api.UploadSessionLogEntry
560583 for _ , entry := range entries {
561584 logs = append (logs , api.UploadSessionLogEntry {
0 commit comments