Skip to content

Commit

Permalink
sidecar: when injecting, expose the admin port so that prometheus can…
Browse files Browse the repository at this point in the history
… scrape it

Signed-off-by: Jonathan Rockway <jrockway@users.noreply.github.com>
  • Loading branch information
jrockway committed Feb 24, 2020
1 parent de6fff1 commit 560bcdb
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 2 deletions.
7 changes: 6 additions & 1 deletion pkg/inject/sidecar.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ var (
// PrometheusDefaultAnnotations is a map containing annotations for prometheus to be inserted at sidecar in case it doesn't have any
PrometheusDefaultAnnotations = map[string]string{
"prometheus.io/scrape": "true",
"prometheus.io/port": "5778",
"prometheus.io/port": "14271",
}
)

Expand Down Expand Up @@ -138,6 +138,7 @@ func container(jaeger *v1.Jaeger, dep *appsv1.Deployment) corev1.Container {
configRest := util.GetPort("--http-server.host-port=", args, 5778)
jgCompactTrft := util.GetPort("--processor.jaeger-compact.server-host-port=", args, 6831)
jgBinaryTrft := util.GetPort("--processor.jaeger-binary.server-host-port=", args, 6832)
adminPort := util.GetPort("--admin-http-port=", args, 14271)

if len(util.FindItem("--jaeger.tags=", args)) == 0 {
agentTags := fmt.Sprintf("%s=%s,%s=%s,%s=%s,%s=%s,%s=%s",
Expand Down Expand Up @@ -205,6 +206,10 @@ func container(jaeger *v1.Jaeger, dep *appsv1.Deployment) corev1.Container {
Name: "jg-binary-trft",
Protocol: corev1.ProtocolUDP,
},
{
ContainerPort: adminPort,
Name: "admin-http",
},
},
Resources: commonSpec.Resources,
}
Expand Down
3 changes: 2 additions & 1 deletion pkg/inject/sidecar_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -176,11 +176,12 @@ func TestSidecarDefaultPorts(t *testing.T) {
assert.Len(t, dep.Spec.Template.Spec.Containers, 2)
assert.Contains(t, dep.Spec.Template.Spec.Containers[1].Image, "jaeger-agent")

assert.Len(t, dep.Spec.Template.Spec.Containers[1].Ports, 4)
assert.Len(t, dep.Spec.Template.Spec.Containers[1].Ports, 5)
assert.Contains(t, dep.Spec.Template.Spec.Containers[1].Ports, corev1.ContainerPort{ContainerPort: 5775, Name: "zk-compact-trft", Protocol: corev1.ProtocolUDP})
assert.Contains(t, dep.Spec.Template.Spec.Containers[1].Ports, corev1.ContainerPort{ContainerPort: 5778, Name: "config-rest"})
assert.Contains(t, dep.Spec.Template.Spec.Containers[1].Ports, corev1.ContainerPort{ContainerPort: 6831, Name: "jg-compact-trft", Protocol: corev1.ProtocolUDP})
assert.Contains(t, dep.Spec.Template.Spec.Containers[1].Ports, corev1.ContainerPort{ContainerPort: 6832, Name: "jg-binary-trft", Protocol: corev1.ProtocolUDP})
assert.Contains(t, dep.Spec.Template.Spec.Containers[1].Ports, corev1.ContainerPort{ContainerPort: 14271, Name: "admin-http"})
}

func TestSkipInjectSidecar(t *testing.T) {
Expand Down

0 comments on commit 560bcdb

Please sign in to comment.