NewTempoService creates a Tempo service with the specified service name and target. serviceName is the name of the service in the e2e environment (can include replica/zone suffixes). target is the Tempo -target flag value (e.g., "distributor", "live-store", "querier"). additionalPorts are optional e
(serviceName, target string, readinessProbe e2e.ReadinessProbe, additionalPorts []int, additionalArgs ...string)
| 82 | // target is the Tempo -target flag value (e.g., "distributor", "live-store", "querier"). |
| 83 | // additionalPorts are optional extra ports to expose beyond the default 3200. |
| 84 | func NewTempoService(serviceName, target string, readinessProbe e2e.ReadinessProbe, additionalPorts []int, additionalArgs ...string) *e2e.HTTPService { |
| 85 | args := []string{ |
| 86 | "-config.file=" + filepath.Join(e2e.ContainerSharedDir, tempoConfigFile), |
| 87 | "-target=" + target, |
| 88 | } |
| 89 | |
| 90 | additionalPorts = append(additionalPorts, 3201) // internal server port if enabled |
| 91 | args = append(args, additionalArgs...) |
| 92 | |
| 93 | s := e2e.NewHTTPService( |
| 94 | serviceName, |
| 95 | image, |
| 96 | e2e.NewCommandWithoutEntrypoint("/tempo", args...), |
| 97 | readinessProbe, |
| 98 | 3200, // primary http port |
| 99 | additionalPorts..., |
| 100 | ) |
| 101 | |
| 102 | s.SetMetricsTimeout(MetricsTimeout) |
| 103 | s.SetBackoff(tempoBackoff()) |
| 104 | return s |
| 105 | } |
| 106 | |
| 107 | func newPrometheus() *e2e.HTTPService { |
| 108 | s := e2e.NewHTTPService( |
no test coverage detected