Function TestSession_InsertOverflow

management/session_test.go:121–147

Validate that the session has a max amount of events to hold

(t *testing.T)

// Validate that the session has a max amount of events to hold
func TestSession_InsertOverflow(t *testing.T) {
	_, cancel := context.WithCancel(context.Background())
	defer cancel()
	session := newSession(1, actor{}, cancel)
	log := Log{
		Time:    time.Now().UTC().Format(time.RFC3339),
		Event:   HTTP,
		Level:   Info,
		Message: "test",
	}
	// Insert 2 but only max channel size for 1
	session.Insert(&log)
	session.Insert(&log)
	select {
	case <-session.listener:
		// pass
	default:
		require.Fail(t, "expected one log event")
	}
	// Second dequeue should fail
	select {
	case <-session.listener:
		require.Fail(t, "expected no more remaining log events")
	default:
		// pass
	}
}