changed collector url

Signed-off-by: chahatsagarmain <chahatsagar2003@gmail.com>

crossdock/main.go

@@ -19,8 +19,8 @@ import (
 const (
 	behaviorEndToEnd = "endtoend"
 
-	envAgentHostPort = "JAEGER_AGENT_HOST_PORT"
-	envQueryHostPort = "JAEGER_QUERY_HOST_PORT"
+	envCollectorSamplingHostPort = "JAEGER_COLLECTOR_SAMPLING_HOST_PORT"
+	envQueryHostPort             = "JAEGER_QUERY_HOST_PORT"
 
 	envQueryHealthcheckHostPort     = "JAEGER_QUERY_HC_HOST_PORT"
 	envCollectorHealthcheckHostPort = "JAEGER_COLLECTOR_HC_HOST_PORT"
@@ -29,8 +29,8 @@ const (
 var (
 	logger, _ = zap.NewDevelopment()
 
-	agentHostPort string
-	queryHostPort string
+	collectorSamplingHostPort string
+	queryHostPort             string
 
 	queryHealthcheckHostPort     string
 	collectorHealthcheckHostPort string
@@ -44,7 +44,7 @@ type clientHandler struct {
 }
 
 func main() {
-	agentHostPort = getEnv(envAgentHostPort, "jaeger-agent:5778")
+	collectorSamplingHostPort = getEnv(envCollectorSamplingHostPort, "jaeger-collector:14268")
 	queryHostPort = getEnv(envQueryHostPort, "jaeger-query:16686")
 	queryHealthcheckHostPort = getEnv(envQueryHealthcheckHostPort, "jaeger-query:16687")
 	collectorHealthcheckHostPort = getEnv(envCollectorHealthcheckHostPort, "jaeger-collector:14269")
@@ -78,9 +78,9 @@ func (h *clientHandler) initialize() {
 	httpHealthCheck(logger, "jaeger-collector", "http://"+collectorHealthcheckHostPort)
 
 	queryService := services.NewQueryService("http://"+queryHostPort, logger)
-	agentService := services.NewAgentService("http://"+agentHostPort, logger)
+	samplingService := services.NewAgentService("http://"+collectorSamplingHostPort, logger)
 
-	traceHandler := services.NewTraceHandler(queryService, agentService, logger)
+	traceHandler := services.NewTraceHandler(queryService, samplingService, logger)
 	behaviors := crossdock.Behaviors{
 		behaviorEndToEnd: traceHandler.EndToEndTest,
 	}

crossdock/services/agent.go

@@ -37,7 +37,7 @@ func NewAgentService(url string, logger *zap.Logger) AgentService {
 }
 
 func getSamplingURL(url string) string {
-	return url + "/sampling?service=%s"
+	return url + "/api/sampling?service=%s"
 }
 
 // GetSamplingRate returns the sampling rate for the service-operation from the agent service.