fix: verbose debug logging (#3700)

backend/controller/state/runners.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/alecthomas/types/optional"
 
+	"github.com/TBD54566975/ftl/internal/eventstream"
 	"github.com/TBD54566975/ftl/internal/model"
 )
 
@@ -42,6 +43,7 @@ func (r *State) RunnersForDeployment(deployment string) []Runner {
 }
 
 var _ ControllerEvent = (*RunnerRegisteredEvent)(nil)
+var _ eventstream.VerboseMessage = (*RunnerRegisteredEvent)(nil)
 var _ ControllerEvent = (*RunnerDeletedEvent)(nil)
 
 type RunnerRegisteredEvent struct {
@@ -52,6 +54,10 @@ type RunnerRegisteredEvent struct {
 	Deployment model.DeploymentKey
 }
 
+func (r *RunnerRegisteredEvent) VerboseMessage() {
+	// Stops this message being logged every second
+}
+
 func (r *RunnerRegisteredEvent) Handle(t State) (State, error) {
 	if existing := t.runners[r.Key.String()]; existing != nil {
 		existing.LastSeen = r.Time

internal/eventstream/eventstream.go

@@ -52,7 +52,11 @@ func (i *inMemoryEventStream[T, E]) Publish(ctx context.Context, e E) error {
 	defer i.lock.Unlock()
 	logger := log.FromContext(ctx)
 
-	logger.Debugf("Publishing event %T%v", e, e)
+	if _, ok := any(e).(VerboseMessage); ok {
+		logger.Tracef("Publishing event %T%v", e, e)
+	} else {
+		logger.Debugf("Publishing event %T%v", e, e)
+	}
 	newView, err := e.Handle(reflect.DeepCopy(i.view))
 	if err != nil {
 		return fmt.Errorf("failed to handle event: %w", err)
@@ -69,3 +73,7 @@ func (i *inMemoryEventStream[T, E]) View() T {
 func (i *inMemoryEventStream[T, E]) Updates() *pubsub.Topic[E] {
 	return i.topic
 }
+
+type VerboseMessage interface {
+	VerboseMessage()
+}