chore: add istio access logging to tests (#3311)

backend/controller/scaling/kube_scaling_integration_test.go

@@ -55,7 +55,7 @@ func TestKubeScaling(t *testing.T) {
 			go func() {
 				defer func() {
 					if r := recover(); r != nil {
-						failure.Store(fmt.Errorf("panic in verb: %v at %v", r, time.Now()))
+						failure.Store(fmt.Errorf("panic calling verb: %v at %v", r, time.Now()))
 					}
 					routineStopped.Done()
 				}()

backend/provisioner/service.go

@@ -223,14 +223,18 @@ func (s *Service) UploadArtefact(ctx context.Context, req *connect.Request[ftlv1
 func (s *Service) GetSchema(ctx context.Context, req *connect.Request[ftlv1.GetSchemaRequest]) (*connect.Response[ftlv1.GetSchemaResponse], error) {
 	resp, err := s.controllerClient.GetSchema(ctx, req)
 	if err != nil {
+		logger := log.FromContext(ctx)
+		logger.Errorf(err, "get schema failed")
 		return nil, fmt.Errorf("call to ftl-controller failed: %w", err)
 	}
 	return connect.NewResponse(resp.Msg), nil
 }
 
 func (s *Service) PullSchema(ctx context.Context, req *connect.Request[ftlv1.PullSchemaRequest], to *connect.ServerStream[ftlv1.PullSchemaResponse]) error {
+	logger := log.FromContext(ctx)
 	stream, err := s.controllerClient.PullSchema(ctx, req)
 	if err != nil {
+		logger.Errorf(err, "pull schema failed")
 		return fmt.Errorf("call to ftl-controller failed: %w", err)
 	}
 	defer stream.Close()

deployment/Justfile

@@ -62,6 +62,7 @@ setup-istio-cluster: setup-cluster
       helm install istiod istio/istiod -n istio-system --wait
   fi
   kubectl label namespace default istio-injection=enabled --overwrite
+  kubectl apply -f istio-access-logs.yaml
 
 setup: setup-registry setup-istio-cluster
 

deployment/istio-access-logs.yaml

@@ -0,0 +1,9 @@
+apiVersion: telemetry.istio.io/v1
+kind: Telemetry
+metadata:
+  name: mesh-default
+  namespace: istio-system
+spec:
+  accessLogging:
+    - providers:
+        - name: envoy