Add timestamp to pool events.

inbound/pool.go

@@ -9,6 +9,7 @@ import (
 	"log/slog"
 	"sync"
 	"sync/atomic"
+	"time"
 )
 
 // Types
@@ -34,6 +35,7 @@ type OnExitFunction func(kind WorkerExitKind)
 type PoolEvent struct {
 	ID   string
 	Kind PoolEventKind
+	At   time.Time
 }
 
 type PoolStats struct {
@@ -374,7 +376,7 @@ func (p *Pool) addLocked(id string, socket types.Socket) error {
 			conn.Close()
 
 			select {
-			case p.events <- PoolEvent{ID: id, Kind: workerToPoolEvent[kind]}:
+			case p.events <- PoolEvent{ID: id, Kind: workerToPoolEvent[kind], At: time.Now()}:
 			case <-p.ctx.Done():
 				return
 			}

inbound/pool_test.go

@@ -30,7 +30,7 @@ func expectEvent(
 	honeybeetest.Eventually(t, func() bool {
 		select {
 		case e := <-events:
-			return e.ID == expectedURL && e.Kind == expectedKind
+			return e.ID == expectedURL && e.Kind == expectedKind && !e.At.IsZero()
 		default:
 			return false
 		}

outbound/pool.go

@@ -8,6 +8,7 @@ import (
 	"log/slog"
 	"sync"
 	"sync/atomic"
+	"time"
 )
 
 // Types
@@ -22,6 +23,7 @@ const (
 type PoolEvent struct {
 	ID   string
 	Kind PoolEventKind
+	At   time.Time
 }
 
 type PoolStats struct {

outbound/pool_test.go

@@ -36,7 +36,7 @@ func expectEvent(
 	honeybeetest.Eventually(t, func() bool {
 		select {
 		case e := <-events:
-			return e.ID == expectedURL && e.Kind == expectedKind
+			return e.ID == expectedURL && e.Kind == expectedKind && !e.At.IsZero()
 		default:
 			return false
 		}

outbound/worker.go

@@ -261,7 +261,7 @@ func (s *Session) Start(
 
 		// set up new connection
 		s.connPtr.Store(conn)
-		pool.Events <- PoolEvent{ID: s.id, Kind: EventConnected}
+		pool.Events <- PoolEvent{ID: s.id, Kind: EventConnected, At: time.Now()}
 
 		// set up session context
 		sctx, scancel := context.WithCancel(ctx)
@@ -296,7 +296,7 @@ func (s *Session) Start(
 
 		// tear down connection
 		s.connPtr.Store(nil)
-		pool.Events <- PoolEvent{ID: s.id, Kind: EventDisconnected}
+		pool.Events <- PoolEvent{ID: s.id, Kind: EventDisconnected, At: time.Now()}
 
 		// exit if worker is shutting down
 		select {