diff --git a/api/v1/loadtest_types.go b/api/v1/loadtest_types.go
index bd7765b8..9779ed52 100644
--- a/api/v1/loadtest_types.go
+++ b/api/v1/loadtest_types.go
@@ -181,6 +181,8 @@ type Server struct {
 	// Run describes a list of run containers. The container for the test server is always
 	// the first container on the list.
 	Run []corev1.Container `json:"run"`
+
+	MetricsPort int32 `json:"metricsPort,omitempty"`
 }
 
 // Client defines a component that sends traffic to a server component.
@@ -235,6 +237,8 @@ type Client struct {
 	// Run describes a list of run containers. The container for the test client is always
 	// the first container on the list.
 	Run []corev1.Container `json:"run"`
+
+	MetricsPort int32 `json:"metricsPort,omitempty"`
 }
 
 // Results defines where and how test results and artifacts should be
diff --git a/config/crd/bases/e2etest.grpc.io_loadtests.yaml b/config/crd/bases/e2etest.grpc.io_loadtests.yaml
index c3b840ef..d5a7fbdd 100644
--- a/config/crd/bases/e2etest.grpc.io_loadtests.yaml
+++ b/config/crd/bases/e2etest.grpc.io_loadtests.yaml
@@ -254,6 +254,9 @@ spec:
                         the operator to clone and build code, it must also manually set a build
                         image.
                       type: string
+                    metricsPort:
+                      format: int32
+                      type: integer
                     name:
                       description: |-
                         Name is a string that distinguishes this client from others in the test.
@@ -3419,6 +3422,9 @@ spec:
                         the operator to clone and build code, it must also manually set a build
                         image.
                       type: string
+                    metricsPort:
+                      format: int32
+                      type: integer
                     name:
                       description: |-
                         Name is a string that distinguishes this server from others in the test.
diff --git a/podbuilder/podbuilder.go b/podbuilder/podbuilder.go
index ea0d853a..a01bc549 100644
--- a/podbuilder/podbuilder.go
+++ b/podbuilder/podbuilder.go
@@ -177,6 +177,14 @@ func (pb *PodBuilder) PodForClient(client *grpcv1.Client) (*corev1.Pod, error) {
 		ContainerPort: config.DriverPort,
 	})
 
+	if client.MetricsPort != 0 {
+		runContainer.Ports = append(runContainer.Ports, corev1.ContainerPort{
+			Name:          "metrics",
+			Protocol:      corev1.ProtocolTCP,
+			ContainerPort: client.MetricsPort,
+		})
+	}
+
 	return pod, nil
 }
 
@@ -285,6 +293,14 @@ func (pb *PodBuilder) PodForServer(server *grpcv1.Server) (*corev1.Pod, error) {
 		ContainerPort: config.DriverPort,
 	})
 
+	if server.MetricsPort != 0 {
+		runContainer.Ports = append(runContainer.Ports, corev1.ContainerPort{
+			Name:          "metrics",
+			Protocol:      corev1.ProtocolTCP,
+			ContainerPort: server.MetricsPort,
+		})
+	}
+
 	return pod, nil
 }
 
diff --git a/podbuilder/podbuilder_test.go b/podbuilder/podbuilder_test.go
index a8a280f4..88d67f51 100644
--- a/podbuilder/podbuilder_test.go
+++ b/podbuilder/podbuilder_test.go
@@ -374,6 +374,36 @@ var _ = Describe("PodBuilder", func() {
 				Expect(getValue("driver", "ContainerPort", runContainer.Ports)).To(BeEquivalentTo(config.DriverPort))
 			})
 
+			It("does not expose the metrics port if not set", func() {
+				client.Run = []corev1.Container{{}}
+				client.Run[0].Name = config.RunContainerName
+				client.Run[0].Command = []string{"go"}
+				client.Run[0].Args = []string{"run", "main.go"}
+
+				pod, err := builder.PodForClient(client)
+				Expect(err).ToNot(HaveOccurred())
+				Expect(pod.Spec.Containers).ToNot(BeEmpty())
+
+				runContainer := kubehelpers.ContainerForName(config.RunContainerName, pod.Spec.Containers)
+				Expect(getNames(runContainer.Ports)).NotTo(ContainElement("metrics"))
+			})
+
+			It("exposes the metrics port if set", func() {
+				client.Run = []corev1.Container{{}}
+				client.Run[0].Name = config.RunContainerName
+				client.Run[0].Command = []string{"go"}
+				client.Run[0].Args = []string{"run", "main.go"}
+				client.MetricsPort = 4242
+
+				pod, err := builder.PodForClient(client)
+				Expect(err).ToNot(HaveOccurred())
+				Expect(pod.Spec.Containers).ToNot(BeEmpty())
+
+				runContainer := kubehelpers.ContainerForName(config.RunContainerName, pod.Spec.Containers)
+				Expect(getNames(runContainer.Ports)).To(ContainElement("metrics"))
+				Expect(getValue("metrics", "ContainerPort", runContainer.Ports)).To(BeEquivalentTo(client.MetricsPort))
+			})
+
 			It("attached the env to other run containers", func() {
 				pod, err := builder.PodForClient(client)
 				Expect(err).ToNot(HaveOccurred())